16261454132

Committed 14 Jul 2025 08:06AM UTC coverage: 89.486% (-0.2%) from 89.688%

Build # 16261454132

Build Type

Pull #2625

github

Committed by

web-flow

Commit Message

Merge e1f3f122f into e22deb33b

Pull Request Pull Request #2625: feat: Add BullMQ job queue system

Run Details

3467 of 4242 branches covered (81.73%)

Branch coverage included in aggregate %.

35 of 75 new or added lines in 11 files covered. (46.67%)

1 existing line in 1 file now uncovered.

12015 of 13059 relevant lines covered (92.01%)

545.14 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/modules/csv-export/csv-export.module.ts

import { CsvExportService } from '@/modules/csv-export/csv-export.service';
import { JobQueueService } from '@/datasources/job-queue/job-queue.service';
import { JobQueueShutdownHook } from '@/datasources/job-queue/job-queue.shutdown.hook';
import { CSV_EXPORT_QUEUE } from '@/domain/common/entities/jobs.constants';
import { IJobQueueService } from '@/domain/interfaces/job-queue.interface';
import { ILoggingService, LoggingService } from '@/logging/logging.interface';
import { BullModule, getQueueToken } from '@nestjs/bullmq';
import { Module } from '@nestjs/common';
import { Queue } from 'bullmq';
import { CsvExportConsumer } from '@/modules/csv-export/csv-export.consumer';

@Module({
  imports: [
    BullModule.registerQueue({
      name: CSV_EXPORT_QUEUE,
      defaultJobOptions: {
        removeOnComplete: 10,
        removeOnFail: 5,
        backoff: {
          type: 'exponential',
          delay: 2000,
        },
        attempts: 3,
      },
    }),
  ],
  providers: [
    CsvExportConsumer,
    CsvExportService,
    {
      provide: IJobQueueService,
      useFactory: (queue: Queue): IJobQueueService =>
        new JobQueueService(queue),
      inject: [getQueueToken(CSV_EXPORT_QUEUE)],
    },
    {
      provide: JobQueueShutdownHook,
      useFactory: (
        queue: Queue,
        logging: ILoggingService,
      ): JobQueueShutdownHook => new JobQueueShutdownHook(queue, logging),
      inject: [getQueueToken(CSV_EXPORT_QUEUE), LoggingService],
    },
  ],
  exports: [CsvExportService, BullModule],
})
export class CsvExportModule {}

1	import { CsvExportService } from '@/modules/csv-export/csv-export.service';	×
NEW 2	import { JobQueueService } from '@/datasources/job-queue/job-queue.service';	×
NEW 3	import { JobQueueShutdownHook } from '@/datasources/job-queue/job-queue.shutdown.hook';	×
NEW 4	import { CSV_EXPORT_QUEUE } from '@/domain/common/entities/jobs.constants';	×
NEW 5	import { IJobQueueService } from '@/domain/interfaces/job-queue.interface';	×
NEW 6	import { ILoggingService, LoggingService } from '@/logging/logging.interface';	×
NEW 7	import { BullModule, getQueueToken } from '@nestjs/bullmq';	×
UNCOV 8	import { Module } from '@nestjs/common';	×
9	import { Queue } from 'bullmq';
NEW 10	import { CsvExportConsumer } from '@/modules/csv-export/csv-export.consumer';	×
11
12	@Module({
13	imports: [
14	BullModule.registerQueue({
15	name: CSV_EXPORT_QUEUE,
16	defaultJobOptions: {
17	removeOnComplete: 10,
18	removeOnFail: 5,
19	backoff: {
20	type: 'exponential',
21	delay: 2000,
22	},
23	attempts: 3,
24	},
25	}),
26	],
27	providers: [
28	CsvExportConsumer,
29	CsvExportService,
30	{
31	provide: IJobQueueService,
32	useFactory: (queue: Queue): IJobQueueService =>
NEW 33	new JobQueueService(queue),	×
34	inject: [getQueueToken(CSV_EXPORT_QUEUE)],
35	},
36	{
37	provide: JobQueueShutdownHook,
38	useFactory: (
39	queue: Queue,
40	logging: ILoggingService,
NEW 41	): JobQueueShutdownHook => new JobQueueShutdownHook(queue, logging),	×
42	inject: [getQueueToken(CSV_EXPORT_QUEUE), LoggingService],
43	},
44	],
45	exports: [CsvExportService, BullModule],
46	})
47	export class CsvExportModule {}	×

safe-global / safe-client-gateway / 16261454132

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous