Merge pull request #1 from launchdarkly/http-method-and-body

allow setting of HTTP request method and body

Author: eli-darkly

lib/eventsource.js

@@ -130,6 +130,10 @@ function EventSource (url, eventSourceInitDict) {
       options.withCredentials = eventSourceInitDict.withCredentials
     }
 
+    if (eventSourceInitDict && eventSourceInitDict.method) {
+      options.method = eventSourceInitDict.method
+    }
+
     req = (isSecure ? https : http).request(options, function (res) {
       // Handle HTTP errors
       if (res.statusCode === 500 || res.statusCode === 502 || res.statusCode === 503 || res.statusCode === 504) {
@@ -227,6 +231,10 @@ function EventSource (url, eventSourceInitDict) {
       })
     })
 
+    if (eventSourceInitDict && eventSourceInitDict.body) {
+      req.write(eventSourceInitDict.body)
+    }
+
     req.on('error', function (err) {
       onConnectionClosed(err.message)
     })

test/eventsource_test.js

@@ -527,6 +527,42 @@ describe('HTTP Request', function () {
         }
       )
     })
+  })
+
+  it('uses GET method by default', function (done) {
+    createServer(function (err, server) {
+      if (err) return done(err)
+
+      server.on('request', function (req) {
+        assert.equal(req.method, 'GET')
+        server.close(done)
+      })
+
+      new EventSource(server.url)
+    })
+  })
+
+  it('can specify HTTP method and body', function (done) {
+    var content = '{ "test": true }'
+
+    createServer(function (err, server) {
+      if (err) return done(err)
+
+      server.on('request', function (req) {
+        assert.equal(req.method, 'POST')
+
+        var receivedContent = ''
+        req.on('data', function (chunk) {
+          receivedContent += chunk
+        })
+        req.on('end', function () {
+          assert.equal(content, receivedContent)
+          server.close(done)
+        })
+      })
+
+      new EventSource(server.url, { method: 'POST', body: content })
+    })
   });
 
   [301, 307].forEach(function (status) {