Merge pull request #922 from aaronmaturen/sse

SSE example and test

Author: jcrugzz

Diff for: examples/http/sse.js

@@ -0,0 +1,67 @@
+/*
+  sse.js: Basic example of proxying over HTTP
+
+  Copyright (c) Nodejitsu 2013
+
+  Permission is hereby granted, free of charge, to any person obtaining
+  a copy of this software and associated documentation files (the
+  "Software"), to deal in the Software without restriction, including
+  without limitation the rights to use, copy, modify, merge, publish,
+  distribute, sublicense, and/or sell copies of the Software, and to
+  permit persons to whom the Software is furnished to do so, subject to
+  the following conditions:
+
+  The above copyright notice and this permission notice shall be
+  included in all copies or substantial portions of the Software.
+
+  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+  MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+  NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+  LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+  OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+  WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+*/
+
+var util = require('util'),
+    colors = require('colors'),
+    http = require('http'),
+    httpProxy = require('../../lib/http-proxy'),
+    SSE = require('sse');
+
+//
+// Basic Http Proxy Server
+//
+var proxy = new httpProxy.createProxyServer();
+http.createServer(function (req, res) {
+  proxy.web(req, res, {
+    target: 'http://localhost:9003'
+  });
+}).listen(8003);
+
+//
+// Target Http Server
+//
+var server = http.createServer(function(req, res) {
+  res.writeHead(200, {'Content-Type': 'text/html'});
+  res.write('request successfully proxied to: ' + req.url + '\n' + JSON.stringify(req.headers, true, 2));
+  res.end();
+});
+
+//
+// Use SSE 
+//
+
+var sse = new SSE(server, {path: '/'});
+sse.on('connection', function(client) {
+  var count = 0;
+  setInterval(function(){
+    client.send('message #' + count++);
+  }, 1500);
+});
+
+server.listen(9003);
+
+util.puts('http proxy server'.blue + ' started '.green.bold + 'on port '.blue + '8003'.yellow);
+util.puts('http server '.blue + 'started '.green.bold + 'on port '.blue + '9003 '.yellow);

Diff for: examples/package.json

@@ -9,6 +9,7 @@
     "connect-restreamer": "~1.0.0",
     "request": "~2.27.0",
     "socket.io": "~0.9.16",
-    "socket.io-client": "~0.9.16"
+    "socket.io-client": "~0.9.16",
+    "sse": "0.0.6"
   }
 }

Diff for: package.json

@@ -27,6 +27,7 @@
     "semver": "^5.0.3",
     "socket.io": "*",
     "socket.io-client": "*",
+    "sse": "0.0.6",
     "ws": "^0.8.0"
   },
   "scripts": {

Diff for: test/lib-http-proxy-test.js

@@ -3,6 +3,7 @@ var httpProxy = require('../lib/http-proxy'),
     http      = require('http'),
     ws        = require('ws')
     io        = require('socket.io'),
+    SSE       = require('sse'),
     ioClient  = require('socket.io-client');
 
 //
@@ -62,6 +63,41 @@ describe('lib/http-proxy.js', function() {
   });
 
   describe('#createProxyServer using the web-incoming passes', function () {
+    it('should proxy sse', function(done){
+      var ports = { source: gen.port, proxy: gen.port },
+      proxy = httpProxy.createProxyServer({
+        target: 'http://localhost:' + ports.source,
+      }),
+      proxyServer = proxy.listen(ports.proxy),
+      source = http.createServer(),
+      sse = new SSE(source, {path: '/'});
+
+      sse.on('connection', function(client) {
+        client.send('Hello over SSE');
+        client.close();
+      });
+
+      source.listen(ports.source);
+
+      var options = {
+        hostname: 'localhost',
+        port: ports.proxy,
+      };
+
+      var req = http.request(options, function(res) {
+        var streamData = '';
+        res.on('data', function (chunk) {
+          streamData += chunk.toString('utf8');
+        });
+        res.on('end', function (chunk) {
+          expect(streamData).to.equal(':ok\n\ndata: Hello over SSE\n\n');
+          source.close();
+          proxy.close();
+          done();
+        });
+      }).end();
+    });
+
     it('should make the request on pipe and finish it', function(done) {
       var ports = { source: gen.port, proxy: gen.port };
       var proxy = httpProxy.createProxyServer({
@@ -336,7 +372,6 @@ describe('lib/http-proxy.js', function() {
       });
     });
 
-
     it('should proxy a socket.io stream', function (done) {
       var ports = { source: gen.port, proxy: gen.port },
       proxy = httpProxy.createProxyServer({