matrix/matrix-js-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-js-sdk.git synced 2025-11-23 17:02:25 +03:00
Code Activity

Resume to-device message queue after resumed sync

Browse Source
This commit is contained in:
Andy Uhnak
2022-11-30 10:24:28 +00:00
parent acd220b8a9
commit 071d5e71e4
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/ToDeviceMessageQueue.ts
View File

@@ -16,9 +16,10 @@ limitations under the License.
import { ToDeviceMessageId } from "./@types/event"; import { ToDeviceMessageId } from "./@types/event";
import { logger } from "./logger"; import { logger } from "./logger";
import { MatrixError, MatrixClient } from "./matrix"; import { MatrixError, MatrixClient, ClientEvent } from "./matrix";
import { IndexedToDeviceBatch, ToDeviceBatch, ToDeviceBatchWithTxnId, ToDevicePayload } from "./models/ToDeviceMessage"; import { IndexedToDeviceBatch, ToDeviceBatch, ToDeviceBatchWithTxnId, ToDevicePayload } from "./models/ToDeviceMessage";
import { MatrixScheduler } from "./scheduler"; import { MatrixScheduler } from "./scheduler";
import { SyncState } from "./sync";
const MAX_BATCH_SIZE = 20; const MAX_BATCH_SIZE = 20;
@@ -37,12 +38,14 @@ export class ToDeviceMessageQueue {
public start(): void { public start(): void {
this.running = true; this.running = true;
this.sendQueue(); this.sendQueue();
this.client.on(ClientEvent.Sync, this.onResumedSync);
} }
public stop(): void { public stop(): void {
this.running = false; this.running = false;
if (this.retryTimeout !== null) clearTimeout(this.retryTimeout); if (this.retryTimeout !== null) clearTimeout(this.retryTimeout);
this.retryTimeout = null; this.retryTimeout = null;
this.client.removeListener(ClientEvent.Sync, this.onResumedSync);
} }
public async queueBatch(batch: ToDeviceBatch): Promise<void> { public async queueBatch(batch: ToDeviceBatch): Promise<void> {
@@ -132,4 +135,15 @@ export class ToDeviceMessageQueue {
await this.client.sendToDevice(batch.eventType, contentMap, batch.txnId); await this.client.sendToDevice(batch.eventType, contentMap, batch.txnId);
} }
/**
* Listen to sync state changes and automatically resend any pending events
* once syncing is resumed
*/
private onResumedSync = (state: SyncState | null, oldState: SyncState | null): void => {
if (state === SyncState.Syncing && oldState !== SyncState.Syncing) {
logger.info(`Resuming queue after resumed sync`);
this.sendQueue();
}
};
} }