mirrors/signal-desktop
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 2 Wiki Activity Actions 1

Fix session transactions for archive sessions

Browse source
This commit is contained in:
Fedor Indutny 2021-05-21 09:03:01 -07:00 • committed by GitHub
parent 6323dd6492
commit b878cad625
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
ts/SignalProtocolStore.ts
View file

@ -972,24 +972,28 @@ export class SignalProtocolStore extends EventsMixin {
});
}
private async _archiveSession(entry?: SessionCacheEntry) {
private async _archiveSession(entry?: SessionCacheEntry, zone?: Zone) {
if (!entry) {
return;
}
await this.enqueueSessionJob(entry.fromDB.id, async () => {
const item = entry.hydrated
? entry.item
: await this._maybeMigrateSession(entry.fromDB);
await this.enqueueSessionJob(
entry.fromDB.id,
async () => {
const item = entry.hydrated
? entry.item
: await this._maybeMigrateSession(entry.fromDB);
if (!item.hasCurrentState()) {
return;
}
if (!item.hasCurrentState()) {
return;
}
item.archiveCurrentState();
item.archiveCurrentState();
await this.storeSession(entry.fromDB.id, item);
});
await this.storeSession(entry.fromDB.id, item);
},
zone
);
}
async archiveSession(encodedAddress: string): Promise<void> {
@ -1037,7 +1041,7 @@ export class SignalProtocolStore extends EventsMixin {
await Promise.all(
entries.map(async entry => {
await this._archiveSession(entry);
await this._archiveSession(entry, zone);
})
);
});