Arsharth/hydrogen-web
1
0
Fork 0
forked from mystiq/hydrogen-web
Code Issues Pull requests Projects Releases Packages Wiki Activity

add more logging to backup storage migration

Browse source
This commit is contained in:
Bruno Windels 2022-02-01 12:18:28 +01:00
parent c6820eccab
commit b29ecd339d
1 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
src/matrix/storage/idb/schema.ts
View file

@ -281,14 +281,23 @@ async function clearAllStores(db: IDBDatabase, txn: IDBTransaction) {
// v15 add backup index to inboundGroupSessions // v15 add backup index to inboundGroupSessions
async function addInboundSessionBackupIndex(db: IDBDatabase, txn: IDBTransaction, localStorage: IDOMStorage, log: ILogItem): Promise<void> { async function addInboundSessionBackupIndex(db: IDBDatabase, txn: IDBTransaction, localStorage: IDOMStorage, log: ILogItem): Promise<void> {
const inboundGroupSessions = txn.objectStore("inboundGroupSessions"); const inboundGroupSessions = txn.objectStore("inboundGroupSessions");
let countWithSession = 0;
let countWithoutSession = 0;
await iterateCursor<InboundGroupSessionEntry>(inboundGroupSessions.openCursor(), (value, key, cursor) => { await iterateCursor<InboundGroupSessionEntry>(inboundGroupSessions.openCursor(), (value, key, cursor) => {
value.backup = BackupStatus.NotBackedUp; if (value.session) {
// we'll also have backup keys in here, we can't tell, value.backup = BackupStatus.NotBackedUp;
// but the worst thing that can happen is that we try // we'll also have backup keys in here, we can't tell,
// to backup keys that were already in backup, which // but the worst thing that can happen is that we try
// the server will ignore // to backup keys that were already in backup, which
value.source = KeySource.DeviceMessage; // the server will ignore
value.source = KeySource.DeviceMessage;
countWithSession += 1;
} else {
countWithoutSession += 1;
}
return NOT_DONE; return NOT_DONE;
}); });
log.set("countWithoutSession", countWithoutSession);
log.set("countWithSession", countWithSession);
inboundGroupSessions.createIndex("byBackup", "backup", {unique: false}); inboundGroupSessions.createIndex("byBackup", "backup", {unique: false});
} }