feat: allow to specify connect timeout in config

src/config.ts

@@ -26,6 +26,7 @@ const configSchema = z.object({
 		.url()
 		.default('https://sdk-writer.eu.smartlook.cloud'),
 	managerHost: z.string().url().default('https://manager.eu.smartlook.cloud'),
+	undiciConnectTimeout: z.coerce.number().positive().default(30_000),
 })
 
 export let config: z.infer<typeof configSchema>
@@ -55,5 +56,6 @@ export function initConfig(): void {
 		webSdkWriterHost: process.env['WEB_SDK_WRITER_HOST'],
 		mobileSdkWriterHost: process.env['MOBILE_SDK_WRITER_HOST'],
 		managerHost: process.env['MANAGER_HOST'],
+		undiciConnectTimeout: process.env['UNDICI_CONNECT_TIMEOUT'],
 	})
 }

src/proxy/handler.ts

@@ -3,6 +3,7 @@ import { IncomingMessage, ServerResponse } from 'http'
 
 import undici from 'undici'
 
+import { config } from '../config.js'
 import { logger } from '../logger.js'
 
 import { internalError } from './internal-error.js'
@@ -11,7 +12,11 @@ import { statusRoute } from './routes/status-route.js'
 import type { IStreamOpaque, RouteMapping } from './types.js'
 import { buildUrl, prepareHeaders } from './utils.js'
 
-undici.setGlobalDispatcher(new undici.Agent({ connect: { timeout: 30_000 } }))
+export function initUndiciDispatcher(): void {
+	undici.setGlobalDispatcher(
+		new undici.Agent({ connect: { timeout: config.undiciConnectTimeout } })
+	)
+}
 
 async function pipeResponse(
 	routeTargetHost: string,
@@ -66,7 +71,7 @@ async function pipeResponse(
 				outgoingHeaders,
 				err,
 			},
-			'Error while piping response. This is just a warning and you can safely ignore it, since Web SDK will retry the request later'
+			'Error while piping response. This is just a warning and you can safely ignore it, since Smartlook Web SDK will retry the request later'
 		)
 
 		internalError(res)

src/proxy/http-server.ts

@@ -1,14 +1,15 @@
 import { createServer, Server } from 'http'
 
-import { handler as rootHandler } from './handler.js'
+import { initUndiciDispatcher, handler } from './handler.js'
 import { initRouteMappings } from './routes/route-mappings.js'
 
 export function initHTTPServer(): Server {
 	const routeMappings = initRouteMappings()
+	initUndiciDispatcher()
 
 	// eslint-disable-next-line @typescript-eslint/no-misused-promises
 	return createServer(async (req, res) => {
-		return rootHandler(req, res, routeMappings)
+		return handler(req, res, routeMappings)
 	})
 }