feat: add LATENCY_RESET command (#3047)

2025-12-11 09:22:35 +03:00 · 2025-08-27 18:10:15 +03:00
parent 672246dbd2
commit 1d824df9e1
3 changed files with 131 additions and 0 deletions
--- a/packages/client/lib/commands/LATENCY_RESET.spec.ts
+++ b/packages/client/lib/commands/LATENCY_RESET.spec.ts
@@ -0,0 +1,104 @@
+import { strict as assert } from 'node:assert';
+import testUtils, { GLOBAL } from '../test-utils';
+import LATENCY_RESET, { LATENCY_EVENTS } from './LATENCY_RESET';
+import { parseArgs } from './generic-transformers';
+
+describe('LATENCY RESET', function () {
+
+
+    it('transformArguments with no events', () => {
+        assert.deepEqual(
+            parseArgs(LATENCY_RESET),
+            [
+                'LATENCY',
+                'RESET'
+            ]
+        );
+    });
+
+    it('transformArguments with one event', () => {
+        assert.deepEqual(
+            parseArgs(LATENCY_RESET, LATENCY_EVENTS.COMMAND),
+            [
+                'LATENCY',
+                'RESET',
+                'command'
+            ]
+        );
+    });
+
+    it('transformArguments with multiple events', () => {
+        assert.deepEqual(
+            parseArgs(LATENCY_RESET, LATENCY_EVENTS.COMMAND, LATENCY_EVENTS.FORK),
+            [
+                'LATENCY',
+                'RESET',
+                'command',
+                'fork'
+            ]
+        );
+    });
+
+
+    testUtils.testWithClient('client.latencyReset', async client => {
+
+        await client.configSet('latency-monitor-threshold', '1');
+
+
+        await client.sendCommand(['DEBUG', 'SLEEP', '0.1']);
+
+
+        const latestLatencyBeforeReset = await client.latencyLatest();
+        assert.ok(latestLatencyBeforeReset.length > 0, 'Expected latency events to be recorded before first reset.');
+        assert.equal(latestLatencyBeforeReset[0][0], 'command', 'Expected "command" event to be recorded.');
+        assert.ok(Number(latestLatencyBeforeReset[0][2]) >= 100, 'Expected latest latency for "command" to be at least 100ms.');
+
+
+        const replyAll = await client.latencyReset();
+
+        assert.equal(typeof replyAll, 'number');
+        assert.ok(replyAll >= 0);
+
+
+        const latestLatencyAfterAllReset = await client.latencyLatest();
+        assert.deepEqual(latestLatencyAfterAllReset, [], 'Expected no latency events after resetting all.');
+
+
+        await client.sendCommand(['DEBUG', 'SLEEP', '0.05']);
+        const latestLatencyBeforeSpecificReset = await client.latencyLatest();
+        assert.ok(latestLatencyBeforeSpecificReset.length > 0, 'Expected latency events before specific reset.');
+
+
+        const replySpecific = await client.latencyReset(LATENCY_EVENTS.COMMAND);
+        assert.equal(typeof replySpecific, 'number');
+        assert.ok(replySpecific >= 0);
+
+
+        const latestLatencyAfterSpecificReset = await client.latencyLatest();
+        assert.deepEqual(latestLatencyAfterSpecificReset, [], 'Expected no latency events after specific reset of "command".');
+
+
+        await client.sendCommand(['DEBUG', 'SLEEP', '0.02']);
+
+
+        const latestLatencyBeforeMultipleReset = await client.latencyLatest();
+        assert.ok(latestLatencyBeforeMultipleReset.length > 0, 'Expected latency events before multiple reset.');
+
+
+        const replyMultiple = await client.latencyReset(LATENCY_EVENTS.COMMAND, LATENCY_EVENTS.FORK);
+        assert.equal(typeof replyMultiple, 'number');
+        assert.ok(replyMultiple >= 0);
+
+        const latestLatencyAfterMultipleReset = await client.latencyLatest();
+        assert.deepEqual(latestLatencyAfterMultipleReset, [], 'Expected no latency events after multiple specified resets.');
+
+    }, {
+
+        ...GLOBAL.SERVERS.OPEN,
+        clientOptions: {
+            socket: {
+                connectTimeout: 300000
+            }
+        }
+    });
+});