summaryrefslogtreecommitdiff
path: root/tools
diff options
context:
space:
mode:
Diffstat (limited to 'tools')
-rw-r--r--tools/deno_http_proxy.ts2
-rw-r--r--tools/deno_tcp_proxy.ts2
-rw-r--r--tools/node_http_proxy.js4
-rw-r--r--tools/node_tcp.js6
-rw-r--r--tools/node_tcp_promise.js4
-rw-r--r--tools/node_tcp_proxy.js20
6 files changed, 19 insertions, 19 deletions
diff --git a/tools/deno_http_proxy.ts b/tools/deno_http_proxy.ts
index 589a14338..6e5141377 100644
--- a/tools/deno_http_proxy.ts
+++ b/tools/deno_http_proxy.ts
@@ -9,7 +9,7 @@ async function proxyRequest(req: ServerRequest): Promise<void> {
const url = `http://${originAddr}${req.url}`;
const resp = await fetch(url, {
method: req.method,
- headers: req.headers
+ headers: req.headers,
});
req.respond(resp);
}
diff --git a/tools/deno_tcp_proxy.ts b/tools/deno_tcp_proxy.ts
index cd1bad247..43c61831c 100644
--- a/tools/deno_tcp_proxy.ts
+++ b/tools/deno_tcp_proxy.ts
@@ -10,7 +10,7 @@ const listener = Deno.listen({ hostname, port: Number(port) });
async function handle(conn: Deno.Conn): Promise<void> {
const origin = await Deno.connect({
hostname: originHostname,
- port: Number(originPort)
+ port: Number(originPort),
});
try {
await Promise.all([Deno.copy(conn, origin), Deno.copy(origin, conn)]);
diff --git a/tools/node_http_proxy.js b/tools/node_http_proxy.js
index d90cbe835..b984c484f 100644
--- a/tools/node_http_proxy.js
+++ b/tools/node_http_proxy.js
@@ -9,10 +9,10 @@ http
port: originPort,
path: req.url,
method: req.method,
- headers: req.headers
+ headers: req.headers,
};
- const proxy = http.request(options, proxyRes => {
+ const proxy = http.request(options, (proxyRes) => {
res.writeHead(proxyRes.statusCode, proxyRes.headers);
proxyRes.pipe(res, { end: true });
});
diff --git a/tools/node_tcp.js b/tools/node_tcp.js
index 3899a671a..7c6147dbf 100644
--- a/tools/node_tcp.js
+++ b/tools/node_tcp.js
@@ -8,11 +8,11 @@ const response = Buffer.from(
"HTTP/1.1 200 OK\r\nContent-Length: 12\r\n\r\nHello World\n"
);
-Server(socket => {
- socket.on("data", _ => {
+Server((socket) => {
+ socket.on("data", (_) => {
socket.write(response);
});
- socket.on("error", _ => {
+ socket.on("error", (_) => {
socket.destroy();
});
}).listen(port);
diff --git a/tools/node_tcp_promise.js b/tools/node_tcp_promise.js
index d522f1751..c59a9a7b4 100644
--- a/tools/node_tcp_promise.js
+++ b/tools/node_tcp_promise.js
@@ -15,8 +15,8 @@ function write(socket, buffer) {
return Promise.resolve(p);
}
-Server(async socket => {
- socket.on("error", _ => {
+Server(async (socket) => {
+ socket.on("error", (_) => {
socket.destroy();
});
for await (const _ of socket) {
diff --git a/tools/node_tcp_proxy.js b/tools/node_tcp_proxy.js
index 7dc1b2612..304ed0407 100644
--- a/tools/node_tcp_proxy.js
+++ b/tools/node_tcp_proxy.js
@@ -1,6 +1,6 @@
const net = require("net");
-process.on("uncaughtException", function(error) {
+process.on("uncaughtException", function (error) {
console.error(error);
});
@@ -14,46 +14,46 @@ const remoteport = process.argv[3];
const remotehost = "127.0.0.1";
-const server = net.createServer(function(localsocket) {
+const server = net.createServer(function (localsocket) {
const remotesocket = new net.Socket();
remotesocket.connect(remoteport, remotehost);
- localsocket.on("data", function(data) {
+ localsocket.on("data", function (data) {
const flushed = remotesocket.write(data);
if (!flushed) {
localsocket.pause();
}
});
- remotesocket.on("data", function(data) {
+ remotesocket.on("data", function (data) {
const flushed = localsocket.write(data);
if (!flushed) {
remotesocket.pause();
}
});
- localsocket.on("drain", function() {
+ localsocket.on("drain", function () {
remotesocket.resume();
});
- remotesocket.on("drain", function() {
+ remotesocket.on("drain", function () {
localsocket.resume();
});
- localsocket.on("close", function() {
+ localsocket.on("close", function () {
remotesocket.end();
});
- remotesocket.on("close", function() {
+ remotesocket.on("close", function () {
localsocket.end();
});
- localsocket.on("error", function() {
+ localsocket.on("error", function () {
localsocket.end();
});
- remotesocket.on("error", function() {
+ remotesocket.on("error", function () {
remotesocket.end();
});
});