test(socket): add tests for socketTimeout option

Author: nkaradzhov

packages/client/lib/client/socket.spec.ts

@@ -2,13 +2,12 @@ import { strict as assert } from 'node:assert';
 import { spy } from 'sinon';
 import { once } from 'node:events';
 import RedisSocket, { RedisSocketOptions } from './socket';
+import testUtils, { GLOBAL } from '../test-utils';
+import { setTimeout } from 'timers/promises';
 
 describe('Socket', () => {
   function createSocket(options: RedisSocketOptions): RedisSocket {
-    const socket = new RedisSocket(
-      () => Promise.resolve(),
-      options
-    );
+    const socket = new RedisSocket(() => Promise.resolve(), options);
 
     socket.on('error', () => {
       // ignore errors
@@ -84,4 +83,51 @@ describe('Socket', () => {
       assert.equal(socket.isOpen, false);
     });
   });
+
+  describe('socketTimeout', () => {
+    const timeout = 50;
+    testUtils.testWithClient(
+      'should timeout with positive socketTimeout values',
+      async client => {
+        let timedOut = false;
+        assert.equal(client.isOpen, true);
+        client.on('error', err => {
+          assert.equal(
+            err.message,
+            `Socket timeout timeout. Expecting data, but didn't receive any in ${timeout}ms.`
+          );
+          timedOut = true;
+        });
+        await setTimeout(timeout! * 2);
+        if (!timedOut) assert.fail('Should have timed out');
+      },
+      {
+        ...GLOBAL.SERVERS.OPEN,
+        clientOptions: {
+          socket: {
+            socketTimeout: timeout
+          }
+        }
+      }
+    );
+
+    testUtils.testWithClient(
+      'should not timeout with undefined socketTimeout',
+      async client => {
+        assert.equal(client.isOpen, true);
+        client.on('error', err => {
+          assert.fail('Should not have timed out or errored in any way');
+        });
+        await setTimeout(100);
+      },
+      {
+        ...GLOBAL.SERVERS.OPEN,
+        clientOptions: {
+          socket: {
+            socketTimeout: undefined
+          }
+        }
+      }
+    );
+  });
 });