import { ValTown } from "npm:@valtown/sdk"; import { Hono } from "npm:hono"; import { logger } from "npm:hono/logger"; type WebdavOptions = { token?: string; }; export function serveVals( req: Request, options?: WebdavOptions, ): Response | Promise { const app = new Hono(); const vt = new ValTown({ bearerToken: options?.token, }); app.use(logger()); app.on("PROPFIND", "/", async () => { try { const me = await vt.me.profile.retrieve(); const vals: ValTown.BasicVal[] = []; while (true) { const { data, links } = await vt.users.vals.list(me.id, { offset: vals.length, limit: 100, }); vals.push(...data); if (!links.next) { break; } } const body = ` ${ vals.map((val) => ` ${xmlEscape(val.name + ".tsx")} ${xmlEscape(val.name + ".tsx")} ${val.code ? getByteLength(val.code) : 0} text/plain ${val.createdAt} HTTP/1.1 200 OK `).join("") } `; return new Response(body, { status: 207, headers: { "content-type": "application/xml", }, }); } catch (error) { return new Response( `Internal Server Error: ${xmlEscape(error.message)}`, { status: 500, headers: { "content-type": "text/plain", }, }, ); } }); app.on("PROPFIND", "/:val", async (c) => { const valName = c.req.param("val").slice(0, -4); const me = await vt.me.profile.retrieve(); if (!me.username) { return c.text("You must set a username to use this feature", 400); } try { const val = await vt.alias.username.valName.retrieve( me.username, valName, ); const body = ` ${xmlEscape(val.name + ".tsx")} ${xmlEscape(val.name + ".tsx")} ${val.code ? getByteLength(val.code) : 0} text/plain ${val.createdAt} HTTP/1.1 200 OK `; return c.text(body, 207); } catch (_) { return c.text("Not Found", 404); } }); app.get("/:val", async (c) => { const valName = c.req.param("val").slice(0, -4); const me = await vt.me.profile.retrieve(); if (!me.username) { return c.text("You must set a username to use this feature", 400); } const val = await vt.alias.username.valName.retrieve( me.username, valName, ); if (!val) { return c.text("Not Found", 404); } return c.text(val.code || "", 200, { "Content-Type": "text/tsx" }); }); app.put("/:val", async (c) => { const valName = c.req.param("val").slice(0, -4); const me = await vt.me.profile.retrieve(); if (!me.username) { return c.text("You must set a username to use this feature", 400); } try { const val = await vt.alias.username.valName.retrieve( me.username, valName, ); // val exists, update it await vt.vals.versions.create(val.id, { code: await c.req.text(), }); return c.text("OK", 201); } catch (_) { // val does not exist, create it try { await vt.vals.create({ name: valName, code: await c.req.text() || "\n", }); return c.text("OK", 201); } catch (error) { console.error(error); } } }); app.delete("/:val", async (c) => { const valName = c.req.param("val").slice(0, -4); const me = await vt.me.profile.retrieve(); if (!me.username) { return c.text("You must set a username to use this feature", 400); } const val = await vt.alias.username.valName.retrieve( me.username, valName, ); if (!val) { return c.text("Not Found", 404); } await vt.vals.delete(val.id); return c.text("OK", 200); }); app.on("MOVE", "/:val", async (c) => { const srcValName = c.req.param("val").slice(0, -4); const dstValName = c.req.header("Destination")?.split("/").pop() ?.slice(0, -4); if (!dstValName) { return c.text("Bad Request", 400); } const me = await vt.me.profile.retrieve(); if (!me.username) { return c.text("You must set a username to use this feature", 400); } const srcVal = await vt.alias.username.valName.retrieve( me.username, srcValName, ); try { const dstVal = await vt.alias.username.valName.retrieve( me.username, dstValName, ); await vt.vals.versions.create(dstVal.id, { code: srcVal.code || "\n", }); await vt.vals.delete(srcVal.id); return c.text("OK", 201); } catch (_) { // val not found, create it await vt.vals.create({ code: srcVal.code || "\n", name: dstValName, }); await vt.vals.delete(srcVal.id); return c.text("OK", 201); } }); app.on("COPY", "/:val", async (c) => { const srcValName = c.req.param("val").slice(0, -4); const dstValName = c.req.header("Destination")?.split("/").pop() ?.slice(0, -4); if (!dstValName) { return c.text("Bad Request", 400); } const me = await vt.me.profile.retrieve(); if (!me.username) { return c.text("You must set a username to use this feature", 400); } const srcVal = await vt.alias.username.valName.retrieve( me.username, srcValName, ); try { const dstVal = await vt.alias.username.valName.retrieve( me.username, dstValName, ); await vt.vals.versions.create(dstVal.id, { code: srcVal.code || "", }); return c.text("OK", 201); } catch (_) { // val not found, create it await vt.vals.create({ code: srcVal.code || "", name: dstValName, }); return c.text("OK", 201); } }); app.on("LOCK", "/:val", (c) => { return c.text("Method Not Allowed", 405); }); app.on("UNLOCK", "/:val", (c) => { return c.text("Method Not Allowed", 405); }); app.on("PROPPATCH", "/:val", (c) => { return c.text("Method Not Allowed", 405); }); app.options("/", () => { const headers = new Headers(); headers.set( "Allow", "OPTIONS, GET, HEAD, POST, PUT, DELETE, TRACE, COPY, MOVE, PROPFIND, PROPPATCH, LOCK, UNLOCK", ); headers.set("DAV", "1, 2"); // Indicate WebDAV level 1 and 2 support return new Response(null, { status: 204, headers, }); }); return app.fetch(req); } const xmlEscape = (str: string): string => { return str.replace(/&/g, "&") .replace(//g, ">") .replace(/"/g, """) .replace(/'/g, "'"); }; const getByteLength = (str: string): number => new TextEncoder().encode(str).length;

webdavServer