1import type { Context, Hono } from "hono";2import { BucketWriteError } from "../bucket/reader.ts";3import { syncAll } from "../bucket/sync.ts";4import { MAX_CHARS } from "../issues/spam.ts";5import { operatorIssues } from "../issues/store.ts";6import { languageLines, repoStats } from "../mirror/queries.ts";7import { openMirror, quarantinedPaths } from "../mirror/store.ts";8import { html } from "../pages/html.ts";9import { formatDate, plural } from "../pages/layout.ts";10import {11 deleteRelease,12 type OperatorRelease,13 operatorReleases,14 setRelease,15 visibleReleases,16} from "../releases/releases.ts";17import { type RepoText, repoText, setRepoText } from "../server/db.ts";18import { type AdminContext, adminPage, formField, notice, textFields } from "./console.ts";19import { type AdminRepo, allRepos, findRepo, type RepoEdit, updateRepo } from "./store.ts";20import { LIMITS } from "./text.ts";2122const MAX_FIELD = 500;23const HTTP_URL = /^https?:\/\/[^\s]+$/i;24const MAX_LANGUAGES = 5;25const MAX_LANGUAGE = 30;262728function languageNames(value: string): string[] {29 return value30 .split(",")31 .map((name) => name.trim())32 .filter((name) => name !== "");33}343536export function registerRepos(app: Hono, ctx: AdminContext): void {37 app.get("/admin/repos", (c) => c.html(reposPage(c, ctx, "")));3839 app.post("/admin/sync", async (c) => {40 await syncAll(ctx.sync);41 return c.redirect("/admin/repos", 303);42 });4344 app.post("/admin/repos/:repo", async (c) => {45 const repo = findRepo(ctx.kepr, c.req.param("repo"));46 if (!repo) return c.notFound();47 const fields = await textFields(c);48 const text = (name: string) => (fields[name] ?? "").trim();49 const languages = languageNames(fields.languages ?? "");50 const edit: RepoEdit = {51 public: fields.public === "1" ? 1 : 0,52 category: text("category"),53 homepage: text("homepage"),54 55 languages: languages.join(", "),56 issues_paused: fields.issues_paused === "1" ? 1 : 0,57 };58 const refuse = (error: string) =>59 c.html(reposPage(c, ctx, `${repo.name}: ${error}`, repo.name), 400);60 const texts = (["description", "details"] as const).map((field): [RepoText, string] => [61 field,62 (fields[field] ?? "").replace(/\r\n/g, "\n").trim(),63 ]);64 const long = texts.find(([field, value]) => value.length > LIMITS[field]);65 if (long) {66 const [field] = long;67 return refuse(`Keep the ${field} under ${LIMITS[field].toLocaleString("en-US")} characters.`);68 }69 if ([edit.category, edit.homepage, fields.languages ?? ""].some((v) => v.length > MAX_FIELD)) {70 return refuse(`keep each field under ${MAX_FIELD} characters.`);71 }72 if (edit.homepage !== "" && !HTTP_URL.test(edit.homepage)) {73 return refuse("the homepage must be an http or https address.");74 }75 if (languages.length > MAX_LANGUAGES) return refuse("up to five languages.");76 if (languages.some((name) => name.length > MAX_LANGUAGE)) {77 return refuse(`a language name is at most ${MAX_LANGUAGE} characters.`);78 }79 if (languages.some((name) => /\p{C}/u.test(name))) {80 return refuse("a language name is printable text.");81 }82 updateRepo(ctx.kepr, repo.name, edit);83 for (const [field, value] of texts) setRepoText(ctx.kepr, repo.name, field, value);84 return c.redirect(`/admin/repos?repo=${repo.name}&saved=1#repo-editor`, 303);85 });8687 88 app.post("/admin/releases/:repo/:version", async (c) => {89 const found = findRelease(ctx, c.req.param("repo"), c.req.param("version"));90 if (!found) return c.notFound();91 const { repo, release } = found;92 const fields = await textFields(c);93 const notes = (fields.notes ?? "").replace(/\r\n/g, "\n");94 if (notes.length > MAX_CHARS) {95 const limit = MAX_CHARS.toLocaleString("en-US");96 const error = `${repo.name} ${release.version}: notes are over ${limit} characters.`;97 return c.html(reposPage(c, ctx, error, repo.name), 400);98 }99 100 const override = notes === release.recordNotes ? null : notes;101 setRelease(ctx.kepr, repo.name, release.version, fields.hidden === "1", override);102 return c.redirect(103 `/admin/repos?repo=${repo.name}&saved=1#${repo.name}-${release.version}`,104 303,105 );106 });107108 app.post("/admin/releases/:repo/:version/delete", async (c) => {109 const found = findRelease(ctx, c.req.param("repo"), c.req.param("version"));110 if (!found) return c.notFound();111 const { repo, mirror, release } = found;112 const refuse = (status: 400 | 503, error: string) =>113 c.html(reposPage(c, ctx, `${repo.name} ${release.version}: ${error}`, repo.name), status);114 if ((await textFields(c)).confirm !== "1") return refuse(400, "tick the box to delete it.");115 try {116 await deleteRelease(ctx.sync.bucket, ctx.kepr, mirror, repo.name, release.version);117 } catch (error) {118 if (error instanceof BucketWriteError) return refuse(503, error.message);119 throw error;120 }121 return c.redirect(`/admin/repos?repo=${repo.name}&saved=1#builds`, 303);122 });123}124125126function findRelease(ctx: AdminContext, name: string, version: string) {127 const repo = findRepo(ctx.kepr, name);128 const mirror = repo && openMirror(ctx.mirrorDir, repo.name);129 const release =130 repo &&131 mirror &&132 operatorReleases(ctx.kepr, mirror, repo.name).find((r) => r.version === version);133 return repo && mirror && release ? { repo, mirror, release } : null;134}135136function reposPage(c: Context, ctx: AdminContext, error: string, chosen = c.req.query("repo")) {137 const repos = allRepos(ctx.kepr);138 const selected = repos.find((repo) => repo.name === chosen) ?? repos[0];139 const body = html`${notice(error)}140<p class="admin-intro">Choose a repository to manage its visibility and public page.</p>141<form method="post" action="/admin/sync">142${formField(c)}<button class="issues-submit" type="submit">sync now</button></form>143${repos.length === 0 && html`<p class="muted mono save-empty">no repos found in the bucket yet</p>`}144<div class="admin-repos">145<nav aria-label="repositories">146${repos.map(147 (repo) => html`<a class="issue-row" id="repo-${repo.name}"148href="/admin/repos?repo=${repo.name}#repo-editor"${selected?.name === repo.name ? html` aria-current="page"` : ""}>149<span>${repo.name}</span><span>${repo.public ? "public" : "private"}</span>150<span class="issue-meta mono">${repo.last_sync_at === null ? "never synced" : `last sync ${formatDate(repo.last_sync_at)} UTC`}</span>151${repo.last_sync_error && html`<span class="issues-error">${repo.last_sync_error}</span>`}</a>`,152)}153</nav>154${selected && repoForm(c, ctx, selected)}155</div>`;156 return adminPage(c, ctx, "repos", body);157}158159160function workspace(ctx: AdminContext, repo: AdminRepo) {161 const mirror = openMirror(ctx.mirrorDir, repo.name);162 const stats = repoStats(mirror);163 const releases = operatorReleases(ctx.kepr, mirror, repo.name);164 const downloads = (release: (typeof releases)[number]) =>165 release.downloads.reduce((sum, [, count]) => sum + count, 0);166 const open = operatorIssues(ctx.kepr, "open").filter((issue) => issue.repo === repo.name);167 const vital = (label: string, value: string | number) =>168 html`<div><strong>${String(value)}</strong><span class="mono">${label}</span></div>`;169 return html`<div class="admin-vitals">170${vital("saves", stats.saves)}171${vital("lines", stats.lines)}172${vital("newest version", visibleReleases(ctx.kepr, mirror, repo.name)[0]?.version ?? "none")}173${vital("open issues", open.length)}174${vital(175 "downloads",176 releases.reduce((sum, release) => sum + downloads(release), 0),177)}178</div>179<p class="issue-meta mono">detected languages:180${languageLines(mirror).map(181 ([language, lines], i) =>182 html`${i > 0 ? " · " : " "}${language} <span class="muted">${plural(lines, "line")}</span>`,183)}</p>184`;185}186187function repoForm(c: Context, ctx: AdminContext, repo: AdminRepo) {188 const quarantined = quarantinedPaths(openMirror(ctx.mirrorDir, repo.name));189 const own = repoText(ctx.kepr, repo.name);190 const releases = operatorReleases(ctx.kepr, openMirror(ctx.mirrorDir, repo.name), repo.name);191 const input = (name: keyof RepoEdit, label: string) =>192 html`<label class="issues-label" for="${repo.name}-${name}">${label}</label>193<input class="issues-input" id="${repo.name}-${name}" name="${name}" maxlength="${MAX_FIELD}" value="${String(repo[name])}">`;194 const synced =195 repo.last_sync_at === null ? "never synced" : `last sync ${formatDate(repo.last_sync_at)} UTC`;196 return html`<article class="issue-post" id="repo-editor">197<p class="issue-post-head mono">198<span class="issue-author">199${repo.public ? html`<a href="/${repo.name}">${repo.name}</a>` : repo.name}</span>200<span>${repo.public ? "public" : "private"}</span><span class="history-when">${synced}</span></p>201${workspace(ctx, repo)}202${203 repo.last_sync_error && html`<p class="issues-error mono">sync error: ${repo.last_sync_error}</p>`204}205${206 quarantined.length > 0 &&207 html`<p class="issues-error mono">${plural(quarantined.length, "path")} quarantined: ${quarantined.join(", ")}</p>`208}209<form class="issues-form" method="post" action="/admin/repos/${repo.name}">210${formField(c)}211<label class="issues-label">212<input type="checkbox" name="public" value="1"${repo.public ? html` checked` : ""}> public</label>213<label class="issues-label">214<input type="checkbox" name="issues_paused" value="1"${repo.issues_paused ? html` checked` : ""}>215pause new issues</label>216${input("category", "category")}217${input("homepage", "homepage")}218${input("languages", "shown languages")}219<p class="issue-meta mono">Up to five, separated by commas. Leave blank to show the detected one.</p>220${textArea(repo.name, "description", "description", 3, own.description)}221${textArea(repo.name, "details", "details", 12, own.details)}222<p class="issue-meta mono">Markdown. Leave either blank to use the README's.</p>223<button class="issues-submit" type="submit">save ${repo.name}</button>224</form>225${226 releases.length > 0 &&227 html`<section class="repo-section" id="builds"><h2 class="section-label mono">builds</h2>228${releases.map((release) => releaseForm(c, repo.name, release))}</section>`229}230</article>`;231}232233function textArea(repo: string, name: RepoText, label: string, rows: number, value: string) {234 return html`<label class="issues-label" for="${repo}-${name}">${label}</label>235<textarea class="issues-textarea" id="${repo}-${name}" name="${name}" rows="${String(rows)}"236maxlength="${String(LIMITS[name])}">${value}</textarea>`;237}238239function releaseForm(c: Context, repo: string, release: OperatorRelease) {240 const total = release.downloads.reduce((sum, [, n]) => sum + n, 0);241 const id = `${repo}-${release.version}`;242 return html`<article class="issue-post" id="${id}">243<p class="issue-post-head mono">244${ ""}${html`<span class="issue-author">${release.version}</span>`}${html`<span>${release.hidden ? "hidden" : "shown"}</span>`}${html`<span>${plural(total, "download")}</span>`}${release.downloads.map(245 ([platform, n]) => html`<span class="muted">${platform} ${n}</span>`,246)}247</p>248<form class="issues-form" method="post" action="/admin/releases/${repo}/${release.version}">249${formField(c)}250<label class="issues-label" for="${id}-notes">notes251${release.notes !== release.recordNotes ? html` <span class="muted">(edited)</span>` : ""}</label>252<textarea class="issues-textarea" id="${id}-notes" name="notes" rows="3"253maxlength="${MAX_CHARS}">${release.notes}</textarea>254${255 256 257 ""258}<label class="issues-label">${html`<input type="checkbox"`}${html` name="hidden" value="1"`}${release.hidden ? html` checked` : ""}> hidden</label>259<button class="issues-submit" type="submit">save ${release.version}</button>260</form>261<form class="issues-form" method="post" action="/admin/releases/${repo}/${release.version}/delete">262${formField(c)}263<label class="issues-label"><input type="checkbox" name="confirm" value="1" required>264delete ${release.version} and its files from the bucket; this cannot be undone</label>265<button class="issues-submit" type="submit">delete ${release.version}</button>266</form>267</article>`;268}