michael/scrypted
1
0
Fork 0
mirror of https://github.com/koush/scrypted.git synced 2026-02-11 01:32:02 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

common: rtsp server fixes

Browse Source
This commit is contained in:
Koushik Dutta
2022-02-07 23:41:28 -08:00
parent 43d5e6bf1b
commit 44f1d05aa3
1 changed files with 18 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
common/src/rtsp-server.ts
View File

@@ -76,6 +76,8 @@ export class RtspServer {
constructor(public client: Duplex, public sdp?: string, public udp?: dgram.Socket) {
this.session = randomBytes(4).toString('hex');
if (sdp)
sdp = sdp.trim();
}
async handleSetup() {
@@ -171,13 +173,26 @@ export class RtspServer {
headers['Transport'] = requestHeaders['transport'];
headers['Session'] = this.session;
if (transport.includes('UDP')) {
const match = transport.match(/.*?client_port=([0-9]+)-([0-9]+)/)
const match = transport.match(/.*?client_port=([0-9]+)-([0-9]+)/);
const [_, rtp, rtcp] = match;
if (url.includes('audio'))
this.udpPorts.audio = parseInt(rtp);
else
this.udpPorts.video = parseInt(rtp);
}
else if (transport.includes('TCP')) {
const match = transport.match(/.*?interleaved=([0-9]+)-([0-9]+)/);
if (match) {
const low = parseInt(match[1]);
const high = parseInt(match[2]);
if (url.includes('audio')) {
this.audioChannel = low;
}
else {
this.videoChannel = low;
}
}
}
this.respond(200, 'OK', requestHeaders, headers)
}
@@ -225,6 +240,8 @@ export class RtspServer {
}
respond(code: number, message: string, requestHeaders: Headers, headers: Headers, buffer?: Buffer) {
// this.console?.log(requestHeaders);
// this.console?.log(headers);
let response = `RTSP/1.0 ${code} ${message}\r\n`;
if (requestHeaders['cseq'])
headers['CSeq'] = requestHeaders['cseq'];