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
|
/**************************
TODO:
1. Make it work with existing HTTP servers and listen to resource URLs
**************************/
var http = require('http'),
sys = require('sys'),
url = require('url');
Proxy = exports.Proxy = function (srcURL, options) {
if (!srcURL) throw new Error("Please provide a source feed URL");
srcURL = url.parse(srcURL);
var srcClient = http.createClient(srcURL.port || 80, srcURL.hostname);
var audienceServer = options.audienceServer || http.createServer();
var audienceServerPort = options.port || 5080;
var audienceClients = [];
// Starting the stream on from the source
var request = srcClient.request('GET', srcURL.pathname +
(srcURL.search ? srcURL.search : ""),
{'host': srcURL.hostname});
request.end();
request.on('response', function (srcResponse) {
/** Setup Audience server listener **/
audienceServer.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);
});
});
audienceServer.listen(audienceServerPort);
sys.puts('node-mjpeg-proxy server started on port 5080');
/** 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');
}
});
});
};
|
