feat: command executor method (#6)

commands/commandExecutor.js

@@ -0,0 +1,13 @@
+const debug = require('debug')('systemic-aws-sqs');
+
+module.exports = client => async ({ commandParams, commandName }) => {
+    try {
+        debug(`Calling ${commandName}`);
+        const data = await client[commandName](commandParams);
+        debug(`${commandName} executed successfully`);
+        return data;
+    } catch (error) {
+        debug(`Error executing ${commandName}: ${error.message}`);
+        throw error;
+    }
+};

index.js

@@ -1,20 +1,20 @@
 const debug = require("debug")("systemic-aws-sqs");
-const { SQSClient } = require("@aws-sdk/client-sqs");
+const { SQS, SQSClient } = require("@aws-sdk/client-sqs");
 
 const commands = require("require-all")(__dirname + "/commands");
 
 let client = null;
+let aggregatedSQS = null;
 
 module.exports = () => {
   const start = async ({ config }) => {
     debug("Initializing SQSClient");
     client = new SQSClient(config);
+    aggregatedSQS = new SQS(config);
 
     return {
       client,
-      getQueueUrl: commands["getQueueUrl"](client),
-      sendMessage: commands["sendMessage"](client),
-      receiveMessage: commands["receiveMessage"](client),
+      commandExecutor: commands['commandExecutor'](aggregatedSQS),
     };
   };
 

test/__tests__/commandExecutor.test.js

@@ -0,0 +1,75 @@
+const crypto = require("crypto");
+
+const startSQSComponent = require("../helpers/startSQSComponent");
+const createSQSQueue = require("../helpers/createSQSQueue");
+const deleteSQSQueue = require("../helpers/deleteSQSQueue");
+
+const getLocalstackConfig = require("../fixtures/getLocalstackConfig");
+
+let sqs;
+let createQueue;
+let deleteQueue;
+
+describe("Systemic SQS - commandExecutor function", () => {
+  beforeAll(async () => {
+    sqs = await startSQSComponent(getLocalstackConfig());
+    createQueue = createSQSQueue(sqs);
+    deleteQueue = deleteSQSQueue(sqs);
+  });
+
+  it("should execute the \"getQueueUrl\" command and retrieve it", async () => {
+    const awsAccountId = "000000000000";
+    const queueName = "testQName";
+    await createQueue(queueName);
+
+    const commandParams = { QueueName: queueName, AwsAccountId: awsAccountId }
+    const res = await sqs.commandExecutor({ commandParams, commandName: 'getQueueUrl' });
+
+    expect(res.QueueUrl).toBe(`http://localhost/${awsAccountId}/${queueName}`);
+
+    await deleteQueue(queueName);
+  });
+
+  it("should execute the \"receiveMessage\" command and receive a message from the queue", async () => {
+    const awsAccountId = "000000000000";
+    const messageBody = "Example message";
+    const queueName = "receiveMessageQueueName";
+
+    await createQueue(queueName);
+
+    const getUrlCommandParams = { QueueName: queueName, AwsAccountId: awsAccountId }
+    const urlResponse = await sqs.commandExecutor({ commandParams: getUrlCommandParams, commandName: 'getQueueUrl' });
+
+    const sendMessageCommandParams = { QueueUrl: urlResponse.QueueUrl, MessageBody: messageBody }
+    await sqs.commandExecutor({ commandParams: sendMessageCommandParams, commandName: 'sendMessage' });
+
+    const res = await sqs.commandExecutor({ commandParams: { QueueUrl: urlResponse.QueueUrl }, commandName: 'receiveMessage' });
+
+    expect(res.Messages).toHaveLength(1);
+    expect(res.Messages[0].Body).toBe(messageBody);
+
+    await deleteQueue(queueName);
+  });
+
+  it("should execute the \"sendMessage\" command and send a message", async () => {
+    const awsAccountId = "000000000000";
+    const messageBody = "Example message";
+    const queueName = "testQName1";
+    await createQueue(queueName);
+
+    const getUrlCommandParams = { QueueName: queueName, AwsAccountId: awsAccountId }
+    const urlResponse = await sqs.commandExecutor({ commandParams: getUrlCommandParams, commandName: 'getQueueUrl' });
+
+    const sendMessageCommandParams = { QueueUrl: urlResponse.QueueUrl, MessageBody: messageBody }
+    const res = await sqs.commandExecutor({ commandParams: sendMessageCommandParams, commandName: 'sendMessage' });
+
+    const md5MessageBodySent = crypto
+        .createHash("md5")
+        .update(messageBody)
+        .digest("hex");
+    expect(res.$metadata.httpStatusCode).toBe(200); //enviado
+    expect(res.MD5OfMessageBody).toBe(md5MessageBodySent); // comprobación de md5
+
+    await deleteQueue(queueName);
+  });
+});

test/helpers/createSQSQueue.js

@@ -1,3 +1,7 @@
-const { CreateQueueCommand } = require("@aws-sdk/client-sqs");
-
-module.exports = (sqs) => (queueName) => sqs.client.send(new CreateQueueCommand({ QueueName: queueName }));
+const commandConfig = (queueName) => ({
+    commandParams: {
+        QueueName: queueName
+    },
+    commandName:'createQueue'
+})
+module.exports = (sqs) => (queueName) => sqs.commandExecutor(commandConfig(queueName))

test/helpers/deleteSQSQueue.js

@@ -1,4 +1,8 @@
-const { DeleteQueueCommand } = require("@aws-sdk/client-sqs");
-
-module.exports = (sqs) => (queueName) => sqs.client
-    .send(new DeleteQueueCommand({ QueueUrl: `https://localhost/000000000000/${queueName}` }));
+const commandConfig = (queueName) => ({
+    commandParams: {
+        QueueUrl: queueName
+    },
+    commandName:'deleteQueue'
+})
+module.exports = (sqs) => (queueName) => sqs
+    .commandExecutor(commandConfig(`https://localhost/000000000000/${queueName}`))