8752745253

Committed 19 Apr 2024 11:20AM UTC coverage: 92.954% (+0.3%) from 92.677%

Build # 8752745253

Build Type

Pull #1418

github

Committed by

hectorgomezv

Commit Message

Add missing type

Pull Request Pull Request #1418: Add queues domain layer

Run Details

1937 of 2335 branches covered (82.96%)

Branch coverage included in aggregate %.

9 of 21 new or added lines in 5 files covered. (42.86%)

1 existing line in 1 file now uncovered.

6902 of 7174 relevant lines covered (96.21%)

311.56 hits per line

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

90.48

/src/datasources/queues/queues-api.service.ts

import { IConfigurationService } from '@/config/configuration.service.interface';
import { QueueConsumer } from '@/datasources/queues/queues-api.module';
import { IQueuesApiService } from '@/datasources/queues/queues-api.service.interface';
import { IQueueReadiness } from '@/domain/interfaces/queue-readiness.interface';
import { ILoggingService, LoggingService } from '@/logging/logging.interface';
import { Inject } from '@nestjs/common';
import { ConsumeMessage } from 'amqplib';

export class QueueApiService implements IQueuesApiService, IQueueReadiness {
  private readonly isEventsQueueEnabled: boolean;

  constructor(
    @Inject('QueueConsumer') private readonly consumer: QueueConsumer,
    @Inject(LoggingService) private readonly loggingService: ILoggingService,
    @Inject(IConfigurationService)
    private readonly configurationService: IConfigurationService,
  ) {
    this.isEventsQueueEnabled = this.configurationService.getOrThrow<boolean>(
      'features.eventsQueue',
    );
  }

  isReady(): boolean {
    if (this.isEventsQueueEnabled) {
      return this.consumer.connection.isConnected();
    }
    return true;
  }

  async subscribe(
    queueName: string,
    fn: (msg: ConsumeMessage) => Promise<void>,
  ): Promise<void> {
    if (!this.isEventsQueueEnabled) {
      return this.loggingService.warn(
        `Cannot subscribe to queue: ${queueName}. AMQP consumer is disabled`,
      );
    }
    await this.consumer.channel.consume(
      queueName,
      async (msg: ConsumeMessage) => {
        await fn(msg);
        // Note: each message is explicitly acknowledged at this point, only after a success callback execution.
        this.consumer.channel.ack(msg);
      },
    );
    this.loggingService.info(`Subscribed to queue: ${queueName}`);
  }
}

1	import { IConfigurationService } from '@/config/configuration.service.interface';	94✔
2	import { QueueConsumer } from '@/datasources/queues/queues-api.module';
3	import { IQueuesApiService } from '@/datasources/queues/queues-api.service.interface';
4	import { IQueueReadiness } from '@/domain/interfaces/queue-readiness.interface';
5	import { ILoggingService, LoggingService } from '@/logging/logging.interface';	94✔
6	import { Inject } from '@nestjs/common';	94✔
7	import { ConsumeMessage } from 'amqplib';
8
9	export class QueueApiService implements IQueuesApiService, IQueueReadiness {	94✔
10	private readonly isEventsQueueEnabled: boolean;
11
12	constructor(
13	@Inject('QueueConsumer') private readonly consumer: QueueConsumer,	1,214✔
14	@Inject(LoggingService) private readonly loggingService: ILoggingService,	1,214✔
15	@Inject(IConfigurationService)
16	private readonly configurationService: IConfigurationService,	1,214✔
17	) {
18	this.isEventsQueueEnabled = this.configurationService.getOrThrow<boolean>(	1,214✔
19	'features.eventsQueue',
20	);
21	}
22
23	isReady(): boolean {
24	if (this.isEventsQueueEnabled) {	8✔
25	return this.consumer.connection.isConnected();	4✔
26	}
27	return true;	4✔
28	}
29
30	async subscribe(
31	queueName: string,
32	fn: (msg: ConsumeMessage) => Promise<void>,
33	): Promise<void> {
34	if (!this.isEventsQueueEnabled) {	4✔
35	return this.loggingService.warn(	2✔
36	`Cannot subscribe to queue: ${queueName}. AMQP consumer is disabled`,
37	);
38	}
39	await this.consumer.channel.consume(	2✔
40	queueName,
41	async (msg: ConsumeMessage) => {
NEW 42	await fn(msg);	×
43	// Note: each message is explicitly acknowledged at this point, only after a success callback execution.
NEW 44	this.consumer.channel.ack(msg);	×
45	},
46	);
47	this.loggingService.info(`Subscribed to queue: ${queueName}`);	2✔
48	}
49	}

safe-global / safe-client-gateway / 8752745253

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