[Feat]: Configurable per-server network request timeout for remote models

e2e/helpers/selectors.ts

@@ -623,6 +623,9 @@ export const Selectors = {
     get apiKeyInput(): string {
       return byTestId('remote-apikey-input');
     },
+    get timeoutInput(): string {
+      return byTestId('remote-timeout-input');
+    },
     get addModelButton(): string {
       return byTestId('add-model-button');
     },
@@ -636,6 +639,9 @@ export const Selectors = {
     get apiKeyInput(): string {
       return byTestId('server-details-apikey-input');
     },
+    get timeoutInput(): string {
+      return byTestId('server-details-timeout-input');
+    },
     get removeButton(): string {
       return byTestId('remove-server-button');
     },

src/api/__tests__/completionEngines.test.ts

@@ -145,6 +145,7 @@ describe('OpenAICompletionEngine', () => {
       'sk-key',
       expect.any(Object), // AbortSignal
       onToken,
+      undefined, // timeoutMs
     );
 
     expect(result).toEqual(mockResult);
@@ -186,6 +187,7 @@ describe('OpenAICompletionEngine', () => {
       'sk-key',
       expect.any(Object),
       undefined,
+      undefined,
     );
   });
 
@@ -215,6 +217,7 @@ describe('OpenAICompletionEngine', () => {
       'sk-key',
       expect.any(Object),
       undefined,
+      undefined,
     );
   });
 
@@ -244,6 +247,7 @@ describe('OpenAICompletionEngine', () => {
       'sk-key',
       expect.any(Object),
       undefined,
+      undefined,
     );
   });
 
@@ -272,6 +276,32 @@ describe('OpenAICompletionEngine', () => {
     await engine.stopCompletion();
   });
 
+  // The engine carries the timeoutMs it was constructed with and forwards it
+  // raw (no normalization here) to streamChatCompletion. A rebuilt engine (on
+  // the next setRemoteModel) therefore applies an edited value.
+  it('forwards the constructed timeoutMs to streamChatCompletion', async () => {
+    const timedEngine = new OpenAICompletionEngine(
+      'http://localhost:1234',
+      'test-model',
+      'sk-key',
+      600000,
+    );
+    mockedStreamChat.mockResolvedValueOnce({text: '', content: ''});
+
+    await timedEngine.completion({
+      messages: [{role: 'user', content: 'Hi'}],
+    } as any);
+
+    expect(mockedStreamChat).toHaveBeenCalledWith(
+      expect.any(Object),
+      'http://localhost:1234',
+      'sk-key',
+      expect.any(Object), // AbortSignal
+      undefined, // callback
+      600000, // raw timeoutMs forwarded, not normalized
+    );
+  });
+
   it('creates engine without api key', () => {
     const noKeyEngine = new OpenAICompletionEngine(
       'http://localhost:1234',
@@ -288,6 +318,7 @@ describe('OpenAICompletionEngine', () => {
       undefined,
       expect.any(Object),
       undefined,
+      undefined,
     );
   });
 });