david/ota-tv-web
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

data in websocket
All checks were successful
OTA TV / deploy (push) Successful in 4s
Details

Browse Source
This commit is contained in:
david 2025-04-21 15:55:53 -07:00
parent bf57130f98
commit d1f26ede2f
6 changed files with 117 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/http.ts
View File

@ -8,7 +8,7 @@ export default class HttpServer {
private httpServer: http.Server; private httpServer: http.Server;
private port: number; private port: number;
private root: string; private root: string;
public constructor(port: number, root: string, tune: (ch: string, adp?: number) => void, getChannels: ()=>string[], getSignal: (adapter:number)=>object) { public constructor(port: number, root: string, tune: (ch: string, adp?: number) => void, getChannels: ()=>string[]) {
this.port = port; this.port = port;
this.root = root; this.root = root;
this.httpServer = http.createServer((req, res) => { this.httpServer = http.createServer((req, res) => {
@ -27,11 +27,6 @@ export default class HttpServer {
body = JSON.stringify(getChannels()); body = JSON.stringify(getChannels());
status = 200; status = 200;
break; break;
case "signal":
const adapter = parseInt(url.searchParams.get('adapter'));
body = JSON.stringify(getSignal(adapter));
status = 200;
break;
} }
break; break;

15
src/server.ts
View File

@ -20,16 +20,17 @@ const tune = (reqChannel: string, reqAdapter?: number) => {
}); });
} }
const getChannels = () => const getChannels = zap.getChannels.bind(zap)
zap.getChannels(); const getMetaData0 = zap.getMetaData.bind(zap,0)
const getMetaData1 = zap.getMetaData.bind(zap,1)
const getSignal = (adapter: number) =>
zap.getSignal(adapter)
const httpServer = new HttpServer(HTTP_PORT, STATIC_ROOT, tune, getChannels, getSignal); const httpServer = new HttpServer(HTTP_PORT, STATIC_ROOT, tune, getChannels);
const tvWebSocket0 = new TVWebSocket(WS_PORT, TV_DEV_0); const tvWebSocket0 = new TVWebSocket(WS_PORT, TV_DEV_0, getMetaData0);
const tvWebSocket1 = new TVWebSocket(WS_PORT + 1, TV_DEV_1); const tvWebSocket1 = new TVWebSocket(WS_PORT + 1, TV_DEV_1, getMetaData1);
httpServer.start(); httpServer.start();
tune('ION',0);
tune("KGW",1);
process.stdin.setEncoding("utf8"); process.stdin.setEncoding("utf8");

19
src/static/index.html
View File

@ -2,7 +2,7 @@
<html> <html>
<head> <head>
<title>WebRTC Stream</title> <title>PDX Airwave TV</title>
<meta charset="utf-8" /> <meta charset="utf-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" />
<link rel="stylesheet" href="css/index.css" /> <link rel="stylesheet" href="css/index.css" />
@ -11,24 +11,23 @@
<body> <body>
<header></header> <header></header>
<main> <main>
<h1>Video streams</h1> <h1>Portland Airwave Television</h1>
<h2>WebRTC</h2>
<div class="content"> <div class="content">
<div class="player"> <div class="player">
<video id="video0" autoplay playsinline controls></video> <h2 id="station-0">N/A</h2>
<video id="video-0" autoplay playsinline controls></video>
<div id="channel-container-0" class="channel-group"></div> <div id="channel-container-0" class="channel-group"></div>
<button onClick="tune(0)">Tune</button> <button onClick="tune(0)">Tune</button>
<p id="signal-0">N/A</p> <h3 id="signal-0"></h3>
<button onClick="getSignal(0)">Get Signal</button>
</div> </div>
<div class="player"> <div class="player">
<video id="video1" autoplay playsinline controls></video> <h2 id="station-1">N/A</h2>
<video id="video-1" autoplay playsinline controls></video>
<div id="channel-container-1" class="channel-group"></div> <div id="channel-container-1" class="channel-group"></div>
<button onClick="tune(1)">Tune</button> <button onClick="tune(1)">Tune</button>
<p id="signal-1">N/A</p> <h3 id="signal-1"></h3>
<button onClick="getSignal(1)">Get Signal</button>
</div> </div>
</main> </main>
</div> </div>

52
src/static/js/video.ts
View File

@ -13,10 +13,40 @@ const config = {
} }
] ]
}; };
interface IData {
channel: string,
signal: number,
cn: number
}
const pc0 = new RTCPeerConnection(config); const pc0 = new RTCPeerConnection(config);
const pc1 = new RTCPeerConnection(config); const pc1 = new RTCPeerConnection(config);
const video0 = document.getElementById('video0') as HTMLVideoElement; const video0 = document.getElementById('video-0') as HTMLVideoElement;
const video1 = document.getElementById('video1') as HTMLVideoElement; const video1 = document.getElementById('video-1') as HTMLVideoElement;
const station0 = document.getElementById('station-0') as HTMLHeadElement;
const station1 = document.getElementById('station-1') as HTMLHeadElement;
const signal0 = document.getElementById('signal-0') as HTMLHeadElement;
const signal1 = document.getElementById('signal-1') as HTMLHeadElement;
// 0
const dataChannel0 = pc0.createDataChannel('meta');
console.log("📡 Data channel created by client");
dataChannel0.onopen = () => {
console.log('📬 Client: Data channel opened');
};
dataChannel0.onmessage = (event) => {
const json = JSON.parse(event.data) as IData;
station0.textContent = json.channel;
signal0.textContent = `Signal: ${json.signal}\tC/N: ${json.cn}`
};
dataChannel0.onclose = () => {
console.log("📴 Client: Data channel closed");
};
// 0 // 0
pc0.ontrack = (event) => { pc0.ontrack = (event) => {
@ -49,6 +79,24 @@ ws0.onmessage = async (message) => {
}; };
// 1 // 1
const dataChannel1 = pc1.createDataChannel('meta');
console.log("📡 Data channel created by client");
dataChannel1.onopen = () => {
console.log('📬 Client: Data channel opened');
};
dataChannel1.onmessage = (event) => {
const json = JSON.parse(event.data) as IData;
station1.textContent = json.channel;
signal1.textContent = `Signal: ${json.signal}\tC/N: ${json.cn}`
};
dataChannel1.onclose = () => {
console.log("📴 Client: Data channel closed");
};
pc1.ontrack = (event) => { pc1.ontrack = (event) => {
console.log("Received track event", event.streams); console.log("Received track event", event.streams);
video1.srcObject = event.streams[0]; video1.srcObject = event.streams[0];

28
src/ws.ts
View File

@ -9,7 +9,7 @@ const FRAME_SIZE = WIDTH * HEIGHT * 1.5; // YUV420p frame size (460800 bytes)
export default class TVWebSocket { export default class TVWebSocket {
videoDevice: string; videoDevice: string;
public constructor(port: number, videoDevice) { public constructor(port: number, videoDevice, getMetaData: ()=>any) {
this.videoDevice = videoDevice this.videoDevice = videoDevice
const ffmpegProcess = this.startFFmpeg(); const ffmpegProcess = this.startFFmpeg();
const videoTrack = this.createVideoTrack(ffmpegProcess); const videoTrack = this.createVideoTrack(ffmpegProcess);
@ -25,7 +25,29 @@ export default class TVWebSocket {
wss.on('connection', async (ws: ws.WebSocket) => { wss.on('connection', async (ws: ws.WebSocket) => {
const peerConnection: RTCPeerConnection = this.createPeerConnection(videoTrack, audioTrack); const peerConnection: RTCPeerConnection = this.createPeerConnection(videoTrack, audioTrack);
peerConnection.ondatachannel = (event) => {
const dataChannel = event.channel; // This is the data channel created by the client
dataChannel.onopen = () => {
console.log('📬 Server: Data channel opened');
// Now you can send data through the channel
setInterval(() => {
if (dataChannel.readyState === 'open') {
const metaData = getMetaData(); // Example function to fetch data
dataChannel.send(JSON.stringify(metaData)); // Send data to the client
}
}, 1000);
};
dataChannel.onmessage = (event) => {
console.log("📦 Server received message:", event.data);
};
dataChannel.onclose = () => {
console.log("📴 Server: Data channel closed");
};
}
ws.on('message', async (message: Buffer) => { ws.on('message', async (message: Buffer) => {
const { type, data } = JSON.parse(message.toString()); const { type, data } = JSON.parse(message.toString());
@ -71,10 +93,12 @@ export default class TVWebSocket {
// Video // Video
'-map', '0:v:0', '-map', '0:v:0',
'-vf', `scale=${WIDTH}:${HEIGHT}`, '-framerate', '24',
'-vf', `scale=${WIDTH}:${HEIGHT}:flags=fast_bilinear`,
'-vcodec', 'rawvideo', '-vcodec', 'rawvideo',
'-pix_fmt', 'yuv420p', '-pix_fmt', 'yuv420p',
'-f', 'rawvideo', '-f', 'rawvideo',
'-threads', '1',
//quality //quality
'-fflags', '+discardcorrupt', '-fflags', '+discardcorrupt',

55
src/zap.ts
View File

@ -5,10 +5,10 @@ export interface IZap {
process: ChildProcessWithoutNullStreams | null, process: ChildProcessWithoutNullStreams | null,
channel: string, channel: string,
adapter: 0 | 1 adapter: 0 | 1
strength: {
signal: string; signal: string;
cn: string; cn: string;
},
} }
export default class Zap { export default class Zap {
@ -17,27 +17,27 @@ export default class Zap {
private channelNameList: string[]; private channelNameList: string[];
private fileName: string; private fileName: string;
private regex = /Signal=\s*(-?\d+(\.\d+)?dBm)\s+C\/N=\s*(\d+(\.\d+)?dB)/; private regex = /Signal=\s*(-?\d+(\.\d+)?dBm)\s+C\/N=\s*(\d+(\.\d+)?dB)/;
public constructor(fileName = "dvb_channel.conf", channel = "ION") { public constructor(fileName = "dvb_channel.conf", channel = "ION") {
const zap0: IZap = { const zap0: IZap = {
process: null, process: null,
channel, channel: "None",
adapter: 0, adapter: 0,
strength: {
signal: "None", signal: "None",
cn: "None" cn: "None"
}
} }
const zap1: IZap = { const zap1: IZap = {
process: null, process: null,
channel, channel: "None",
adapter: 1, adapter: 1,
strength: {
signal: "None", signal: "None",
cn: "None" cn: "None"
}
} }
this.zap0 = zap0; this.zap0 = zap0;
this.zap1 = zap1; this.zap1 = zap1;
@ -53,19 +53,12 @@ export default class Zap {
return this.channelNameList; return this.channelNameList;
} }
public getSignal(adapter: number) { public getMetaData(adapter: 0 | 1) {
if(adapter == 0){ const { channel, signal, cn } = adapter === 0 ? this.zap0 : this.zap1
return this.zap0.strength; return { channel, signal, cn }
}
else if (adapter == 1){
return this.zap1.strength;
}
else {
return {signal: 'N/A', cn: 'N/A'}
}
} }
private nextChannel(channel: string) :string { private nextChannel(channel: string): string {
const size = this.channelNameList.length; const size = this.channelNameList.length;
const currentIndex = this.channelNameList.indexOf(channel); const currentIndex = this.channelNameList.indexOf(channel);
if (currentIndex >= 0) { if (currentIndex >= 0) {
@ -76,11 +69,11 @@ export default class Zap {
} }
} }
private mod(n: number, m: number) :number{ private mod(n: number, m: number): number {
return ((n % m) + m) % m; return ((n % m) + m) % m;
} }
private previousChannel(channel: string):string { private previousChannel(channel: string): string {
const size = this.channelNameList.length; const size = this.channelNameList.length;
const currentIndex = this.channelNameList.indexOf(channel); const currentIndex = this.channelNameList.indexOf(channel);
if (currentIndex >= 0) { if (currentIndex >= 0) {
@ -138,10 +131,8 @@ export default class Zap {
clearTimeout(lockTimer); clearTimeout(lockTimer);
const match = output.match(this.regex); const match = output.match(this.regex);
zap.channel = verifiedChannel; zap.channel = verifiedChannel;
zap.strength = { zap.signal = match[1],
signal: match[1], zap.cn = match[3]
cn: match[3]
}
resolve(zap); resolve(zap);
} }