akanealw
99819b70ff
Some checks failed
Build and Push Docker Images (Trusted) / build-and-push (., docker/caddy/Dockerfile, caddy) (push) Has been cancelled
Build and Push Docker Images (Trusted) / build-and-push (., docker/l4-port-manager/Dockerfile, l4-port-manager) (push) Has been cancelled
Build and Push Docker Images (Trusted) / build-and-push (., docker/web/Dockerfile, web) (push) Has been cancelled
Tests / test (push) Has been cancelled
100 lines
3.3 KiB
TypeScript
Executable File
100 lines
3.3 KiB
TypeScript
Executable File
/**
|
|
* Low-level HTTP helper for functional tests.
|
|
*
|
|
* Sends requests directly to Caddy on port 80 using a custom Host header,
|
|
* bypassing DNS so test domains don't need to be resolvable.
|
|
*/
|
|
import http from 'node:http';
|
|
import type { Page } from '@playwright/test';
|
|
|
|
export interface HttpResponse {
|
|
status: number;
|
|
headers: Record<string, string | string[] | undefined>;
|
|
body: string;
|
|
}
|
|
|
|
/** Make an HTTP request to Caddy (localhost:80) with a custom Host header. */
|
|
export function httpGet(domain: string, path = '/', extraHeaders: Record<string, string> = {}): Promise<HttpResponse> {
|
|
return new Promise((resolve, reject) => {
|
|
const req = http.request(
|
|
{
|
|
hostname: '127.0.0.1',
|
|
port: 80,
|
|
path,
|
|
method: 'GET',
|
|
headers: { Host: domain, ...extraHeaders },
|
|
},
|
|
(res) => {
|
|
let body = '';
|
|
res.on('data', (chunk: Buffer) => { body += chunk.toString(); });
|
|
res.on('end', () =>
|
|
resolve({ status: res.statusCode!, headers: res.headers as HttpResponse['headers'], body })
|
|
);
|
|
}
|
|
);
|
|
req.on('error', reject);
|
|
req.end();
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Poll until the route responds with a status other than 502/503/504
|
|
* (which Caddy returns while the config reload is in-flight or the
|
|
* upstream hasn't been wired up yet).
|
|
*/
|
|
export async function waitForRoute(domain: string, timeoutMs = 15_000): Promise<void> {
|
|
const deadline = Date.now() + timeoutMs;
|
|
let lastStatus = 0;
|
|
while (Date.now() < deadline) {
|
|
try {
|
|
const res = await httpGet(domain);
|
|
lastStatus = res.status;
|
|
if (res.status !== 502 && res.status !== 503 && res.status !== 504) return;
|
|
} catch {
|
|
// Connection refused — Caddy not ready yet
|
|
}
|
|
await new Promise(r => setTimeout(r, 500));
|
|
}
|
|
throw new Error(`Route for "${domain}" not ready after ${timeoutMs}ms (last status: ${lastStatus})`);
|
|
}
|
|
|
|
/**
|
|
* Poll until the route returns a specific expected status code.
|
|
* Useful for forward auth routes where you expect 302 (redirect to portal).
|
|
*/
|
|
export async function waitForStatus(domain: string, expectedStatus: number, timeoutMs = 20_000): Promise<void> {
|
|
const deadline = Date.now() + timeoutMs;
|
|
let lastStatus = 0;
|
|
while (Date.now() < deadline) {
|
|
try {
|
|
const res = await httpGet(domain);
|
|
lastStatus = res.status;
|
|
if (res.status === expectedStatus) return;
|
|
} catch {
|
|
// Connection refused — not ready yet
|
|
}
|
|
await new Promise(r => setTimeout(r, 500));
|
|
}
|
|
throw new Error(`Route for "${domain}" did not return ${expectedStatus} after ${timeoutMs}ms (last status: ${lastStatus})`);
|
|
}
|
|
|
|
/** Inject hidden form fields into #create-host-form before submitting. */
|
|
export async function injectFormFields(page: Page, fields: Record<string, string>): Promise<void> {
|
|
await page.evaluate((f) => {
|
|
const form = document.getElementById('create-host-form');
|
|
if (!form) throw new Error('create-host-form not found');
|
|
for (const [name, value] of Object.entries(f)) {
|
|
const existing = form.querySelector<HTMLInputElement>(`input[name="${name}"]`);
|
|
if (existing) {
|
|
existing.value = value;
|
|
} else {
|
|
const input = document.createElement('input');
|
|
input.type = 'hidden';
|
|
input.name = name;
|
|
input.value = value;
|
|
form.appendChild(input);
|
|
}
|
|
}
|
|
}, fields);
|
|
}
|