1 files changed, 34 insertions, 14 deletions

diff --git a/src/main/java/de/thedevstack/conversationsplus/ui/listeners/ConversationSwipeRefreshListener.java b/src/main/java/de/thedevstack/conversationsplus/ui/listeners/ConversationSwipeRefreshListener.java
index bd616691..30b7bf73 100644
--- a/src/main/java/de/thedevstack/conversationsplus/ui/listeners/ConversationSwipeRefreshListener.java
+++ b/src/main/java/de/thedevstack/conversationsplus/ui/listeners/ConversationSwipeRefreshListener.java
@@ -1,8 +1,5 @@
 package de.thedevstack.conversationsplus.ui.listeners;
 
-import de.thedevstack.conversationsplus.R;
-import de.thedevstack.conversationsplus.services.MessageArchiveService;
-import de.thedevstack.conversationsplus.utils.Logging;
 import android.widget.ListView;
 
 import com.orangegangsters.github.swipyrefreshlayout.library.SwipyRefreshLayout;
@@ -10,6 +7,10 @@ import com.orangegangsters.github.swipyrefreshlayout.library.SwipyRefreshLayoutD
 
 import java.util.List;
 
+import de.thedevstack.android.logcat.Logging;
+import de.thedevstack.conversationsplus.R;
+import de.thedevstack.conversationsplus.entities.Conversation;
+import de.thedevstack.conversationsplus.services.MessageArchiveService;
 import de.thedevstack.conversationsplus.Config;
 import de.thedevstack.conversationsplus.entities.Message;
 import de.thedevstack.conversationsplus.ui.ConversationActivity;
@@ -36,7 +37,7 @@ public class ConversationSwipeRefreshListener implements SwipyRefreshLayout.OnRe
         Logging.d(Config.LOGTAG, "Refresh direction " + direction);
         synchronized (this.messageList) {
             long timestamp;
-            if (SwipyRefreshLayoutDirection.TOP == direction) {
+            if (SwipyRefreshLayoutDirection.TOP == direction) { // Load history -> messages sent/received before first message in database
                 if (messageList.isEmpty()) {
                     timestamp = System.currentTimeMillis();
                 } else {
@@ -45,28 +46,47 @@ public class ConversationSwipeRefreshListener implements SwipyRefreshLayout.OnRe
                 ConversationActivity activity = (ConversationActivity) fragment.getActivity();
                 this.listener.setLoadHistory(true);
                 activity.xmppConnectionService.loadMoreMessages(activity.getSelectedConversation(), timestamp, this.listener);
-            } else if (SwipyRefreshLayoutDirection.BOTTOM == direction) {
+            } else if (SwipyRefreshLayoutDirection.BOTTOM == direction) { // load messages sent/received between last received or last session establishment and now
                 Logging.d("mam", "loading missing messages from mam (last session establishing or last received message)");
                 final ConversationActivity activity = (ConversationActivity) fragment.getActivity();
-                long lastSessionEstablished = activity.getSelectedConversation().getAccount().getXmppConnection().getLastSessionEstablished();
-                int lastMessageIndex = this.messageList.size() - 1;
-                long lastReceivedMessage = (0 <= lastMessageIndex) ? this.messageList.get(lastMessageIndex).getTimeSent() : Long.MAX_VALUE;
+                long lastSessionEstablished = this.getTimestampOfLastSessionEstablished(activity.getSelectedConversation());
+                long lastReceivedMessage = this.getTimestampOfLastReceivedOrTransmittedMessage();
                 long startTimestamp = Math.min(lastSessionEstablished, lastReceivedMessage);
                 MessageArchiveService.Query query = activity.xmppConnectionService.getMessageArchiveService().query(activity.getSelectedConversation(), startTimestamp, System.currentTimeMillis());
                 if (query != null) {
                     this.listener.setLoadHistory(false);
                     query.setCallback(this.listener);
                 } else {
-                    activity.runOnUiThread(new Runnable() {
-                        @Override
-                        public void run() {
-                            listener.onMoreMessagesLoaded(0, activity.getSelectedConversation());
-                        }
-                    });
+                    Logging.d("mam", "no query built - no messages loaded");
+                    this.listener.onMoreMessagesLoaded(0, activity.getSelectedConversation());
+                    this.listener.informUser(R.string.no_more_history_on_server);
                 }
                 this.listener.informUser(R.string.fetching_history_from_server);
             }
         }
         Logging.d(Config.LOGTAG, "End Refresh swipe container");
     }
+
+    private long getTimestampOfLastReceivedOrTransmittedMessage() {
+        long lastReceivedOrTransmittedMessage = Long.MAX_VALUE;
+        if (null != this.messageList
+                && !this.messageList.isEmpty()) {
+            int lastMessageIndex = this.messageList.size() - 1;
+            if (0 <= lastMessageIndex && this.messageList.size() > lastMessageIndex) {
+                lastReceivedOrTransmittedMessage = this.messageList.get(lastMessageIndex).getTimeSent();
+            }
+        }
+
+        return lastReceivedOrTransmittedMessage;
+    }
+
+    private long getTimestampOfLastSessionEstablished(Conversation conversation) {
+        long lastSessionEstablished = Long.MAX_VALUE;
+        if (null != conversation
+                && null != conversation.getAccount()
+                && null != conversation.getAccount().getXmppConnection()) {
+            lastSessionEstablished = conversation.getAccount().getXmppConnection().getLastSessionEstablished();
+        }
+        return lastSessionEstablished;
+    }
 }