// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license. import { serve, ServerRequest } from "../../std/http/server.ts"; import { assertEquals } from "../../std/testing/asserts.ts"; const addr = Deno.args[1] || "127.0.0.1:4555"; async function proxyServer(): Promise { const server = serve(addr); console.log(`Proxy server listening on http://${addr}/`); for await (const req of server) { proxyRequest(req); } } async function proxyRequest(req: ServerRequest): Promise { console.log(`Proxy request to: ${req.url}`); const resp = await fetch(req.url, { method: req.method, headers: req.headers, }); req.respond({ status: resp.status, body: new Uint8Array(await resp.arrayBuffer()), headers: resp.headers, }); } async function testFetch(): Promise { const c = Deno.run({ cmd: [ Deno.execPath(), "run", "--quiet", "--reload", "--allow-net", "045_proxy_client.ts", ], stdout: "piped", env: { HTTP_PROXY: `http://${addr}`, }, }); const status = await c.status(); assertEquals(status.code, 0); c.close(); } async function testModuleDownload(): Promise { const http = Deno.run({ cmd: [ Deno.execPath(), "cache", "--reload", "--quiet", "http://localhost:4545/std/examples/colors.ts", ], stdout: "piped", env: { HTTP_PROXY: `http://${addr}`, }, }); const httpStatus = await http.status(); assertEquals(httpStatus.code, 0); http.close(); } async function testFetchNoProxy(): Promise { const c = Deno.run({ cmd: [ Deno.execPath(), "run", "--quiet", "--reload", "--allow-net", "045_proxy_client.ts", ], stdout: "piped", env: { HTTP_PROXY: "http://not.exising.proxy.server", NO_PROXY: "localhost", }, }); const status = await c.status(); assertEquals(status.code, 0); c.close(); } async function testModuleDownloadNoProxy(): Promise { const http = Deno.run({ cmd: [ Deno.execPath(), "cache", "--reload", "--quiet", "http://localhost:4545/std/examples/colors.ts", ], stdout: "piped", env: { HTTP_PROXY: "http://not.exising.proxy.server", NO_PROXY: "localhost", }, }); const httpStatus = await http.status(); assertEquals(httpStatus.code, 0); http.close(); } proxyServer(); await testFetch(); await testModuleDownload(); await testFetchNoProxy(); await testModuleDownloadNoProxy(); Deno.exit(0);