From e4760727f1b8d652abfeaa407f5ddfd252e9483e Mon Sep 17 00:00:00 2001
From: "Aaron T. Maturen" <aaron.maturen@gmail.com>
Date: Sun, 6 Dec 2015 19:34:42 -0500
Subject: [PATCH] SSE example and test

---
 examples/http/sse.js        | 67 +++++++++++++++++++++++++++++++++++++
 examples/package.json       |  3 +-
 package.json                |  1 +
 test/lib-http-proxy-test.js | 37 +++++++++++++++++++-
 4 files changed, 106 insertions(+), 2 deletions(-)
 create mode 100644 examples/http/sse.js

diff --git a/examples/http/sse.js b/examples/http/sse.js
new file mode 100644
index 000000000..b6e3f065c
--- /dev/null
+++ b/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 --git a/examples/package.json b/examples/package.json
index 9bc57095a..93cc86519 100644
--- a/examples/package.json
+++ b/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 --git a/package.json b/package.json
index b003eb8c7..c951425ff 100644
--- a/package.json
+++ b/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 --git a/test/lib-http-proxy-test.js b/test/lib-http-proxy-test.js
index 6380b8bce..edbb6f9f1 100644
--- a/test/lib-http-proxy-test.js
+++ b/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({