Add objectMode option for objectMode streams

README.md

@@ -48,6 +48,10 @@ morgan('combined', {
 
 Output stream for writing log lines, defaults to `process.stdout`.
 
+##### objectMode
+
+Interpret log lines as objects when writing to `stream`.
+
 #### Predefined Formats
 
 There are various pre-defined formats provided:

index.js

@@ -75,6 +75,9 @@ function morgan (format, options) {
   // output on request instead of response
   var immediate = opts.immediate
 
+  // output to an objectMode stream
+  var objectMode = opts.objectMode
+
   // check if log entry should be skipped
   var skip = opts.skip || false
 
@@ -127,6 +130,11 @@ function morgan (format, options) {
       }
 
       debug('log request')
+      if (objectMode) {
+        stream.write(line)
+        return
+      }
+
       stream.write(line + '\n')
     };
 

test/morgan.js

@@ -1290,6 +1290,40 @@ describe('morgan()', function () {
       .expect(200, done)
     })
   })
+
+  describe('with objectMode option', function () {
+    it('should write the literal object value', function (done) {
+      var cb = after(1, function (err) {
+        if (err) return done(err)
+        done()
+      })
+
+      function format (tokens, req, res) {
+        return {
+          method: tokens.method(req, res),
+          url: tokens.url(req, res),
+          status: tokens.status(req, res)
+        }
+      }
+
+      var stream = {
+        write: function (obj) {
+          assert.equal(obj.method, 'GET')
+          assert.equal(obj.url, '/')
+          assert.equal(obj.status, 200)
+        }
+      }
+
+      var server = createServer(format, {
+        stream: stream,
+        objectMode: true
+      })
+
+      request(server)
+      .get('/')
+      .expect(200, cb)
+    })
+  })
 })
 
 describe('morgan.compile(format)', function () {