Merge lp:~mandel/unity-lens-music/musicstore-purchase into lp:unity-lens-music

[Manuel de la Peña]

Adds support for music purchase from the musicstore scope.

[lp:~mandel/unity-lens-music/musicstore-purchase]

135. By Manuel de la Peña on 2013-04-02

Add u1 icon to action.

[PS Jenkins bot (ps-jenkins)]

FAILED: Continuous integration, rev:135
No commit message was specified in the merge proposal. Click on the following link and set the commit message (if you want a jenkins rebuild you need to trigger it yourself):
https://code.launchpad.net/~mandel/unity-lens-music/musicstore-purchase/+merge/156513/+edit-commit-message

http://jenkins.qa.ubuntu.com/job/unity-lens-music-ci/2/
Executed test runs:
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-lens-music-raring-amd64-ci/2
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-lens-music-raring-armhf-ci/2
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-lens-music-raring-i386-ci/2

Click here to trigger a rebuild:
http://s-jenkins:8080/job/unity-lens-music-ci/2/rebuild

review: Needs Fixing (continuous-integration)

[lp:~mandel/unity-lens-music/musicstore-purchase]

136. By Manuel de la Peña on 2013-04-17

Removed cached password.

[PS Jenkins bot (ps-jenkins)]

FAILED: Continuous integration, rev:136
No commit message was specified in the merge proposal. Click on the following link and set the commit message (if you want a jenkins rebuild you need to trigger it yourself):
https://code.launchpad.net/~mandel/unity-lens-music/musicstore-purchase/+merge/156513/+edit-commit-message

http://jenkins.qa.ubuntu.com/job/unity-lens-music-ci/3/
Executed test runs:
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-lens-music-raring-amd64-ci/3
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-lens-music-raring-armhf-ci/3
    SUCCESS: http://jenkins.qa.ubuntu.com/job/unity-lens-music-raring-i386-ci/3

Click here to trigger a rebuild:
http://s-jenkins:8080/job/unity-lens-music-ci/3/rebuild

review: Needs Fixing (continuous-integration)

Unmerged revisions

136. By Manuel de la Peña on 2013-04-17

Removed cached password.

135. By Manuel de la Peña on 2013-04-02

Add u1 icon to action.

134. By Manuel de la Peña on 2013-04-02

Fixed debian changelog.

133. By Manuel de la Peña on 2013-04-02

Added payment code to the music store.

=== modified file 'configure.ac'
--- configure.ac	2013-02-15 13:06:28 +0000
+++ configure.ac	2013-04-17 10:13:28 +0000
@@ -75,6 +75,7 @@
                   sqlite3 >= 3.7.7
                   gee-1.0
                   json-glib-1.0
+                  libnotify
                   libsoup-2.4
                   oauth
                   unity >= 6.90.0
 
=== modified file 'debian/changelog'
--- debian/changelog	2013-03-04 04:01:17 +0000
+++ debian/changelog	2013-04-17 10:13:28 +0000
@@ -1,3 +1,11 @@
+unity-lens-music (6.8.1daily13.03.04-0ubuntu3) UNRELEASED; urgency=low
+
+  [ Alejandro J. Cura ]
+  * debian/control:
+    - added libnotify-dev build dependency
+
+ -- Alejandro J. Cura <[e-mail]>  Tue, 19 Mar 2013 18:45:38 -0300
+
 unity-lens-music (6.8.1daily13.03.04-0ubuntu1) raring; urgency=low
 
   [ Pawel Stolowski ]
 
=== modified file 'debian/control'
--- debian/control	2012-12-12 16:12:30 +0000
+++ debian/control	2013-04-17 10:13:28 +0000
@@ -11,11 +11,12 @@
                libglib2.0-dev (>= 2.32),
                libgee-dev,
                libjson-glib-dev,
+               libnotify-dev,
                libsoup2.4-dev,
                liboauth-dev,
                libdee-dev (>= 1.0.7),
                libsqlite3-dev (>= 3.7.7),
-               libunity-dev (>= 6.90.0),
+               libunity-dev (>= 6.9),
                libtdb-dev (>= 1.2.6),
                libgstreamer1.0-dev,
                libgstreamer-plugins-base1.0-dev
 
=== modified file 'src/Makefile.am'
--- src/Makefile.am	2013-02-15 13:06:28 +0000
+++ src/Makefile.am	2013-04-17 10:13:28 +0000
@@ -72,8 +72,9 @@
 
 unity_musicstore_daemon_VALAFLAGS = \
   --pkg json-glib-1.0 \
+  --pkg libnotify \
+  --pkg libsoup-2.4 \
   --pkg oauth \
-  --pkg libsoup-2.4 \
   $(unity_music_daemon_VALAFLAGS)
 
 unity_musicstore_daemon_LDADD = \
 
=== modified file 'src/album.vala'
--- src/album.vala	2012-09-11 12:50:34 +0000
+++ src/album.vala	2013-04-17 10:13:28 +0000
@@ -28,5 +28,6 @@
     public string uri { get; set; }
     public string artwork_path { get; set; }
     public string formatted_price { get; set; }
+    public string purchase_sku { get; set; }
   }
 }
 \ No newline at end of file
 
=== modified file 'src/musicstore-collection.vala'
--- src/musicstore-collection.vala	2012-12-06 19:29:07 +0000
+++ src/musicstore-collection.vala	2013-04-17 10:13:28 +0000
@@ -104,6 +104,18 @@
               track.duration = (int)root_obj.get_member ("duration").get_int ();
               tracks.append (track);
             }
+
+            if (root_obj.has_member ("id"))
+            {
+                album.purchase_sku = root_obj.get_string_member ("id");
+            }
+            else
+            {
+                // U1MS does not allow purchases of an album with no purchase_sku
+                album.purchase_sku = "";
+                warning ("Json has no purchase_sku in '%s'", details_uri);
+            }
+
           }
           else
           {
@@ -125,6 +137,7 @@
     {
       var timer = new Timer ();
       debug ("Searching %s", file.get_uri ());
+      var empty_asv = new Variant.array (VariantType.VARDICT.element (), {});
 
       try {
         var stream = yield file.read_async (Priority.DEFAULT, cancellable);
 
=== modified file 'src/musicstore-daemon.vala'
--- src/musicstore-daemon.vala	2012-09-04 09:53:02 +0000
+++ src/musicstore-daemon.vala	2013-04-17 10:13:28 +0000
@@ -25,6 +25,8 @@
   static Application? app = null;
   static MusicStoreScopeProxy? daemon = null;
 
+  static const string BUS_NAME = "com.canonical.Unity.Scope.MusicStore";
+
   /* Check if a given well known DBus is owned.
    * WARNING: This does sync IO!  */
   public static bool dbus_name_has_owner (string name)
@@ -65,7 +67,7 @@
      * making it race against GDBus' worker thread to export our
      * objects on the bus before/after owning our name and receiving
      * method calls on our objects (which may not yet be up!)*/
-    if (dbus_name_has_owner ("com.canonical.Unity.Scope.MusicStore"))
+    if (dbus_name_has_owner (BUS_NAME))
       {
         print ("Another instance of the UbuntuOne Music Daemon " +
                "already appears to be running.\nBailing out.\n");
@@ -75,10 +77,14 @@
     /* Now register our DBus objects *before* acquiring the name!
      * See above for reasons */
     daemon = new MusicStoreScopeProxy ();
+    try {
+        daemon.scope.export ();
+    } catch (GLib.IOError e) {
+        stdout.printf ("error %s\n", e.message);
+    }
   
     /* Use GApplication directly for single instance app functionality */
-    app = new Application ("com.canonical.Unity.Scope.MusicStore",
-                           ApplicationFlags.IS_SERVICE);
+    app = new Application (BUS_NAME, ApplicationFlags.IS_SERVICE);
     try {
       app.register ();
     } catch (Error e) {
 
=== modified file 'src/musicstore-scope.vala'
--- src/musicstore-scope.vala	2013-02-28 09:48:46 +0000
+++ src/musicstore-scope.vala	2013-04-17 10:13:28 +0000
@@ -18,15 +18,30 @@
  */
 
 using GLib;
+using Notify;
+using Unity;
+using Gdk;
+using Ubuntuone.Webservice;
 
 namespace Unity.MusicLens {
+  private const string FORGOTTEN_PASSWORD_URL = "https://login.ubuntu.com/+forgot_password";
+  private const string CHANGE_PAYMENT_METHOD_URL = "https://pay.ubuntu.com/account/";
+  private const string ERROR_MESSAGE_NOT_LOGGED_IN = _("It seems you don't have an Ubuntu One account, or you are not logged in. To continue, please login and visit the Ubuntu One online store.");
+  private const string ERROR_MESSAGE_NO_PAYMENT_METHOD = _("It seems you haven't set yet your preferred Ubuntu One payment method. To add a payment method, please visit the Ubuntu One online store.");
+  private const string ERROR_MESSAGE_TECHNICAL_PROBLEM = _("Sorry, we have encountered a technical problem. No money has been taken from your account. To try your purchase again, please visit the Ubuntu One online store.");
+  private const string U1_SSO_UI = "u1_login_register";
 
   public class MusicStoreScopeProxy : SimpleScope
   {
+    const string NO_CREDENTIALS_LABEL_TEXT = _("Before you can purchase music you need to log in to the Ubuntu One app.");
     private MusicStoreCollection collection;
     private Unity.Extras.PreviewPlayerController preview_player;
     private Unity.MusicPreview? music_preview;
     private PreferencesManager preferences = PreferencesManager.get_default ();
+    private HashTable<string, Album> album_map;
+    private PurchaseService purchase_service;
+    private Notification notification;
+    private bool have_credentials = false;
 
     public MusicStoreScopeProxy ()
     {
@@ -40,7 +55,11 @@
 
       base.initialize ();
 
+      Notify.init ("Music Store Scope");
+      notification = new Notification("Album name", _("Purchase started"), "");
       collection = new MusicStoreCollection ();
+      album_map = new HashTable<string, Album>(str_hash, str_equal);
+      purchase_service = new PurchaseService ();
 
       preferences.notify["remote-content-search"].connect((obj, pspec) => { scope.queue_search_changed(SearchType.DEFAULT); });
 
@@ -65,11 +84,11 @@
       else
       {
         warning ("Failed to generate preview for %s", uri);
-        return download_album (uri);
+        return open_uri (uri);
       }
     }
 
-    public Unity.ActivationResponse download_album (string uri)
+    public Unity.ActivationResponse open_uri (string uri)
     {
       /* launch the music store streaming client  or the webstore or whatevz */
       try {
@@ -89,6 +108,7 @@
 
       if (album != null)
       {
+        album_map.insert (uri, album);
         File cover_file = File.new_for_uri (album.artwork_path); //artwork path is a remote uri
         var cover = new FileIcon (cover_file);
 
@@ -111,12 +131,19 @@
           }
         }
 
-        GLib.Icon? icon = new GLib.FileIcon (File.new_for_path (Config.DATADIR + "/icons/unity-icon-theme/places/svg/service-u1.svg"));
-        var download_action = new Unity.PreviewAction ("download_album", _("Download"), icon);
-        if (album.formatted_price != null)
-            download_action.extra_text = album.formatted_price;
-        download_action.activated.connect (download_album);
-        music_preview.add_action (download_action);
+        if (have_credentials) {
+            GLib.Icon? icon = new GLib.FileIcon (File.new_for_path (Config.DATADIR + "/icons/unity-icon-theme/places/svg/service-u1.svg"));
+            var download_action = new Unity.PreviewAction ("show_purchase_preview", _("Download"), icon);
+            if (album.formatted_price != null)
+                download_action.extra_text = album.formatted_price;
+            download_action.activated.connect (show_purchase_preview);
+            music_preview.add_action (download_action);
+        } else {
+            var data = new HashTable<string, Variant>(str_hash, str_equal);
+            data["no_credentials_label"] = NO_CREDENTIALS_LABEL_TEXT;
+            InfoHint info_hint = new InfoHint.with_variant("music_preview", "", null, data);
+            music_preview.add_info(info_hint);
+        }
       }
       return music_preview;
     }
@@ -142,12 +169,227 @@
       }
 
       try {
-	debug ("model has %u rows before search", search.results_model.get_n_rows ());
-	yield collection.search (search, search_type, (owned) filters, max_results, cancellable);
-	debug ("model has %u rows after search", search.results_model.get_n_rows ());
+        yield purchase_service.fetch_credentials ();
+        have_credentials = true;
+      } catch (PurchaseError e) {
+        // this is not a serious error, just missing credentials
+        have_credentials = false;
+      }
+
+      try {
+          debug ("model has %u rows before search", search.results_model.get_n_rows ());
+	      yield collection.search (search, search_type, (owned) filters, max_results, cancellable);
+	      debug ("model has %u rows after search", search.results_model.get_n_rows ());
       } catch (IOError e) {
-	warning ("Failed to search for '%s': %s", search.search_string, e.message);
-      }
+	      warning ("Failed to search for '%s': %s", search.search_string, e.message);
+      }
+
+      try {
+        yield purchase_service.fetch_account_info ();
+        debug ("retrieved account info: %s %s", purchase_service.nickname, purchase_service.email);
+      } catch (PurchaseError e) {
+        debug ("can't get account info: %s", e.message);
+      }
+    }
+
+    delegate Unity.ActivationResponse LinkHandler (string uri);
+
+    private Unity.ActivationResponse build_error_preview (string uri, string error_header, string link_text, LinkHandler link_handler)
+    {
+      Album album = null;
+      SList<Track> tracks = null;
+      collection.get_album_details (uri, out album, out tracks);
+      debug ("album art uri: %s", album.artwork_path);
+      File cover_file = File.new_for_uri (album.artwork_path); //artwork path is a remote uri
+      var cover = new FileIcon (cover_file);
+      var error_preview = new Unity.PaymentPreview.for_error(album.title, album.artist, cover);
+      error_preview.header = error_header;
+
+      var cancel_action = new Unity.PreviewAction ("cancel", _("Cancel"), null);
+      cancel_action.activated.connect (() => cancel_purchase (uri));
+      error_preview.add_action (cancel_action);
+
+      GLib.Icon? icon = new GLib.FileIcon (File.new_for_path (Config.DATADIR + "/icons/unity-icon-theme/places/svg/service-u1.svg"));
+      var error_action = new Unity.PreviewAction ("go_to_u1", link_text, icon);
+      error_action.activated.connect (() => link_handler (uri));
+      error_preview.add_action (error_action);
+      return new Unity.ActivationResponse.with_preview (error_preview);
+    }
+
+    public Unity.ActivationResponse open_forgot_password_url (string uri)
+    {
+      return open_uri (FORGOTTEN_PASSWORD_URL);
+    }
+
+    public Unity.ActivationResponse change_payment_method (string uri)
+    {
+      if (purchase_service.open_url != null)
+      {
+        debug ("Open url is %s", purchase_service.open_url);
+        return open_uri (purchase_service.open_url);
+      }
+      return open_uri (CHANGE_PAYMENT_METHOD_URL);
+    }
+
+    public Unity.ActivationResponse cancel_purchase (string uri)
+    {
+      return new Unity.ActivationResponse.with_preview (preview (uri));
+    }
+
+    public Unity.ActivationResponse open_sso_login (string uri)
+    {
+      Album album = null;
+      SList<Track> tracks = null;
+      collection.get_album_details (uri, out album, out tracks);
+
+      var ui_path = Environment.find_program_in_path (U1_SSO_UI);
+      GLib.Pid child_pid;
+      string argv[11] = {
+        ui_path,
+        "--album", album.title,
+        "--artist", album.artist,
+        "--price", album.formatted_price,
+        "--picture", album.artwork_path,
+        "--url", uri
+      };
+      if (ui_path != null) {
+        try {
+          bool was_started = Process.spawn_async (null, argv, null, 0, null, out child_pid);
+          // hide dash
+          if (was_started) {
+              return new Unity.ActivationResponse (Unity.HandledType.HIDE_DASH);
+          }
+        } catch (GLib.SpawnError e) {
+          debug ("Failed to start u1_sso_ui for uri %s", uri);
+        }
+      }
+      return open_uri (uri);
+    }
+
+    public Unity.ActivationResponse show_purchase_preview (string uri)
+    {
+      if (purchase_service.got_credentials () == false)
+      {
+        debug ("no credentials available, opening sso login. %s", uri);
+        return build_error_preview (uri, ERROR_MESSAGE_NOT_LOGGED_IN, _("Continue"), open_sso_login);
+      }
+
+      Album album = null;
+      SList<Track> tracks = null;
+      collection.get_album_details (uri, out album, out tracks);
+      if (album != null)
+      {
+        try {
+          purchase_service.fetch_payment_info (album.purchase_sku);
+          debug ("retrieved payment method: %s", purchase_service.selected_payment_method);
+          return new Unity.ActivationResponse.with_preview (purchase_preview (uri, null));
+        } catch (PurchaseError e) {
+          debug ("can't get default payment method: %s", e.message);
+          return build_error_preview (uri, ERROR_MESSAGE_NO_PAYMENT_METHOD, _("Choose Payment Method"), change_payment_method);
+        }
+      }
+      return open_uri (uri);
+    }
+
+    public Unity.ActivationResponse purchase_album (Unity.PreviewAction action, string uri)
+    {
+      var password = action.hints["password"].get_string();
+
+      if (password == null) {
+          var preview = purchase_preview (uri, _("Please enter your password"));
+          debug ("empty password.");
+          return new Unity.ActivationResponse.with_preview (preview);
+      }
+
+      var album = album_map.get (uri);
+
+      File cover_file = File.new_for_uri (album.artwork_path); //artwork path is a remote uri
+      try {
+        var cover_pixbuf = new Pixbuf.from_stream (cover_file.read ());
+        notification.set_icon_from_pixbuf (cover_pixbuf);
+      } catch (GLib.Error e) {
+        debug ("Cannot set notification icon from uri %s", uri);
+      }
+
+      notification.summary = album.title;
+      notification.body = _("Authorizing purchase");
+      try {
+        notification.show ();
+      } catch (GLib.Error e) {
+        debug ("Error while showing notification: %s", e.message);
+      }
+
+      try {
+        purchase_service.purchase (album.purchase_sku, password);
+        debug ("purchase completed.");
+        notification.update (album.title, _("Purchase completed"), "");
+        try {
+          notification.show ();
+        } catch (GLib.Error e) {
+          debug ("Error while showing notification: %s", e.message);
+        }
+        return new Unity.ActivationResponse (Unity.HandledType.HIDE_DASH);
+      } catch (PurchaseError e) {
+        if (e is PurchaseError.WRONG_PASSWORD_ERROR) {
+            debug ("wrong password error: %s", e.message);
+            return new Unity.ActivationResponse.with_preview (purchase_preview (uri, _("Wrong password")));
+        } else {
+            debug ("got purchase error: %s", e.message);
+            return build_error_preview (uri, ERROR_MESSAGE_TECHNICAL_PROBLEM, _("Continue"), open_uri);
+        }
+      }
+    }
+
+    public Unity.Preview purchase_preview (string uri, string? error_message)
+    {
+      Unity.PaymentPreview album_purchase_preview = null;
+      Album album = null;
+      SList<Track> tracks = null;
+      collection.get_album_details (uri, out album, out tracks);
+
+      if (album != null)
+      {
+        File cover_file = File.new_for_uri (album.artwork_path); //artwork path is a remote uri
+
+        var cover = new FileIcon (cover_file);
+        album_purchase_preview = new Unity.PaymentPreview.for_music(album.title, album.artist, cover);
+
+        album_purchase_preview.header = _("Hi %s, you purchased in the past from Ubuntu One,"
+        + " would you like to use the same payment details? Please review your order.").printf (purchase_service.nickname);
+        album_purchase_preview.email = purchase_service.email;
+        album_purchase_preview.payment_method = purchase_service.selected_payment_method;
+        album_purchase_preview.purchase_prize = album.formatted_price;
+        album_purchase_preview.purchase_type = _("Digital CD");
+
+        // data
+
+        var data = new HashTable<string, Variant>(str_hash, str_equal);
+        if (error_message != null) {
+            data["error_message"] = error_message;
+        }
+
+        InfoHint info_hint = new InfoHint.with_variant("album_purchase_preview", "", null, data);
+        album_purchase_preview.add_info(info_hint);
+
+        // actions
+
+        var purchase_action = new Unity.PreviewAction ("purchase_album", _("Purchase"), null);
+        purchase_action.activated.connect (purchase_album);
+        album_purchase_preview.add_action (purchase_action);
+
+        var forgot_password_action = new Unity.PreviewAction ("forgot_password", _("forgotten your Ubuntu One password?"), null);
+        forgot_password_action.activated.connect (open_forgot_password_url);
+        album_purchase_preview.add_action (forgot_password_action);
+
+        var cancel_action = new Unity.PreviewAction ("cancel_purchase", _("Cancel"), null);
+        cancel_action.activated.connect (cancel_purchase);
+        album_purchase_preview.add_action (cancel_action);
+
+        var change_payment_method_action = new Unity.PreviewAction ("change_payment_method", _("change payment method"), null);
+        change_payment_method_action.activated.connect (change_payment_method);
+        album_purchase_preview.add_action (change_payment_method_action);
+      }
+      return album_purchase_preview;
     }
 
   }
 
=== modified file 'src/ubuntuone-webservices.vala'
--- src/ubuntuone-webservices.vala	2012-12-06 15:39:38 +0000
+++ src/ubuntuone-webservices.vala	2013-04-17 10:13:28 +0000
@@ -21,26 +21,29 @@
 
 [DBus (name = "com.ubuntuone.CredentialsManagement")]
 interface CredentialsManagement : GLib.Object {
+    public signal void authorization_denied ();
     public signal void credentials_found (HashTable <string, string> info);
+    public signal void credentials_not_found ();
     public signal void credentials_error ();
 
     [DBus (name = "find_credentials")]
     public abstract void find_credentials () throws IOError;
 }
 
-const string WEBAPI_URI = "https://edge.one.ubuntu.com/";
-const string ACCOUNT_URI = WEBAPI_URI + "api/account";
-const string PAYMENT_METHOD_URI = WEBAPI_URI + "music-store/api/1/user/retrieve-payment-method?purchase_sku=%s";
-const string PURCHASE_WITH_DEFAULT_PAYMENT_URI = WEBAPI_URI + "music-store/api/1/user/purchase-with-default-payment?purchase_sku=%s&authentication=%s";
-const string AUTHENTICATION_URI = "https://login.staging.ubuntu.com/api/1.1/authentications";
+const string WEBAPI_SERVER = "https://one.ubuntu.com/";
+const string ACCOUNT_PATH = "api/account";
+const string PAYMENT_METHOD_PATH = "music-store-up/api/1/user/retrieve-payment-method?purchase_sku=%s";
+const string PURCHASE_WITH_DEFAULT_PAYMENT_PATH = "music-store-up/api/1/user/purchase-with-default-payment?purchase_sku=%s&authentication=%s";
+const string AUTHENTICATION_SERVER = "https://login.ubuntu.com/";
+const string AUTHENTICATION_PATH = "api/1.1/authentications";
 const string AUTHENTICATE_PARAMS = "ws.op=authenticate&token_name=Purchase_Token";
-const int PASSWORD_CACHE_SECONDS = 300;
-const int PAYMENT_METHOD_CACHE_SECONDS = 120;
+
 
 namespace Ubuntuone.Webservice
 {
     public errordomain PurchaseError
     {
+        MISSING_CREDENTIALS_ERROR,
         PURCHASE_ERROR,
         WRONG_PASSWORD_ERROR,
         UNSPECIFIED_ERROR
@@ -56,17 +59,13 @@
         public string selected_payment_method { get; internal set; default = null; }
         public string consumer_key { get; private set; default = null; }
         public string token { get; private set; default = null; }
-        internal DateTime _selected_payment_method_expiry;
-        DateTime _password_expiry;
+        public string open_url { get; private set; default = null; }
         internal HashTable <string, string> _ubuntuone_credentials = null;
 
         construct {
             http_session = build_http_session ();
             http_session_sso = build_http_session ();
 
-            reset_payment_method_cache (0);
-            reset_password_cache (0);
-
             credentials_management = build_credentials_management ();
         }
 
@@ -77,24 +76,40 @@
             return session;
         }
 
-        internal DateTime now ()
-        {
-            return new DateTime.now_utc ();
-        }
-
-        internal bool expired_payment_method_cache ()
-        {
-            return _selected_payment_method_expiry.compare (now ()) <= 0;
-        }
-
-        internal void reset_payment_method_cache (int seconds_from_now)
-        {
-            _selected_payment_method_expiry = now ().add_seconds (seconds_from_now);
-        }
-
-        internal void reset_password_cache (int seconds_from_now)
-        {
-            _password_expiry = now ().add_seconds (seconds_from_now);
+        string webapi_server ()
+        {
+            string staging_webapi = Environment.get_variable ("U1_STAGING_WEBAPI");
+            return staging_webapi != null ? staging_webapi : WEBAPI_SERVER;
+        }
+
+        string account_uri ()
+        {
+            return webapi_server() + ACCOUNT_PATH;
+        }
+
+        string payment_method_uri ()
+        {
+            return webapi_server() + PAYMENT_METHOD_PATH;
+        }
+
+        string purchase_with_default_payment_uri ()
+        {
+            return webapi_server() + PURCHASE_WITH_DEFAULT_PAYMENT_PATH;
+        }
+
+        string authentication_server ()
+        {
+            string staging_authentication = Environment.get_variable ("U1_STAGING_AUTHENTICATION");
+            return staging_authentication != null ? staging_authentication : AUTHENTICATION_SERVER;
+        }
+
+        string authentication_uri ()
+        {
+            return authentication_server() + AUTHENTICATION_PATH;
+        }
+
+        public bool got_credentials () {
+            return _ubuntuone_credentials != null;
         }
 
         internal virtual CredentialsManagement build_credentials_management ()
@@ -125,28 +140,36 @@
             email = root_object.get_string_member("email");
         }
 
-        internal void parse_payment_method_json (string json_string) throws GLib.Error
+        internal void parse_payment_method_json (string json_string) throws GLib.Error, PurchaseError
         {
             var root_object = parse_json (json_string);
-            Json.Object payload = root_object.get_object_member("payload");
-            selected_payment_method = payload.get_string_member("selected_payment_method");
+            if (root_object.has_member ("selected_payment_method")) {
+                selected_payment_method = root_object.get_string_member("selected_payment_method");
+            } else {
+                open_url = root_object.get_string_member ("open_url");
+                var error_message = root_object.get_string_member ("error_message");
+                throw new PurchaseError.PURCHASE_ERROR (error_message);
+            }
         }
 
         internal void parse_authentication_json (string json_string) throws GLib.Error
         {
             var root_object = parse_json (json_string);
-            consumer_key = root_object.get_string_member("consumer_key");
-            token = root_object.get_string_member("token");
+            consumer_key = root_object.get_string_member ("consumer_key");
+            token = root_object.get_string_member ("token");
         }
 
         internal string parse_purchase_json (string json_string) throws GLib.Error
         {
             var root_object = parse_json (json_string);
-            Json.Object payload = root_object.get_object_member("payload");
-            return payload.get_string_member("open_url");
+            if (root_object.has_member ("open_url")) {
+                return root_object.get_string_member("open_url");
+            } else {
+                return "";
+            }
         }
 
-        internal virtual async void fetch_credentials () throws PurchaseError
+        public virtual async void fetch_credentials () throws PurchaseError
         {
             PurchaseError error = null;
 
@@ -155,8 +178,12 @@
                 debug ("got credentials");
                 fetch_credentials.callback ();
             });
+            ulong not_found_handler = credentials_management.credentials_not_found.connect ((credentials) => {
+                error = new PurchaseError.MISSING_CREDENTIALS_ERROR ("Can't get Ubuntu One tokens.");
+                fetch_credentials.callback ();
+            });
             ulong error_handler = credentials_management.credentials_error.connect (() => {
-                error = new PurchaseError.PURCHASE_ERROR ("Can't get Ubuntu One tokens.");
+                error = new PurchaseError.MISSING_CREDENTIALS_ERROR ("Can't get Ubuntu One tokens.");
                 fetch_credentials.callback ();
             });
 
@@ -164,10 +191,11 @@
                 credentials_management.find_credentials ();
                 yield;
             } catch (IOError e) {
-                error = new PurchaseError.PURCHASE_ERROR ("Can't get Ubuntu One tokens: %s", e.message);
+                error = new PurchaseError.MISSING_CREDENTIALS_ERROR ("Can't get Ubuntu One tokens: %s", e.message);
             }
 
             credentials_management.disconnect (found_handler);
+            credentials_management.disconnect (not_found_handler);
             credentials_management.disconnect (error_handler);
 
             if (error != null) {
@@ -208,7 +236,7 @@
         internal virtual async void fetch_account () throws PurchaseError
         {
             string response;
-            PurchaseError error = yield call_api ("GET", ACCOUNT_URI, out response);
+            PurchaseError error = yield call_api ("GET", account_uri(), out response);
 
             if (error != null) {
                 debug ("Error while fetching U1 account: %s.", error.message);
@@ -224,43 +252,40 @@
             }
         }
 
-        internal virtual async void fetch_payment_method (string purchase_sku) throws PurchaseError
+        internal virtual void fetch_payment_method (string purchase_sku) throws PurchaseError
         {
-            string response;
-            var uri = PAYMENT_METHOD_URI.printf (purchase_sku);
-            PurchaseError error = yield call_api ("GET", uri, out response);
+            var uri = payment_method_uri().printf (purchase_sku);
 
-            if (error != null) {
-                debug ("Error while fetching payment method: %s.", error.message);
-                throw error;
+            var message = send_signed_webservice_call ("GET", uri);
+            if (message.status_code != Soup.KnownStatusCode.OK) {
+                debug ("Purchase request failed: HTTP %u", message.status_code);
+                debug ("Reason: %s", message.reason_phrase);
+                try {
+                    message.response_body.flatten ();
+                    debug ("body: ------\n%s\n------\n", (string) message.response_body.data);
+                } catch (Error e) {
+                }
+                throw new PurchaseError.PURCHASE_ERROR ("Retrieve payment method failed: %s".printf (message.reason_phrase));
             }
-
             try {
-                parse_payment_method_json (response);
-                debug ("got payment method");
+                message.response_body.flatten ();
+                var result = (string) message.response_body.data;
+                parse_payment_method_json (result);
             } catch (GLib.Error e) {
                 debug ("Error while getting payment method: %s.", e.message);
                 throw new PurchaseError.PURCHASE_ERROR (e.message);
             }
         }
 
-        internal virtual async void refetch_payment_info (string purchase_sku) throws PurchaseError
+        public virtual async void fetch_account_info () throws PurchaseError
         {
             yield fetch_credentials ();
             yield fetch_account ();
-            yield fetch_payment_method (purchase_sku);
-            reset_payment_method_cache (PAYMENT_METHOD_CACHE_SECONDS);
         }
 
-        public async void fetch_payment_info (string purchase_sku) throws PurchaseError
+        public void fetch_payment_info (string purchase_sku) throws PurchaseError
         {
-            if (expired_payment_method_cache ())
-            {
-                debug ("refetching");
-                yield refetch_payment_info (purchase_sku);
-            } else {
-                debug ("in cache");
-            }
+            fetch_payment_method (purchase_sku);
         }
 
         internal virtual void _do_sso_webcall (Soup.Message message, string password)
@@ -286,6 +311,11 @@
                 if (message.status_code == Soup.KnownStatusCode.UNAUTHORIZED) {
                     throw new PurchaseError.WRONG_PASSWORD_ERROR ("Wrong password");
                 }
+                try {
+                    message.response_body.flatten ();
+                    debug ("body: ------\n%s\n------\n", (string) message.response_body.data);
+                } catch (Error e) {
+                }
                 throw new PurchaseError.PURCHASE_ERROR (message.reason_phrase);
             }
             message.response_body.flatten ();
@@ -294,12 +324,13 @@
 
         internal virtual string get_purchase_token (string password) throws PurchaseError
         {
-            var result = authenticated_sso_webcall ("POST", AUTHENTICATION_URI, AUTHENTICATE_PARAMS, password);
+            var result = authenticated_sso_webcall ("POST", authentication_uri(), AUTHENTICATE_PARAMS, password);
             try {
                 parse_authentication_json (result);
             } catch (GLib.Error e) {
                 throw new PurchaseError.PURCHASE_ERROR (e.message);
             }
+
             return "%s:%s".printf (consumer_key, token);
         }
 
@@ -311,14 +342,20 @@
             return message;
         }
 
-        internal virtual void purchase_with_default_payment (string sku, string purchase_token) throws PurchaseError
+        internal virtual void purchase_with_default_payment (string album_id, string purchase_token) throws PurchaseError
         {
-            var uri = PURCHASE_WITH_DEFAULT_PAYMENT_URI.printf (sku, purchase_token);
+            var uri = purchase_with_default_payment_uri().printf (album_id, purchase_token);
+
             var message = send_signed_webservice_call ("GET", uri);
 
             if (message.status_code != Soup.KnownStatusCode.OK) {
                 debug ("Purchase request failed: HTTP %u", message.status_code);
                 debug ("Reason: %s", message.reason_phrase);
+                try {
+                    message.response_body.flatten ();
+                    debug ("body: ------\n%s\n------\n", (string) message.response_body.data);
+                } catch (Error e) {
+                }
                 throw new PurchaseError.PURCHASE_ERROR ("Purchase failed: %s".printf (message.reason_phrase));
             }
             try {
@@ -336,7 +373,9 @@
         public void purchase (string album_id, string password) throws PurchaseError
         {
             var purchase_token = get_purchase_token (password);
+            debug ("purchasing...");
             purchase_with_default_payment (album_id, purchase_token);
+            debug ("purchase completed.");
         }
     }
 }
 
=== modified file 'tests/unit/test-ubuntuone-purchases.vala'
--- tests/unit/test-ubuntuone-purchases.vala	2012-12-06 15:39:38 +0000
+++ tests/unit/test-ubuntuone-purchases.vala	2013-04-17 10:13:28 +0000
@@ -25,7 +25,7 @@
 
 const string FAKE_URL = "http://fake/url";
 const string FAKE_PASSWORD = "PezEspada";
-const string FAKE_SKU = "fake_store:fake_album:id";
+const string FAKE_SKU = "7digital:fake_album:id";
 const string FAKE_TOKEN = "a fake token";
 
 const string BROKEN_JSON = """
@@ -45,14 +45,17 @@
 
 const string FAKE_JSON_PAYMENT_METHOD = """
     {
-        "meta": {
-            "status": "Ok"
-        },
-        "payload": {
-            "open_url": "",
-            "user_email": "[e-mail]",
-            "selected_payment_method": "Visa 1234"
-        }
+        "open_url": "",
+        "user_email": "[e-mail]",
+        "selected_payment_method": "Visa 1234"
+    }
+""";
+
+
+const string FAKE_JSON_PAYMENT_METHOD_ERROR = """
+    {
+        "open_url": "http://somewhere/else",
+        "error_message": "No default payment method selected."
     }
 """;
 
@@ -69,30 +72,18 @@
 
 const string FAKE_JSON_PURCHASE = """
     {
-        "meta": {
-            "status": "Ok"
-        },
-        "payload": {
-            "order_id": "1111",
-            "order_status": "OK",
-            "order_detail": "TBD",
-            "open_url": ""
-        }
+        "order_id": "1111",
+        "order_status": "OK"
     }
 """;
 
 
 const string FAKE_JSON_PURCHASE_FAILURE = """
     {
-        "meta": {
-            "status": "Ok"
-        },
-        "payload": {
-            "order_id": "1111",
-            "order_status": "PAYMENT_FAILURE",
-            "order_detail": "TBD",
-            "open_url": "http://slashdot.org/"
-        }
+        "order_id": "1111",
+        "order_status": "PAYMENT_FAILURE",
+        "order_detail": "TBD",
+        "open_url": "http://slashdot.org/"
     }
 """;
 
@@ -113,12 +104,11 @@
     Test.add_data_func ("/Unit/PurchaseChecker/ParseAccount", test_parse_account);
     Test.add_data_func ("/Unit/PurchaseChecker/ParseBrokenAccount", test_parse_broken_account);
     Test.add_data_func ("/Unit/PurchaseChecker/ParsePaymentMethod", test_parse_payment_method);
+    Test.add_data_func ("/Unit/PurchaseChecker/ParsePaymentMethodError", test_parse_payment_method_error);
     Test.add_data_func ("/Unit/PurchaseChecker/ParseAuthentication", test_parse_authentication);
     Test.add_data_func ("/Unit/PurchaseChecker/ReadyToPurchase", test_ready_to_purchase);
-    Test.add_data_func ("/Unit/PurchaseChecker/FetchPaymentInvalidated", test_fetch_payment_invalidated);
-    Test.add_data_func ("/Unit/PurchaseChecker/FetchPaymentCached", test_fetch_payment_cached);
-    Test.add_data_func ("/Unit/PurchaseChecker/ReFetchPayment", test_refetch_payment);
-    Test.add_data_func ("/Unit/PurchaseChecker/ReFetchPaymentSetsCache", test_refetch_payment_sets_cache);
+    Test.add_data_func ("/Unit/PurchaseChecker/FetchAccountInfo", test_fetch_account_info);
+    Test.add_data_func ("/Unit/PurchaseChecker/FetchPaymentInfo", test_fetch_payment_info);
     Test.add_data_func ("/Unit/PurchaseChecker/FetchCredentials", test_fetch_credentials);
     Test.add_data_func ("/Unit/PurchaseChecker/FetchCredentialsFails", test_fetch_credentials_fails);
     Test.add_data_func ("/Unit/PurchaseChecker/FetchCredentialsFailsExtra", test_fetch_credentials_fails_extra);
@@ -163,11 +153,12 @@
   async void irl_test_async ()
   {
     var purchase_service = new PurchaseService();
-    var purchase_sku = "1";
+    var purchase_sku = "7digital:album:1347423:WORLD";
     try {
-      yield purchase_service.fetch_payment_info (purchase_sku);
+      yield purchase_service.fetch_account_info ();
+      purchase_service.fetch_payment_info (purchase_sku);
       debug ("data was available: %s %s %s", purchase_service.nickname, purchase_service.email, purchase_service.selected_payment_method);
-      var real_user_password = "****fake_password_in_bzr***";
+      var real_user_password = FAKE_PASSWORD;
       purchase_service.purchase (purchase_sku, real_user_password);
       debug ("purchase completed.");
     } catch (PurchaseError e) {
@@ -186,7 +177,7 @@
       });
       return false;
     });
-    assert (run_with_timeout (loop, 10000));
+    assert (run_with_timeout (loop, 60000));
   }
 
   class FakeCredentialsManagement : GLib.Object, CredentialsManagement
@@ -290,6 +281,19 @@
     assert_cmpstr (purchase_service.selected_payment_method, OperatorType.EQUAL, "Visa 1234");
   }
 
+  private static void test_parse_payment_method_error ()
+  {
+    var purchase_service = new BaseTestPurchaseService ();
+    try
+    {
+        purchase_service.parse_payment_method_json (FAKE_JSON_PAYMENT_METHOD_ERROR);
+        assert_not_reached ();
+    } catch (PurchaseError e)
+    {
+        assert_cmpstr (purchase_service.open_url, OperatorType.EQUAL, "http://somewhere/else");
+    }
+  }
+
   private static void test_parse_authentication ()
   {
     var purchase_service = new BaseTestPurchaseService ();
@@ -313,30 +317,6 @@
     assert (purchase_service.ready_to_purchase == true);
   }
 
-  class TestFetchPurchaseService : BaseTestPurchaseService {
-    internal bool fetch_called = false;
-    internal override async void refetch_payment_info (string purchase_sku)
-    {
-      fetch_called = true;
-    }
-  }
-
-  private static void test_fetch_payment_invalidated ()
-  {
-    var purchase_service = new TestFetchPurchaseService ();
-    purchase_service._selected_payment_method_expiry = new DateTime.now_utc ();
-    purchase_service.fetch_payment_info ("fake_sku");
-    assert (purchase_service.fetch_called);
-  }
-
-  private static void test_fetch_payment_cached ()
-  {
-    var purchase_service = new TestFetchPurchaseService ();
-    purchase_service._selected_payment_method_expiry = new DateTime.now_utc ().add_seconds (60);
-    purchase_service.fetch_payment_info ("fake_sku");
-    assert (purchase_service.fetch_called == false);
-  }
-
   class TestRefetchPurchaseService : BaseTestPurchaseService {
     internal bool credentials_fetched = false;
     internal bool account_fetched = false;
@@ -360,26 +340,21 @@
       });
       yield;
     }
-    internal override async void fetch_payment_method (string purchase_sku)
+    internal override void fetch_payment_method (string purchase_sku)
     {
-      Idle.add (() => {
-        payment_method_fetched = true;
-        fetch_payment_method.callback ();
-        return false;
-      });
-      yield;
+      payment_method_fetched = true;
     }
   }
 
-  private static void test_refetch_payment ()
+  private static void test_fetch_account_info ()
   {
     var purchase_service = new TestRefetchPurchaseService ();
 
     MainLoop mainloop = new MainLoop ();
-    purchase_service.refetch_payment_info.begin("fake_sku", (obj, res) => {
+    purchase_service.fetch_account_info.begin((obj, res) => {
         mainloop.quit ();
         try {
-            purchase_service.refetch_payment_info.end (res);
+            purchase_service.fetch_account_info.end (res);
         } catch (PurchaseError e) {
             error ("Can't fetch payment info: %s", e.message);
         }
@@ -388,29 +363,19 @@
 
     assert (purchase_service.credentials_fetched);
     assert (purchase_service.account_fetched);
+  }
+
+  private static void test_fetch_payment_info ()
+  {
+    var purchase_service = new TestRefetchPurchaseService ();
+    try {
+        purchase_service.fetch_payment_info("fake_sku");
+    } catch (PurchaseError e) {
+        error ("Can't fetch payment info: %s", e.message);
+    }
     assert (purchase_service.payment_method_fetched);
   }
 
-  private static void test_refetch_payment_sets_cache ()
-  {
-    var purchase_service = new TestRefetchPurchaseService ();
-
-    assert (true == purchase_service.expired_payment_method_cache ());
-
-    MainLoop mainloop = new MainLoop ();
-    purchase_service.refetch_payment_info.begin("fake_sku", (obj, res) => {
-        mainloop.quit ();
-        try {
-            purchase_service.refetch_payment_info.end (res);
-        } catch (PurchaseError e) {
-            error ("Can't fetch payment info: %s", e.message);
-        }
-    });
-    assert (run_with_timeout (mainloop, 1000));
-
-    assert (false == purchase_service.expired_payment_method_cache ());
-  }
-
   private static void test_fetch_credentials ()
   {
     var purchase_service = new BaseTestPurchaseService ();
@@ -431,7 +396,7 @@
 
   private static void test_fetch_credentials_fails ()
   {
-    bool failed = false;
+    PurchaseError failure = null;
     var purchase_service = new FailingCredentialsPurchaseService ();
 
     MainLoop mainloop = new MainLoop ();
@@ -440,17 +405,16 @@
         try {
             purchase_service.fetch_credentials.end (res);
         } catch (PurchaseError e) {
-            failed = true;
+            failure = e;
         }
     });
     assert (run_with_timeout (mainloop, 1000));
-
-    assert (failed);
+    assert (failure is PurchaseError.MISSING_CREDENTIALS_ERROR);
   }
 
   private static void test_fetch_credentials_fails_extra ()
   {
-    bool failed = false;
+    PurchaseError failure = null;
     var purchase_service = new ExtraFailingCredentialsPurchaseService ();
 
     MainLoop mainloop = new MainLoop ();
@@ -459,12 +423,11 @@
         try {
             purchase_service.fetch_credentials.end (res);
         } catch (PurchaseError e) {
-            failed = true;
+            failure = e;
         }
     });
     assert (run_with_timeout (mainloop, 1000));
-
-    assert (failed);
+    assert (failure is PurchaseError.MISSING_CREDENTIALS_ERROR);
   }
 
   class FakeWebcallPurchaseService : BaseTestPurchaseService
@@ -565,21 +528,7 @@
   {
     var purchase_service = new FakeWebcallPurchaseService (_status_code, _found_json);
     purchase_service._ubuntuone_credentials = new HashTable <string, string> (str_hash, str_equal);
-
-    PurchaseError error = null;
-    MainLoop mainloop = new MainLoop ();
-    purchase_service.fetch_payment_method.begin("fake_sku", (obj, res) => {
-        mainloop.quit ();
-        try {
-            purchase_service.fetch_payment_method.end (res);
-        } catch (PurchaseError e) {
-            error = e;
-        }
-    });
-    assert (run_with_timeout (mainloop, 1000));
-    if (error != null) {
-        throw error;
-    }
+    purchase_service.fetch_payment_method("fake_sku");
     return purchase_service;
   }
 
@@ -616,7 +565,7 @@
   class TestPurchaseService : BaseTestPurchaseService
   {
     internal string password;
-    internal string sku;
+    internal string album_id;
     internal string purchase_token;
 
     internal override string get_purchase_token (string password)
@@ -624,9 +573,9 @@
         this.password = password;
         return FAKE_TOKEN;
     }
-    internal override void purchase_with_default_payment (string sku, string purchase_token)
+    internal override void purchase_with_default_payment (string album_id, string purchase_token)
     {
-        this.sku = sku;
+        this.album_id = album_id;
         this.purchase_token = purchase_token;
     }
   }
@@ -637,7 +586,7 @@
         var purchase_service = new TestPurchaseService ();
         purchase_service.purchase (FAKE_SKU, FAKE_PASSWORD);
         assert_cmpstr (purchase_service.password, OperatorType.EQUAL, FAKE_PASSWORD);
-        assert_cmpstr (purchase_service.sku, OperatorType.EQUAL, FAKE_SKU);
+        assert_cmpstr (purchase_service.album_id, OperatorType.EQUAL, FAKE_SKU);
         assert_cmpstr (purchase_service.purchase_token, OperatorType.EQUAL, FAKE_TOKEN);
     } catch (Error e) {
         assert_not_reached ();
@@ -722,6 +671,7 @@
     try {
       purchase_service.purchase_with_default_payment (FAKE_SKU, FAKE_TOKEN);
     } catch (PurchaseError e) {
+      warning (e.message);
       assert_not_reached ();
     }
   }