Refine handle event

qiscus · Jun 16, 2017 · 82bba7c · 82bba7c
1 parent 96695ee
commit 82bba7c
Showing 1 changed file with 14 additions and 18 deletions.
diff --git a/chat/src/main/java/com/qiscus/sdk/presenter/QiscusChatPresenter.java b/chat/src/main/java/com/qiscus/sdk/presenter/QiscusChatPresenter.java
@@ -63,6 +63,9 @@ public class QiscusChatPresenter extends QiscusPresenter<QiscusChatPresenter.Vie
 
     public QiscusChatPresenter(View view, QiscusChatRoom room) {
         super(view);
+        if (!EventBus.getDefault().isRegistered(this)) {
+            EventBus.getDefault().register(this);
+        }
         this.room = room;
         this.currentTopicId = room.getLastTopicId();
         qiscusAccount = Qiscus.getQiscusAccount();
@@ -72,9 +75,6 @@ public QiscusChatPresenter(View view, QiscusChatRoom room) {
         updateReadState();
         listenRoomTask = this::listenRoomEvent;
         QiscusAndroidUtil.runOnUIThread(listenRoomTask, 1000);
-        if (!EventBus.getDefault().isRegistered(this)) {
-            EventBus.getDefault().register(this);
-        }
     }
 
     private void doInIo(Runnable runnable) {
@@ -536,23 +536,21 @@ private void handleEvent(QiscusChatRoomEvent event) {
         if (event.getTopicId() == currentTopicId) {
             switch (event.getEvent()) {
                 case TYPING:
-                    view.onUserTyping(event.getUser(), event.isTyping());
+                    QiscusAndroidUtil.runOnUIThread(() -> view.onUserTyping(event.getUser(), event.isTyping()));
                     break;
                 case DELIVERED:
                     QiscusComment deliveredComment = Qiscus.getDataStore()
                             .getComment(event.getCommentId(), event.getCommentUniqueId());
                     if (deliveredComment != null) {
                         deliveredComment.setId(event.getCommentId());
                         updateLastDeliveredComment(deliveredComment);
-                        doInIo(() -> {
-                            if (QiscusComment.STATE_DELIVERED > deliveredComment.getState()) {
-                                deliveredComment.setState(QiscusComment.STATE_DELIVERED);
-                                Qiscus.getDataStore().update(deliveredComment);
-                            }
-                        });
+                        if (QiscusComment.STATE_DELIVERED > deliveredComment.getState()) {
+                            deliveredComment.setState(QiscusComment.STATE_DELIVERED);
+                            Qiscus.getDataStore().update(deliveredComment);
+                        }
                     } else {
                         lastDeliveredCommentId.set(event.getCommentId());
-                        view.updateLastDeliveredComment(lastDeliveredCommentId.get());
+                        QiscusAndroidUtil.runOnUIThread(() -> view.updateLastDeliveredComment(lastDeliveredCommentId.get()));
                     }
                     break;
                 case READ:
@@ -561,16 +559,14 @@ private void handleEvent(QiscusChatRoomEvent event) {
                     if (readComment != null) {
                         readComment.setId(event.getCommentId());
                         updateLastReadComment(readComment);
-                        doInIo(() -> {
-                            if (QiscusComment.STATE_READ > readComment.getState()) {
-                                readComment.setState(QiscusComment.STATE_READ);
-                                Qiscus.getDataStore().update(readComment);
-                            }
-                        });
+                        if (QiscusComment.STATE_READ > readComment.getState()) {
+                            readComment.setState(QiscusComment.STATE_READ);
+                            Qiscus.getDataStore().update(readComment);
+                        }
                     } else {
                         lastReadCommentId.set(event.getCommentId());
                         lastDeliveredCommentId.set(lastReadCommentId.get());
-                        view.updateLastReadComment(lastReadCommentId.get());
+                        QiscusAndroidUtil.runOnUIThread(() -> view.updateLastReadComment(lastReadCommentId.get()));
                     }
                     break;
             }