1 files changed, 159 insertions, 0 deletions
diff --git a/WordPress/src/main/java/org/wordpress/android/ui/plans/PlanUpdateService.java b/WordPress/src/main/java/org/wordpress/android/ui/plans/PlanUpdateService.java
new file mode 100644
index 000000000..317a38810
--- /dev/null
+++ b/WordPress/src/main/java/org/wordpress/android/ui/plans/PlanUpdateService.java
@@ -0,0 +1,159 @@
+package org.wordpress.android.ui.plans;
+
+import android.app.Service;
+import android.content.Context;
+import android.content.Intent;
+import android.os.IBinder;
+
+import com.android.volley.VolleyError;
+import com.wordpress.rest.RestRequest;
+
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.wordpress.android.WordPress;
+import org.wordpress.android.networking.RestClientUtils;
+import org.wordpress.android.ui.plans.models.Plan;
+import org.wordpress.android.ui.prefs.AppPrefs;
+import org.wordpress.android.util.AppLog;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import de.greenrobot.event.EventBus;
+
+/**
+ * service which updates both global plans and available plans for a specific site
+ */
+
+public class PlanUpdateService extends Service {
+
+    private static final String ARG_LOCAL_BLOG_ID = "local_blog_id";
+    private int mNumActiveRequests;
+    private int mLocalBlogId;
+    private final List<Plan> mSitePlans = new ArrayList<>();
+
+    public static void startService(Context context, int localTableBlogId) {
+        Intent intent = new Intent(context, PlanUpdateService.class);
+        intent.putExtra(ARG_LOCAL_BLOG_ID, localTableBlogId);
+        context.startService(intent);
+    }
+
+    public static void stopService(Context context) {
+        if (context == null) return;
+
+        Intent intent = new Intent(context, PlanUpdateService.class);
+        context.stopService(intent);
+    }
+
+    @Override
+    public IBinder onBind(Intent intent) {
+        return null;
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+        AppLog.i(AppLog.T.PLANS, "plan update service > created");
+    }
+
+    @Override
+    public void onDestroy() {
+        AppLog.i(AppLog.T.PLANS, "plan update service > destroyed");
+        super.onDestroy();
+    }
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        mLocalBlogId = intent.getIntExtra(ARG_LOCAL_BLOG_ID, 0);
+
+        mNumActiveRequests = 2;
+        downloadPlanFeatures();
+        downloadAvailablePlansForSite();
+
+        return START_NOT_STICKY;
+    }
+
+    /*
+     * called when any plan data has been successfully updated
+     */
+    private void requestCompleted() {
+        // send event once all requests have successfully completed
+        mNumActiveRequests--;
+        if (mNumActiveRequests == 0) {
+            EventBus.getDefault().post(new PlanEvents.PlansUpdated(mLocalBlogId, mSitePlans));
+        }
+    }
+
+    /*
+     * called when updating any plan data fails
+     */
+    private void requestFailed() {
+        EventBus.getDefault().post(new PlanEvents.PlansUpdateFailed());
+    }
+
+    /*
+     * download features for the global plans
+     */
+    private void downloadPlanFeatures() {
+        WordPress.getRestClientUtilsV1_2().get("plans/features/", RestClientUtils.getRestLocaleParams(PlanUpdateService.this), null, new RestRequest.Listener() {
+            @Override
+            public void onResponse(JSONObject response) {
+                if (response != null) {
+                    AppLog.d(AppLog.T.PLANS, response.toString());
+                    // Store the response into App Prefs
+                    AppPrefs.setGlobalPlansFeatures(response.toString());
+                    requestCompleted();
+                } else {
+                    AppLog.w(AppLog.T.PLANS, "Unexpected empty response from server when downloading Features");
+                    requestFailed();
+                }
+            }
+        }, new RestRequest.ErrorListener() {
+            @Override
+            public void onErrorResponse(VolleyError volleyError) {
+                AppLog.e(AppLog.T.PLANS, "Error Loading Plans/Features", volleyError);
+                requestFailed();
+            }
+        });
+    }
+
+    /*
+     * download plans for the specific site
+     */
+    private void downloadAvailablePlansForSite() {
+        int remoteBlogId = WordPress.wpDB.getRemoteBlogIdForLocalTableBlogId(mLocalBlogId);
+        WordPress.getRestClientUtilsV1_2().get("sites/" + remoteBlogId + "/plans", RestClientUtils.getRestLocaleParams(PlanUpdateService.this), null, new RestRequest.Listener() {
+            @Override
+            public void onResponse(JSONObject response) {
+                if (response == null) {
+                    AppLog.w(AppLog.T.PLANS, "Unexpected empty response from server");
+                    requestFailed();
+                    return;
+                }
+
+                AppLog.d(AppLog.T.PLANS, response.toString());
+                mSitePlans.clear();
+
+                try {
+                    JSONArray plansArray = response.getJSONArray("originalResponse");
+                    for (int i=0; i < plansArray.length(); i ++) {
+                        JSONObject currentPlanJSON = plansArray.getJSONObject(i);
+                        Plan currentPlan = new Plan(currentPlanJSON);
+                        mSitePlans.add(currentPlan);
+                    }
+                    requestCompleted();
+                } catch (JSONException e) {
+                    AppLog.e(AppLog.T.PLANS, "Can't parse the plans list returned from the server", e);
+                    requestFailed();
+                }
+            }
+        }, new RestRequest.ErrorListener() {
+            @Override
+            public void onErrorResponse(VolleyError volleyError) {
+                AppLog.e(AppLog.T.UTILS, "Error downloading site plans", volleyError);
+                requestFailed();
+            }
+        });
+    }
+}