Process update message events.

Author: Sam1301

app/src/main/java/com/zulip/android/activities/MessageListFragment.java

@@ -719,4 +719,8 @@ public boolean scrolledToLastMessage() {
         Object object = adapter.getItem(linearLayoutManager.findLastVisibleItemPosition());
         return object instanceof Message && (((Message) object).getId() >= app.getMaxMessageId() - 2);
     }
+
+    public RecyclerMessageAdapter getAdapter() {
+        return this.adapter;
+    }
 }

app/src/main/java/com/zulip/android/activities/ZulipActivity.java

@@ -2308,4 +2308,16 @@ public void onClick(View view) {
     public enum Flag {
         RESET_DATABASE,
     }
+
+    /**
+     * TODO: add description
+     * @return
+     */
+    public MessageListFragment getCurrentMessageList() {
+        if (narrowedList == null) {
+            return homeList;
+        } else {
+            return narrowedList;
+        }
+    }
 }

app/src/main/java/com/zulip/android/networking/AsyncGetEvents.java

@@ -7,6 +7,7 @@
 import android.util.Log;
 import android.widget.Toast;
 
+import com.j256.ormlite.dao.Dao;
 import com.j256.ormlite.dao.RuntimeExceptionDao;
 import com.j256.ormlite.misc.TransactionManager;
 import com.zulip.android.R;
@@ -24,6 +25,7 @@
 import com.zulip.android.networking.response.events.MessageWrapper;
 import com.zulip.android.networking.response.events.MutedTopicsWrapper;
 import com.zulip.android.networking.response.events.SubscriptionWrapper;
+import com.zulip.android.networking.response.events.UpdateMessageWrapper;
 import com.zulip.android.util.MutedTopics;
 import com.zulip.android.util.TypeSwapper;
 import com.zulip.android.util.ZLog;
@@ -341,16 +343,21 @@ public Message convert(MessageWrapper messageWrapper) {
             processMessages(messages);
         }
 
+        // update message
+        List<EventsBranch> updateMessageEvents = events.getEventsOfBranchType(EventsBranch.BranchType.UPDATE_MESSAGE);
+        if (!updateMessageEvents.isEmpty()) {
+            Log.i("AsyncGetEvents", "Received " + updateMessageEvents.size()
+                    + " update message events");
+            processUpdateMessages(updateMessageEvents);
+        }
+
         //get message time limit events
         List<EventsBranch> messageTimeLimit = events.getEventsOfBranchType(EventsBranch.BranchType.EDIT_MESSAGE_TIME_LIMIT);
         if (!messageTimeLimit.isEmpty()) {
             Log.i("AsyncGetEvents", "Received " + messageTimeLimit.size()
                     + " realm event");
             processMessageEditParam(messageTimeLimit);
         }
-
-        // update message
-        // TODO: handle update message event
     }
 
     /**
@@ -453,6 +460,10 @@ public void run() {
         });
     }
 
+    /**
+     * TODO: add description
+     * @param messageEditLimitEvents
+     */
     private void processMessageEditParam(List<EventsBranch> messageEditLimitEvents) {
         for (EventsBranch wrapper : messageEditLimitEvents) {
             EditMessageWrapper timeLimitResponse = (EditMessageWrapper) wrapper;
@@ -462,4 +473,30 @@ private void processMessageEditParam(List<EventsBranch> messageEditLimitEvents)
             );
         }
     }
+
+    private void processUpdateMessages(List<EventsBranch> updateEvents) {
+        for (EventsBranch event : updateEvents) {
+            UpdateMessageWrapper updateEvent = (UpdateMessageWrapper) event;
+            Message message = updateEvent.getMessage();
+            if (message != null) {
+                message.setFormattedContent(updateEvent.getFormattedContent());
+
+                // update the message in database
+                Dao<Message, Integer> messageDao = app.getDao(Message.class);
+                try {
+                    messageDao.update(message);
+                } catch (SQLException e) {
+                    ZLog.logException(e);
+                }
+            }
+        }
+
+        mActivity.runOnUiThread(new Runnable() {
+            @Override
+            public void run() {
+                // notify adapter dataset changed
+                mActivity.getCurrentMessageList().getAdapter().notifyDataSetChanged();
+            }
+        });
+    }
 }

app/src/main/java/com/zulip/android/networking/response/events/UpdateMessageWrapper.java

@@ -6,7 +6,6 @@
 import com.zulip.android.models.Message;
 import com.zulip.android.util.ZLog;
 
-import java.sql.Date;
 import java.sql.SQLException;
 import java.util.List;
 
@@ -26,7 +25,7 @@ public class UpdateMessageWrapper extends EventsBranch {
     private String senderEmail;
 
     @SerializedName("edit_timestamp")
-    private Date editedTimeStamp;
+    private long editedTimeStamp;
 
     @SerializedName("orig_content")
     private String origContent;
@@ -62,6 +61,7 @@ public Message getMessage() {
         return null;
     }
 
+    // TODO: remove these if cntent is not used
     public String getContent() {
         return this.content;
     }