8708732261

Committed 16 Apr 2024 03:55PM UTC coverage: 92.917% (-0.2%) from 93.09%

Build # 8708732261

Build Type

Pull #1418

github

Committed by

hectorgomezv

Commit Message

Add AMQP-related test configuration to e2e-setup.ts

Pull Request Pull Request #1418: Add queues domain layer

Run Details

1910 of 2303 branches covered (82.94%)

Branch coverage included in aggregate %.

6 of 18 new or added lines in 4 files covered. (33.33%)

1 existing line in 1 file now uncovered.

6840 of 7114 relevant lines covered (96.15%)

311.75 hits per line

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

78.95

/src/domain/health/health.repository.ts

import { Inject, Injectable } from '@nestjs/common';
import { HealthEntity } from '@/domain/health/entities/health.entity';
import { IHealthRepository } from '@/domain/health/health.repository.interface';
import {
  CacheReadiness,
  ICacheReadiness,
} from '@/domain/interfaces/cache-readiness.interface';
import { ILoggingService, LoggingService } from '@/logging/logging.interface';
import {
  IQueueReadiness,
  QueueReadiness,
} from '@/domain/interfaces/queue-readiness.interface';

@Injectable()
export class HealthRepository implements IHealthRepository {
  constructor(
    @Inject(LoggingService) private readonly loggingService: ILoggingService,
    @Inject(CacheReadiness) private readonly cacheService: ICacheReadiness,
    @Inject(QueueReadiness) private readonly queuesApi: IQueueReadiness,
  ) {}

  async isReady(): Promise<HealthEntity> {
    try {
      await this.cacheService.ping();
    } catch (error) {
      this.loggingService.warn('Cache service connection is not established');
      return HealthEntity.NOT_READY;
    }

    if (!this.queuesApi.isReady()) {
      this.loggingService.warn('AMQP connection is not established');
      return HealthEntity.NOT_READY;
    }

    return HealthEntity.READY;
  }
}

1	import { Inject, Injectable } from '@nestjs/common';	92✔
2	import { HealthEntity } from '@/domain/health/entities/health.entity';	92✔
3	import { IHealthRepository } from '@/domain/health/health.repository.interface';
4	import {	92✔
5	CacheReadiness,
6	ICacheReadiness,
7	} from '@/domain/interfaces/cache-readiness.interface';
8	import { ILoggingService, LoggingService } from '@/logging/logging.interface';	92✔
9	import {	92✔
10	IQueueReadiness,
11	QueueReadiness,
12	} from '@/domain/interfaces/queue-readiness.interface';
13
14	@Injectable()
15	export class HealthRepository implements IHealthRepository {	92✔
16	constructor(
17	@Inject(LoggingService) private readonly loggingService: ILoggingService,	1,206✔
18	@Inject(CacheReadiness) private readonly cacheService: ICacheReadiness,	1,206✔
19	@Inject(QueueReadiness) private readonly queuesApi: IQueueReadiness,	1,206✔
20	) {}
21
22	async isReady(): Promise<HealthEntity> {
23	try {	4✔
24	await this.cacheService.ping();	4✔
25	} catch (error) {
26	this.loggingService.warn('Cache service connection is not established');	2✔
27	return HealthEntity.NOT_READY;	2✔
28	}
29
30	if (!this.queuesApi.isReady()) {	2!
NEW 31	this.loggingService.warn('AMQP connection is not established');	×
NEW 32	return HealthEntity.NOT_READY;	×
33	}
34
35	return HealthEntity.READY;	2✔
36	}
37	}

safe-global / safe-client-gateway / 8708732261

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