Clean up

apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.module.ts

@@ -15,6 +15,7 @@ import { Module } from '@nestjs/common';
 import { PortfolioSnapshotProcessor } from './portfolio-snapshot.processor';
 
 @Module({
+  exports: [BullModule, PortfolioSnapshotService],
   imports: [
     BullModule.registerQueue({
       name: PORTFOLIO_SNAPSHOT_QUEUE
@@ -31,7 +32,6 @@ import { PortfolioSnapshotProcessor } from './portfolio-snapshot.processor';
     PortfolioCalculatorFactory,
     PortfolioSnapshotProcessor,
     PortfolioSnapshotService
-  ],
+  ]
-  exports: [BullModule, PortfolioSnapshotService]
 })
 export class PortfolioSnapshotQueueModule {}

apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.service.mock.ts

@@ -1,4 +1,4 @@
-import * as Bull from 'bull';
+import { Job, JobOptions } from 'bull';
 import { setTimeout } from 'timers/promises';
 
 import { IPortfolioSnapshotQueueJob } from './interfaces/portfolio-snapshot-queue-job.interface';
@@ -11,9 +11,9 @@ export const PortfolioSnapshotServiceMock = {
   }: {
     data: IPortfolioSnapshotQueueJob;
     name: string;
-    opts?: Bull.JobOptions;
+    opts?: JobOptions;
-  }): Promise<Bull.Job<any>> {
+  }): Promise<Job<any>> {
-    const mockJob: Partial<Bull.Job<any>> = {
+    const mockJob: Partial<Job<any>> = {
       finished: async () => {
         await setTimeout(100);
 
@@ -23,12 +23,12 @@ export const PortfolioSnapshotServiceMock = {
 
     this.jobsStore.set(opts?.jobId, mockJob);
 
-    return Promise.resolve(mockJob as Bull.Job<any>);
+    return Promise.resolve(mockJob as Job<any>);
   },
-  getJob(jobId: string): Promise<Bull.Job<any>> {
+  getJob(jobId: string): Promise<Job<any>> {
     const job = this.jobsStore.get(jobId);
 
-    return Promise.resolve(job as Bull.Job<any>);
+    return Promise.resolve(job as Job<any>);
   },
-  jobsStore: new Map<string, Partial<Bull.Job<any>>>()
+  jobsStore: new Map<string, Partial<Job<any>>>()
 };