const cmn = require("../$common.js"); const fs = require("fs"); const https = require("https"); const child_process = require("child_process"); const generateTemplate = require("./template.js"); let moddir = null; let repodir = null; const repoRemote = "https://git.tomsmeding.com/blog"; // Cache for rendered posts; null if currently being rendered let templateCache = new Map(); // Clients that requested a post that is currently being rendered; values are // callbacks that take (http status code, rendered html [= null if status != 200]) let renderWatchers = new Map(); function triggerRenderWatchers(path, statusCode, rendered) { const list = renderWatchers.get(path); if (list !== undefined) { try { for (const callback of list) callback(statusCode, rendered); } catch(e) { console.error("While triggering render watchers:", e); } renderWatchers.delete(path); } } function fetch(url) { return new Promise((resolve, reject) => { https.get(url, res => { if (res.statusCode != 200) { reject(`HTTP status code ${res.statusCode}`); return; } let buffers = []; res.on("data", d => buffers.push(d)); res.on("end", () => { resolve(Buffer.concat(buffers)); }); }).on("error", err => { reject(err); }); }); } function runCommand(cmd, args) { console.log(`blog: ${cmd} ${JSON.stringify(args)}`); child_process.execFileSync( cmd, args, { stdio: "inherit", timeout: 20000 } ); } function runCommandOutput(cmd, args) { return child_process.execFileSync( cmd, args, { timeout: 20000 } ); } function ensureRepo() { try { const stats = fs.statSync(repodir); if (stats.isDirectory()) return; } catch (e) {} runCommand("git", ["clone", "https://git.tomsmeding.com/blog", repodir]); } function currentCommit() { return runCommandOutput("git", ["-C", repodir, "rev-parse", "HEAD"]).toString().trim(); } async function upstreamCommit() { const body = await fetch(repoRemote + "/info/refs"); return body.toString().split("\t")[0]; } function updateRepo() { try { runCommand("git", ["-C", repodir, "fetch", "--all"]); runCommand("git", ["-C", repodir, "reset", "origin/master", "--hard"]); // Reset cache _after_ the commands succeeded; if anything failed, we // might at least still have stale cache data templateCache = new Map(); } catch (e) { console.error("Cannot update blog git repo!"); console.error(e); } } async function periodicUpdateCheck() { let shouldUpdate = false; try { const local = currentCommit(); const remote = await upstreamCommit(); if (local != remote) shouldUpdate = true; } catch (e) { // Also update if our pre-check fails for some reason shouldUpdate = true; } if (shouldUpdate) updateRepo(); } setInterval(function () { periodicUpdateCheck().catch(err => console.error(err)); }, 3600 * 1000); module.exports = (app, io, _moddir) => { moddir = _moddir; repodir = moddir + "/repo"; ensureRepo(); updateRepo(); app.get("/blog", (req, res, next) => { req.url = "/blog/index"; next(); }); app.get("/blog/*", (req, res) => { if (req.path.indexOf("/.") != -1) { res.sendStatus(404); return; } const path = req.path .slice(6) .replace(/\/[\/]*/g, "/") .replace(/\/\.+/g, "/") .replace(/\.html$/, ""); const fromCache = templateCache.get(path); if (fromCache != null) { // neither null nor undefined res.send(fromCache); } else if (fromCache !== undefined) { // Is currently being renderered for another client if (!renderWatchers.has(path)) renderWatchers.set(path, []); renderWatchers.get(path).push((statusCode, rendered) => { if (statusCode == 200) res.send(rendered); else res.sendStatus(statusCode); }); } else { // Indicate that this path is currently being rendered templateCache.set(path, null); generateTemplate(repodir, path ? path + ".html" : undefined) .then(rendered => { templateCache.set(path, rendered); triggerRenderWatchers(path, 200, rendered); res.send(rendered); }) .catch(err => { if (err.code && err.code == "ENOENT") { triggerRenderWatchers(path, 400, null); res.sendStatus(404); } else { triggerRenderWatchers(path, 500, null); console.error(err); res.sendStatus(500); } }); } }); };