feat: added worker to mail queue provider

src/infra/queue/worker.ts

@@ -0,0 +1,41 @@
+import 'dotenv/config';
+import { AwilixContainer } from 'awilix';
+
+import { setupContainer } from '~infra/bootstrap/container';
+import { config } from '~infra/config';
+import IMailProvider from '~infra/providers/MailProvider/models/IMailProvider';
+import IMailQueueProvider from '~infra/providers/QueueProvider/models/IMailQueueProvider';
+import { Logger } from '~infra/tools/log/types';
+
+const worker = async (container: AwilixContainer): Promise<void> => {
+  const mailQueueProvider =
+    container.resolve<IMailQueueProvider>('mailQueueProvider');
+  const mailProvider = container.resolve<IMailProvider>('mailProvider');
+  const logger = container.resolve<Logger>('logger');
+
+  return mailQueueProvider.process(async ({ data }) => {
+    logger.info(data);
+
+    await mailProvider.sendMail({
+      from: {
+        email: '[email protected]',
+        name: 'deusimar',
+      },
+      html: '<div><p>Olá {{name}}</p></div>',
+      subject: 'Ola test',
+      to: {
+        email: '[email protected]',
+        name: 'deusimar',
+      },
+      variables: {
+        name: 'Deusimar',
+      },
+    });
+  });
+};
+
+(async () => {
+  const container = await setupContainer(config);
+
+  await worker(container);
+})();

src/useCases/SendMail/SendMail.ts

@@ -1,37 +1,35 @@
 import { AppContainer } from '~infra/bootstrap/container';
 import IMailProvider from '~infra/providers/MailProvider/models/IMailProvider';
-import IQueueProvider from '~infra/providers/QueueProvider/models/IQueueProvider';
+import IMailQueueProvider from '~infra/providers/QueueProvider/models/IMailQueueProvider';
 import { Logger } from '~infra/tools/log/types';
 
 class SendMail {
   private logger: Logger;
-  private mailProvider: IMailProvider;
-  private queueProvider: IQueueProvider;
+  private mailQueueProvider: IMailQueueProvider;
 
   constructor(params: AppContainer) {
     this.logger = params.logger;
-    this.mailProvider = params.mailProvider;
-    this.queueProvider = params.queueProvider;
+    this.mailQueueProvider = params.mailQueueProvider;
   }
 
   public async execute(input: string): Promise<void> {
-    await this.mailProvider.sendMail({
-      from: {
-        email: '[email protected]',
-        name: 'deusimar',
-      },
-      html: '<div><p>Olá {{name}}</p></div>',
-      subject: 'Ola test',
-      to: {
-        email: '[email protected]',
-        name: 'deusimar',
-      },
-      variables: {
-        name: input,
-      },
-    });
+    // await this.mailProvider.sendMail({
+    //   from: {
+    //     email: '[email protected]',
+    //     name: 'deusimar',
+    //   },
+    //   html: '<div><p>Olá {{name}}</p></div>',
+    //   subject: 'Ola test',
+    //   to: {
+    //     email: '[email protected]',
+    //     name: 'deusimar',
+    //   },
+    //   variables: {
+    //     name: input,
+    //   },
+    // });
 
-    await this.queueProvider.add('Oi', input);
+    await this.mailQueueProvider.addJob('Oi');
   }
 }