|
@@ -27,7 +27,7 @@ socketServer.connectionCount = 0;
|
27
|
27
|
socketServer.on('connection', function(socket, upgradeReq) {
|
28
|
28
|
socketServer.connectionCount++;
|
29
|
29
|
console.log(
|
30
|
|
- 'New WebSocket Connection: ',
|
|
30
|
+ 'New WebSocket Connection: ',
|
31
|
31
|
(upgradeReq || socket.upgradeReq).socket.remoteAddress,
|
32
|
32
|
(upgradeReq || socket.upgradeReq).headers['user-agent'],
|
33
|
33
|
'('+socketServer.connectionCount+' total)'
|
|
@@ -61,7 +61,7 @@ var streamServer = http.createServer( function(request, response) {
|
61
|
61
|
|
62
|
62
|
response.connection.setTimeout(0);
|
63
|
63
|
console.log(
|
64
|
|
- 'Stream Connected: ' +
|
|
64
|
+ 'Stream Connected: ' +
|
65
|
65
|
request.socket.remoteAddress + ':' +
|
66
|
66
|
request.socket.remotePort
|
67
|
67
|
);
|
|
@@ -83,7 +83,10 @@ var streamServer = http.createServer( function(request, response) {
|
83
|
83
|
var path = 'recordings/' + Date.now() + '.ts';
|
84
|
84
|
request.socket.recording = fs.createWriteStream(path);
|
85
|
85
|
}
|
86
|
|
-}).listen(STREAM_PORT);
|
|
86
|
+})
|
|
87
|
+// Keep the socket open for streaming
|
|
88
|
+streamServer.headersTimeout = 0;
|
|
89
|
+streamServer.listen(STREAM_PORT);
|
87
|
90
|
|
88
|
91
|
console.log('Listening for incomming MPEG-TS Stream on http://127.0.0.1:'+STREAM_PORT+'/<secret>');
|
89
|
92
|
console.log('Awaiting WebSocket connections on ws://127.0.0.1:'+WEBSOCKET_PORT+'/');
|