Fix #42

logger.js

@@ -12,7 +12,7 @@ function pinoLogger (opts, stream) {
 
   opts = opts || {}
   opts.serializers = opts.serializers || {}
-  opts.serializers.req = opts.serializers.req || asReqValue
+  opts.serializers.req = wrapReqSerializer(opts.serializers.req || asReqValue)
   opts.serializers.res = opts.serializers.res || pino.stdSerializers.res
   opts.serializers.err = opts.serializers.err || pino.stdSerializers.err
 
@@ -64,6 +64,18 @@ function pinoLogger (opts, stream) {
   }
 }
 
+function wrapReqSerializer (serializer) {
+  if (serializer === asReqValue) return asReqValue
+  return function wrappedReqSerializer (req) {
+    var _req = asReqValue(req)
+    Object.defineProperty(_req, 'raw', {
+      enumerable: false,
+      value: req
+    })
+    return serializer(_req)
+  }
+}
+
 function asReqValue (req) {
   var connection = req.connection
   return {

test.js

@@ -303,3 +303,34 @@ test('does not crash when no request connection object', function (t) {
     res.end()
   }
 })
+
+// https://github.com/pinojs/pino-http/issues/42
+test('does not return excessively log object', function (t) {
+  var dest = split(JSON.parse)
+  var logger = pinoHttp({
+    logger: pino(dest),
+    serializers: {
+      req: function (req) {
+        delete req.connection
+        return req
+      }
+    }
+  })
+  t.plan(1)
+
+  var server = http.createServer(handler)
+  server.unref()
+  server.listen(0, () => {
+    const port = server.address().port
+    http.get(`http://127.0.0.1:${port}`, () => {})
+  })
+
+  function handler (req, res) {
+    logger(req, res)
+    res.end()
+  }
+
+  dest.on('data', function (obj) {
+    t.is(Object.keys(obj.req).length, 6)
+  })
+})