Add clickhouse timeout

.gitignore

@@ -139,3 +139,5 @@ dist
 # Vite logs files
 vite.config.js.timestamp-*
 vite.config.ts.timestamp-*
+
+launch.json

docs/CONFIGURATION.md

@@ -25,6 +25,11 @@ cp .env.example .env
 - **`CLICKHOUSE_DATABASE`** - ClickHouse database name
   - Default: `default`
 
+- **`CLICKHOUSE_REQUEST_TIMEOUT_MS`** - Timeout in milliseconds for ClickHouse HTTP requests
+  - Default: `30000` (30 seconds)
+  - Guards against indefinitely hung queries — particularly important when running under Bun, which does not send TCP keepalive probes via `http.Agent`, meaning a silently dead connection (e.g. NAT table expiry in Kubernetes) would otherwise hang forever
+  - Increase if your ClickHouse queries legitimately take longer than 30 seconds
+
 ### RPC Configuration
 
 - **`NODE_URL`** - EVM RPC node URL (required)

lib/clickhouse.ts

@@ -1,4 +1,5 @@
 import { type ClickHouseClient, createClient } from '@clickhouse/client';
+import { CLICKHOUSE_REQUEST_TIMEOUT_MS } from './config';
 import { createLogger } from './logger';
 import { trackClickHouseOperation } from './prometheus';
 
@@ -31,6 +32,7 @@ function getClient(): ClickHouseClient {
             username: process.env.CLICKHOUSE_USERNAME || 'default',
             password: process.env.CLICKHOUSE_PASSWORD || '',
             database: process.env.CLICKHOUSE_DATABASE,
+            request_timeout: CLICKHOUSE_REQUEST_TIMEOUT_MS,
         });
     }
     return _client;
@@ -47,6 +49,7 @@ function getInsertClient(): ClickHouseClient {
             username: process.env.CLICKHOUSE_USERNAME || 'default',
             password: process.env.CLICKHOUSE_PASSWORD || '',
             database: getInsertDatabase(),
+            request_timeout: CLICKHOUSE_REQUEST_TIMEOUT_MS,
         });
     }
     return _insertClient;
@@ -64,6 +67,7 @@ function getSetupClient(): ClickHouseClient {
             username: process.env.CLICKHOUSE_USERNAME || 'default',
             password: process.env.CLICKHOUSE_PASSWORD || '',
             database: getInsertDatabase(),
+            request_timeout: CLICKHOUSE_REQUEST_TIMEOUT_MS,
         });
     }
     return _setupClient;
@@ -149,13 +153,23 @@ export async function query<T = any>(
     // Track total operation time
     const startTime = performance.now();
 
+    const controller = new AbortController();
+    const timeoutHandle = setTimeout(() => {
+        controller.abort(
+            new Error(
+                `ClickHouse query timed out after ${CLICKHOUSE_REQUEST_TIMEOUT_MS}ms`,
+            ),
+        );
+    }, CLICKHOUSE_REQUEST_TIMEOUT_MS);
+
     try {
         // Track query execution time
         const queryStartTime = performance.now();
         const resultSet = await client.query({
             query,
             query_params,
             format: 'JSONEachRow',
+            abort_signal: controller.signal,
         });
         trackClickHouseOperation('read', 'success', startTime);
         const queryEndTime = performance.now();
@@ -182,6 +196,7 @@ export async function query<T = any>(
             totalTimeMs,
         });
 
+        clearTimeout(timeoutHandle);
         return {
             data,
             metrics: {
@@ -191,6 +206,7 @@ export async function query<T = any>(
             },
         };
     } catch (error: unknown) {
+        clearTimeout(timeoutHandle);
         trackClickHouseOperation('read', 'error', startTime);
         const url = process.env.CLICKHOUSE_URL || 'http://localhost:8123';
         const urlObj = new URL(url);

lib/config.ts

@@ -40,6 +40,9 @@ export const DEFAULT_CONFIG = {
 
     // Auto-restart
     AUTO_RESTART_DELAY: 10,
+
+    // ClickHouse request timeout
+    CLICKHOUSE_REQUEST_TIMEOUT_MS: 30_000,
 } as const;
 
 // ============================================================================
@@ -112,6 +115,16 @@ export const CLICKHOUSE_PASSWORD =
     process.env.CLICKHOUSE_PASSWORD || DEFAULT_CONFIG.CLICKHOUSE_PASSWORD;
 export const CLICKHOUSE_DATABASE = process.env.CLICKHOUSE_DATABASE;
 
+/**
+ * Timeout in milliseconds for ClickHouse HTTP requests
+ * Default: 30000ms (30 seconds)
+ */
+export const CLICKHOUSE_REQUEST_TIMEOUT_MS = parseInt(
+    process.env.CLICKHOUSE_REQUEST_TIMEOUT_MS ||
+        String(DEFAULT_CONFIG.CLICKHOUSE_REQUEST_TIMEOUT_MS),
+    10,
+);
+
 /**
  * Database name for insert operations (INSERT, DDL)
  * Optional override - falls back to CLICKHOUSE_DATABASE if not set

lib/logger.ts

@@ -36,7 +36,10 @@ function transportJSON(logObj: Record<string, unknown>): void {
         logger: meta.name,
         msg,
     };
-    if (payload !== undefined && (payload === null || typeof payload !== 'object')) {
+    if (
+        payload !== undefined &&
+        (payload === null || typeof payload !== 'object')
+    ) {
         flat.data = payload;
     }
     process.stdout.write(JSON.stringify(flat) + '\n');

services/polymarket/fetch-gamma.test.ts

@@ -12,8 +12,7 @@ const mockFetch = mock(() =>
 );
 globalThis.fetch = mockFetch as unknown as typeof fetch;
 
-const conditionId = (i: number) =>
-    `0x${i.toString(16).padStart(64, '0')}`;
+const conditionId = (i: number) => `0x${i.toString(16).padStart(64, '0')}`;
 
 const marketStub = (id: number) => ({
     id: String(id),
@@ -31,7 +30,9 @@ describe('fetchGammaApi', () => {
             Promise.resolve({
                 ok: true,
                 json: () =>
-                    Promise.resolve({ markets: [marketStub(1), marketStub(2)] }),
+                    Promise.resolve({
+                        markets: [marketStub(1), marketStub(2)],
+                    }),
             }),
         );
         const result = await fetchGammaApi(