vbatts/llama.cpp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

mark old conv as "migrated" instead deleting them

Browse source
This commit is contained in:
Xuan Son Nguyen 2025-02-10 14:40:35 +01:00
parent dfc33d1cb8
commit 3acee866ff
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
examples/server/webui/src/utils/storage.ts
View file

@ -211,6 +211,7 @@ interface LSConversation {
id: string; // format: `conv-{timestamp}` id: string; // format: `conv-{timestamp}`
lastModified: number; // timestamp from Date.now() lastModified: number; // timestamp from Date.now()
messages: LSMessage[]; messages: LSMessage[];
migrated?: boolean; // additionally, we add a flag to prevent duplicate migration
} }
interface LSMessage { interface LSMessage {
id: number; id: number;
@ -227,10 +228,15 @@ async function migrationLStoIDB() {
} }
if (res.length === 0) return; if (res.length === 0) return;
await db.transaction('rw', db.conversations, db.messages, async () => { await db.transaction('rw', db.conversations, db.messages, async () => {
let migratedCount = 0;
for (const conv of res) { for (const conv of res) {
const { id: convId, lastModified, messages } = conv; const { id: convId, lastModified, messages } = conv;
const firstMsg = messages[0]; const firstMsg = messages[0];
const lastMsg = messages.at(-1); const lastMsg = messages.at(-1);
if (conv.migrated) {
console.log(`Skipping conversation ${convId} already migrated`);
continue;
}
if (messages.length < 2 || !firstMsg || !lastMsg) { if (messages.length < 2 || !firstMsg || !lastMsg) {
console.log( console.log(
`Skipping conversation ${convId} with ${messages.length} messages` `Skipping conversation ${convId} with ${messages.length} messages`
@ -266,13 +272,14 @@ async function migrationLStoIDB() {
children: i === messages.length - 1 ? [] : [messages[i + 1].id], children: i === messages.length - 1 ? [] : [messages[i + 1].id],
}); });
} }
localStorage.removeItem(convId); localStorage.setItem(convId, JSON.stringify({ ...conv, migrated: true }));
migratedCount++;
console.log( console.log(
`Migrated conversation ${convId} with ${messages.length} messages` `Migrated conversation ${convId} with ${messages.length} messages`
); );
} }
console.log( console.log(
`Migrated ${res.length} conversations from localStorage to IndexedDB` `Migrated ${migratedCount} conversations from localStorage to IndexedDB`
); );
}); });
} }