1 files changed, 103 insertions, 0 deletions
diff --git a/src/main/java/eu/siacs/conversations/ui/listeners/ConversationSwipeRefreshListener.java b/src/main/java/eu/siacs/conversations/ui/listeners/ConversationSwipeRefreshListener.java
new file mode 100644
index 00000000..0cbde814
--- /dev/null
+++ b/src/main/java/eu/siacs/conversations/ui/listeners/ConversationSwipeRefreshListener.java
@@ -0,0 +1,103 @@
+package eu.siacs.conversations.ui.listeners;
+
+import android.widget.ListView;
+
+import com.orangegangsters.github.swipyrefreshlayout.library.SwipyRefreshLayout;
+import com.orangegangsters.github.swipyrefreshlayout.library.SwipyRefreshLayoutDirection;
+
+import java.util.List;
+
+import de.thedevstack.android.logcat.Logging;
+import eu.siacs.conversations.Config;
+import eu.siacs.conversations.R;
+import eu.siacs.conversations.entities.Account;
+import eu.siacs.conversations.entities.Conversation;
+import eu.siacs.conversations.entities.Message;
+import eu.siacs.conversations.services.MessageArchiveService;
+import eu.siacs.conversations.ui.ConversationActivity;
+import eu.siacs.conversations.ui.ConversationFragment;
+import eu.siacs.conversations.ui.adapter.MessageAdapter;
+
+/**
+ * This listener starts loading messages from the server.
+ */
+public class ConversationSwipeRefreshListener implements SwipyRefreshLayout.OnRefreshListener {
+    private List<Message> messageList;
+    private ConversationFragment fragment;
+    private ConversationMoreMessagesLoadedListener listener;
+    private SwipyRefreshLayout swipeLayout;
+
+    public ConversationSwipeRefreshListener(List<Message> messageList, SwipyRefreshLayout swipeLayout, ConversationFragment fragment, ListView messagesView, MessageAdapter messageListAdapter) {
+        this.messageList = messageList;
+        this.fragment = fragment;
+        this.swipeLayout = swipeLayout;
+        this.listener = new ConversationMoreMessagesLoadedListener(swipeLayout, messageList, fragment, messagesView, messageListAdapter);
+    }
+
+    @Override
+    public void onRefresh(SwipyRefreshLayoutDirection direction) {
+        Logging.d(Config.LOGTAG, "Refresh swipe container");
+        Logging.d(Config.LOGTAG, "Refresh direction " + direction);
+        final ConversationActivity activity = (ConversationActivity) fragment.getActivity();
+        if (activity.getSelectedConversation().getAccount().getStatus() != Account.State.DISABLED) {
+            synchronized (this.messageList) {
+                long timestamp;
+                if (SwipyRefreshLayoutDirection.TOP == direction) { // Load history -> messages sent/received before first message in database
+                    if (messageList.isEmpty()) {
+                        timestamp = System.currentTimeMillis();
+                    } else {
+                        timestamp = this.messageList.get(0).getTimeSent(); // works only because of the ordering (last msg = first msg in list)
+                    }
+                    this.listener.setLoadHistory(true);
+                    activity.xmppConnectionService.loadMoreMessages(activity.getSelectedConversation(), timestamp, this.listener);
+                } else if (SwipyRefreshLayoutDirection.BOTTOM == direction) { // load messages sent/received between last received or last session establishment and now
+                    if (activity.getSelectedConversation().getAccount().isOnlineAndConnected()) {
+                        Logging.d("mam", "loading missing messages from mam (last session establishing or last received message)");
+                        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(), this.listener);
+                        if (query != null) {
+                            this.listener.setLoadHistory(false);
+                        } else {
+                            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);
+                    } else {
+                        this.listener.informUser(R.string.not_connected_try_again);
+                        swipeLayout.setRefreshing(false);
+                    }
+                }
+            }
+        } else {
+            this.listener.informUser(R.string.this_account_is_disabled);
+            swipeLayout.setRefreshing(false);
+        }
+        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;
+    }
+}