Merge pull request #3 from flocasts/feature/infra-4818-2

fixed main and types

jest.config.js

@@ -0,0 +1,6 @@
+// jest.config.js
+module.exports = {
+    preset: 'ts-jest',
+    testEnvironment: 'node',
+  };
+

lib/decorators.d.ts

@@ -0,0 +1 @@
+export { SqsMessageHandler } from '@ssut/nestjs-sqs';

lib/decorators.ts

@@ -1 +1,3 @@
-export { SqsMessageHandler } from '@ssut/nestjs-sqs';
+import { SqsMessageHandler } from '@ssut/nestjs-sqs';
+
+export type { SqsMessageHandler };

lib/index.d.ts

@@ -0,0 +1,3 @@
+export * from './decorators';
+export * from './module';
+export * from './sqs.service';

lib/index.ts

@@ -1,2 +1,3 @@
 export * from './decorators';
 export * from './module';
+export * from './sqs.service';

lib/module.d.ts

@@ -0,0 +1,8 @@
+import { DynamicModule, LoggerService } from '@nestjs/common';
+import { SqsConsumerOptions, SqsProducerOptions } from '@ssut/nestjs-sqs/dist/sqs.types';
+export interface SQSOptions {
+    consumers?: SqsConsumerOptions[];
+    producers?: SqsProducerOptions[];
+    logger?: LoggerService;
+}
+export declare function SQSModule(options: SQSOptions): DynamicModule;

lib/sqs.service.d.ts

@@ -0,0 +1,6 @@
+export { Message } from '@aws-sdk/client-sqs';
+export declare class SqsService {
+    private static sqsClient;
+    static Configure(region: string): void;
+    static DeleteMessage(queueUrl: string, receiptHandle: string): Promise<void>;
+}

lib/sqs.service.spec.ts

@@ -0,0 +1,47 @@
+// libs/my-sqs-wrapper/src/lib/sqs.service.spec.ts
+
+import { SqsService } from './sqs.service';
+import { SQS } from '@aws-sdk/client-sqs';
+
+describe('SqsService', () => {
+  beforeEach(() => {
+    // Reset the configuration before each test
+    SqsService['sqsClient'] = undefined;
+  });
+
+  it('should configure the SQS client', () => {
+    SqsService.Configure('test-region');
+    expect(SqsService['sqsClient']).toBeDefined();
+  });
+
+  it('should throw an error if DeleteMessage is called without configuring', async () => {
+    const queueUrl = 'test-queue-url';
+    const receiptHandle = 'test-receipt-handle';
+
+    // Use async/await to handle the promise rejection
+    await expect(
+      SqsService.DeleteMessage(queueUrl, receiptHandle),
+    ).rejects.toThrowError(
+      'SQS client not configured. Call configure method first.',
+    );
+  });
+
+  it('should delete a message when configured', async () => {
+    SqsService.Configure('test-region');
+    const queueUrl = 'test-queue-url';
+    const receiptHandle = 'test-receipt-handle';
+
+    // Mock the SQS DeleteMessage method
+    (SqsService['sqsClient'] as SQS).deleteMessage = jest
+      .fn()
+      .mockResolvedValue({});
+
+    await SqsService.DeleteMessage(queueUrl, receiptHandle);
+    expect((SqsService['sqsClient'] as SQS).deleteMessage).toHaveBeenCalledWith(
+      {
+        QueueUrl: queueUrl,
+        ReceiptHandle: receiptHandle,
+      },
+    );
+  });
+});

lib/sqs.service.ts

@@ -0,0 +1,31 @@
+import { SQS } from '@aws-sdk/client-sqs';
+export { Message } from '@aws-sdk/client-sqs';
+
+export class SqsService {
+  private static sqsClient: SQS | undefined;
+
+  static Configure(region: string): void {
+    this.sqsClient = new SQS({ region });
+  }
+
+  static async DeleteMessage(
+    queueUrl: string,
+    receiptHandle: string,
+  ): Promise<void> {
+    try {
+      await this.sqsClient.deleteMessage({
+        QueueUrl: queueUrl,
+        ReceiptHandle: receiptHandle,
+      });
+    } catch (error) {
+      if (this.sqsClient === undefined) {
+        throw new Error(
+          'SQS client not configured. Call configure method first.',
+        );
+      } else {
+        console.error('Error deleting message:', error);
+        throw error;
+      }
+    }
+  }
+}

package.json

@@ -2,12 +2,15 @@
   "name": "@flocasts/nestjs-aws-sqs-connector",
   "version": "0.0.1",
   "description": "",
-  "main": ".eslintrc.js",
+  "main": "dist/index.js",
+  "types": "dist/index.js.ts",
   "engines": {
     "node": ">=16.10 <=20"
   },
   "scripts": {
-    "build": "tsc -p tsconfig.json"
+    "build": "tsc -p tsconfig.json",
+    "test": "jest",
+    "package": "npm pack"
   },
   "repository": {
     "type": "git",
@@ -21,6 +24,7 @@
   },
   "homepage": "https://github.com/flocasts/nestjs-aws-sqs-connector#readme",
   "dependencies": {
+    "@aws-sdk/client-sqs": "^3.451.0",
     "@ssut/nestjs-sqs": "^2.2.0"
   },
   "devDependencies": {

tsconfig.json

@@ -16,7 +16,7 @@
       "skipLibCheck": true,
       "baseUrl": "./"
     },
-    "include": ["lib", "e2e"],
+    "include": ["lib/**/*.ts"],
     "exclude": ["node_modules", "dist", "test", "**/*spec.ts"]
   }