fix logger reference in onEnd (#119)

Author: mj-hd

index.js

@@ -382,7 +382,7 @@ function compress (params) {
 }
 
 function onEnd (err) {
-  if (err) this.raw.log.error(err)
+  if (err) this.log.error(err)
 }
 
 function trackEncodedLength (chunk) {

test/test-global-compress.js

@@ -5,6 +5,7 @@ const test = t.test
 const zlib = require('zlib')
 const fs = require('fs')
 const JSONStream = require('jsonstream')
+const { Readable, Writable } = require('stream')
 const createReadStream = fs.createReadStream
 const readFileSync = fs.readFileSync
 const Fastify = require('fastify')
@@ -1692,3 +1693,45 @@ test('Should send data gzipped according to zlibOptions', t => {
     t.same(res.rawPayload, zlib.gzipSync(fileBuffer, zlibOptions))
   })
 })
+
+test('stream onEnd handler should log an error if exists', t => {
+  t.plan(1)
+
+  let actual = null
+  const logger = new Writable({
+    write (chunk, encoding, callback) {
+      actual = JSON.parse(chunk.toString())
+    }
+  })
+
+  const fastify = Fastify({
+    global: false,
+    logger: {
+      level: 'error',
+      stream: logger
+    }
+  })
+
+  fastify.register(compressPlugin)
+
+  const expect = new Error('something wrong')
+
+  fastify.get('/', (req, reply) => {
+    const stream = new Readable({
+      read (size) {
+        this.destroy(expect)
+      }
+    })
+    reply.type('text/plain').compress(stream)
+  })
+
+  fastify.inject({
+    url: '/',
+    method: 'GET',
+    headers: {
+      'accept-encoding': 'gzip'
+    }
+  }, (_, res) => {
+    t.equal(actual.msg, expect.message)
+  })
+})