Add connectionAttemptFailed event.

danielwippermann · Jan 21, 2024 · 54f2f93 · 54f2f93
1 parent 82b4907
commit 54f2f93
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 0 deletions.
diff --git a/src/tcp-connection-endpoint.js b/src/tcp-connection-endpoint.js
@@ -162,6 +162,13 @@ class TcpConnectionEndpoint extends EventEmitter {
 
                 const callback = function(err, result, transition) {
                     if (err) {
+                        _this.emit('connectionAttemptFailed', {
+                            ip: socket.remoteAddress,
+                            family: socket.remoteFamily,
+                            port: socket.remotePort,
+                            error: err,
+                        });
+
                         write('-ERROR: ' + JSON.stringify(err.toString()) + '\r\n');
                     } else {
                         write(result.toString() + '\r\n');

diff --git a/test/specs/tcp-connection-endpoint.spec.js b/test/specs/tcp-connection-endpoint.spec.js
@@ -343,6 +343,10 @@ describe('TcpConnectionEndpoint', () => {
 
         it('should work correctly with a rejecting viaTag verifier', async () => {
             await runTestableEndpointAndSocket(async ({ ep, socket, read }) => {
+                const onConnectionAttemptFailed = jest.fn();
+
+                ep.on('connectionAttemptFailed', onConnectionAttemptFailed);
+
                 const endPromise = new Promise(resolve => {
                     socket.once('end', () => {
                         resolve();
@@ -365,6 +369,22 @@ describe('TcpConnectionEndpoint', () => {
 
                 socket.end();
 
+                expect(onConnectionAttemptFailed.mock.calls).toHaveLength(1);
+                expect(onConnectionAttemptFailed.mock.calls [0]).toHaveLength(1);
+
+                const ev1 = onConnectionAttemptFailed.mock.calls [0] [0];
+
+                expectOwnPropertyNamesToEqual(ev1, [
+                    'ip',
+                    'port',
+                    'family',
+                    'error',
+                ]);
+                expect(typeof ev1.ip).toBe('string');
+                expect(typeof ev1.port).toBe('number');
+                expect(ev1.family).toBe('IPv6');
+                expect(ev1.error.message).toBe('Unknown viaTag: unknownViaTag');
+
                 await endPromise;
             });
         });