Fix endless loading of messages

Signed-off-by: Mario Danic <mario@lovelyhq.com>
This commit is contained in:
Mario Danic 2019-09-09 13:40:26 +02:00
parent 31ce180c6d
commit ec44092676

View File

@ -593,17 +593,18 @@ public class ChatController extends BaseController implements MessagesListAdapte
lobbyView.setVisibility(View.GONE); lobbyView.setVisibility(View.GONE);
messagesListView.setVisibility(View.VISIBLE); messagesListView.setVisibility(View.VISIBLE);
messageInput.setVisibility(View.VISIBLE); messageInput.setVisibility(View.VISIBLE);
if (isFirstMessagesProcessing) {
pullChatMessages(0);
} else {
pullChatMessages(1);
}
} }
} else { } else {
lobbyView.setVisibility(View.GONE); lobbyView.setVisibility(View.GONE);
messagesListView.setVisibility(View.VISIBLE); messagesListView.setVisibility(View.VISIBLE);
messageInput.setVisibility(View.VISIBLE); messageInput.setVisibility(View.VISIBLE);
} }
if (isFirstMessagesProcessing) {
pullChatMessages(0);
} else {
pullChatMessages(1);
}
} }
private void showBrowserScreen(BrowserController.BrowserType browserType) { private void showBrowserScreen(BrowserController.BrowserType browserType) {
@ -813,15 +814,8 @@ public class ChatController extends BaseController implements MessagesListAdapte
ApplicationWideCurrentRoomHolder.getInstance().setSession(currentCall.getSessionId()); ApplicationWideCurrentRoomHolder.getInstance().setSession(currentCall.getSessionId());
startPing(); startPing();
checkLobbyState();
setupWebsocket(); setupWebsocket();
checkLobbyState();
if (isFirstMessagesProcessing) {
pullChatMessages(0);
} else {
pullChatMessages(1);
}
if (magicWebSocketInstance != null) { if (magicWebSocketInstance != null) {
magicWebSocketInstance.joinRoomWithRoomTokenAndSession(roomToken, magicWebSocketInstance.joinRoomWithRoomTokenAndSession(roomToken,
@ -873,8 +867,6 @@ public class ChatController extends BaseController implements MessagesListAdapte
@Override @Override
public void onNext(GenericOverall genericOverall) { public void onNext(GenericOverall genericOverall) {
dispose();
checkingLobbyStatus = false; checkingLobbyStatus = false;
if (lobbyTimerHandler != null) { if (lobbyTimerHandler != null) {
@ -1011,6 +1003,8 @@ public class ChatController extends BaseController implements MessagesListAdapte
fieldMap.put("limit", 10); fieldMap.put("limit", 10);
fieldMap.put("setReadMarker", 1); fieldMap.put("setReadMarker", 1);
Log.d("MARIO lookIntoFuture", String.valueOf(lookIntoFuture));
int lastKnown; int lastKnown;
if (lookIntoFuture > 0) { if (lookIntoFuture > 0) {
lastKnown = globalLastKnownFutureMessageId; lastKnown = globalLastKnownFutureMessageId;