bkvargyasandClaude Fable 5.1
a5222953dd
Cached app.css from before 0.4.0 left the score keeper page unstyled on phones. Assets are now /static/x?v=<version> with a one-year immutable cache; unversioned requests get 60s. Release 0.4.2. Co-Authored-By: Claude Fable 5.1 <[email protected]> Claude-Session: https://claude.ai/code/session_01MB7nCCAscYsb3zzkT6LHZi
71 lines
3.6 KiB
JavaScript
71 lines
3.6 KiB
JavaScript
// Courtside server entry point. One process: HTTP pages + WebSocket fan-out + SQLite.
|
|
import { createServer } from 'node:http';
|
|
import { fileURLToPath } from 'node:url';
|
|
import { dirname, join } from 'node:path';
|
|
import { WebSocketServer } from 'ws';
|
|
import { Store } from './store.js';
|
|
import { Registry } from './state.js';
|
|
import { Auth } from './auth.js';
|
|
import { buildRouter } from './routes.js';
|
|
import { HttpError, send, serveStatic } from './http.js';
|
|
import { publicState } from './public-state.js';
|
|
|
|
const here = dirname(fileURLToPath(import.meta.url));
|
|
const env = process.env;
|
|
const PORT = Number(env.PORT ?? 3000);
|
|
const HOST = env.HOST ?? '0.0.0.0';
|
|
const DB_PATH = env.DB_PATH ?? join(here, '..', 'data', 'courtside.sqlite');
|
|
|
|
const store = new Store(DB_PATH);
|
|
const registry = new Registry(store);
|
|
const auth = new Auth({ password: env.ADMIN_PASSWORD, secret: env.SESSION_SECRET, trustCfAccess: env.TRUST_CF_ACCESS === 'true' });
|
|
const router = buildRouter({ registry, auth, store });
|
|
const staticRoot = join(here, 'public');
|
|
|
|
const server = createServer(async (req, res) => {
|
|
const url = new URL(req.url, 'http://x');
|
|
try {
|
|
if (url.pathname.startsWith('/static/')) return await serveStatic(res, staticRoot, url.pathname.slice('/static'.length), url.searchParams.has('v'));
|
|
const m = router.match(req.method, url.pathname);
|
|
if (!m) throw new HttpError(404, 'Not found');
|
|
await m.handler(req, res, m.params);
|
|
} catch (e) {
|
|
const status = e instanceof HttpError ? e.status : 500;
|
|
if (status === 500) console.error(`[${new Date().toISOString()}] ${req.method} ${req.url}`, e);
|
|
if (!res.headersSent) send.html(res, `<!doctype html><meta charset="utf-8"><meta name="viewport" content="width=device-width"><title>${status}</title><body style="font-family:sans-serif;padding:40px"><h1>${status}</h1><p>${escape(e.message)}</p><p><a href="/">Home</a></p>`, status);
|
|
else res.end();
|
|
}
|
|
});
|
|
|
|
// ---------- WebSocket: /ws/<slug> pushes the public state on every change ----------
|
|
const wss = new WebSocketServer({ noServer: true, maxPayload: 1024 });
|
|
server.on('upgrade', (req, socket, head) => {
|
|
const m = req.url.match(/^\/ws\/([a-z0-9-]+)\/?$/);
|
|
const item = m && registry.get(m[1]);
|
|
if (!item) { socket.write('HTTP/1.1 404 Not Found\r\n\r\n'); socket.destroy(); return; }
|
|
wss.handleUpgrade(req, socket, head, ws => {
|
|
ws.isAlive = true;
|
|
ws.on('pong', () => { ws.isAlive = true; });
|
|
ws.on('message', () => { /* clients never send; ignore */ });
|
|
const unsub = registry.subscribe(m[1], state => { if (ws.readyState === ws.OPEN) ws.send(JSON.stringify(state)); });
|
|
ws.on('close', unsub);
|
|
ws.send(JSON.stringify(publicState(item)));
|
|
});
|
|
});
|
|
const heartbeat = setInterval(() => { for (const ws of wss.clients) { if (!ws.isAlive) return ws.terminate(); ws.isAlive = false; ws.ping(); } }, 30000);
|
|
|
|
// ---------- ETA refresh: queue ETAs drift as time passes even with no results ----------
|
|
const etaTimer = setInterval(() => { for (const [slug, { t }] of registry.items) if (t.phase === 'live' && registry.subscribers.get(slug)?.size) registry.notify(slug); }, 60000);
|
|
|
|
server.listen(PORT, HOST, () => console.log(`Courtside listening on http://${HOST}:${PORT} db=${DB_PATH} tournaments=${registry.items.size}`));
|
|
|
|
for (const sig of ['SIGINT', 'SIGTERM']) process.on(sig, () => {
|
|
console.log(`\n${sig}: shutting down`);
|
|
clearInterval(heartbeat); clearInterval(etaTimer);
|
|
for (const ws of wss.clients) ws.close();
|
|
server.close(() => { store.close(); process.exit(0); });
|
|
setTimeout(() => process.exit(0), 3000).unref();
|
|
});
|
|
|
|
function escape(s) { return String(s).replace(/[&<>]/g, c => ({ '&': '&', '<': '<', '>': '>' }[c])); }
|