import { RemoteInfo } from "dgram"; import http from "node:http"; import { logger } from "./logger.js"; import { config } from "./settings.js"; import { discoverDevices } from "./discovery.js"; import { DevSerial } from "./impl.js"; import { Handlers, makeSession, Session, startVideoStream } from "./session.js"; import { addExifToJpeg, createExifOrientation } from "./exif.js"; // @ts-expect-error TS2307 import favicon from "./cam.ico.gz"; // @ts-expect-error TS2307 import html_template from "./asd.html"; const BOUNDARY = "a very good boundary line"; const responses: Record = {}; const audioResponses: Record = {}; const sessions: Record = {}; // https://sirv.com/help/articles/rotate-photos-to-be-upright/ const oMap = [1, 8, 3, 6]; const oMapMirror = [2, 7, 4, 5]; const orientations = [1, 2, 3, 4, 5, 6, 7, 8].reduce((acc, cur) => { return { [cur]: createExifOrientation(cur), ...acc }; }, {}); // Reads the mapping of serial numbers to camera names from the text file. // Returns the camera name (custom name, if it exists, otherwise its ID). const cameraName = (id: string): string => config.cameras[id].alias || id; // The HTTP server. export const serveHttp = (port: number) => { const server = http.createServer((req, res) => { if (req.url.startsWith("/ui/")) { let devId = req.url.split("/")[2]; let s = sessions[devId]; if (s === undefined) { res.writeHead(400); res.end("invalid ID"); return; } if (!s.connected) { res.writeHead(400); res.end("Nothing online"); return; } const ui = html_template .toString() .replace(/\${id}/g, devId) .replace(/\${name}/g, cameraName(devId)) .replace(/\${audio}/g, config.cameras[devId].audio ? "true" : "false"); res.end(ui); return; } if (req.url.startsWith("/audio/")) { let devId = req.url.split("/")[2]; let s = sessions[devId]; if (s === undefined) { res.writeHead(400); res.end("invalid ID"); return; } if (!s.connected) { res.writeHead(400); res.end("Nothing online"); return; } res.setHeader("Content-Type", `text/event-stream`); audioResponses[devId].push(res); logger.info(`Audio stream requested for camera ${devId}`); return; } if (req.url.startsWith("/favicon.ico")) { res.setHeader("Content-Type", "image/x-icon"); res.setHeader("Content-Encoding", "gzip"); res.end(Buffer.from(favicon)); return; } if (req.url.startsWith("/rotate/")) { let devId = req.url.split("/")[2]; let curPos = config.cameras[devId]?.rotate || 0; let nextPos = (curPos + 1) % 4; logger.debug(`Rotating ${devId} to ${nextPos}`); config.cameras[devId].rotate = nextPos; res.writeHead(204); res.end(); return; } else if (req.url.startsWith("/mirror/")) { let devId = req.url.split("/")[2]; logger.debug(`Mirroring ${devId}`); config.cameras[devId].mirror = !config.cameras[devId].mirror; res.writeHead(204); res.end(); return; } else if (req.url.startsWith("/camera/")) { let devId = req.url.split("/")[2]; logger.info(`Video stream requested for camera ${devId}`); let s = sessions[devId]; if (s === undefined) { res.writeHead(400); res.end(`Camera ${devId} not discovered`); return; } if (!s.connected) { res.writeHead(400); res.end(`Camera ${devId} offline`); return; } res.setHeader("Content-Type", `multipart/x-mixed-replace; boundary="${BOUNDARY}"`); responses[devId].push(res); res.on("close", () => { responses[devId] = responses[devId].filter((r) => r !== res); logger.info(`Video stream closed for camera ${devId}`); }); } else { res.write(""); res.write(""); res.write(``); res.write("All cameras"); res.write(""); res.write(""); res.write("

All cameras

"); Object.keys(sessions).forEach((id) => res.write(`

${cameraName(id)}

`), ); res.write(""); res.write(""); res.end(); } }); let devEv = discoverDevices(config.discovery_ips); const startSession = (s: Session) => { startVideoStream(s); logger.info(`Camera ${s.devName} is now ready to stream`); }; devEv.on("discover", (rinfo: RemoteInfo, dev: DevSerial) => { if (dev.devId in sessions) { logger.info(`Camera ${dev.devId} at ${rinfo.address} already discovered, ignoring`); return; } logger.info(`Discovered camera ${dev.devId} at ${rinfo.address}`); responses[dev.devId] = []; audioResponses[dev.devId] = []; const s = makeSession(Handlers, dev, rinfo, startSession, 5000); sessions[dev.devId] = s; config.cameras[dev.devId] = { rotate: 0, mirror: false, audio: true, ...(config.cameras[dev.devId] || {}) }; s.eventEmitter.on("frame", () => { // Add an EXIF header to indicate if the image should be rotated or mirrored let orientation = config.cameras[dev.devId].rotate; orientation = config.cameras[dev.devId].mirror ? oMapMirror[orientation] : oMap[orientation]; const exifSegment = orientations[orientation]; const jpegHeader = addExifToJpeg(s.curImage[0], exifSegment); const assembled = Buffer.concat([jpegHeader, ...s.curImage.slice(1)]); const header = Buffer.from(`\r\n--${BOUNDARY}\r\nContent-Length: ${assembled.length}\r\nContent-Type: image/jpeg\r\n\r\n`); responses[dev.devId].forEach((res) => { res.write(header); res.write(assembled); }); }); s.eventEmitter.on("disconnect", () => { logger.info(`Camera ${dev.devId} disconnected`); delete sessions[dev.devId]; }); if (config.cameras[dev.devId].audio) { s.eventEmitter.on("audio", ({ gap, data }) => { // ew, maybe WS? var b64encoded = Buffer.from(data).toString("base64"); audioResponses[dev.devId].forEach((res) => { res.write("data: "); res.write(b64encoded); res.write("\n\n"); }); }); } }); logger.info(`Starting HTTP server on port ${port}`); server.listen(port); };