diff options
Diffstat (limited to 'tools')
-rw-r--r-- | tools/deno_http_proxy.ts | 2 | ||||
-rw-r--r-- | tools/deno_tcp_proxy.ts | 2 | ||||
-rw-r--r-- | tools/node_http_proxy.js | 4 | ||||
-rw-r--r-- | tools/node_tcp.js | 6 | ||||
-rw-r--r-- | tools/node_tcp_promise.js | 4 | ||||
-rw-r--r-- | tools/node_tcp_proxy.js | 20 |
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(); }); }); |