123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
// === Needed importsimport { Agent as HttpAgent } from "http";import { Agent as HttpsAgent } from "https";import { Readable } from "stream";
// === Export debugexport { debug } from "debug";
// === Export system-specific operations// Turn an AsyncIterable<Uint8Array> into a streamexport const itrToStream = (itr: AsyncIterable<Uint8Array>) =>    Readable.from(itr, { objectMode: false });
// === Base configuration for `fetch` callsconst httpAgents = new Map<string, HttpAgent>();const httpsAgents = new Map<string, HttpsAgent>();function getCached<K, V>(map: Map<K, V>, key: K, otherwise: () => V) {    let value = map.get(key);    if (value === undefined) {        value = otherwise();        map.set(key, value);    }    return value;}export function baseFetchConfig(apiRoot: string) {    if (apiRoot.startsWith("https:")) {        return {            compress: true,            agent: getCached(                httpsAgents,                apiRoot,                () => new HttpsAgent({ keepAlive: true }),            ),        };    } else if (apiRoot.startsWith("http:")) {        return {            agent: getCached(                httpAgents,                apiRoot,                () => new HttpAgent({ keepAlive: true }),            ),        };    } else return {};}
// === Default webhook adapterexport const defaultAdapter = "express";