Added ability to send custom http headers to server

lib/eventsource.js

@@ -4,13 +4,18 @@ var http = require('http')
   , events = require('events')
   , eventstream = require('./eventstream');
 
+function isPlainObject(obj) {
+    return Object.getPrototypeOf(obj) === Object.prototype;
+}
+
 /**
  * Creates a new EventSource object
  *
  * @param {String} url the URL to which to connect
+ * @param {Object} headers headers to use
  * @api public
  **/
-function EventSource(url) {
+function EventSource(url, headers) {
     var readyState = EventSource.CONNECTING;
     Object.defineProperty(this, 'readyState', {
         get: function() {
@@ -54,6 +59,12 @@ function EventSource(url) {
         var isSecure = options.protocol == 'https:';
         options.headers = { 'Cache-Control': 'no-cache', 'Accept': 'text/event-stream' };
         if (lastEventId) options.headers['last-event-id'] = lastEventId;
+        if (headers && isPlainObject(headers)) {
+            for (var i in headers) {
+                var header = headers[i];
+                options.headers[i] = header;
+            }
+        }
 
         req = (isSecure ? https : http).request(options, function(res) {
             // Handle HTTP redirects

test/eventsource_test.js

@@ -260,6 +260,29 @@ exports['HTTP Request'] = {
         }, function(req) { headers = req.headers; });
     },
 
+    'sets headers by user': function(test) {
+        var url = 'http://localhost:' + port;
+        var headers = {
+          'User-Agent': 'test',
+          'Cookie': 'test=test'
+        };
+        createServer([],
+            function(close) {
+                var es = new EventSource(url, headers);
+                es.onopen = function() {
+                    es.close();
+                    close(test.done);
+                };
+            },
+            function(req, res) {
+                test.equal(req.headers['user-agent'], headers['User-Agent']);
+                test.equal(req.headers['cookie'], headers['Cookie']);
+                res.writeHead(200);
+                res.end();
+                return true;
+            });
+    },
+
     'follows http 301 redirect': function(test) {
         var headers;
         var url = 'http://localhost:' + port;