import { runIfMain, test } from "https://deno.land/std@v0.15.0/testing/mod.ts";import { defer, Deferred } from "./promises.ts";import { encode } from "https://deno.land/std@v0.15.0/strings/encode.ts";import { createAgent } from "./agent.ts";import { createRouter } from "./router.ts";import { assertEquals, assertThrows} from "https://deno.land/std@v0.15.0/testing/asserts.ts";import Reader = Deno.Reader;import Buffer = Deno.Buffer;import copy = Deno.copy;
async function readString(r: Reader) { const buf = new Buffer(); await copy(buf, r); return buf.toString();}
let _port = 8700;function setupRouter(port: number): Deferred { const d = defer(); const router = createRouter(); router.handle("/get", async req => { return req.respond({ status: 200, body: encode("ok") }); }); router.handle("/post", async req => { return req.respond({ status: 200, headers: req.headers, body: req.body }); }); router.listen(`:${port}`, { cancel: d.promise }); return d;}
test(async function agent() { setupRouter(++_port); const agent = createAgent(`http://127.0.0.1:${_port}`); try { { const res = await agent.send({ path: "/get", method: "GET" }); assertEquals(res.status, 200); assertEquals(await readString(res.body), "ok"); } { const res = await agent.send({ path: "/post", method: "POST", body: encode("denoland") }); assertEquals(res.status, 200); assertEquals(await readString(res.body), "denoland"); } } catch (e) { console.error(e); } finally { agent.conn.close(); }});
test(async function agentUnreadBody() { setupRouter(++_port); const agent = createAgent(`http://127.0.0.1:${_port}`); try { await agent.send({ path: "/get", method: "GET" }); await agent.send({ path: "/post", method: "POST", body: encode("ko") }); const { body } = await agent.send({ path: "/post", method: "POST", body: encode("denoland") }); assertEquals(await readString(body), "denoland"); } catch (e) { console.error(e); } finally { agent.conn.close(); }});
test(async function agentHttps() { assertThrows(() => { createAgent("https://127.0.0.1"); }); assertThrows(() => { createAgent("https://127.0.0.1:8888"); });});
test(async function agentInvalidScheme() { assertThrows(() => { createAgent("ftp://127.0.0.1"); });});
runIfMain(import.meta);