matrix/matrix-js-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-js-sdk.git synced 2025-08-09 10:22:46 +03:00
Code Activity

quick update docs and renaming

Browse Source
This commit is contained in:
Valere
2025-06-30 15:23:50 +02:00
parent 464b9ee7f8
commit 9819ca1a98
2 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/sliding-sync-sdk.ts
View File

@@ -152,11 +152,11 @@ class ExtensionToDevice implements Extension<ExtensionToDeviceRequest, Extension
public async onResponse(data: ExtensionToDeviceResponse): Promise<void> {
const events = data["events"] || [];
let processedEvents: ReceivedToDeviceMessage[];
let receivedToDeviceMessages: ReceivedToDeviceMessage[];
if (this.cryptoCallbacks) {
processedEvents = await this.cryptoCallbacks.preprocessToDeviceMessages(events);
receivedToDeviceMessages = await this.cryptoCallbacks.preprocessToDeviceMessages(events);
} else {
processedEvents = events
receivedToDeviceMessages = events
.filter((e) => e.type !== EventType.RoomMessageEncrypted)
.map((clearEvent) => {
// Crypto is not enabled, so we just return the clear events.
@@ -166,7 +166,7 @@ class ExtensionToDevice implements Extension<ExtensionToDeviceRequest, Extension
};
});
}
processToDeviceMessages(processedEvents, this.client);
processToDeviceMessages(receivedToDeviceMessages, this.client);
this.nextBatch = data.next_batch;
}

12
src/sync.ts
View File

@@ -1147,11 +1147,12 @@ export class SyncApi {
if (data.to_device && Array.isArray(data.to_device.events) && data.to_device.events.length > 0) {
const toDeviceMessages: IToDeviceEvent[] = data.to_device.events.filter(noUnsafeEventProps);
let processedEvents: ReceivedToDeviceMessage[];
let receivedToDeviceMessages: ReceivedToDeviceMessage[];
if (this.syncOpts.cryptoCallbacks) {
processedEvents = await this.syncOpts.cryptoCallbacks.preprocessToDeviceMessages(toDeviceMessages);
receivedToDeviceMessages =
await this.syncOpts.cryptoCallbacks.preprocessToDeviceMessages(toDeviceMessages);
} else {
processedEvents = toDeviceMessages
receivedToDeviceMessages = toDeviceMessages
.filter((e) => e.type !== EventType.RoomMessageEncrypted)
.map((clearEvent) => {
// Crypto is not enabled, so we just return the clear events.
@@ -1162,7 +1163,7 @@ export class SyncApi {
});
}
processToDeviceMessages(processedEvents, client);
processToDeviceMessages(receivedToDeviceMessages, client);
} else {
// no more to-device events: we can stop polling with a short timeout.
this.catchingUp = false;
@@ -1921,7 +1922,8 @@ export function _createAndReEmitRoom(client: MatrixClient, roomId: string, opts:
/**
* Process a list of (decrypted, where possible) received to-device events.
*
* Converts the events into `MatrixEvent`s, and emits appropriate {@link ClientEvent.ToDeviceEvent} events.
* Converts the to-device message and OlmEncryptionIngo and emits appropriate {@link ClientEvent.ReceivedToDeviceMessage} events.
* Converts the events into `MatrixEvent`s, and emits the now deprecated {@link ClientEvent.ToDeviceEvent} events for compatibility.
* */
export function processToDeviceMessages(toDeviceMessages: ReceivedToDeviceMessage[], client: MatrixClient): void {
const cancelledKeyVerificationTxns: string[] = [];