fix: timeoutSignal is lost after being overriden with controller.signal

Author: sachiniyer

src/watch.ts

@@ -6,6 +6,7 @@ import { KubeConfig } from './config.js';
 export class Watch {
     public static SERVER_SIDE_CLOSE: object = { error: 'Connection closed on server' };
     public config: KubeConfig;
+    private defaultRequestTimeoutMs: number = 30000;
 
     public constructor(config: KubeConfig) {
         this.config = config;
@@ -39,7 +40,7 @@ export class Watch {
         const requestInit = await this.config.applyToFetchOptions({});
 
         const controller = new AbortController();
-        const timeoutSignal = AbortSignal.timeout(30000);
+        const timeoutSignal = AbortSignal.timeout(this.defaultRequestTimeoutMs);
         requestInit.signal = AbortSignal.any([controller.signal, timeoutSignal]);
         requestInit.method = 'GET';
 

src/watch_test.ts

@@ -452,6 +452,41 @@ describe('Watch', () => {
         s.done();
     });
 
+    it('should timeout when server takes too long to respond', async (t) => {
+        const kc = await setupMockSystem(t, (_req: any, _res: any) => {
+            // Don't respond - simulate a hanging server
+        });
+        const watch = new Watch(kc);
+        // Hack around type system to make the default timeout shorter.
+        (watch as any).timeoutMs = 100;
+
+        let doneCalled = false;
+        let doneErr: any;
+
+        let doneResolve: () => void;
+        const donePromise = new Promise<void>((resolve) => {
+            doneResolve = resolve;
+        });
+
+        await watch.watch(
+            '/some/path/to/object',
+            {},
+            () => {
+                throw new Error('Unexpected data received - timeout should have occurred before any data');
+            },
+            (err: any) => {
+                doneCalled = true;
+                doneErr = err;
+                doneResolve();
+            },
+        );
+
+        await donePromise;
+
+        strictEqual(doneCalled, true);
+        strictEqual(doneErr.name, 'AbortError');
+    });
+
     it('should throw on empty config', async () => {
         const kc = new KubeConfig();
         const watch = new Watch(kc);