redis v4 passing

Author: amychisholm03

lib/subscribers/redis/commands-executor.js

@@ -0,0 +1,17 @@
+/*
+ * Copyright 2026 New Relic Corporation. All rights reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+'use strict'
+const ClientPropagationSubscriber = require('./client-propagation')
+
+/**
+ * Listens to events on RedisClient.commandsExectutor for redis versions <=5.
+ * Replacement for send-command.js for that version.
+ */
+module.exports = class ClientCommandsExecutorSubscriber extends ClientPropagationSubscriber {
+  constructor({ agent, logger }) {
+    super({ agent, logger, channelName: 'nr_commandsExecutor' })
+  }
+}

lib/subscribers/redis/config.js

@@ -7,9 +7,7 @@ const addCommand = {
   path: './redis/add-command',
   instrumentations: [{
     channelName: 'nr_addCommand',
-    module: { name: '@redis/client',
-      versionRange: '>=4',
-      filePath: 'dist/lib/client/commands-queue.js' },
+    module: { name: '@redis/client', versionRange: '>=1', filePath: 'dist/lib/client/commands-queue.js' },
     functionQuery: {
       className: 'RedisCommandsQueue',
       methodName: 'addCommand',
@@ -38,7 +36,7 @@ const clientSelect = {
   instrumentations: [
     {
       channelName: 'nr_select',
-      module: { name: '@redis/client', versionRange: '>=4', filePath: 'dist/lib/client/index.js' },
+      module: { name: '@redis/client', versionRange: '>=1', filePath: 'dist/lib/client/index.js' },
       functionQuery: {
         className: 'RedisClient',
         methodName: 'SELECT',
@@ -53,7 +51,7 @@ const clientMulti = {
   instrumentations: [
     {
       channelName: 'nr_multi',
-      module: { name: '@redis/client', versionRange: '>=4', filePath: 'dist/lib/client/index.js' },
+      module: { name: '@redis/client', versionRange: '>=1', filePath: 'dist/lib/client/index.js' },
       functionQuery: {
         className: 'RedisClient',
         methodName: 'MULTI',
@@ -63,11 +61,27 @@ const clientMulti = {
   ]
 }
 
+const commandsExecutor = {
+  path: './redis/commands-executor',
+  instrumentations: [
+    {
+      channelName: 'nr_commandsExecutor',
+      module: { name: '@redis/client', versionRange: '>=1 <4', filePath: 'dist/lib/client/index.js' },
+      functionQuery: {
+        className: 'RedisClient',
+        methodName: 'commandsExecutor',
+        kind: 'Async'
+      }
+    }
+  ]
+}
+
 module.exports = {
   '@redis/client': [
     addCommand,
-    sendCommand,
+    sendCommand, // >=v5
     clientSelect,
-    clientMulti
+    clientMulti,
+    commandsExecutor // v4
   ]
 }

test/versioned/redis/package.json

@@ -1,6 +1,11 @@
 {
   "name": "redis-tests",
-  "targets": [{"name":"redis","minAgentVersion":"1.31.0"}],
+  "targets": [
+    {
+      "name": "redis",
+      "minAgentVersion": "1.31.0"
+    }
+  ],
   "version": "0.0.0",
   "private": true,
   "tests": [
@@ -29,5 +34,8 @@
         "tls.test.js"
       ]
     }
-  ]
+  ],
+  "dependencies": {
+    "redis": "^4.7.1"
+  }
 }

test/versioned/redis/redis-v4.test.js

@@ -58,7 +58,7 @@ test('Redis instrumentation', async function (t) {
 
   await t.test('should log tracking metrics', function(t) {
     const { agent } = t.nr
-    const { version } = require('redis/package.json')
+    const { version } = require('@redis/client/package.json')
     assertPackageMetrics({ agent, pkg: '@redis/client', version, subscriberType: true })
   })