Blame · pages-deployer.ts

e5b523e	1	import { execFileSync } from "child_process";
e5b523e	2	import { mkdirSync, rmSync, existsSync, renameSync } from "fs";
e5b523e	3	import type Database from "better-sqlite3";
e5b523e	4
e5b523e	5	export class PagesDeployer {
e5b523e	6	constructor(
e5b523e	7	private db: Database.Database,
e5b523e	8	private bridgeUrl: string,
e5b523e	9	private sitesDir: string,
e5b523e	10	private logger: {
e5b523e	11	info: (...args: any[]) => void;
e5b523e	12	error: (...args: any[]) => void;
e5b523e	13	}
e5b523e	14	) {
e5b523e	15	mkdirSync(sitesDir, { recursive: true });
e5b523e	16	}
e5b523e	17
e5b523e	18	/**
ff50d03	19	* Get the deploy path for a repo's pages.
ff50d03	20	* Custom domain: sitesDir/{domain}/ (Caddy serves via {host} matching)
ff50d03	21	* Default: sitesDir/_pages/{owner}/{repo}/ (Caddy serves via path-based routing on pages.grove.host)
e5b523e	22	*/
ff50d03	23	getDeployPath(repoName: string): { path: string; isCustomDomain: boolean } \| null {
e5b523e	24	const repo = this.db
e5b523e	25	.prepare(
ff50d03	26	`SELECT r.pages_domain, r.pages_enabled, rwo.owner_name, r.name
ff50d03	27	FROM repos r
ff50d03	28	JOIN repos_with_owner rwo ON rwo.id = r.id
ff50d03	29	WHERE r.name = ? AND r.pages_enabled = 1`
e5b523e	30	)
e5b523e	31	.get(repoName) as any;
e5b523e	32
ff50d03	33	if (!repo) return null;
e5b523e	34
ff50d03	35	if (repo.pages_domain) {
ff50d03	36	return { path: `${this.sitesDir}/${repo.pages_domain}`, isCustomDomain: true };
e5b523e	37	}
e5b523e	38
ff50d03	39	return { path: `${this.sitesDir}/_pages/${repo.owner_name}/${repo.name}`, isCustomDomain: false };
ff50d03	40	}
ff50d03	41
ff50d03	42	/**
ff50d03	43	* Deploy a repo's pages content to disk.
ff50d03	44	* Archives the repo from bridge and extracts to the deploy path.
ff50d03	45	* Uses atomic rename so Caddy never sees a half-written site.
ff50d03	46	*/
ff50d03	47	async deploy(repoName: string, ref: string): Promise<void> {
ff50d03	48	const deployInfo = this.getDeployPath(repoName);
ff50d03	49	if (!deployInfo) return;
ff50d03	50
ff50d03	51	const { path: destDir } = deployInfo;
ff50d03	52
ff50d03	53	this.logger.info({ repo: repoName, dest: destDir, ref }, "Deploying pages");
e5b523e	54
ff50d03	55	const tmpDir = `${destDir}.tmp-${Date.now()}`;
e5b523e	56
e5b523e	57	try {
e5b523e	58	const url = `${this.bridgeUrl}/repos/${repoName}/archive/${ref}`;
e5b523e	59	const res = await fetch(url);
e5b523e	60	if (!res.ok) {
e5b523e	61	throw new Error(
e5b523e	62	`Archive fetch failed: ${res.status} ${res.statusText}`
e5b523e	63	);
e5b523e	64	}
e5b523e	65
e5b523e	66	mkdirSync(tmpDir, { recursive: true });
e5b523e	67	const tarData = Buffer.from(await res.arrayBuffer());
e5b523e	68	execFileSync("tar", ["xf", "-", "-C", tmpDir], { input: tarData });
e5b523e	69
e5b523e	70	// Atomic swap
e5b523e	71	const oldDir = `${destDir}.old`;
e5b523e	72	if (existsSync(destDir)) {
e5b523e	73	renameSync(destDir, oldDir);
e5b523e	74	}
ff50d03	75	// Ensure parent directory exists for nested paths
ff50d03	76	mkdirSync(destDir.substring(0, destDir.lastIndexOf("/")), { recursive: true });
e5b523e	77	renameSync(tmpDir, destDir);
e5b523e	78	if (existsSync(oldDir)) {
e5b523e	79	rmSync(oldDir, { recursive: true, force: true });
e5b523e	80	}
e5b523e	81
e5b523e	82	this.logger.info(
ff50d03	83	{ repo: repoName, dest: destDir },
e5b523e	84	"Pages deployed successfully"
e5b523e	85	);
e5b523e	86	} catch (err) {
e5b523e	87	if (existsSync(tmpDir)) {
e5b523e	88	rmSync(tmpDir, { recursive: true, force: true });
e5b523e	89	}
e5b523e	90	throw err;
e5b523e	91	}
e5b523e	92	}
e5b523e	93
ff50d03	94	/** Remove a site's deployed files by deploy path. */
ff50d03	95	undeploy(deployPath: string): void {
ff50d03	96	if (existsSync(deployPath)) {
ff50d03	97	rmSync(deployPath, { recursive: true, force: true });
ff50d03	98	this.logger.info({ path: deployPath }, "Pages undeployed");
e5b523e	99	}
e5b523e	100	}
e5b523e	101
ff50d03	102	/** Check if a custom domain is configured for any repo (used by Caddy's on-demand TLS). */
e5b523e	103	isDomainConfigured(domain: string): boolean {
e5b523e	104	const row = this.db
e5b523e	105	.prepare(
e5b523e	106	`SELECT id FROM repos WHERE pages_domain = ? AND pages_enabled = 1`
e5b523e	107	)
e5b523e	108	.get(domain);
e5b523e	109	return !!row;
e5b523e	110	}
e5b523e	111	}