convert examples to typescript, extract out classes

convert examples to typescript, extract out classes

tsconfig

Author: jonluca

examples/forwardHttps.js

@@ -0,0 +1,64 @@
+const port = 8081;
+import net from "net";
+import assert from "assert";
+import Proxy from "../";
+const proxy = new Proxy();
+import { exec } from "child_process";
+
+proxy.onConnect((req, socket, head) => {
+  const host = req.url.split(":")[0];
+  const port = req.url.split(":")[1];
+
+  console.log("Tunnel to", req.url);
+  const conn = net.connect(
+    {
+      port,
+      host,
+      allowHalfOpen: true,
+    },
+    () => {
+      conn.on("finish", () => {
+        socket.destroy();
+      });
+      socket.on("close", () => {
+        conn.end();
+      });
+      socket.write("HTTP/1.1 200 OK\r\n\r\n", "UTF-8", () => {
+        conn.pipe(socket);
+        socket.pipe(conn);
+      });
+    }
+  );
+
+  conn.on("error", (err) => {
+    filterSocketConnReset(err, "PROXY_TO_SERVER_SOCKET");
+  });
+  socket.on("error", (err) => {
+    filterSocketConnReset(err, "CLIENT_TO_PROXY_SOCKET");
+  });
+});
+
+// Since node 0.9.9, ECONNRESET on sockets are no longer hidden
+function filterSocketConnReset(err, socketDescription) {
+  if (err.errno === "ECONNRESET") {
+    console.log(`Got ECONNRESET on ${socketDescription}, ignoring.`);
+  } else {
+    console.log(`Got unexpected error on ${socketDescription}`, err);
+  }
+}
+
+proxy.listen({ port }, () => {
+  console.log(`Proxy server listening on ${port}`);
+
+  const cmd = `curl -x http://localhost:${port} https://github.com/ | grep html`;
+  console.log(`> ${cmd}`);
+  exec(cmd, (error, stdout, stderr) => {
+    if (error) {
+      console.error(`exec error: ${error}`);
+      return;
+    }
+    console.log(`${stdout}`);
+    assert(/DOCTYPE/.test(stdout));
+    proxy.close();
+  });
+});

examples/forwardHttps.ts

@@ -0,0 +1,54 @@
+const port = 8081;
+
+import Proxy from "../";
+const proxy = new Proxy();
+
+proxy.onError((ctx, err, errorKind) => {
+  // ctx may be null
+  const url = ctx?.clientToProxyRequest?.url || "";
+  console.error(`${errorKind} on ${url}:`, err);
+});
+
+proxy.onRequest((ctx, callback) => {
+  //console.log('REQUEST: http://' + ctx.clientToProxyRequest.headers.host + ctx.clientToProxyRequest.url);
+  if (
+    ctx.clientToProxyRequest.headers.host == "www.google.com" &&
+    ctx.clientToProxyRequest.url.indexOf("/search") == 0
+  ) {
+    ctx.use(Proxy.gunzip);
+
+    ctx.onResponseData((ctx, chunk, callback) => {
+      chunk = new Buffer(
+        chunk.toString().replace(/<h3.*?<\/h3>/g, "<h3>Pwned!</h3>")
+      );
+      return callback(null, chunk);
+    });
+  }
+  return callback();
+});
+
+proxy.onRequestData(
+  (
+    ctx,
+    chunk,
+    callback //console.log('request data length: ' + chunk.length);
+  ) => callback(null, chunk)
+);
+
+proxy.onResponse(
+  (
+    ctx,
+    callback //console.log('RESPONSE: http://' + ctx.clientToProxyRequest.headers.host + ctx.clientToProxyRequest.url);
+  ) => callback(null)
+);
+
+proxy.onResponseData(
+  (
+    ctx,
+    chunk,
+    callback //console.log('response data length: ' + chunk.length);
+  ) => callback(null, chunk)
+);
+
+proxy.listen({ port });
+console.log(`listening on ${port}`);

examples/modifyGoogle.js

@@ -0,0 +1,26 @@
+const port = 8081;
+import Proxy from "../";
+const proxy = new Proxy();
+
+proxy.onError((ctx, err, errorKind) => {
+  // ctx may be null
+  const url = ctx?.clientToProxyRequest?.url || "";
+  console.error(`${errorKind} on ${url}:`, err);
+});
+
+proxy.onCertificateMissing = (ctx, files, callback) => {
+  console.log('Looking for "%s" certificates', ctx.hostname);
+  console.log('"%s" missing', ctx.files.keyFile);
+  console.log('"%s" missing', ctx.files.certFile);
+
+  // Here you have the last chance to provide certificate files data
+  // A tipical use case would be creating them on the fly
+  //
+  // return callback(null, {
+  //   key: keyFileData,
+  //   cert: certFileData
+  // });
+};
+
+proxy.listen({ port });
+console.log(`listening on ${port}`);

examples/modifyGoogle.ts

@@ -0,0 +1,20 @@
+const port = 8081;
+import path from "path";
+import Proxy from "../";
+const proxy = new Proxy();
+
+proxy.onError((ctx, err, errorKind) => {
+  // ctx may be null
+  const url = ctx?.clientToProxyRequest?.url || "";
+
+  console.error(`${errorKind} on ${url}:`, err);
+});
+
+proxy.onCertificateRequired = (hostname, callback) =>
+  callback(null, {
+    keyFile: path.resolve("/ca/certs/", `${hostname}.key`),
+    certFile: path.resolve("/ca/certs/", `${hostname}.crt`),
+  });
+
+proxy.listen({ port });
+console.log(`listening on ${port}`);

examples/onCertificateMissing.js

@@ -0,0 +1,19 @@
+const port = 8081;
+
+import Proxy from "../";
+const proxy = new Proxy();
+
+proxy.onError((ctx, err, errorKind) => {
+  // ctx may be null
+  const url = ctx?.clientToProxyRequest?.url || "";
+
+  console.error(`${errorKind} on ${url}:`, err);
+});
+
+proxy.onRequest((ctx, callback) => {
+  ctx.proxyToClientResponse.end("Hacked, you cannot proceed to the website");
+  // no callback() so proxy request is not sent to the server
+});
+
+proxy.listen({ port });
+console.log(`listening on ${port}`);