6236265189

Committed 19 Sep 2023 01:34PM UTC coverage: 90.87% (-1.2%) from 92.077%

Build # 6236265189

Build Type

push

github

Committed by

hectorgomezv

Commit Message

Adapt CacheFirstDataSource.get calls payload

Run Details

1221 of 1472 branches covered (0.0%)

Branch coverage included in aggregate %.

38 of 92 new or added lines in 8 files covered. (41.3%)

23 existing lines in 3 files now uncovered.

4552 of 4881 relevant lines covered (93.26%)

144.19 hits per line

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

0.0

/src/domain/relay/relay.repository.ts

NEW 1	import { Inject, Injectable } from '@nestjs/common';	×
2	import { RelayApi } from '../interfaces/relay-api.interface';
NEW 3	import { LimitAddressesMapper, RelayPayload } from './limit-addresses.mapper';	×
NEW 4	import { IConfigurationService } from '@/config/configuration.service.interface';	×
NEW 5	import { ILoggingService, LoggingService } from '@/logging/logging.interface';	×
6	import { Hex } from 'viem/src/types/misc';
7
8	class RelayLimitReachedError extends Error {
9	constructor(
NEW 10	readonly address: Hex,	×
NEW 11	readonly current: number,	×
NEW 12	readonly limit: number,	×
13	) {
NEW 14	super(	×
15	`Relay limit reached for ${address} \| current: ${current} \| limit: ${limit}`,
16	);
17	}
18	}
19
20	@Injectable({})
NEW 21	export class RelayRepository {	×
22	// Number of relay requests per ttl
23	private readonly limit: number;
24
25	constructor(
NEW 26	@Inject(LoggingService) private readonly loggingService: ILoggingService,	×
27	@Inject(IConfigurationService) configurationService: IConfigurationService,
NEW 28	private readonly limitAddressesMapper: LimitAddressesMapper,	×
NEW 29	private readonly relayApi: RelayApi,	×
30	) {
NEW 31	this.limit = configurationService.getOrThrow('relay.limit');	×
32	}
33
34	async relay(relayPayload: RelayPayload): Promise<unknown> {
35	const relayAddresses =
NEW 36	this.limitAddressesMapper.getLimitAddresses(relayPayload);	×
NEW 37	for (const address of relayAddresses) {	×
NEW 38	const canRelay = await this.canRelay({	×
39	chainId: relayPayload.chainId,
40	address,
41	});
NEW 42	if (!canRelay.result) {	×
NEW 43	const error = new RelayLimitReachedError(	×
44	address,
45	canRelay.currentCount,
46	this.limit,
47	);
NEW 48	this.loggingService.info(error.message);	×
NEW 49	throw error;	×
50	}
51	}
52
NEW 53	return this.relayApi.relay(relayPayload);	×
54	}
55
56	private async canRelay(args: {
57	chainId: string;
58	address: string;
59	}): Promise<{ result: boolean; currentCount: number }> {
NEW 60	const currentCount = await this.getRelayCount(args);	×
NEW 61	return { result: currentCount < this.limit, currentCount };	×
62	}
63
64	getRelayCount(args: { chainId: string; address: string }): Promise<number> {
NEW 65	return this.relayApi.getRelayCount(args);	×
66	}
67	}

safe-global / safe-client-gateway / 6236265189

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