From 9a53327546c0e3dd257e3ba69fe8f0afcc550208 Mon Sep 17 00:00:00 2001 From: Thomas Kaul <4159106+dtslvr@users.noreply.github.com> Date: Tue, 10 Sep 2024 20:20:11 +0200 Subject: [PATCH] Clean up --- .../portfolio-snapshot.module.ts | 4 ++-- .../portfolio-snapshot.service.mock.ts | 16 ++++++++-------- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.module.ts b/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.module.ts index 9ff04897a..331e5849f 100644 --- a/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.module.ts +++ b/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 {} diff --git a/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.service.mock.ts b/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.service.mock.ts index 172f44052..8d7526906 100644 --- a/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.service.mock.ts +++ b/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; - }): Promise> { - const mockJob: Partial> = { + opts?: JobOptions; + }): Promise> { + const mockJob: Partial> = { 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); + return Promise.resolve(mockJob as Job); }, - getJob(jobId: string): Promise> { + getJob(jobId: string): Promise> { const job = this.jobsStore.get(jobId); - return Promise.resolve(job as Bull.Job); + return Promise.resolve(job as Job); }, - jobsStore: new Map>>() + jobsStore: new Map>>() };