feat(pkg): remove unexpected use of any and add prettier fix

remove unexpected use of any and add prettier fix

gh-3

Author: Sunny Tyagi

.github/ISSUE_TEMPLATE/bug_report.md

@@ -4,14 +4,14 @@ about: Create a report to help us improve
 title: ''
 labels: ''
 assignees: ''
-
 ---
 
 **Describe the bug**
 A clear and concise description of what the bug is.
 
 **To Reproduce**
 Steps to reproduce the behavior:
+
 1. Go to '...'
 2. Click on '....'
 3. Scroll down to '....'

.github/ISSUE_TEMPLATE/feature_request.md

@@ -4,7 +4,6 @@ about: Suggest an idea for this project
 title: ''
 labels: ''
 assignees: ''
-
 ---
 
 **Is your feature request related to a problem? Please describe.**

.github/workflows/release.yml

@@ -49,4 +49,4 @@ jobs:
           GH_TOKEN: ${{ secrets.RELEASE_COMMIT_GH_PAT }}
           NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
       - name: Changelog 📝
-        run: cd src/release_notes && HUSKY=0 node release-notes.js
+        run: cd src/release_notes && HUSKY=0 node release-notes.js

README.md

@@ -12,6 +12,7 @@ Install EventStreamConnectorComponent using `npm`;
 ```sh
 $ [npm install | yarn add] @sourceloop/message-bus-queue-connectors
 ```
+
 ## Flow Diagram
 
 <img width="659" alt="Screenshot 2025-06-06 at 10 53 06 AM" src="https://github.com/user-attachments/assets/baf1bcaa-5f67-44bb-a01a-b8d1c41644bc" />
@@ -22,9 +23,7 @@ Configure and load EventStreamConnectorComponent in the application constructor
 as shown below.
 
 ```ts
-import {
-  EventStreamConnectorComponent
-} from '@sourceloop/message-bus-queue-connectors';
+import {EventStreamConnectorComponent} from '@sourceloop/message-bus-queue-connectors';
 
 // ...
 export class MyApplication extends BootMixin(
@@ -47,7 +46,7 @@ To use SQS as their message queue, bind its required config and connector compon
 import {
   SQSConnector,
   SQSBindings,
-  EventStreamConnectorComponent
+  EventStreamConnectorComponent,
 } from '@sourceloop/message-bus-queue-connectors';
 
 // ...
@@ -156,10 +155,10 @@ const config = {
 
 ## Integration
 
- @sourceloop/message-bus-queue-connectors provides a decorator '@producer()' that can be used to access the producer of each msg queue. It expects one arguement defining the type of queue, of which producer u want to use. like
+@sourceloop/message-bus-queue-connectors provides a decorator '@producer()' that can be used to access the producer of each msg queue. It expects one arguement defining the type of queue, of which producer u want to use. like
 
- ```ts 
- @injectable({scope: BindingScope.TRANSIENT})
+```ts
+@injectable({scope: BindingScope.TRANSIENT})
 export class EventConnector implements IEventConnector<PublishedEvents> {
   constructor(
     @producer(QueueType.EventBridge)
@@ -171,48 +170,55 @@ export class EventConnector implements IEventConnector<PublishedEvents> {
   ) {}
 
   // rest of implementation
-
 }
- ```
+```
 
- Producer provider two ways of sending events - single event at a time and multiple event at a time.
+Producer provider two ways of sending events - single event at a time and multiple event at a time.
 
- ```ts
- export type Producer<Stream extends AnyObject = AnyObject> = {
-    send: <Event extends keyof Stream>(data: Stream[Event], topic?: Event) => Promise<void>;
-    sendMultiple: <Event extends keyof Stream>(data: Stream[Event][], topic?: Event) => Promise<void>;
+```ts
+export type Producer<Stream extends AnyObject = AnyObject> = {
+  send: <Event extends keyof Stream>(
+    data: Stream[Event],
+    topic?: Event,
+  ) => Promise<void>;
+  sendMultiple: <Event extends keyof Stream>(
+    data: Stream[Event][],
+    topic?: Event,
+  ) => Promise<void>;
 };
- ```
+```
 
 It provides '@consumer' decorator to make a service as consumer. consumer needs to follow an interface.
 
 ```ts
-export interface IConsumer<Stream extends AnyObject, Event extends keyof Stream> {
-    event: Event;
-    queue: QueueType;
-    handle(data: Stream[Event]): Promise<void>;
+export interface IConsumer<
+  Stream extends AnyObject,
+  Event extends keyof Stream,
+> {
+  event: Event;
+  queue: QueueType;
+  handle(data: Stream[Event]): Promise<void>;
 }
 ```
 
-and can be used as 
+and can be used as
 
 ```ts
 import {
   IConsumer,
   QueueType,
   consumer,
 } from '@sourceloop/message-bus-queue-connectors';
-import { OrchestratorStream, EventTypes, ProvisioningInputs } from '../../types';
+import {OrchestratorStream, EventTypes, ProvisioningInputs} from '../../types';
 
 @consumer
 export class TenantProvisioningConsumerForEventSQS
   implements IConsumer<OrchestratorStream, EventTypes.TENANT_PROVISIONING>
 {
-  constructor(
-  ) {}
+  constructor() {}
   event: EventTypes.TENANT_PROVISIONING = EventTypes.TENANT_PROVISIONING;
   queue: QueueType = QueueType.SQS;
-  async handle(data: ProvisioningInputs): Promise<void> {    
+  async handle(data: ProvisioningInputs): Promise<void> {
     console.log(`SQS: ${this.event} Event Recieved ` + JSON.stringify(data));
     return;
   }

src/__tests__/acceptance/bullmq/fixtures/consumer-app.ts

@@ -4,10 +4,7 @@ import {ApplicationConfig} from '@loopback/core';
 import {RestApplication} from '@loopback/rest';
 import {ServiceMixin} from '@loopback/service-proxy';
 import {EventStreamConnectorComponent} from '../../../../component';
-import {
-  BullMQBindings,
-  BullMQConnector,
-} from '../../../../strategies';
+import {BullMQBindings, BullMQConnector} from '../../../../strategies';
 import {EventAConsumer} from './services/event-a.consumer';
 import {EventBConsumer} from './services/event-b.consumer';
 import {EventBSecondConsumer} from './services/event-b-second.consumer';

src/__tests__/acceptance/bullmq/fixtures/producers-app.ts

@@ -3,10 +3,7 @@ import {ApplicationConfig} from '@loopback/core';
 import {RestApplication} from '@loopback/rest';
 import {ServiceMixin} from '@loopback/service-proxy';
 import {EventStreamConnectorComponent} from '../../../../component';
-import {
-  BullMQBindings,
-  BullMQConnector,
-} from '../../../../strategies';
+import {BullMQBindings, BullMQConnector} from '../../../../strategies';
 
 export class ProducerApp extends BootMixin(ServiceMixin(RestApplication)) {
   constructor(options: ApplicationConfig = {}) {

src/__tests__/acceptance/bullmq/helpers/app-builder.ts

@@ -1,4 +1,4 @@
-import {givenHttpServerConfig,sinon} from '@loopback/testlab';
+import {givenHttpServerConfig, sinon} from '@loopback/testlab';
 import {ProducerApp} from '../fixtures/producers-app';
 import {BullMQBindings} from '../../../../strategies';
 import {ConsumerApp} from '../fixtures/consumer-app';

src/__tests__/acceptance/bullmq/types.ts

@@ -6,7 +6,6 @@ export type StubListener = (
   data: AnyObject,
 ) => void;
 
-
 export interface BullMqQueueParams {
   name: string;
   data: Record<string, unknown>;

src/__tests__/acceptance/event-bridge/event-bridge.acceptance.ts

@@ -44,7 +44,7 @@ import {DEFAULT_SOURCE} from '../../../constants';
         sinon.assert.calledWithExactly(listenerStub, Events.A, DEFAULT_SOURCE, {
           name: 'Event A',
           data: 'test string',
-          type: Events.A
+          type: Events.A,
         });
       });
       it('should produce multiple events for a particular topic', async () => {
@@ -57,12 +57,12 @@ import {DEFAULT_SOURCE} from '../../../constants';
         sinon.assert.calledWithExactly(calls[0], Events.A, DEFAULT_SOURCE, {
           name: 'Event A',
           data: 'test string 1',
-          type: Events.A
+          type: Events.A,
         });
         sinon.assert.calledWithExactly(calls[1], Events.A, DEFAULT_SOURCE, {
           name: 'Event A',
           data: 'test string 2',
-          type: Events.A
+          type: Events.A,
         });
       });
     });

src/__tests__/acceptance/sqs/fixtures/consumer-app.ts

@@ -4,10 +4,7 @@ import {ApplicationConfig} from '@loopback/core';
 import {RestApplication} from '@loopback/rest';
 import {ServiceMixin} from '@loopback/service-proxy';
 import {EventStreamConnectorComponent} from '../../../../component';
-import {
-  SQSBindings,
-  SQSConnector,
-} from '../../../../strategies';
+import {SQSBindings, SQSConnector} from '../../../../strategies';
 import {EventAConsumer} from './services/event-a.consumer';
 import {EventBConsumer} from './services/event-b.consumer';
 import {EventBSecondConsumer} from './services/event-b-second.consumer';
@@ -21,29 +18,26 @@ export class ConsumerApp extends BootMixin(
     this.service(EventBConsumer);
     this.service(EventBSecondConsumer);
     this.component(EventStreamConnectorComponent);
-    this.bind(SQSBindings.Config).to(
-      {
-        queueConfig: {
-          QueueUrl: 'http://127.0.0.1:4566/000000000000/my-test-queue',
-          MessageRetentionPeriod: 60, // at least 60 seconds
-          MaximumMessageSize: 262144,
-          ReceiveMessageWaitTimeSeconds: 20, // typical polling time
-          VisibilityTimeout: 30, // 30 seconds
-          },
-          Credentials: {
-            region: 'us-east-1',
-            accessKeyId: 'test',
-            secretAccessKey: 'test',
-          },
-          ConsumerConfig: {
-            MaxNumberOfMessages: 10,
-            WaitTimeSeconds: 20,
-            maxConsumers: 2,
-          },
-          isConsumer:true,
-      }
-      
-    );
+    this.bind(SQSBindings.Config).to({
+      queueConfig: {
+        QueueUrl: 'http://127.0.0.1:4566/000000000000/my-test-queue',
+        MessageRetentionPeriod: 60, // at least 60 seconds
+        MaximumMessageSize: 262144,
+        ReceiveMessageWaitTimeSeconds: 20, // typical polling time
+        VisibilityTimeout: 30, // 30 seconds
+      },
+      Credentials: {
+        region: 'us-east-1',
+        accessKeyId: 'test',
+        secretAccessKey: 'test',
+      },
+      ConsumerConfig: {
+        MaxNumberOfMessages: 10,
+        WaitTimeSeconds: 20,
+        maxConsumers: 2,
+      },
+      isConsumer: true,
+    });
     this.component(SQSConnector);
 
     this.projectRoot = __dirname;