vndangkhoa/kv-music
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(DB): why did i make it overwrite

Browse source
This commit is contained in:
Samidy 2026-03-09 04:23:08 +03:00
parent 0662796d73
commit fe95cb23cd
2 changed files with 29 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
js/accounts/pocketbase.js
View file

@ -534,22 +534,15 @@ const syncManager = {
database = await database;
}
const getAll = async (store) => {
if (database && typeof database.getAll === 'function') return database.getAll(store);
if (database && database.db && typeof database.db.getAll === 'function')
return database.db.getAll(store);
return [];
};
const localData = {
tracks: (await getAll('favorites_tracks')) || [],
albums: (await getAll('favorites_albums')) || [],
artists: (await getAll('favorites_artists')) || [],
playlists: (await getAll('favorites_playlists')) || [],
mixes: (await getAll('favorites_mixes')) || [],
history: (await getAll('history_tracks')) || [],
userPlaylists: (await getAll('user_playlists')) || [],
userFolders: (await getAll('user_folders')) || [],
tracks: (await database.getAll('favorites_tracks')) || [],
albums: (await database.getAll('favorites_albums')) || [],
artists: (await database.getAll('favorites_artists')) || [],
playlists: (await database.getAll('favorites_playlists')) || [],
mixes: (await database.getAll('favorites_mixes')) || [],
history: (await database.getAll('history_tracks')) || [],
userPlaylists: (await database.getAll('user_playlists')) || [],
userFolders: (await database.getAll('user_folders')) || [],
};
let { library, history, userPlaylists, userFolders } = cloudData;
@ -612,8 +605,23 @@ const syncManager = {
}
});
if (history.length === 0 && localData.history.length > 0) {
history = localData.history;
const combinedHistory = [...history, ...localData.history];
combinedHistory.sort((a, b) => (b.timestamp || 0) - (a.timestamp || 0));
const uniqueHistory = [];
const seenTimestamps = new Set();
for (const item of combinedHistory) {
if (!item.timestamp) continue;
if (!seenTimestamps.has(item.timestamp)) {
seenTimestamps.add(item.timestamp);
uniqueHistory.push(item);
}
if (uniqueHistory.length >= 100) break;
}
if (JSON.stringify(history) !== JSON.stringify(uniqueHistory)) {
history = uniqueHistory;
needsUpdate = true;
}

4
js/db.js
View file

@ -89,6 +89,10 @@ export class MusicDatabase {
});
}
async getAll(storeName) {
return this.performTransaction(storeName, 'readonly', (store) => store.getAll());
}
// History API
async addToHistory(track) {
const storeName = 'history_tracks';