fix: update Redis client deletion method to accept an array of keys

Author: arnabrahman

packages/idempotency/src/persistence/RedisPersistenceLayer.ts

@@ -86,7 +86,7 @@ class RedisPersistenceLayer extends BasePersistenceLayer {
    * Initializes the Redis connection if it's the default Redis client and not already open.
    *
    * This method attempts to connect to Redis if necessary. If using a custom Redis client,
-   * it assumes the client is already initialized.
+   * it assumes the client is already connected.
    *
    * @throws {IdempotencyPersistenceConnectionError} When the connection to Redis fails
    */
@@ -123,7 +123,7 @@ class RedisPersistenceLayer extends BasePersistenceLayer {
     console.debug(
       `Deleting record for idempotency key: ${record.idempotencyKey}`
     );
-    await this.#client.del(record.idempotencyKey);
+    await this.#client.del([record.idempotencyKey]);
   }
 
   protected async _putRecord(record: IdempotencyRecord): Promise<void> {

packages/idempotency/src/types/RedisPersistence.ts

@@ -1,6 +1,11 @@
+import type { JSONValue } from '@aws-lambda-powertools/commons/types';
+
 /**
  * Protocol defining the interface for a Redis client.
- * This ensures standardization among different Redis client implementations.
+ *
+ * This protocol outlines the expected behavior of a Redis client, allowing for
+ * standardization among different implementations and allowing customers to extend it
+ * in their own implementation.
  */
 interface RedisClientProtocol {
   /**
@@ -17,18 +22,18 @@ interface RedisClientProtocol {
    */
   set(
     name: string,
-    value: string,
+    value: JSONValue,
     options?: {
       EX?: number; // Expiration time in seconds
       NX?: boolean; // Only set the key if it does not already exist
     }
   ): Promise<string | null>;
 
   /**
-   * Deletes one or more keys.
-   * @param keys The key(s) to delete
+   * Deletes the specified keys from Redis.
+   * @param keys The keys to delete
    */
-  del(keys: string): Promise<number>;
+  del(keys: string[]): Promise<number>;
 }
 
 /**

packages/idempotency/tests/unit/persistence/RedisPersistenceLayer.test.ts

@@ -399,7 +399,7 @@ describe('Class: RedisPersistenceLayerTestClass', () => {
         await layer._deleteRecord(record);
 
         // Assess
-        expect(client.del).toHaveBeenCalledWith(dummyKey);
+        expect(client.del).toHaveBeenCalledWith([dummyKey]);
         expect(consoleDebugSpy).toHaveBeenCalledWith(
           `Deleting record for idempotency key: ${record.idempotencyKey}`
         );