Emit a reconnectFailure event

Readme.md

@@ -54,11 +54,12 @@ pino(transport)
 
 ### Events
 
-| Name          | Callback Signature               | Description                                                                                                                                          |
-|---------------|----------------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------|
-| `open`        | `(address: AddressInfo) => void` | Emitted when the TCP or UDP connection is established.                                                                                               |
-| `socketError` | `(error: Error) => void`         | Emitted when an error occurs on the TCP or UDP socket. The socket won't be closed.                                                                   |
-| `close`       | `(hadError: Boolean) => void`    | Emitted after the TCP or UDP socket is closed. The argument `hadError` is a boolean which says if the socket was closed due to a transmission error. |
+| Name               | Callback Signature                      | Description                                                                                                                                          |
+|--------------------|-----------------------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------|
+| `open`             | `(address: AddressInfo) => void`        | Emitted when the TCP or UDP connection is established.                                                                                               |
+| `socketError`      | `(error: Error) => void`                | Emitted when an error occurs on the TCP or UDP socket. The socket won't be closed.                                                                   |
+| `close`            | `(hadError: Boolean) => void`           | Emitted after the TCP or UDP socket is closed. The argument `hadError` is a boolean which says if the socket was closed due to a transmission error. |
+| `reconnectFailure` | `(error: Error|undefined) => void` | Emitted when the maximum number of backoffs (i.e., reconnect tries) is reached on a TCP connection.                                                  |
 
 **IMPORTANT:** In version prior to 6.0, an `error` event was emitted on the writable stream when an error occurs on the TCP or UDP socket.
 In other words, it was not possible to write data to the writable stream after an error occurs on the TCP or UDP socket.

lib/TcpConnection.js

@@ -130,8 +130,8 @@ module.exports = function factory (userOptions) {
     }
   }
 
-  function reconnect () {
-    retryBackoff.backoff()
+  function reconnect (err) {
+    retryBackoff.backoff(err)
   }
   // end: connection handlers
 
@@ -144,7 +144,7 @@ module.exports = function factory (userOptions) {
       }
     }
     if (options.reconnect) {
-      reconnect()
+      reconnect(hadError && socketError)
     } else {
       outputStream.emit('close', hadError)
     }
@@ -218,7 +218,7 @@ module.exports = function factory (userOptions) {
         }
       })
     })
-    retry.on('fail', (err) => process.stderr.write(`could not reconnect: ${err.message}`))
+    retry.on('fail', (err) => outputStream.emit('reconnectFailure', err))
     return retry
   }
 

test/tcpRetyFail.js

@@ -0,0 +1,24 @@
+'use strict'
+/* eslint-env node, mocha */
+
+const { expect } = require('chai')
+const TcpConnection = require('../lib/TcpConnection')
+
+test('tcp retry fail', function testTcpRetryFail (done) {
+  let socketErrorCount = 0
+  const tcpConnection = TcpConnection({
+    address: '127.0.0.1',
+    port: 0,
+    reconnect: true,
+    reconnectTries: 2
+  }
+  )
+  tcpConnection.on('socketError', () => {
+    socketErrorCount++
+  })
+  tcpConnection.on('reconnectFailure', (lastError) => {
+    expect(socketErrorCount).to.eq(3)
+    expect(lastError).to.be.an('error')
+    done()
+  })
+})