add http2 fetch

Author: DmitryBorisov-sm

package.json

@@ -88,5 +88,8 @@
     "suiteNameTemplate": "{filepath}",
     "classNameTemplate": "{classname}",
     "titleTemplate": "{title}"
+  },
+  "dependencies": {
+    "undici": "^7.16.0"
   }
-}
+}

src/orkes/OrkesConductorClient.ts

@@ -16,6 +16,9 @@ export const orkesConductorClient = async (
   CustomHttpRequest: HttpRequestConstructor = OrkesHttpRequest
 ) => {
   const serverUrl = process.env.CONDUCTOR_SERVER_URL || config?.serverUrl;
+
+  if (!serverUrl) throw new Error("Conductor server URL is not set");
+
   const keyId = process.env.CONDUCTOR_AUTH_KEY || config?.keyId;
   const keySecret = process.env.CONDUCTOR_AUTH_SECRET || config?.keySecret;
 

src/orkes/request/OrkesHttpRequest.ts

@@ -4,14 +4,34 @@ import {
   CancelablePromise,
   OpenAPIConfig,
 } from "../../common";
+import { FetchFn } from "../types";
 import { orkesRequest } from "./request";
+import {
+  fetch as undiciFetch,
+  Agent as UndiciAgent,
+  RequestInfo as UndiciRequestInfo,
+  RequestInit as UndiciRequestInit,
+} from "undici";
 
 export class OrkesHttpRequest extends BaseHttpRequest {
+  private fetchFn: FetchFn;
+
   constructor(config: OpenAPIConfig) {
     super(config);
+    const undiciHttp2Agent = new UndiciAgent({ allowH2: true });
+    const undiciHttp2Fetch = async (
+      input: UndiciRequestInfo,
+      init: UndiciRequestInit = {}
+    ) => {
+      return undiciFetch(input, {
+        ...init,
+        dispatcher: undiciHttp2Agent,
+      });
+    };
+    this.fetchFn = undiciHttp2Fetch as FetchFn;
   }
 
   public request<T>(options: ApiRequestOptions): CancelablePromise<T> {
-    return orkesRequest(this.config, options);
+    return orkesRequest(this.config, options, this.fetchFn);
   }
 }

yarn.lock

@@ -3445,6 +3445,11 @@ undici-types@~6.21.0:
   resolved "https://registry.npmjs.org/undici-types/-/undici-types-6.21.0.tgz"
   integrity sha512-iwDZqg0QAGrg9Rav5H4n0M64c3mkR59cJ6wQp+7C4nI0gsmExaedaYLNO44eT4AtBBwjbTiGPMlt2Md0T9H9JQ==
 
+undici@^7.16.0:
+  version "7.16.0"
+  resolved "https://registry.yarnpkg.com/undici/-/undici-7.16.0.tgz#cb2a1e957726d458b536e3f076bf51f066901c1a"
+  integrity sha512-QEg3HPMll0o3t2ourKwOeUAZ159Kn9mx5pnzHRQO8+Wixmh88YdZRiIwat0iNzNNXn0yoEtXJqFpyW7eM8BV7g==
+
 update-browserslist-db@^1.1.3:
   version "1.1.3"
   resolved "https://registry.npmjs.org/update-browserslist-db/-/update-browserslist-db-1.1.3.tgz"