app.ts

1import type { Database } from "bun:sqlite";2import { join } from "node:path";3import { Hono } from "hono";4import { bodyLimit } from "hono/body-limit";5import { secureHeaders } from "hono/secure-headers";6import { registerStatus } from "../admin/console.ts";7import { registerIssues } from "../admin/issues.ts";8import { registerReleases } from "../admin/releases.ts";9import { registerRepos } from "../admin/repos.ts";10import { registerSite } from "../admin/site.ts";11import { registerRepoText } from "../admin/text.ts";12import { openBucket } from "../bucket/reader.ts";13import { isSafePath } from "../bucket/repo.ts";14import { registerIssuePages } from "../issues/pages.ts";15import { registerKohRemote } from "../mirror/remote.ts";16import { registerArchivesPage } from "../pages/archives.ts";17import { registerDocsPages } from "../pages/docs.ts";18import { registerFileRoutes } from "../pages/files.ts";19import { registerFrontPages } from "../pages/front.ts";20import { registerHousekeeping } from "../pages/housekeeping.ts";21import { registerKepr2Routes } from "../pages/kepr2.ts";22import { registerProfilePage } from "../pages/profile.ts";23import { registerReleasesPage } from "../pages/releases.ts";24import { registerRepoPage } from "../pages/repo.ts";25import { registerSavePage } from "../pages/save.ts";26import { registerReleaseRoutes } from "../releases/routes.ts";27import { registerTarballRoutes } from "../tarball/archive.ts";28import type { Config } from "./config.ts";29import { connectKeys, noCode, registerConnect } from "./connect.ts";30import { registerLogin } from "./login.ts";3132const MAX_BODY_BYTES = 64 * 1024;33// §25's cap, except for the operator's picture and video uploads, which only a session reaches.34const MAX_MEDIA_BYTES = 64 * 1024 * 1024;35const MEDIA_UPLOAD = /^\/admin\/repos\/[^/]+\/media$/;36const PUBLIC_DIR = join(import.meta.dir, "../../public");37// §18 allows Bunny Fonts: its stylesheet and the font files it points at.38const FONTS = "https://fonts.bunny.net";3940/** The Hono app with §25's headers and body cap, and every route built so far. */41export function createApp(config: Config, kepr: Database): Hono {42	const app = new Hono();43	// §25 allows images from the presigned host, which is the bucket endpoint's origin; uploaded44	// videos come from there too.45	const imgSrc =46		config.bucket.kind === "s3" ? ["'self'", new URL(config.bucket.endpoint).origin] : ["'self'"];47	app.use("*", async (c, next) => {48		await next();49		const path = c.req.path;50		if (/^\/[^/]+\/raw\/.+/.test(path) || path.startsWith("/static/assets/")) {51			const policy = c.res.headers.get("Content-Security-Policy");52			c.header("Content-Security-Policy", policy ? `${policy}; sandbox` : "sandbox");53		}54	});55	app.use(56		secureHeaders({57			contentSecurityPolicy: {58				defaultSrc: ["'self'"],59				scriptSrc: ["'self'"],60				styleSrc: ["'self'", FONTS],61				fontSrc: [FONTS],62				imgSrc,63				mediaSrc: imgSrc,64				objectSrc: ["'none'"],65				baseUri: ["'none'"],66				formAction: ["'self'"],67				frameAncestors: ["'none'"],68			},69			xFrameOptions: "DENY",70		}),71	);72	const limit = (maxSize: number) =>73		bodyLimit({74			maxSize,75			onError: (c) =>76				// An oversized redemption is one more failed redemption — but only where the route77				// exists: without write keys it is an unknown path and answers as one.78				c.req.path === "/api/connect" && connectKeys(config)79					? noCode(c)80					: c.text("Request body too large", 413),81		});82	const [small, large] = [limit(MAX_BODY_BYTES), limit(MAX_MEDIA_BYTES)];83	app.use((c, next) => (MEDIA_UPLOAD.test(c.req.path) ? large : small)(c, next));84	// `/static/assets/` is the operator's uploads in `data/assets/` (§19), such as the signature.85	const assetsDir = join(config.dataDir, "assets");86	app.get("/static/:path{.+}", async (c, next) => {87		const path = c.req.param("path");88		if (!isSafePath(path)) return c.notFound();89		// A repo's uploads have their own route: as private as the repo (§20), and Range for video.90		if (path.startsWith("assets/media/")) return next();91		const file = Bun.file(92			path.startsWith("assets/") ? join(assetsDir, path.slice(7)) : join(PUBLIC_DIR, path),93		);94		if (!(await file.exists())) return c.notFound();95		c.header("Cache-Control", "public, max-age=3600");96		return c.body(await file.bytes(), 200, { "Content-Type": file.type });97	});98	const ctx = { domain: config.domain, kepr, mirrorDir: join(config.dataDir, "mirror") };99	const bucket = openBucket(config.bucket);100	// Before every other route, so the admin guard runs ahead of each `/admin` handler.101	registerLogin(app, ctx, config.adminPasswordHash);102	registerConnect(app, config, ctx);103	const admin = {104		...ctx,105		canConnect: connectKeys(config) !== null,106		dataDir: config.dataDir,107		sync: { bucket, kepr, mirrorDir: ctx.mirrorDir, tarballDir: join(config.dataDir, "tarballs") },108	};109	registerStatus(app, admin);110	registerRepos(app, admin);111	registerIssues(app, admin);112	registerReleases(app, admin);113	registerSite(app, admin);114	registerRepoText(app, admin);115	registerHousekeeping(app, ctx);116	registerFrontPages(app, ctx);117	registerDocsPages(app, ctx);118	registerProfilePage(app, ctx);119	registerKepr2Routes(app, ctx);120	registerRepoPage(app, ctx);121	registerFileRoutes(app, ctx);122	registerSavePage(app, ctx);123	registerKohRemote(app, ctx);124	registerArchivesPage(app, ctx);125	registerReleasesPage(app, ctx);126	registerIssuePages(app, ctx);127	registerTarballRoutes(app, ctx, join(config.dataDir, "tarballs"));128	registerReleaseRoutes(app, ctx, bucket);129	return app;130}