qak2019
/
cents
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: preserve other users local sync data

This commit is contained in:
openclaw 2026-07-25 02:06:38 +08:00
parent f7756d8936
commit 508e63aca2
2 changed files with 2 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/web/src/stores/entries.ts
View File

@ -84,8 +84,7 @@ export const useEntryStore = defineStore("entries", {
); );
const pendingOperations = (await db.syncOperations.filter((operation) => operation.syncedAt === null).toArray()) const pendingOperations = (await db.syncOperations.filter((operation) => operation.syncedAt === null).toArray())
.filter((operation) => .filter((operation) =>
(operation.userId ?? operation.payload.updatedBy) === auth.user!.id (operation.userId ?? operation.payload.updatedBy) === auth.user!.id,
|| operation.ledgerIds.some((ledgerId) => allowedLedgerIds.has(ledgerId)),
); );
this.pendingEntryIds = [...new Set(pendingOperations.map((operation) => operation.entityId))]; this.pendingEntryIds = [...new Set(pendingOperations.map((operation) => operation.entityId))];
this.pendingEntries = [...new Map( this.pendingEntries = [...new Map(

15
apps/web/src/stores/ledgers.ts
View File

@ -55,22 +55,9 @@ export const useLedgerStore = defineStore("ledgers", {
this.ledgers = serverLedgers; this.ledgers = serverLedgers;
const allowedIds = new Set(this.ledgers.map((ledger) => ledger.id)); const allowedIds = new Set(this.ledgers.map((ledger) => ledger.id));
const localEntries = await db.entries.toArray(); await db.transaction("rw", db.ledgers, async () => {
const inaccessibleEntries = localEntries
.filter((entry) => entry.ownerId !== auth.user!.id && !entry.ledgerIds.some((ledgerId) => allowedIds.has(ledgerId)))
.map((entry) => entry.id);
const projectedEntries = localEntries
.filter((entry) => entry.ownerId !== auth.user!.id && entry.ledgerIds.some((ledgerId) => !allowedIds.has(ledgerId)))
.map((entry) => ({ ...entry, ledgerIds: entry.ledgerIds.filter((ledgerId) => allowedIds.has(ledgerId)) }));
const inaccessibleOperations = await db.syncOperations
.filter((item) => (item.userId ?? item.payload.updatedBy) !== auth.user!.id)
.primaryKeys();
await db.transaction("rw", db.ledgers, db.entries, db.syncOperations, async () => {
await db.ledgers.clear(); await db.ledgers.clear();
if (serverLedgers.length) await db.ledgers.bulkPut(serverLedgers); if (serverLedgers.length) await db.ledgers.bulkPut(serverLedgers);
if (projectedEntries.length) await db.entries.bulkPut(projectedEntries);
if (inaccessibleEntries.length) await db.entries.bulkDelete(inaccessibleEntries);
if (inaccessibleOperations.length) await db.syncOperations.bulkDelete(inaccessibleOperations);
}); });
const preferenceId = currentLedgerPreferenceId(auth.user.id); const preferenceId = currentLedgerPreferenceId(auth.user.id);