feat(): Critical Stability & Reliability Fixes

src/library/library.ts

@@ -89,35 +89,40 @@ export class Library {
 
   async upsert(track: Track): Promise<void> {
     this.index.tracks[track.id] = track;
-    this.notify();
+    this.version++;
+    this.sorted = null;
     this.schedulePersist();
   }
 
   /** Apply many track updates with a single notify + persist. */
   async upsertMany(tracks: Track[]): Promise<void> {
     if (tracks.length === 0) return;
     for (const track of tracks) this.index.tracks[track.id] = track;
-    this.notify();
+    this.version++;
+    this.sorted = null;
     this.schedulePersist();
   }
 
   async remove(id: string): Promise<void> {
     delete this.index.tracks[id];
-    this.notify();
+    this.version++;
+    this.sorted = null;
     this.schedulePersist();
   }
 
   /** Remove many tracks with a single notify + persist. */
   async removeMany(ids: string[]): Promise<void> {
     if (ids.length === 0) return;
     for (const id of ids) delete this.index.tracks[id];
-    this.notify();
+    this.version++;
+    this.sorted = null;
     this.schedulePersist();
   }
 
   async clear(): Promise<void> {
     this.index.tracks = {};
-    this.notify();
+    this.version++;
+    this.sorted = null;
     this.schedulePersist();
   }
 

src/player/history.ts

@@ -79,7 +79,8 @@ export class PlayHistory {
       { id, at: new Date().toISOString() },
       ...this.index.entries.filter((e) => e.id !== id),
     ].slice(0, CAP);
-    this.notify();
+    this.version++;
+    for (const fn of this.listeners) fn();
     void this.persist();
   }
 
@@ -88,7 +89,8 @@ export class PlayHistory {
     const kept = this.index.entries.filter((e) => existing(e.id));
     if (kept.length === this.index.entries.length) return;
     this.index.entries = kept;
-    this.notify();
+    this.version++;
+    for (const fn of this.listeners) fn();
     void this.persist();
   }
 

src/player/mpv.ts

@@ -44,6 +44,8 @@ export class MpvPlayer extends EventEmitter {
    * after the last track, after stop), so transport commands are gated on this.
    */
   private loaded = false;
+  /** Lock to prevent connection reset while ensureStarted() is in progress. */
+  private resetting = false;
 
   constructor(mpvPath: string) {
     super();
@@ -73,6 +75,8 @@ export class MpvPlayer extends EventEmitter {
    * Used both on an unexpected exit (auto-respawn) and during teardown.
    */
   private resetConnection(): void {
+    if (this.resetting) return;
+    this.resetting = true;
     this.loaded = false;
     if (this.sock) {
       try {
@@ -91,6 +95,7 @@ export class MpvPlayer extends EventEmitter {
     this.unlinkSocket();
     // Each respawn gets a brand-new endpoint to avoid colliding with a stale one.
     this.ipcPath = MpvPlayer.makeIpcPath();
+    this.resetting = false;
   }
 
   /** Best-effort removal of the unix socket file (no-op on Windows pipes). */

src/sources/spotify/token.ts

@@ -84,7 +84,7 @@ export function clearSpotifyTokenCache(): void {
 /** Fetch (or reuse) an anonymous web-player bearer token. */
 export async function getWebPlayerToken(): Promise<WebPlayerToken> {
   const hit = tokenCache;
-  if (hit && hit.expiresAtMs - Date.now() > TOKEN_SKEW_MS) {
+  if (hit && hit.expiresAtMs > Date.now()) {
     return hit;
   }