wip-fix: client node-fetch http connection reset errors (#303)

front/admin/src/lib/load.ts

@@ -80,7 +80,6 @@ export const load_call = async <T>(
       }
     }
   } catch(e: any) {
-    console.log(e);
     const api_error = new ApiError(502, "FRONT_GATEWAY_FETCH", `Bad gateway (fetch)`);
     error(api_error.status as NumericRange<400, 599>, api_error.toJSON().error);
   }

front/packages/client/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openstream/client",
-  "version": "0.3.2",
+  "version": "0.3.3",
   "description": "Openstream Radio Server Client",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

front/packages/client/src/index.ts

@@ -17,6 +17,9 @@ const qss = (v: any) => {
   return qs.stringify(v, { addQueryPrefix: true, skipNulls: true })
 }
 
+const http_agent = new http.Agent({ keepAlive: true });
+const https_agent = new https.Agent({ keepAlive: true });
+
 export class Client {
 
   private base_url: string;
@@ -64,7 +67,7 @@ export class Client {
     const method = init.method ?? "GET";
     // this.logger.debug(`fetch: ${method} ${url}`);
     return await this.node_fetch(url, {
-      agent: (url) => url.protocol === "http:" ? http.globalAgent : https.globalAgent,
+      agent: (url) => url.protocol === "http:" ? http_agent : https_agent,
       ...init
     }).catch(e => {
       // this.logger.warn(`fetch error: ${e} | cause=${e.cause}`)

front/server/package.json

@@ -16,7 +16,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "@openstream/client": "^0.3.2",
+    "@openstream/client": "^0.3.3",
     "accept-language-parser": "^1.5.0",
     "braintree": "^3.15.0",
     "commander": "^9.4.1",