Search's instant leg read only downloaded items, so with no downloads it returned nothing and every keystroke fell through to a full Recursive=true server query. It now reads the whole synced catalog through the same availability CTE get_items uses, gated on the same include_catalog_browse flag so search and browse cannot diverge. (UR-065, DR-108) Also fixes three defects found while confirming that: - items_fts grew by a full duplicate index every catalog pass. INSERT OR REPLACE fires no AFTER DELETE trigger without recursive_triggers, so the old index row was orphaned, and a TEXT PRIMARY KEY meant the replacement took a fresh rowid and inserted a second entry. Now a real upsert, with migration 021 rebuilding existing indexes. (DR-110) - DELETE FROM items existed nowhere, so server-side deletions never propagated. Adds a post-crawl mark-and-sweep, scoped to crawled types, skipping downloaded items, and refusing to run after a partial crawl because items.parent_id cascades. (DR-110) - The index omitted MusicArtist, Playlist and People, which search groups results by. Adds them plus people_fts (migration 022). (DR-111) Re-indexing moves from a frontend startup call to a Rust background task with a 6h TTL, so a long session no longer searches a stale catalog and a restart no longer forces a crawl regardless of freshness. (DR-109, IR-030) Downloads gain a lifetime tier. Eviction selected every completed row by age with no download_source filter, so hitting the storage limit deleted the oldest download -- typically one saved deliberately for offline -- to make room for a precached track. It now reclaims only 'auto' rows, and expired ones are reclaimed first, before live cache is evicted. (DR-126, DR-127) Downloaded video and audio-only handoffs now play from disk instead of streaming; the video path had never consulted downloads at all. No transcode is involved: MPV runs video=no and ExoPlayer has no surface for an Audio item. (DR-123 in part, DR-128) FTS queries are built as quoted phrases so apostrophes, hyphens and slashes are data rather than operator syntax, and the item-type filter is bound rather than interpolated. Specs: docs/specs/catalog-index-search.md, docs/specs/read-through-media-cache.md Includes concurrently-developed favourites browsing and background-audio stream-end handling; the two workstreams share offline.rs, lib.rs and online.rs, so no subset of files builds independently.
192 lines
5.3 KiB
TypeScript
192 lines
5.3 KiB
TypeScript
// Sync service - manages offline mutation queueing
|
|
//
|
|
// Simplified service that coordinates with the Rust backend.
|
|
// The Rust backend handles sync queue persistence and processing logic.
|
|
// This service provides a thin TypeScript API for queuing mutations.
|
|
//
|
|
// TRACES: UR-002, UR-017, UR-025 | DR-014
|
|
|
|
import { commands } from "$lib/api/bindings";
|
|
import { auth } from "$lib/stores/auth";
|
|
|
|
// Types matching Rust structs
|
|
export interface SyncQueueItem {
|
|
id: number;
|
|
userId: string;
|
|
operation: string;
|
|
itemId: string | null;
|
|
payload: string | null;
|
|
status: string;
|
|
retryCount: number;
|
|
createdAt: string | null;
|
|
errorMessage: string | null;
|
|
}
|
|
|
|
export type SyncOperation =
|
|
| "mark_played"
|
|
| "mark_favorite"
|
|
| "unmark_favorite"
|
|
| "update_progress"
|
|
| "report_playback_start"
|
|
| "report_playback_stopped"
|
|
| "playlist_create"
|
|
| "playlist_delete"
|
|
| "playlist_rename"
|
|
| "playlist_add_items"
|
|
| "playlist_remove_items"
|
|
| "playlist_reorder_item";
|
|
|
|
/**
|
|
* Simplified sync service - handles offline mutation queueing
|
|
*
|
|
* The Rust backend maintains the sync queue in SQLite and is responsible
|
|
* for processing queued items. This service provides a TypeScript API
|
|
* for queueing and managing sync operations.
|
|
*/
|
|
class SyncService {
|
|
/**
|
|
* Start the sync service (lifecycle managed by Rust backend)
|
|
*/
|
|
start(): void {
|
|
console.log("[SyncService] Started");
|
|
}
|
|
|
|
/**
|
|
* Stop the sync service (lifecycle managed by Rust backend)
|
|
*/
|
|
stop(): void {
|
|
console.log("[SyncService] Stopped");
|
|
}
|
|
|
|
/**
|
|
* Queue a mutation for sync to server
|
|
*
|
|
* TRACES: UR-017, UR-025 | DR-014
|
|
*/
|
|
async queueMutation(
|
|
operation: SyncOperation,
|
|
itemId: string,
|
|
payload?: Record<string, unknown>
|
|
): Promise<number> {
|
|
const userId = auth.getUserId();
|
|
if (!userId) {
|
|
throw new Error("Not authenticated");
|
|
}
|
|
|
|
const id = await commands.syncQueueMutation(
|
|
userId,
|
|
operation,
|
|
itemId,
|
|
payload ? JSON.stringify(payload) : null
|
|
);
|
|
|
|
console.log(`[SyncService] Queued ${operation} for item ${itemId}, id: ${id}`);
|
|
return id;
|
|
}
|
|
|
|
// NOTE: `queueFavorite` is gone. Favourites are drained by Rust on the
|
|
// `connectivity:reconnected` signal (DR-120) — the local write already sets
|
|
// `pending_sync`, and a second queue here would push the same change twice.
|
|
// See src-tauri/src/commands/favorites.rs.
|
|
|
|
/**
|
|
* Queue playback progress update
|
|
* Also updates local state immediately
|
|
*/
|
|
async queuePlaybackProgress(
|
|
itemId: string,
|
|
positionMs: number
|
|
): Promise<number> {
|
|
// Update local state first
|
|
await commands.storageUpdatePlaybackProgress(auth.getUserId() ?? "", itemId, positionMs);
|
|
|
|
return this.queueMutation("update_progress", itemId, { positionMs });
|
|
}
|
|
|
|
/**
|
|
* Queue mark as played
|
|
* Also updates local state immediately
|
|
*/
|
|
async queueMarkPlayed(itemId: string): Promise<number> {
|
|
// Update local state first
|
|
await commands.storageMarkPlayed(auth.getUserId() ?? "", itemId);
|
|
|
|
return this.queueMutation("mark_played", itemId);
|
|
}
|
|
|
|
/**
|
|
* Get count of pending sync operations
|
|
*/
|
|
async getPendingCount(): Promise<number> {
|
|
const userId = auth.getUserId();
|
|
if (!userId) {
|
|
return 0;
|
|
}
|
|
|
|
return commands.syncGetPendingCount(userId);
|
|
}
|
|
|
|
/**
|
|
* Get pending sync items (for debugging/monitoring)
|
|
*/
|
|
async getPending(limit?: number): Promise<SyncQueueItem[]> {
|
|
const userId = auth.getUserId();
|
|
if (!userId) {
|
|
return [];
|
|
}
|
|
|
|
return commands.syncGetPending(userId, limit ?? null);
|
|
}
|
|
|
|
/**
|
|
* Clean up completed operations older than specified days
|
|
*/
|
|
async cleanup(daysOld: number = 7): Promise<number> {
|
|
const deleted = await commands.syncCleanupCompleted(daysOld);
|
|
console.log(`[SyncService] Cleaned up ${deleted} old completed operations`);
|
|
return deleted;
|
|
}
|
|
|
|
// ===== Playlist sync operations =====
|
|
|
|
async queuePlaylistCreate(playlistId: string, name: string, itemIds: string[]): Promise<number> {
|
|
return this.queueMutation("playlist_create", playlistId, { name, itemIds });
|
|
}
|
|
|
|
async queuePlaylistDelete(playlistId: string): Promise<number> {
|
|
return this.queueMutation("playlist_delete", playlistId);
|
|
}
|
|
|
|
async queuePlaylistRename(playlistId: string, name: string): Promise<number> {
|
|
return this.queueMutation("playlist_rename", playlistId, { name });
|
|
}
|
|
|
|
async queuePlaylistAddItems(playlistId: string, itemIds: string[]): Promise<number> {
|
|
return this.queueMutation("playlist_add_items", playlistId, { itemIds });
|
|
}
|
|
|
|
async queuePlaylistRemoveItems(playlistId: string, entryIds: string[]): Promise<number> {
|
|
return this.queueMutation("playlist_remove_items", playlistId, { entryIds });
|
|
}
|
|
|
|
async queuePlaylistReorderItem(playlistId: string, itemId: string, newIndex: number): Promise<number> {
|
|
return this.queueMutation("playlist_reorder_item", playlistId, { itemId, newIndex });
|
|
}
|
|
|
|
/**
|
|
* Clear all sync operations for the current user (called during logout)
|
|
*
|
|
* TRACES: UR-017 | DR-014
|
|
*/
|
|
async clearUser(): Promise<void> {
|
|
const userId = auth.getUserId();
|
|
if (userId) {
|
|
await commands.syncClearUser(userId);
|
|
console.log("[SyncService] Cleared sync queue for user");
|
|
}
|
|
}
|
|
}
|
|
|
|
// Export singleton instance
|
|
export const syncService = new SyncService();
|