Refactoring

apps/api/src/app/portfolio/calculator/portfolio-calculator.ts

@@ -1072,7 +1072,7 @@ export abstract class PortfolioCalculator {
       }
     } else {
       // Wait for computation
-      const job = await this.portfolioSnapshotService.addJobToQueue({
+      await this.portfolioSnapshotService.addJobToQueue({
         data: {
           filters: this.filters,
           userCurrency: this.currency,
@@ -1086,7 +1086,11 @@ export abstract class PortfolioCalculator {
         }
       });
 
+      const job = await this.portfolioSnapshotService.getJob(jobId);
+
+      if (job) {
         await job.finished();
+      }
 
       await this.initialize();
     }

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

@@ -13,16 +13,22 @@ export const PortfolioSnapshotServiceMock = {
     name: string;
     opts?: Bull.JobOptions;
   }): Promise<Bull.Job<any>> {
-    // Mock the Job object with a finished method
     const mockJob: Partial<Bull.Job<any>> = {
-      // Mock the finished method to return a resolved promise
       finished: async () => {
         await setTimeout(100);
 
-        return Promise.resolve('Mocked job finished result');
+        return Promise.resolve();
       }
     };
 
+    this.jobsStore.set(opts?.jobId, mockJob);
+
     return Promise.resolve(mockJob as Bull.Job<any>);
-  }
+  },
+  getJob(jobId: string): Promise<Bull.Job<any>> {
+    const job = this.jobsStore.get(jobId);
+
+    return Promise.resolve(job as Bull.Job<any>);
+  },
+  jobsStore: new Map<string, Partial<Bull.Job<any>>>()
 };

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

@@ -24,4 +24,8 @@ export class PortfolioSnapshotService {
   }) {
     return this.portfolioSnapshotQueue.add(name, data, opts);
   }
+
+  public async getJob(jobId: string) {
+    return this.portfolioSnapshotQueue.getJob(jobId);
+  }
 }