From 943e5478361814fab1a442352c1b72aaeae5047b Mon Sep 17 00:00:00 2001
From: Richard R <me@richardr.dev>
Date: Tue, 26 May 2026 16:39:40 -0600
Subject: [PATCH] test: fix JetStream mock typing for tsc

---
 ...ompute-worker-control-plane-jetstream.spec.ts | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/tests/unit/compute-worker-control-plane-jetstream.spec.ts b/tests/unit/compute-worker-control-plane-jetstream.spec.ts
index 641b78e..fb3f3e3 100644
--- a/tests/unit/compute-worker-control-plane-jetstream.spec.ts
+++ b/tests/unit/compute-worker-control-plane-jetstream.spec.ts
@@ -70,11 +70,11 @@ class FakeJetStream {
     },
   };
 
-  async publish(subject: string, data: Uint8Array): Promise<{ seq: number }> {
+  async publish(subject: string, data: Uint8Array): Promise<{ seq: number; stream: string; duplicate: boolean }> {
     this.seq += 1;
     const payload = JSON.parse(new TextDecoder().decode(data)) as unknown;
     this.published.push({ subject, payload, seq: this.seq });
-    return { seq: this.seq };
+    return { seq: this.seq, stream: 'fake', duplicate: false };
   }
 }
 
@@ -126,18 +126,18 @@ test.describe('worker jetstream control-plane adapters', () => {
   test('queue and event adapters publish expected JetStream subjects', async () => {
     const js = new FakeJetStream();
     const queue = new JetStreamOperationQueue({
-      getJs: async () => js,
+      getJs: async () => js as any,
       whisperSubject: 'jobs.whisper',
       layoutSubject: 'jobs.layout',
     });
     const events = new JetStreamOperationEventStream({
-      getJs: async () => js,
+      getJs: async () => js as any,
       getJsm: async () => ({
         consumers: {
           add: async () => ({ name: 'noop' }),
           delete: async () => true,
         },
-      }),
+      }) as any,
       eventsStreamName: 'compute_events',
     });
 
@@ -170,17 +170,17 @@ test.describe('worker jetstream control-plane adapters', () => {
 
     const store = new JetStreamOperationStateStore({ getKv: async () => kv });
     const events = new JetStreamOperationEventStream({
-      getJs: async () => js,
+      getJs: async () => js as any,
       getJsm: async () => ({
         consumers: {
           add: async () => ({ name: 'noop' }),
           delete: async () => true,
         },
-      }),
+      }) as any,
       eventsStreamName: 'compute_events',
     });
     const queue = new JetStreamOperationQueue({
-      getJs: async () => js,
+      getJs: async () => js as any,
       whisperSubject: 'jobs.whisper',
       layoutSubject: 'jobs.layout',
     });