Merge lp:~stolowski/unity-scope-click/edit-reviews-15-04 into lp:unity-scope-click

[Paweł Stołowski]

Support for review editing.

Support for review editing.

[PS Jenkins bot (ps-jenkins)]

FAILED: Continuous integration, rev:320
http://jenkins.qa.ubuntu.com/job/unity-scope-click-ci/592/
Executed test runs:
    FAILURE: http://jenkins.qa.ubuntu.com/job/unity-scope-click-wily-amd64-ci/4/console
    FAILURE: http://jenkins.qa.ubuntu.com/job/unity-scope-click-wily-armhf-ci/4/console

Click here to trigger a rebuild:
http://s-jenkins.ubuntu-ci:8080/job/unity-scope-click-ci/592/rebuild

review: Needs Fixing (continuous-integration)

[lp:~stolowski/unity-scope-click/edit-reviews-15-04]

321. By Paweł Stołowski on 2015-05-15

Renamed sort to bring_to_front and added unit tests for it

Unmerged revisions

=== modified file 'CMakeLists.txt'
--- CMakeLists.txt	2015-05-07 16:11:57 +0000
+++ CMakeLists.txt	2015-05-11 15:29:02 +0000
@@ -27,7 +27,7 @@
 pkg_check_modules(UNITY_SCOPES REQUIRED libunity-scopes>=0.6.7 libunity-api>=0.1.3)
 add_definitions(${UNITY_SCOPES_CFLAGS} ${UNITY_SCOPES_CFLAGS_OTHER})
 
-pkg_check_modules(UBUNTUONE REQUIRED ubuntuoneauth-2.0)
+pkg_check_modules(UBUNTUONE REQUIRED ubuntuoneauth-2.0>=15.04)
 add_definitions(${UBUNTUONE_CFLAGS} ${UBUNTUONE_CFLAGS_OTHER})
 
 pkg_check_modules(UBUNTU_DOWNLOAD_MANAGER_CLIENT REQUIRED ubuntu-download-manager-client)

=== modified file 'debian/control'
--- debian/control	2015-05-07 16:11:57 +0000
+++ debian/control	2015-05-11 15:29:02 +0000
@@ -18,7 +18,7 @@
                libpay2-dev,
                libubuntu-download-manager-client-dev (>= 0.3+14.10.20140430-0ubuntu1),
                libubuntu-download-manager-common-dev (>= 0.3+14.10.20140430-0ubuntu1),
-               libubuntuoneauth-2.0-dev,
+               libubuntuoneauth-2.0-dev (>= 15.04),
                libunity-api-dev (>= 7.80.7),
                libunity-scopes-dev (>= 0.6.7~),
                libgsettings-qt-dev,

=== modified file 'libclickscope/click/preview.cpp'
--- libclickscope/click/preview.cpp	2015-04-10 14:24:10 +0000
+++ libclickscope/click/preview.cpp	2015-05-11 15:29:02 +0000
@@ -36,6 +36,7 @@
 #include <click/dbus_constants.h>
 #include <click/departments-db.h>
 #include <click/utils.h>
+#include <click/smartconnect.h>
 
 #include <boost/algorithm/string/replace.hpp>
 
@@ -644,21 +645,54 @@
 {
 }
 
+std::string InstalledPreview::get_consumer_key()
+{
+    std::promise<std::string> promise;
+    auto future = promise.get_future();
+    QSharedPointer<click::CredentialsService> sso;
+
+    qt::core::world::enter_with_task([this, &sso, &promise]() {
+            sso.reset(new click::CredentialsService());
+
+            QObject::connect(sso.data(), &click::CredentialsService::credentialsFound,
+                    [&promise, &sso](const UbuntuOne::Token& token) {
+                    qDebug() << "Credentials found";
+                    sso.clear();
+                    promise.set_value(token.consumerKey().toStdString());
+                });
+            QObject::connect(sso.data(), &click::CredentialsService::credentialsNotFound,
+                    [&promise, &sso]() {
+                    qDebug() << "No credentials found";
+                    sso.clear();
+                    promise.set_value("");
+                    });
+
+            sso->getCredentials();
+            qDebug() << "getCredentials finished";
+        });
+    return future.get();
+}
+
 void InstalledPreview::run(unity::scopes::PreviewReplyProxy const& reply)
 {
     // Check if the user is submitting a rating, so we can submit it.
     Review review;
     review.rating = 0;
+    std::string widget_id;
     // We use a try/catch here, as scope_data() can be a dict, but not have
     // the values we need, which will result in an exception thrown. 
     try {
         auto metadict = metadata.scope_data().get_dict();
         review.rating = metadict["rating"].get_int();
         review.review_text = metadict["review"].get_string();
+        widget_id = metadict["widget_id"].get_string();
     } catch(...) {
         // Do nothing as we are not submitting a review.
     }
 
+    auto userid = get_consumer_key();
+
+    //
     // Get the click manifest.
     Manifest manifest;
     std::promise<Manifest> manifest_promise;
@@ -684,35 +718,68 @@
         if (review.rating > 0) {
             std::promise<bool> submit_promise;
             std::future<bool> submit_future = submit_promise.get_future();
-            qt::core::world::enter_with_task([this, review, &submit_promise]() {
+            qt::core::world::enter_with_task([this, review, &submit_promise, widget_id]() mutable {
                     QSharedPointer<click::CredentialsService> sso(new click::CredentialsService());
                     client->setCredentialsService(sso);
-                    submit_operation = reviews->submit_review(review,
+                    if (widget_id == "rating") {
+                        submit_operation = reviews->submit_review(review,
                                                               [&submit_promise](click::Reviews::Error){
                                                                   // TODO: Need to handle errors properly.
                                                                   submit_promise.set_value(true);
                                                               });
-                });
+
+                    } else {
+                        try {
+                            review.id = std::stoul(widget_id);
+                            qDebug() << "Updating review" << review.id << "with '" << QString::fromStdString(review.review_text) << "'";
+                            submit_operation = reviews->edit_review(review,
+                                                                [&submit_promise](click::Reviews::Error){
+                                                                    // TODO: Need to handle errors properly.
+                                                                    submit_promise.set_value(true);
+                                                                });
+                        } catch (const std::exception &e) {
+                            qWarning() << "Failed to update review:" << QString::fromStdString(e.what()) << " review widget:" << QString::fromStdString(widget_id);
+                            submit_promise.set_value(false);
+                        }
+                }
+            });
             submit_future.get();
         }
     }
-    getApplicationUri(manifest, [this, reply, manifest, app_name, &review](const std::string& uri) {
-            populateDetails([this, reply, uri, manifest, app_name, &review](const PackageDetails &details){
+    getApplicationUri(manifest, [this, reply, manifest, app_name, &review, userid](const std::string& uri) {
+            populateDetails([this, reply, uri, manifest, app_name](const PackageDetails &details){
                 store_department(details);
                 pushPackagePreviewWidgets(reply, details, createButtons(uri, manifest));
-
-                if (review.rating == 0 && manifest.removable) {
-                    scopes::PreviewWidgetList review_input;
-                    scopes::PreviewWidget rating("rating", "rating-input");
-                    rating.add_attribute_value("required", scopes::Variant("rating"));
-                    review_input.push_back(rating);
-                    reply->push(review_input);
-                }
             },
-            [this, reply](const ReviewList& reviewlist,
+            [this, reply, &review, manifest, userid](const ReviewList& reviewlist,
                           click::Reviews::Error error) {
+                auto reviews = sort(reviewlist, userid);
+                scopes::PreviewWidgetList review_input;
+                bool has_reviewed = reviews.size() > 0 && reviews.front().reviewer_username == userid;
+
+                if (has_reviewed) {
+                    auto existing_review = reviews.front();
+                    reviews.pop_front();
+                    qDebug() << "Review for current user already exists, review id:" << existing_review.id;
+                    if (manifest.removable) {
+                        scopes::PreviewWidget rating(std::to_string(existing_review.id), "rating-edit"); // pass review id via widget id
+                        rating.add_attribute_value("required", scopes::Variant("rating"));
+                        rating.add_attribute_value("review", scopes::Variant(existing_review.review_text));
+                        rating.add_attribute_value("rating", scopes::Variant(existing_review.rating));
+                        rating.add_attribute_value("author", scopes::Variant(existing_review.reviewer_name));
+                        review_input.push_back(rating);
+                    }
+                } else {
+                    if (review.rating == 0 && manifest.removable) {
+                        scopes::PreviewWidget rating("rating", "rating-input");
+                        rating.add_attribute_value("required", scopes::Variant("rating"));
+                        review_input.push_back(rating);
+                    }
+                }
+                reply->push(review_input);
+
                 if (error == click::Reviews::Error::NoError) {
-                    reply->push(reviewsWidgets(reviewlist));
+                    reply->push(reviewsWidgets(reviews));
                 } else {
                     qDebug() << "There was an error getting reviews for:" << result["name"].get_string().c_str();
                 }

=== modified file 'libclickscope/click/preview.h'
--- libclickscope/click/preview.h	2015-04-10 14:24:10 +0000
+++ libclickscope/click/preview.h	2015-05-11 15:29:02 +0000
@@ -209,6 +209,7 @@
 
 protected:
     void getApplicationUri(const Manifest& manifest, std::function<void(const std::string&)> callback);
+    std::string get_consumer_key();
 
 private:
     static scopes::PreviewWidgetList createButtons(const std::string& uri,

=== modified file 'libclickscope/click/reviews.cpp'
--- libclickscope/click/reviews.cpp	2014-05-26 14:02:45 +0000
+++ libclickscope/click/reviews.cpp	2015-05-11 15:29:02 +0000
@@ -28,6 +28,7 @@
  */
 
 #include <cstdlib>
+#include <algorithm>
 
 #include <boost/property_tree/ptree.hpp>
 #include <boost/property_tree/json_parser.hpp>
@@ -96,6 +97,25 @@
     return reviews;
 }
 
+ReviewList sort (const ReviewList& reviews, const std::string& userid)
+{
+    if (userid.size() == 0)
+    {
+        return reviews;
+    }
+    auto new_reviews = reviews;
+    auto it = std::find_if(new_reviews.begin(), new_reviews.end(), [userid](const Review& review) {
+                return review.reviewer_username == userid;
+            });
+    if (it != new_reviews.end() && it != new_reviews.begin()) {
+        // move own review to the front
+        auto const review = *it;
+        new_reviews.erase(it);
+        new_reviews.push_front(review);
+    }
+    return new_reviews;
+}
+
 Reviews::Reviews (const QSharedPointer<click::web::Client>& client)
     : client(client)
 {
@@ -174,6 +194,38 @@
     return click::web::Cancellable(response);
 }
 
+click::web::Cancellable Reviews::edit_review (const Review& review,
+                                                std::function<void(Error)> callback)
+{
+    std::map<std::string, std::string> headers({
+            {click::web::CONTENT_TYPE_HEADER, click::web::CONTENT_TYPE_JSON},
+                });
+    Json::Value root(Json::ValueType::objectValue);
+    root["rating"] = review.rating;
+    root["review_text"] = review.review_text;
+    // NOTE: "summary" is a required field, but we don't have one. Use "".
+    root["summary"] = "Review";
+
+    qDebug() << "Rating" << review.package_name.c_str() << review.rating;
+
+    QSharedPointer<click::web::Response> response = client->call
+        (get_base_url() + click::REVIEWS_API_PATH + std::to_string(review.id) + "/", "PUT", true,
+         headers, Json::FastWriter().write(root), click::web::CallParams());
+
+    QObject::connect(response.data(), &click::web::Response::finished,
+                [=](QString) {
+                   qDebug() << "Review updated for:" << review.package_name.c_str();
+                   callback(Error::NoError);
+                });
+    QObject::connect(response.data(), &click::web::Response::error,
+                [=](QString) {
+                    qCritical() << "Network error updating a review for:" << review.package_name.c_str();
+                    callback(Error::NetworkError);
+                });
+
+    return click::web::Cancellable(response);
+}
+
 std::string Reviews::get_base_url ()
 {
     const char *env_url = getenv(REVIEWS_BASE_URL_ENVVAR.c_str());

=== modified file 'libclickscope/click/reviews.h'
--- libclickscope/click/reviews.h	2015-01-13 22:17:36 +0000
+++ libclickscope/click/reviews.h	2015-05-11 15:29:02 +0000
@@ -32,7 +32,7 @@
 
 #include <functional>
 #include <string>
-#include <vector>
+#include <list>
 
 #include <click/webclient.h>
 
@@ -62,9 +62,10 @@
     std::string reviewer_username;
 };
 
-typedef std::vector<Review> ReviewList;
+typedef std::list<Review> ReviewList;
 
 ReviewList review_list_from_json (const std::string& json);
+ReviewList sort (const ReviewList& reviews, const std::string& userid);
 
 class Reviews
 {
@@ -80,6 +81,8 @@
                                            std::function<void(ReviewList, Error)> callback);
     click::web::Cancellable submit_review (const Review& review,
                                            std::function<void(Error)> callback);
+    click::web::Cancellable edit_review (const Review& review,
+                                           std::function<void(Error)> callback);
 
     static std::string get_base_url ();
 };

=== modified file 'libclickscope/tests/test_reviews.cpp'
--- libclickscope/tests/test_reviews.cpp	2014-05-26 14:27:31 +0000
+++ libclickscope/tests/test_reviews.cpp	2015-05-11 15:29:02 +0000
@@ -314,6 +314,49 @@
     }
 }
 
+TEST_F(ReviewsTest, testEditReviewUrlHasReviewId)
+{
+    LifetimeHelper<click::network::Reply, MockNetworkReply> reply;
+    auto response = responseForReply(reply.asSharedPtr());
+
+    click::Review review;
+    review.id = 1234;
+    review.rating = 4;
+    review.review_text = "A review";
+    review.package_name = "com.example.test";
+    review.package_version = "0.1";
+
+    EXPECT_CALL(*clientPtr, callImpl(HasSubstr("/1234/"), "PUT", true, _, _, _))
+            .Times(1)
+            .WillOnce(Return(response));
+
+    auto submit_op = reviewsPtr->edit_review(review,
+                                               [](click::Reviews::Error){});
+}
+
+TEST_F(ReviewsTest, testEditReviewIsCancellable)
+{
+    LifetimeHelper<click::network::Reply, MockNetworkReply> reply;
+    auto response = responseForReply(reply.asSharedPtr());
+
+    click::Review review;
+    review.id = 1234;
+    review.rating = 4;
+    review.review_text = "A review";
+    review.package_name = "com.example.test";
+    review.package_version = "0.1";
+
+    EXPECT_CALL(*clientPtr, callImpl(_, "PUT", true, _, _, _))
+            .Times(1)
+            .WillOnce(Return(response));
+
+    auto submit_op = reviewsPtr->edit_review(review,
+                                               [](click::Reviews::Error){});
+    EXPECT_CALL(reply.instance, abort()).Times(1);
+    submit_op.cancel();
+}
+
+
 TEST_F(ReviewsTest, testGetBaseUrl)
 {
     const char *value = getenv(click::REVIEWS_BASE_URL_ENVVAR.c_str());

=== modified file 'scope/clickapps/apps-scope.cpp'
--- scope/clickapps/apps-scope.cpp	2015-04-10 14:24:10 +0000
+++ scope/clickapps/apps-scope.cpp	2015-05-11 15:29:02 +0000
@@ -105,7 +105,7 @@
 
 
 unity::scopes::ActivationQueryBase::UPtr click::Scope::perform_action(unity::scopes::Result const& result, unity::scopes::ActionMetadata const& metadata,
-        std::string const& /* widget_id */, std::string const& action_id)
+        std::string const& widget_id, std::string const& action_id)
 {
     if (action_id == click::Preview::Actions::CONFIRM_UNINSTALL) {
         auto response = unity::scopes::ActivationResponse(unity::scopes::ActivationResponse::ShowDash);
@@ -137,6 +137,7 @@
         activation->setHint("review", scopes::Variant(review_text));
         activation->setHint(click::Preview::Actions::RATED,
                             scopes::Variant(true));
+        activation->setHint("widget_id", scopes::Variant(widget_id));
         activation->setStatus(scopes::ActivationResponse::Status::ShowPreview);
     }
     return scopes::ActivationQueryBase::UPtr(activation);