Reformat indentation and implement call to loadMissedMessages method

app/src/main/java/chat/rocket/android/api/MethodCallHelper.java

@@ -7,13 +7,16 @@ import org.json.JSONArray;
 import org.json.JSONException;
 import org.json.JSONObject;
 
+import java.util.Iterator;
 import java.util.UUID;
 
 import bolts.Continuation;
 import bolts.Task;
+import chat.rocket.android.RocketChatApplication;
 import chat.rocket.android.RocketChatCache;
 import chat.rocket.android.helper.CheckSum;
 import chat.rocket.android.helper.TextUtils;
+import chat.rocket.android.log.RCLog;
 import chat.rocket.android.service.ConnectivityManager;
 import chat.rocket.android_ddp.DDPClient;
 import chat.rocket.android_ddp.DDPClientCallback;
@@ -32,11 +35,12 @@ import chat.rocket.persistence.realm.models.ddp.RealmSpotlightUser;
 import chat.rocket.persistence.realm.models.internal.MethodCall;
 import chat.rocket.persistence.realm.models.internal.RealmSession;
 import hugo.weaving.DebugLog;
+import io.realm.RealmQuery;
 import okhttp3.HttpUrl;
 
 /**
  * Utility class for creating/handling MethodCall or RPC.
- *
+ * <p>
  * TODO: separate method into several manager classes (SubscriptionManager, MessageManager, ...).
  */
 public class MethodCallHelper {
@@ -299,6 +303,29 @@ public class MethodCallHelper {
                             realm.delete(RealmRoom.class);
                             realm.createOrUpdateAllFromJson(
                                     RealmRoom.class, result);
+
+                            Context appContext = RocketChatApplication.getInstance();
+                            RocketChatCache cache = new RocketChatCache(appContext);
+                            JSONObject openedRooms = cache.getOpenedRooms();
+
+                            RealmQuery<RealmRoom> query = realm.where(RealmRoom.class);
+                            Iterator<String> keys = openedRooms.keys();
+                            while (keys.hasNext()) {
+                                String rid = keys.next();
+                                RealmRoom realmRoom = query.equalTo(RealmRoom.ID, rid).findFirst();
+                                if (realmRoom == null) {
+                                    cache.removeOpenedRoom(rid);
+                                } else {
+                                    loadMissedMessages(rid, realmRoom.getLastSeen())
+                                            .continueWithTask(task1 -> {
+                                                if (task1.isFaulted()) {
+                                                    Exception error = task1.getError();
+                                                    RCLog.e(error);
+                                                }
+                                                return null;
+                                            });
+                                }
+                            }
                             return null;
                         });
                     } catch (JSONException exception) {
@@ -307,6 +334,32 @@ public class MethodCallHelper {
                 });
     }
 
+    public Task<JSONArray> loadMissedMessages(final String roomId, final long timestamp) {
+        return call("loadMissedMessages", TIMEOUT_MS, () -> new JSONArray()
+                .put(roomId)
+                .put(timestamp > 0 ? new JSONObject().put("$date", timestamp) : JSONObject.NULL)
+        ).onSuccessTask(CONVERT_TO_JSON_ARRAY)
+                .onSuccessTask(task -> {
+                    JSONArray result = task.getResult();
+                    for (int i = 0; i < result.length(); i++) {
+                        RealmMessage.customizeJson(result.getJSONObject(i));
+                    }
+
+                    return realmHelper.executeTransaction(realm -> {
+                        if (timestamp == 0) {
+                            realm.where(RealmMessage.class)
+                                    .equalTo("rid", roomId)
+                                    .equalTo("syncstate", SyncState.SYNCED)
+                                    .findAll().deleteAllFromRealm();
+                        }
+                        if (result.length() > 0) {
+                            realm.createOrUpdateAllFromJson(RealmMessage.class, result);
+                        }
+                        return null;
+                    }).onSuccessTask(_task -> Task.forResult(result));
+                });
+    }
+
     /**
      * Load messages for room.
      */
@@ -406,7 +459,7 @@ public class MethodCallHelper {
                     .put("_id", messageID);
 
             return deleteMessage(messageJson);
-    } catch(JSONException exception) {
+        } catch (JSONException exception) {
             return Task.forError(exception);
         }
     }