mirror of
https://github.com/tsightler/ring-mqtt.git
synced 2025-09-26 21:01:12 +08:00
6587f274b9
* Fix minor typos in error logging * Fix model name for First Alert Smoke/CO Alarm * Use rtsp-simple-server v0.20.0 * Increase RTSP start/inactivity timeouts * Move session delete outside of onCallEnded handler * Fix unkillable sessions * Debug for refresh token issue * Tweak stream worker logic * Fix live stream state synchronization * Update to s6-overlay v3 * Release v5.0.3 * Reword discovery warning message
77 lines
3.4 KiB
JavaScript
77 lines
3.4 KiB
JavaScript
const { parentPort } = require('worker_threads')
|
|
const { WebrtcConnection } = require('ring-client-api/lib/api/streaming/webrtc-connection')
|
|
const { RingEdgeConnection } = require('ring-client-api/lib/api/streaming/ring-edge-connection')
|
|
const { StreamingSession } = require('ring-client-api/lib/api/streaming/streaming-session')
|
|
const debug = require('debug')('ring-mqtt')
|
|
const colors = require('colors/safe')
|
|
let activeCalls = []
|
|
|
|
function removeActiveCall(deviceId, deviceName) {
|
|
const callIndex = activeCalls.findIndex(call => call.deviceId === deviceId )
|
|
if (callIndex > -1) {
|
|
debug(colors.green(`[${deviceName}] `)+'Removing active live stream handler')
|
|
activeCalls.splice(callIndex, 1)
|
|
}
|
|
}
|
|
|
|
parentPort.on("message", async(data) => {
|
|
const streamData = data.streamData
|
|
const activeCall = activeCalls.find(call => call.deviceId === streamData.deviceId)
|
|
if (data.command === 'start' && !activeCall) {
|
|
try {
|
|
const cameraData = {
|
|
name: streamData.deviceName,
|
|
id: streamData.doorbotId
|
|
}
|
|
const streamConnection = (streamData.sessionId)
|
|
? new WebrtcConnection(streamData.sessionId, cameraData)
|
|
: new RingEdgeConnection(streamData.authToken, cameraData)
|
|
const liveCall = new StreamingSession(cameraData, streamConnection)
|
|
await liveCall.startTranscoding({
|
|
// The native AVC video stream is copied to the RTSP server unmodified while the audio
|
|
// stream is converted into two output streams using both AAC and Opus codecs. This
|
|
// provides a stream with wide compatibility across various media player technologies.
|
|
audio: [
|
|
'-map', '0:v',
|
|
'-map', '0:a',
|
|
'-map', '0:a',
|
|
'-c:a:0', 'libfdk_aac',
|
|
'-c:a:1', 'copy',
|
|
],
|
|
video: [
|
|
'-c:v', 'copy',
|
|
],
|
|
output: [
|
|
'-flags', '+global_header',
|
|
'-f', 'rtsp',
|
|
'-rtsp_transport', 'tcp',
|
|
streamData.rtspPublishUrl
|
|
]
|
|
})
|
|
const liveCallData = {
|
|
deviceId: streamData.deviceId,
|
|
sessionId: liveCall.sessionId
|
|
}
|
|
parentPort.postMessage({ state: 'active', liveCallData })
|
|
liveCall.onCallEnded.subscribe(() => {
|
|
debug(colors.green(`[${streamData.deviceName}] `)+'Live stream for camera has ended')
|
|
parentPort.postMessage({ state: 'inactive', liveCallData })
|
|
removeActiveCall(liveCallData.deviceId, streamData.deviceName)
|
|
})
|
|
liveCall.deviceId = streamData.deviceId
|
|
activeCalls.push(liveCall)
|
|
} catch(e) {
|
|
debug(e)
|
|
parentPort.postMessage({ state: 'failed', liveCallData: { deviceId: streamData.deviceId }})
|
|
return false
|
|
}
|
|
} else if (data.command === 'stop') {
|
|
if (activeCall) {
|
|
activeCall.stop()
|
|
} else {
|
|
debug(colors.green(`[${streamData.deviceName}] `)+'Received live stream stop command but no active live call found')
|
|
parentPort.postMessage({ state: 'inactive', liveCallData: { deviceId: streamData.deviceId }})
|
|
}
|
|
}
|
|
})
|