Merge branch 'main' into dev

tests/camera-manager/frigate/watcher.test.ts

@@ -1,4 +1,4 @@
-import { afterEach, describe, expect, it, vi } from 'vitest';
+import { afterEach, assert, describe, expect, it, vi } from 'vitest';
 import {
   FrigateEventChange,
   FrigateReviewChange,
@@ -117,6 +117,33 @@ describe('FrigateEventWatcher', () => {
     expect(unsubscribeCallback).toBeCalledTimes(1);
   });
 
+  it('should handle unsubscribe during pending subscription', async () => {
+    const stateWatcher = new FrigateEventWatcher();
+    const hass = createHASS();
+
+    let resolveSubscription: ((callback: () => Promise<void>) => void) | undefined;
+    const subscriptionPromise = new Promise<() => Promise<void>>((resolve) => {
+      resolveSubscription = resolve;
+    });
+    vi.mocked(hass.connection.subscribeMessage).mockReturnValue(subscriptionPromise);
+
+    const request = {
+      instanceID: 'frigate',
+      callback: vi.fn(),
+    };
+
+    // Start subscription (doesn't complete yet as not awaited).
+    const subscribePromise = stateWatcher.subscribe(hass, request);
+
+    // Unsubscribe while subscription is still pending.
+    await stateWatcher.unsubscribe(request);
+
+    // Complete the subscription.
+    assert(resolveSubscription);
+    resolveSubscription(vi.fn());
+    await subscribePromise;
+  });
+
   describe('should call handler', () => {
     afterEach(() => {
       vi.resetAllMocks();