${escape(e.name)}
${escape(e.stack ?? e.message)}
`, { status: 500, headers: { 'Content-Type': 'text/html' } });
}
return Response.json(
{ error: e },
{ status: 500, headers: { 'Content-Type': 'application/json' } },
);
}
const payload = JSON.parse(Deno.args[0]);
if (!payload || !payload.command) {
console.error("Invalid input.");
Deno.exit(1);
}
if (payload.command === "fetch") {
Deno.serve(
{
port: parseInt(payload.port),
onListen: () => {
// This line will signal that the server is ready to the go
console.error("READY");
},
},
async (req) => {
try {
const mod = await import(payload.entrypoint);
if (!mod.default) {
return new Response("The app does not provide a default export.", { status: 500 });
}
if (typeof mod.default !== "object") {
return new Response("The app default export must be an object.", { status: 500 });
}
if (
!("fetch" in mod.default) ||
typeof mod.default.fetch !== "function"
) {
return new Response("The app default export does not have a fetch method.", { status: 500 });
}
const handler = mod.default.fetch;
// Websocket requests are stateful and should be handled differently
if (req.headers.get("upgrade") === "websocket") {
const resp = await handler(req);
if (!(resp instanceof Response)) {
return new Response("Fetch handler must return a Response object.", { status: 500 });
}
return resp;
}
const url = new URL(req.url);
const proto = req.headers.get("x-forwarded-proto");
const host = req.headers.get("x-forwarded-host");
const resp = await handler(new Request(`${proto}://${host}${url.pathname}${url.search}`, {
method: req.method,
headers: req.headers,
body: req.body,
}));
if (!(resp instanceof Response)) {
throw new Error("Fetch handler must return a Response object.");
}
return resp;
} catch (e) {
return respondWithError(req, e as Error);
}
},
);
} else if (payload.command === "run") {
const mod = await import(payload.entrypoint);
if (!mod.default || typeof mod.default !== "object") {
console.error(
"The mod does not provide an object as it's default export.",
);
Deno.exit(1);
}
const handler = mod.default;
if (!("run" in handler)) {
console.error("The mod default export does not have a run function.");
Deno.exit(1);
}
if (!(typeof handler.run === "function")) {
console.error("The mod default export run property must be a function.");
Deno.exit(1);
}
await handler.run(payload.args);
} else if (payload.command === "email") {
const mod = await import(payload.entrypoint);
if (!mod.default || typeof mod.default !== "object") {
console.error(
"The mod does not provide an object as it's default export.",
);
Deno.exit(1);
}
const handler = mod.default;
if (!("email" in handler)) {
console.error("The mod default export does not have a email function.");
Deno.exit(1);
}
const data = decodeBase64(payload.msg)
const blob = new Blob([data]);
await handler.email(blob.stream());
} else {
console.error("Unknown command: ", payload.command);
Deno.exit(1);
}