8691831934

Committed 15 Apr 2024 03:25PM UTC coverage: 92.508% (+0.06%) from 92.445%

Build # 8691831934

Build Type

push

github

Committed by

hectorgomezv

Commit Message

Add documentation

Run Details

1903 of 2301 branches covered (82.7%)

Branch coverage included in aggregate %.

0 of 4 new or added lines in 2 files covered. (0.0%)

1 existing line in 1 file now uncovered.

6777 of 7082 relevant lines covered (95.69%)

311.6 hits per line

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

0.0

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

safe-global / safe-client-gateway / 8691831934

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