Add support for LATENCY LATEST (#2514)

* Add support for LATENCY LATEST.

* Fix the review comments.

* Fix the review comments.

* Update LATENCY_LATEST.ts

* Update dockers.ts

* Update LATENCY_GRAPH.spec.ts

* enable debug mode in tests

---------

Co-authored-by: Leibale Eidelman <me@leibale.com>

packages/client/lib/client/commands.ts

@@ -84,6 +84,7 @@ import * as KEYS from '../commands/KEYS';
 import * as LASTSAVE from '../commands/LASTSAVE';
 import * as LATENCY_DOCTOR from '../commands/LATENCY_DOCTOR';
 import * as LATENCY_GRAPH from '../commands/LATENCY_GRAPH';
+import * as LATENCY_LATEST from '../commands/LATENCY_LATEST';
 import * as LOLWUT from '../commands/LOLWUT';
 import * as MEMORY_DOCTOR from '../commands/MEMORY_DOCTOR';
 import * as MEMORY_MALLOC_STATS from '../commands/MEMORY_MALLOC-STATS';
@@ -290,6 +291,8 @@ export default {
     latencyDoctor: LATENCY_DOCTOR,
     LATENCY_GRAPH,
     latencyGraph: LATENCY_GRAPH,
+    LATENCY_LATEST,
+    latencyLatest: LATENCY_LATEST,
     LOLWUT,
     lolwut: LOLWUT,
     MEMORY_DOCTOR,

packages/client/lib/commands/LATENCY_GRAPH.spec.ts

@@ -24,9 +24,5 @@ describe('LATENCY GRAPH', () => {
             typeof await client.latencyGraph('command'),
             'string'
         );
-    }, {
+    }, GLOBAL.SERVERS.OPEN);
-        serverArguments: testUtils.isVersionGreaterThan([7]) ?
-            ['--enable-debug-command', 'yes'] :
-            GLOBAL.SERVERS.OPEN.serverArguments
-    });
 });

packages/client/lib/commands/LATENCY_LATEST.spec.ts

@@ -0,0 +1,27 @@
+import {strict as assert} from 'assert';
+import testUtils, {GLOBAL} from '../test-utils';
+import { transformArguments } from './LATENCY_LATEST';
+
+describe('LATENCY LATEST', () => {
+    it('transformArguments', () => {
+        assert.deepEqual(
+            transformArguments(),
+            ['LATENCY', 'LATEST']
+        );
+    });
+
+    testUtils.testWithClient('client.latencyLatest', async client => {
+        await Promise.all([
+            client.configSet('latency-monitor-threshold', '100'),
+            client.sendCommand(['DEBUG', 'SLEEP', '1'])
+        ]);
+        const latency = await client.latencyLatest();
+        assert.ok(Array.isArray(latency));
+        for (const [name, timestamp, latestLatency, allTimeLatency] of latency) {
+            assert.equal(typeof name, 'string');
+            assert.equal(typeof timestamp, 'number');
+            assert.equal(typeof latestLatency, 'number');
+            assert.equal(typeof allTimeLatency, 'number');
+        }
+    }, GLOBAL.SERVERS.OPEN);
+});

packages/client/lib/commands/LATENCY_LATEST.ts

@@ -0,0 +1,12 @@
+import { RedisCommandArguments } from '.';
+
+export function transformArguments(): RedisCommandArguments {
+    return ['LATENCY', 'LATEST'];
+}
+
+export declare function transformReply(): Array<[
+    name: string,
+    timestamp: number,
+    latestLatency: number,
+    allTimeLatency: number
+]>;

packages/client/lib/test-utils.ts

@@ -2,18 +2,24 @@ import TestUtils from '@redis/test-utils';
 import { SinonSpy } from 'sinon';
 import { promiseTimeout } from './utils';
 
-export default new TestUtils({
+const utils = new TestUtils({
-    dockerImageName: 'redis',
+  dockerImageName: 'redis',
-    dockerImageVersionArgument: 'redis-version'
+  dockerImageVersionArgument: 'redis-version'
 });
 
+export default utils;
+
+const DEBUG_MODE_ARGS = utils.isVersionGreaterThan([7]) ?
+  ['--enable-debug-command', 'yes'] :
+  [];
+
 export const GLOBAL = {
     SERVERS: {
         OPEN: {
-            serverArguments: []
+            serverArguments: [...DEBUG_MODE_ARGS]
         },
         PASSWORD: {
-            serverArguments: ['--requirepass', 'password'],
+            serverArguments: ['--requirepass', 'password', ...DEBUG_MODE_ARGS],
             clientOptions: {
                 password: 'password'
             }
@@ -21,10 +27,10 @@ export const GLOBAL = {
     },
     CLUSTERS: {
         OPEN: {
-            serverArguments: []
+            serverArguments: [...DEBUG_MODE_ARGS]
         },
         PASSWORD: {
-            serverArguments: ['--requirepass', 'password'],
+            serverArguments: ['--requirepass', 'password', ...DEBUG_MODE_ARGS],
             clusterConfiguration: {
                 defaults: {
                     password: 'password'
@@ -32,7 +38,7 @@ export const GLOBAL = {
             }
         },
         WITH_REPLICAS: {
-            serverArguments: [],
+            serverArguments: [...DEBUG_MODE_ARGS],
             numberOfMasters: 2,
             numberOfReplicas: 1,
             clusterConfiguration: {