Codex Agent
96 lines
3.0 KiB
JavaScript
96 lines
3.0 KiB
JavaScript
import assert from "node:assert/strict";
|
|
import { mkdtemp, rm, writeFile } from "node:fs/promises";
|
|
import { createServer } from "node:http";
|
|
import os from "node:os";
|
|
import path from "node:path";
|
|
import test from "node:test";
|
|
|
|
import { createCloudWebServer } from "./cloud-web-runtime.mjs";
|
|
|
|
test("cloud web auth requests are proxied once", async () => {
|
|
let upstreamRequests = 0;
|
|
const upstream = createServer((request, response) => {
|
|
upstreamRequests += 1;
|
|
request.resume();
|
|
response.writeHead(200, { "content-type": "application/json" });
|
|
response.end(JSON.stringify({ authenticated: true, path: request.url }));
|
|
});
|
|
await listen(upstream);
|
|
|
|
const cloudWeb = createCloudWebServer({
|
|
serviceId: "hwlab-cloud-web",
|
|
cloudApiBaseUrl: serverUrl(upstream),
|
|
cloudApiProxyTimeoutMs: 1000,
|
|
healthPayload: () => ({ status: "ok" }),
|
|
sendJson(response, statusCode, body) {
|
|
const payload = JSON.stringify(body);
|
|
response.writeHead(statusCode, {
|
|
"content-type": "application/json",
|
|
"content-length": Buffer.byteLength(payload)
|
|
});
|
|
response.end(payload);
|
|
}
|
|
});
|
|
await listen(cloudWeb);
|
|
|
|
try {
|
|
const response = await fetch(`${serverUrl(cloudWeb)}/auth/session`, {
|
|
headers: { cookie: "hwlab_session=token" }
|
|
});
|
|
assert.equal(response.status, 200);
|
|
assert.deepEqual(await response.json(), { authenticated: true, path: "/auth/session" });
|
|
assert.equal(upstreamRequests, 1);
|
|
} finally {
|
|
await close(cloudWeb);
|
|
await close(upstream);
|
|
}
|
|
});
|
|
|
|
test("cloud web serves access deep link through the React shell", async () => {
|
|
const root = await mkdtemp(path.join(os.tmpdir(), "hwlab-cloud-web-runtime-"));
|
|
await writeFile(path.join(root, "index.html"), "<div id=\"root\"></div>\n", "utf8");
|
|
const cloudWeb = createCloudWebServer({
|
|
serviceId: "hwlab-cloud-web",
|
|
roots: [root],
|
|
cloudApiBaseUrl: "http://127.0.0.1:1",
|
|
healthPayload: () => ({ status: "ok" }),
|
|
sendJson(response, statusCode, body) {
|
|
const payload = JSON.stringify(body);
|
|
response.writeHead(statusCode, {
|
|
"content-type": "application/json",
|
|
"content-length": Buffer.byteLength(payload)
|
|
});
|
|
response.end(payload);
|
|
}
|
|
});
|
|
await listen(cloudWeb);
|
|
|
|
try {
|
|
const response = await fetch(`${serverUrl(cloudWeb)}/access`);
|
|
assert.equal(response.status, 200);
|
|
assert.equal(response.headers.get("content-type"), "text/html; charset=utf-8");
|
|
assert.equal(await response.text(), "<div id=\"root\"></div>\n");
|
|
} finally {
|
|
await close(cloudWeb);
|
|
await rm(root, { recursive: true, force: true });
|
|
}
|
|
});
|
|
|
|
function listen(server) {
|
|
return new Promise((resolve, reject) => {
|
|
server.once("error", reject);
|
|
server.listen(0, "127.0.0.1", resolve);
|
|
});
|
|
}
|
|
|
|
function close(server) {
|
|
return new Promise((resolve, reject) => {
|
|
server.close((error) => (error ? reject(error) : resolve()));
|
|
});
|
|
}
|
|
|
|
function serverUrl(server) {
|
|
const address = server.address();
|
|
return `http://127.0.0.1:${address.port}`;
|
|
}
|