[tor-commits] [snowflake-mobile/master] Added update notification function

[cohosh at torproject.org]

commit 9b5cb0c0b8840b41878fbd0b8006fce20ff8314e
Author: Hashik Donthineni <HashikDonthineni at gmail.com>
Date:   Tue Jun 9 15:28:30 2020 +0530

    Added update notification function
---
 .../torproject/snowflake/MyPersistentService.java   | 21 ++++++++++++++++++---
 1 file changed, 18 insertions(+), 3 deletions(-)

diff --git a/app/src/main/java/org/torproject/snowflake/MyPersistentService.java b/app/src/main/java/org/torproject/snowflake/MyPersistentService.java
index ddb418f..71545e6 100644
--- a/app/src/main/java/org/torproject/snowflake/MyPersistentService.java
+++ b/app/src/main/java/org/torproject/snowflake/MyPersistentService.java
@@ -1,8 +1,10 @@
 package org.torproject.snowflake;
 
 import android.app.Notification;
+import android.app.NotificationManager;
 import android.app.PendingIntent;
 import android.app.Service;
+import android.content.Context;
 import android.content.Intent;
 import android.content.SharedPreferences;
 import android.os.Build;
@@ -112,6 +114,17 @@ public class MyPersistentService extends Service {
         }
         editor.apply();
     }
+    /////////////// Notifications ////////////////////////
+
+    /**
+     * Method that can be called to update the Notification
+     */
+    private void updateNotification(String updateText) {
+        Notification notification = createPersistentNotification(true, updateText); //Create a new notification.
+
+        NotificationManager mNotificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
+        mNotificationManager.notify(ForegroundServiceConstants.DEF_NOTIFICATION_ID, notification);
+    }
 
     /**
      * Create a new persistent notification
@@ -274,7 +287,7 @@ public class MyPersistentService extends Service {
         Log.d(TAG, "fetchOffer: Fetching offer from broker.");
         ///Retrofit call
         final GetOfferService getOfferService = RetroServiceGenerator.createService(GetOfferService.class);
-        Observable<SDPOfferResponse> offer = getOfferService.getOffer(new OfferRequestBody("555"));
+        Observable<SDPOfferResponse> offer = getOfferService.getOffer(new OfferRequestBody("555")); //TODO:Randomly Generate SID.
         serviceDisposable = offer.subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread()).subscribe(this::offerRequestSuccess, this::offerRequestFailure);
     }
@@ -298,8 +311,9 @@ public class MyPersistentService extends Service {
                 e.printStackTrace();
             }
         } else {
+            updateNotification("No client match, retrying...");
             Log.d(TAG, "requestSuccess: NO CLIENT MATCH");
-            //TODO:Set a time out to resending offer.
+            //TODO:Set a time out (delay) to resending offer.
             if (isServiceStarted)
                 fetchOffer(); //Sending request for offer again.
         }
@@ -311,8 +325,9 @@ public class MyPersistentService extends Service {
      * @param t
      */
     public void offerRequestFailure(Throwable t) {
+        updateNotification("Request failed, retrying...");
         Log.d(TAG, "requestFailure: " + t.getMessage());
-        //TODO:Set a time out to resending offer.
+        //TODO:Set a time out (delay) to resending offer.
         if (isServiceStarted)
             fetchOffer(); //Sending request for offer again.
     }