6238449492

Committed 19 Sep 2023 04:38PM UTC coverage: 90.76% (-0.1%) from 90.87%

Build # 6238449492

Build Type

push

github

Committed by

hectorgomezv

Commit Message

Init Valk API integration

Run Details

1190 of 1437 branches covered (0.0%)

Branch coverage included in aggregate %.

38 of 39 new or added lines in 10 files covered. (97.44%)

5 existing lines in 4 files now uncovered.

4507 of 4840 relevant lines covered (93.12%)

142.27 hits per line

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

80.0

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

import { Inject, Injectable } from '@nestjs/common';
import { IConfigurationService } from '../../config/configuration.service.interface';
import { DataSourceError } from '../../domain/errors/data-source.error';
import { IBalancesApi } from '../../domain/interfaces/portfolios-api.interface';
import { CacheFirstDataSource } from '../cache/cache.first.data.source';
import { CacheRouter } from '../cache/cache.router';
import { CacheService, ICacheService } from '../cache/cache.service.interface';
import { ProviderBalance } from '@/domain/portfolios/entities/provider-balance.entity';

@Injectable()
export class PortfoliosApi implements IBalancesApi {
  private readonly apiKey: string;
  private readonly baseUrl: string;
  private readonly defaultExpirationTimeInSeconds: number;
  private readonly defaultNotFoundExpirationTimeSeconds: number;

  constructor(
    @Inject(CacheService) private readonly cacheService: ICacheService,
    @Inject(IConfigurationService)
    private readonly configurationService: IConfigurationService,
    private readonly dataSource: CacheFirstDataSource,
  ) {
    this.apiKey = this.configurationService.getOrThrow<string>(
      'portfoliosProvider.apiKey',
    );
    this.baseUrl = this.configurationService.getOrThrow<string>(
      'portfoliosProvider.baseUri',
    );
    this.defaultExpirationTimeInSeconds =
      this.configurationService.getOrThrow<number>(
        'expirationTimeInSeconds.default',
      );
    this.defaultNotFoundExpirationTimeSeconds =
      this.configurationService.getOrThrow<number>(
        'expirationTimeInSeconds.notFound.default',
      );
  }

  async clearProviderBalances(args: { safeAddress: string }): Promise<void> {
    await this.cacheService.deleteByKey(
      CacheRouter.getProviderBalancesCacheKey(args),
    );
  }

  async getProviderBalances(args: {
    chainName: string;
    safeAddress: string;
  }): Promise<ProviderBalance[]> {
    try {
      const cacheDir = CacheRouter.getProviderBalancesCacheDir(args);
      const { chainName, safeAddress } = args;
      const url = `${this.baseUrl}/balances/token/${safeAddress}?chain=${chainName}`;
      return await this.dataSource.get({
        cacheDir,
        url,
        notFoundExpireTimeSeconds: this.defaultNotFoundExpirationTimeSeconds,
        networkRequest: { headers: { authorization: `Basic ${this.apiKey}` } },
        expireTimeSeconds: this.defaultExpirationTimeInSeconds,
      });
    } catch (err) {
      throw new DataSourceError(
        `Error getting ${args.safeAddress} positions from provider: ${err?.status}`,
      );
    }
  }
}

1	import { Inject, Injectable } from '@nestjs/common';	60✔
2	import { IConfigurationService } from '../../config/configuration.service.interface';	60✔
3	import { DataSourceError } from '../../domain/errors/data-source.error';	60✔
4	import { IBalancesApi } from '../../domain/interfaces/portfolios-api.interface';
5	import { CacheFirstDataSource } from '../cache/cache.first.data.source';	60✔
6	import { CacheRouter } from '../cache/cache.router';	60✔
7	import { CacheService, ICacheService } from '../cache/cache.service.interface';	60✔
8	import { ProviderBalance } from '@/domain/portfolios/entities/provider-balance.entity';
9
10	@Injectable()
11	export class PortfoliosApi implements IBalancesApi {	60✔
12	private readonly apiKey: string;
13	private readonly baseUrl: string;
14	private readonly defaultExpirationTimeInSeconds: number;
15	private readonly defaultNotFoundExpirationTimeSeconds: number;
16
17	constructor(
18	@Inject(CacheService) private readonly cacheService: ICacheService,	404✔
19	@Inject(IConfigurationService)
20	private readonly configurationService: IConfigurationService,	404✔
21	private readonly dataSource: CacheFirstDataSource,	404✔
22	) {
23	this.apiKey = this.configurationService.getOrThrow<string>(	404✔
24	'portfoliosProvider.apiKey',
25	);
26	this.baseUrl = this.configurationService.getOrThrow<string>(	404✔
27	'portfoliosProvider.baseUri',
28	);
29	this.defaultExpirationTimeInSeconds =	404✔
30	this.configurationService.getOrThrow<number>(
31	'expirationTimeInSeconds.default',
32	);
33	this.defaultNotFoundExpirationTimeSeconds =	404✔
34	this.configurationService.getOrThrow<number>(
35	'expirationTimeInSeconds.notFound.default',
36	);
37	}
38
39	async clearProviderBalances(args: { safeAddress: string }): Promise<void> {
40	await this.cacheService.deleteByKey(	36✔
41	CacheRouter.getProviderBalancesCacheKey(args),
42	);
43	}
44
45	async getProviderBalances(args: {
46	chainName: string;
47	safeAddress: string;
48	}): Promise<ProviderBalance[]> {
49	try {	2✔
50	const cacheDir = CacheRouter.getProviderBalancesCacheDir(args);	2✔
51	const { chainName, safeAddress } = args;	2✔
52	const url = `${this.baseUrl}/balances/token/${safeAddress}?chain=${chainName}`;	2✔
53	return await this.dataSource.get({	2✔
54	cacheDir,
55	url,
56	notFoundExpireTimeSeconds: this.defaultNotFoundExpirationTimeSeconds,
57	networkRequest: { headers: { authorization: `Basic ${this.apiKey}` } },
58	expireTimeSeconds: this.defaultExpirationTimeInSeconds,
59	});
60	} catch (err) {
UNCOV 61	throw new DataSourceError(	×
62	`Error getting ${args.safeAddress} positions from provider: ${err?.status}`,	×
63	);
64	}
65	}
66	}

safe-global / safe-client-gateway / 6238449492

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