1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
/**************************
TODO:
x. better passing of the headers
2. Make in modular
3. Write it modular so it can be dynamically set for cam creds
**************************/
var http = require('http'),
sys = require('sys'),
url = require('url');
var feedurl = "http://192.168.0.196:8080/videofeed";
feedurl = url.parse(feedurl);
// port of the cam
var cam = http.createClient(feedurl.port, feedurl.hostname);
var audienceClients = [];
var testServer = http.createServer();
testServer.listen(5080, "0.0.0.0");
sys.puts('Server started on port 5080');
// Starting the stream on the cam
var request = cam.request('GET', feedurl.pathname +
(feedurl.search ? feedurl.search : ""),
{'host': feedurl.hostname});
request.end();
request.on('response', function (srcResponse) {
/** Setup server listener **/
testServer.on('request', function (req, res) {
/** Replicate the header from the source **/
res.writeHead(200, srcResponse.headers);
/** Push the client into the client list **/
audienceClients.push(res);
/** Clean up connections when they're dead **/
res.socket.on('close', function () {
audienceClients.splice(audienceClients.indexOf(res), 1);
});
});
/** Send data to relevant clients **/
srcResponse.setEncoding('binary');
srcResponse.on('data', function (chunk) {
var i;
for (i = audienceClients.length; i--;) {
audienceClients[i].write(chunk, 'binary');
}
});
});
|
