Improve RR PoC

Author: Germain Souquet

src/client.ts

@@ -4614,6 +4614,7 @@ export class MatrixClient extends TypedEventEmitter<EmittedEvents, ClientEventHa
      * @return {module:http-api.MatrixError} Rejects: with an error response.
      */
     public async sendReadReceipt(event: MatrixEvent, receiptType = ReceiptType.Read, callback?: Callback): Promise<{}> {
+        if (!event) return;
         const eventId = event.getId();
         const room = this.getRoom(event.getRoomId());
         if (room && room.hasPendingEvent(eventId)) {

src/http-api.ts

@@ -390,7 +390,7 @@ export class MatrixHttpApi {
             };
 
             // set an initial timeout of 30s; we'll advance it each time we get a progress notification
-            let timeoutTimer = callbacks.setTimeout(timeoutFn, 30000);
+            let timeoutTimer = callbacks.setTimeout(timeoutFn, 60000);
 
             xhr.onreadystatechange = function() {
                 let resp: string;
@@ -421,7 +421,7 @@ export class MatrixHttpApi {
                 callbacks.clearTimeout(timeoutTimer);
                 upload.loaded = ev.loaded;
                 upload.total = ev.total;
-                timeoutTimer = callbacks.setTimeout(timeoutFn, 30000);
+                timeoutTimer = callbacks.setTimeout(timeoutFn, 60000);
                 if (opts.progressHandler) {
                     opts.progressHandler({
                         loaded: ev.loaded,

src/models/room.ts

@@ -2460,9 +2460,10 @@ export class Room extends TimelineReceipts<EmittedEvents, RoomEventHandlerMap> {
         Object.keys(content).forEach((eventId: string) => {
             Object.keys(content[eventId]).forEach((receiptType: ReceiptType) => {
                 Object.keys(content[eventId][receiptType]).forEach((userId: string) => {
-                    const receipt = content[eventId][receiptType][userId];
+                    // hack, threadId should be thread_id
+                    const receipt = content[eventId][receiptType][userId] as any;
 
-                    const receiptDestination = this.threads.get(event.threadRootId) ?? this;
+                    const receiptDestination = this.threads.get(receipt.threadId) ?? this;
                     receiptDestination.addReceiptToStructure(
                         eventId,
                         receiptType,

src/sliding-sync-sdk.ts

@@ -250,7 +250,7 @@ export class SlidingSyncSdk {
     ) {
         this.opts.initialSyncLimit = this.opts.initialSyncLimit ?? 8;
         this.opts.resolveInvitesToProfiles = this.opts.resolveInvitesToProfiles || false;
-        this.opts.pollTimeout = this.opts.pollTimeout || (30 * 1000);
+        this.opts.pollTimeout = this.opts.pollTimeout || (60 * 1000);
         this.opts.pendingEventOrdering = this.opts.pendingEventOrdering || PendingEventOrdering.Chronological;
         this.opts.experimentalThreadSupport = this.opts.experimentalThreadSupport === true;
 

src/sync.ts

@@ -176,7 +176,7 @@ export class SyncApi {
     constructor(private readonly client: MatrixClient, private readonly opts: Partial<IStoredClientOpts> = {}) {
         this.opts.initialSyncLimit = this.opts.initialSyncLimit ?? 8;
         this.opts.resolveInvitesToProfiles = this.opts.resolveInvitesToProfiles || false;
-        this.opts.pollTimeout = this.opts.pollTimeout || (30 * 1000);
+        this.opts.pollTimeout = this.opts.pollTimeout || (60 * 1000);
         this.opts.pendingEventOrdering = this.opts.pendingEventOrdering || PendingEventOrdering.Chronological;
         this.opts.experimentalThreadSupport = this.opts.experimentalThreadSupport === true;
 
@@ -505,7 +505,7 @@ export class SyncApi {
         // FIXME: gut wrenching; hard-coded timeout values
         this.client.http.authedRequest<IEventsResponse>(undefined, Method.Get, "/events", {
             room_id: peekRoom.roomId,
-            timeout: String(30 * 1000),
+            timeout: String(60 * 1000),
             from: token,
         }, undefined, 50 * 1000).then((res) => {
             if (this._peekRoom !== peekRoom) {