import { Logger } from "@gnu-taler/taler-util"; import chokidar from "chokidar"; import express from "express"; import https from "https"; import { parse } from "url"; import WebSocket, { Server } from "ws"; import locahostCrt from "./keys/localhost.crt"; import locahostKey from "./keys/localhost.key"; import storiesHtml from "./stories.html"; import path from "path"; const httpServerOptions = { key: locahostKey, cert: locahostCrt, }; const logger = new Logger("serve.ts"); const PATHS = { WS: "/ws", NOTIFY: "/notify", EXAMPLE: "/examples", APP: "/app", }; export async function serve(opts: { folder: string; port: number; source?: string; development?: boolean; examplesLocationJs?: string; examplesLocationCss?: string; onUpdate?: () => Promise; }): Promise { const app = express(); app.use(PATHS.APP, express.static(opts.folder)); const server = https.createServer(httpServerOptions, app); logger.info(`serving ${opts.folder} on ${opts.port}`); logger.info(` ${PATHS.APP}: application`); logger.info(` ${PATHS.EXAMPLE}: examples`); logger.info(` ${PATHS.WS}: websocket`); logger.info(` ${PATHS.NOTIFY}: broadcast`); if (opts.development) { const wss = new Server({ noServer: true }); wss.on("connection", function connection(ws) { ws.send("welcome"); }); server.on("upgrade", function upgrade(request, socket, head) { const { pathname } = parse(request.url || ""); if (pathname === PATHS.WS) { wss.handleUpgrade(request, socket, head, function done(ws) { wss.emit("connection", ws, request); }); } else { socket.destroy(); } }); const sendToAllClients = function (data: object): void { wss.clients.forEach(function each(client) { if (client.readyState === WebSocket.OPEN) { client.send(JSON.stringify(data)); } }); }; const watchingFolder = opts.source ?? opts.folder; logger.info(`watching ${watchingFolder} for change`); chokidar.watch(watchingFolder).on("change", (path, stats) => { logger.info(`changed ${path}`); if (opts.onUpdate) { sendToAllClients({ type: "file-updated-start", data: { path } }); opts .onUpdate() .then((result) => { sendToAllClients({ type: "file-updated-done", data: { path, result }, }); }) .catch((error) => { sendToAllClients({ type: "file-updated-failed", data: { path, error }, }); }); } else { sendToAllClients({ type: "file-change", data: { path } }); } }); if (opts.onUpdate) opts.onUpdate(); app.get(PATHS.EXAMPLE, function (req: any, res: any) { res.set("Content-Type", "text/html"); res.send( storiesHtml .replace( "__EXAMPLES_JS_FILE_LOCATION__", opts.examplesLocationJs ?? `.${PATHS.APP}/stories.js`, ) .replace( "__EXAMPLES_CSS_FILE_LOCATION__", opts.examplesLocationCss ?? `.${PATHS.APP}/stories.css`, ), ); }); app.get(PATHS.NOTIFY, function (req: any, res: any) { res.send("ok"); }); server.listen(opts.port); } }