Merge pull request mediaurl#30 from watchedcom/fetch-agent

Fetch agent

Author: MediaURL1

packages/example/package-lock.json

@@ -11,6 +11,7 @@
   "dependencies": {
     "@types/express": "^4.17.3",
     "@watchedcom/schema": "^0.34.1",
+    "agent-base": "^6.0.1",
     "body-parser": "^1.19.0",
     "debug": "^4.1.1",
     "dotenv": "^8.2.0",

packages/i18n/package-lock.json

@@ -1,4 +1,4 @@
-import * as program from "commander";
+import program from "commander";
 import "dotenv/config";
 import { BasicAddonClass } from "./addons";
 import { createEngine } from "./engine";

packages/puppeteer/package-lock.json

@@ -1,9 +1,9 @@
 import { TranslatedText } from "@watchedcom/schema";
-import * as bodyParser from "body-parser";
-import * as express from "express";
+import bodyParser from "body-parser";
+import express from "express";
 import "express-async-errors";
-import * as morgan from "morgan";
-import * as path from "path";
+import morgan from "morgan";
+import path from "path";
 import "pug";
 import { BasicAddonClass } from "./addons";
 import { errorHandler } from "./error-handler";

packages/sdk/package-lock.json

@@ -18,3 +18,4 @@ export {
   replayRecordFile,
 } from "./utils/request-recorder";
 export { translateDeep } from "./utils/translate-deep";
+export { FetchAgent } from "./utils/fetch-agent";

packages/sdk/package.json

@@ -0,0 +1,55 @@
+import { Agent, ClientRequest, RequestOptions } from "agent-base";
+import * as net from "net";
+import { ActionHandlerContext } from "../";
+
+/**
+ * Experimental: can be used basically for GET or POST (with JSON payload)
+ * More complex requests can cause issues
+ */
+export class FetchAgent extends Agent {
+  constructor(private fetchFn: ActionHandlerContext["fetch"]) {
+    super();
+  }
+
+  async callback(
+    req: ClientRequest,
+    opts: RequestOptions
+  ): Promise<net.Socket> {
+    const fakeSocket = new net.Socket({ writable: false });
+    fakeSocket.readable = true;
+
+    const resp = await this.fetchFn((<any>opts).href, {
+      method: opts.method || "GET",
+      body: (<any>opts).body,
+      headers: (opts.headers || {}) as { [key: string]: string },
+    });
+
+    const headers = {
+      ...resp.headers.raw(),
+      "transfer-encoding": ["identity"],
+      "content-length": [undefined],
+    };
+
+    const responseHeadersLines = Object.keys(headers)
+      .filter((key) => headers[key][0])
+      .map((key) => {
+        return `${key}: ${headers[key][0]}`;
+      });
+
+    req.once("socket", async (s) => {
+      s.resume();
+
+      const headersPayload =
+        [`HTTP/1.1 ${resp.status}`, ...responseHeadersLines].join("\n") +
+        "\n\n";
+
+      const text = await resp.text();
+
+      fakeSocket.push(headersPayload);
+      fakeSocket.push(Buffer.from(text));
+      fakeSocket.push(null);
+    });
+
+    return fakeSocket;
+  }
+}

packages/sdk/src/cli.ts

@@ -1,7 +1,8 @@
 {
   "extends": "../../tsconfig.json",
   "compilerOptions": {
-    "outDir": "dist"
+    "outDir": "dist",
+    "esModuleInterop": true
   },
   "include": ["src/index.ts", "src/scripts/**/*.ts"]
 }