TCORE-252 Refactor and Test AWS SQS Plugin for Monorepo

plugins/aws-sqs/package.json

@@ -0,0 +1,24 @@
+{
+  "name": "@tago-io/tcore-plugin-amazon-sqs",
+  "version": "0.7.0",
+  "private": false,
+  "main": "./src/index.ts",
+  "type": "module",
+  "tcore": {
+    "name": "Amazon SQS",
+    "short_description": "Integrates the Amazon SQS queue with TagoCore",
+    "full_description": "./README.md",
+    "icon": "./assets/icon.png",
+    "types": ["queue"],
+    "permissions": ["device-data"],
+    "publisher": {
+      "name": "TagoIO",
+      "domain": "tago.io"
+    }
+  },
+  "dependencies": {
+    "@aws-sdk/client-sqs": "3.675.0",
+    "@rxfork/sqs-consumer": "^6.0.0"
+  },
+  "devDependencies": {}
+}

standalone-plugins/aws-sqs/src/configurations.ts → plugins/aws-sqs/src/configurations.ts

@@ -1,4 +1,4 @@
-import { IPluginConfigField } from "@tago-io/tcore-sdk/build/Types";
+import type { IPluginConfigField } from "@tago-io/tcore-sdk/Types";
 
 const configs: IPluginConfigField[] = [
   {
@@ -36,15 +36,19 @@ const configs: IPluginConfigField[] = [
         type: "password",
         icon: "key",
         required: true,
-        visibility_conditions: [{ condition: "=", field: "type", value: "config" }],
+        visibility_conditions: [
+          { condition: "=", field: "type", value: "config" },
+        ],
       },
       {
         name: "AWS Secret Access Key",
         field: "aws_secret_access_key",
         type: "password",
         icon: "key",
         required: true,
-        visibility_conditions: [{ condition: "=", field: "type", value: "config" }],
+        visibility_conditions: [
+          { condition: "=", field: "type", value: "config" },
+        ],
       },
     ],
   },

standalone-plugins/aws-sqs/src/connection.ts → plugins/aws-sqs/src/connection.ts

@@ -1,9 +1,14 @@
-import { IDatabaseDeviceDataCreate } from "@tago-io/tcore-sdk/build/Types";
-import { SQSClient, SQSClientConfig, SendMessageCommand, GetQueueAttributesCommand } from "@aws-sdk/client-sqs";
+import {
+  GetQueueAttributesCommand,
+  SQSClient,
+  type SQSClientConfig,
+  SendMessageCommand,
+} from "@aws-sdk/client-sqs";
 import { Consumer } from "@rxfork/sqs-consumer";
-import { QueueModule } from "@tago-io/tcore-sdk";
-import { Config } from "./types";
-import { consumeData } from "./consume-data";
+import type { QueueModule } from "@tago-io/tcore-sdk";
+import type { IDatabaseDeviceDataCreate } from "@tago-io/tcore-sdk/Types";
+import { consumeData } from "./consume-data.ts";
+import type { Config } from "./types.ts";
 
 let client: SQSClient;
 
@@ -17,8 +22,12 @@ async function createConnection(this: QueueModule, config: Config) {
     credentials:
       config.type === "config"
         ? {
-            accessKeyId: config.aws_access_key_id || process.env?.AWS_ACCESS_KEY_ID!,
-            secretAccessKey: config.aws_secret_access_key || process.env?.AWS_SECRET_ACCESS_KEY!,
+            accessKeyId:
+              config.aws_access_key_id || process.env.AWS_ACCESS_KEY_ID || "",
+            secretAccessKey:
+              config.aws_secret_access_key ||
+              process.env.AWS_SECRET_ACCESS_KEY ||
+              "",
           }
         : undefined,
   };
@@ -57,7 +66,10 @@ async function createConnection(this: QueueModule, config: Config) {
     });
     const result = await client.send(attributesCommand);
 
-    this.showMessage("info", `Queue running! Messages on queue ≈ ${result?.Attributes?.ApproximateNumberOfMessages}`);
+    this.showMessage(
+      "info",
+      `Queue running! Messages on queue ≈ ${result?.Attributes?.ApproximateNumberOfMessages}`,
+    );
   }, 5000);
 }
 

standalone-plugins/aws-sqs/src/consume-data.ts → plugins/aws-sqs/src/consume-data.ts

@@ -1,4 +1,4 @@
-import { Message } from "@aws-sdk/client-sqs";
+import type { Message } from "@aws-sdk/client-sqs";
 import { core } from "@tago-io/tcore-sdk";
 
 async function consumeData(messages: Message[]): Promise<void> {

standalone-plugins/aws-sqs/src/index.ts → plugins/aws-sqs/src/index.ts

@@ -1,6 +1,6 @@
 import { QueueModule } from "@tago-io/tcore-sdk";
-import { configs } from "./configurations";
-import { addToQueue, closeConnection, createConnection } from "./connection";
+import { configs } from "./configurations.ts";
+import { addToQueue, closeConnection, createConnection } from "./connection.ts";
 
 const amazonSQS = new QueueModule({
   id: "amazon-sqs",

standalone-plugins/aws-sqs/src/types.ts → plugins/aws-sqs/src/types.ts

@@ -11,4 +11,4 @@ type Config = {
     }
 );
 
-export { Config };
+export type { Config };