71 lines
2.0 KiB
TypeScript
71 lines
2.0 KiB
TypeScript
import { RemoteInfo } from "node:dgram";
|
|
import { createWriteStream } from "node:fs";
|
|
import http from "node:http";
|
|
|
|
import { CommandsByValue } from "./datatypes.js";
|
|
import { create_LanSearch } from "./func_replacements.js";
|
|
import { hexdump } from "./hexdump.js";
|
|
import { create_P2pAlive } from "./impl.js";
|
|
import { Handlers, makeSession } from "./server.js";
|
|
|
|
const s = makeSession(
|
|
(session, msg, rinfo, options) => {
|
|
const ab = new Uint8Array(msg).buffer;
|
|
const dv = new DataView(ab);
|
|
const cmd = CommandsByValue[dv.readU16()];
|
|
if (options.debug) {
|
|
console.log(`<< ${cmd}`);
|
|
console.log(hexdump(msg.buffer, { ansi: options.ansi, ansiColor: 1 }));
|
|
}
|
|
Handlers[cmd](session, dv, rinfo);
|
|
session.lastReceivedPacket = Date.now();
|
|
},
|
|
(session) => {
|
|
// ther should be a better way of executing periodic status update
|
|
// requests per device
|
|
const int = setInterval(() => {
|
|
let buf = new DataView(new Uint8Array(4).buffer);
|
|
create_LanSearch(buf);
|
|
session.broadcast(buf);
|
|
}, 1000);
|
|
},
|
|
{ debug: false, ansi: false },
|
|
);
|
|
|
|
let BOUNDARY = "a very good boundary line";
|
|
let responses = [];
|
|
|
|
s.eventEmitter.on("frame", (frame: Buffer) => {
|
|
let s = `--${BOUNDARY}\r\n`;
|
|
s += "Content-Type: image/jpeg\r\n\r\n";
|
|
responses.forEach((res) => {
|
|
res.write(Buffer.from(s));
|
|
res.write(frame);
|
|
});
|
|
});
|
|
|
|
const audioFd = createWriteStream(`audio.pcm`);
|
|
s.eventEmitter.on("audio", (frame: Buffer) => {
|
|
audioFd.write(frame);
|
|
});
|
|
|
|
s.eventEmitter.on("connect", (name: string, rinfo: RemoteInfo) => {
|
|
console.log(`Connected to ${name} - ${rinfo.address}`);
|
|
s.outgoingCommandId = 0;
|
|
s.dst_ip = rinfo.address;
|
|
|
|
const int = setInterval(() => {
|
|
let buf = create_P2pAlive();
|
|
if (Date.now() - s.lastReceivedPacket > 500) {
|
|
s.send(buf);
|
|
}
|
|
}, 1000);
|
|
});
|
|
|
|
const server = http.createServer((req, res) => {
|
|
res.setHeader("Content-Type", `multipart/x-mixed-replace; boundary="${BOUNDARY}"`);
|
|
responses.push(res);
|
|
});
|
|
|
|
server.listen(1234);
|