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

eufy: add audio toggle

Browse Source
This commit is contained in:
Koushik Dutta
2023-03-09 19:06:20 -08:00
parent f02dfa5e14
commit 7ddeda1595
1 changed files with 41 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

73
plugins/eufy/src/main.ts
View File

@@ -9,28 +9,35 @@ import { LocalLivestreamManager } from './stream';
const { deviceManager, mediaManager } = sdk;
let sdp = `v=0
o=- 0 0 IN IP4 127.0.0.1
t=0 0
m=video 0 RTP/AVP 96
c=IN IP4 0.0.0.0
a=recvonly
a=rtpmap:96 H264/90000
m=audio 0 RTP/AVP 97
c=IN IP4 0.0.0.0
a=recvonly
a=rtpmap:97 mpeg4-generic/16000/1
a=fmtp:104 profile-level-id=15; streamtype=5; mode=AAC-hbr; config=1408;SizeLength=13; IndexLength=3; IndexDeltaLength=3; Profile=1;
`;
let sdp: string;
if (true) {
sdp = `v=0
o=- 0 0 IN IP4 127.0.0.1
t=0 0
m=video 0 RTP/AVP 96
c=IN IP4 0.0.0.0
a=recvonly
a=rtpmap:96 H264/90000
m=audio 0 RTP/AVP 97
c=IN IP4 0.0.0.0
a=recvonly
a=rtpmap:97 mpeg4-generic/16000/1
a=fmtp:104 profile-level-id=15; streamtype=5; mode=AAC-hbr; config=1408;SizeLength=13; IndexLength=3; IndexDeltaLength=3; Profile=1;
`;
}
else {
sdp = `v=0
o=- 0 0 IN IP4 127.0.0.1
t=0 0
m=video 0 RTP/AVP 96
c=IN IP4 0.0.0.0
a=recvonly
a=rtpmap:96 H264/90000
`;
}
// let sdp = `v=0
// o=- 0 0 IN IP4 127.0.0.1
// t=0 0
// m=video 0 RTP/AVP 96
// c=IN IP4 0.0.0.0
// a=recvonly
// a=rtpmap:96 H264/90000
// `;
sdp = addTrackControls(sdp);
const parsedSdp = parseSdp(sdp);
@@ -122,18 +129,20 @@ class EufyCamera extends ScryptedDeviceBase implements Camera, VideoCamera, Batt
}
});
proxyStream.audiostream.on('readable', () => {
const allData: Buffer = proxyStream.audiostream.read();
const timestamp = Math.floor(((lastAudioTimestamp - firstTimestamp) / 1000) * 16000);
const header = new RtpHeader({
sequenceNumber: audioSequenceNumber++,
timestamp: timestamp,
payloadType: 97,
if (audioTrack) {
proxyStream.audiostream.on('readable', () => {
const allData: Buffer = proxyStream.audiostream.read();
const timestamp = Math.floor(((lastAudioTimestamp - firstTimestamp) / 1000) * 16000);
const header = new RtpHeader({
sequenceNumber: audioSequenceNumber++,
timestamp: timestamp,
payloadType: 97,
});
const rtp = new RtpPacket(header, allData);
rtsp.sendTrack(audioTrack.control, rtp.serialize(), false);
lastAudioTimestamp = Date.now();
});
const rtp = new RtpPacket(header, allData);
rtsp.sendTrack(audioTrack.control, rtp.serialize(), false);
lastAudioTimestamp = Date.now();
});
}
}
catch (e) {
rtsp.client.destroy();