Adding loadMessagesInRoom back

Author: Hanno Gödecke

android/src/main/java/de/hannojg/MatrixSdkModule.java

@@ -37,6 +37,7 @@
 import org.matrix.androidsdk.rest.model.CreatedEvent;
 import org.matrix.androidsdk.rest.model.Event;
 import org.matrix.androidsdk.rest.model.PushersResponse;
+import org.matrix.androidsdk.rest.model.TokensChunkEvents;
 import org.matrix.androidsdk.rest.model.User;
 import org.matrix.androidsdk.rest.model.login.Credentials;
 
@@ -581,6 +582,37 @@ public void unlisten() {
         }
     }
 
+    @ReactMethod
+    public void loadMessagesInRoom(String roomId, int perPage, boolean initialLoad, Promise promise) {
+        if (mxSession == null) {
+            promise.reject(E_MATRIX_ERROR, "client is not connected yet");
+            return;
+        }
+
+        Room room = mxSession.getDataHandler().getRoom(roomId);
+        if (room == null) {
+            promise.reject(E_MATRIX_ERROR, "Room not found");
+            return;
+        }
+
+        String fromToken = null;
+        if (!initialLoad && roomPaginationTokens.get(roomId) != null) {
+            fromToken = roomPaginationTokens.get(roomId);
+        }
+
+        room.requestServerRoomHistory(fromToken, perPage, new RejectingOnErrorApiCallback<TokensChunkEvents>(promise) {
+            @Override
+            public void onSuccess(TokensChunkEvents info) {
+                roomPaginationTokens.put(roomId, info.end);
+                WritableArray msgs = Arguments.createArray();
+                for (Event event : info.chunk) {
+                    msgs.pushMap(convertEventToMap(event));
+                }
+                promise.resolve(msgs);
+            }
+        });
+    }
+
     @ReactMethod
     public void backPaginate(String roomId, int perPage, boolean initHistory, Promise promise) {
         if (mxSession == null) {

ios/MatrixSdk.m

@@ -58,6 +58,8 @@ + (BOOL)requiresMainQueueSetup
 
 RCT_EXTERN_METHOD(unlisten)
 
+RCT_EXTERN_METHOD(loadMessagesInRoom:(NSString *)roomId perPage:(nonnull NSNumber *)perPage initialLoad:(BOOL *)initialLoad resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject)
+
 RCT_EXTERN_METHOD(backPaginate:(NSString *)roomId perPage:(nonnull NSNumber *)perPage initHistory:(BOOL *)initHistory resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject)
 
 RCT_EXTERN_METHOD(canBackPaginate:(NSString *)roomId resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject)

ios/RNMatrixSDK.swift

@@ -682,6 +682,19 @@ class RNMatrixSDK: RCTEventEmitter {
         })
     }
 
+    @objc(loadMessagesInRoom:perPage:initialLoad:resolver:rejecter:)
+    func loadMessagesInRoom(roomId: String, perPage: NSNumber, initialLoad: Bool, resolve: @escaping RCTPromiseResolveBlock, reject: @escaping RCTPromiseRejectBlock) {
+        var fromToken = ""
+        if(!initialLoad) {
+            fromToken = roomPaginationTokens[roomId] ?? ""
+            if(fromToken.isEmpty) {
+                print("Warning: trying to load not initial messages, but the SDK has no token set for this room currently. You need to run with initialLoad: true first!")
+            }
+        }
+
+        getMessages(roomId: roomId, from: fromToken, direction: "backwards", limit: perPage, resolve: resolve, reject: reject)
+    }
+
     @objc(getMessages:from:direction:limit:resolver:rejecter:)
     func getMessages(roomId: String, from: String, direction: String, limit: NSNumber, resolve: @escaping RCTPromiseResolveBlock, reject: @escaping RCTPromiseRejectBlock) {
         if mxSession == nil {

types/index.d.ts

@@ -154,6 +154,14 @@ declare module 'react-native-matrix-sdk' {
      */
     backPaginate(roomId: string, perPage: number, initHistory: boolean): Promise<MXMessageEvent[]>;
 
+    /**
+     * Requests room history from server.
+     * @param roomId
+     * @param perPage
+     * @param initialLoad set to true on first request (initial request, newest messages), any additional calls with false to get further room history
+     */
+    loadMessagesInRoom(roomId: string, perPage: number, initialLoad: boolean): Promise<MXMessageEvent[]>;
+
     /**
      * Returns true when back pagination is (still) possible.
      * @param roomId