10280822327

Committed 07 Aug 2024 08:26AM UTC coverage: 46.926% (-0.02%) from 46.946%

Build # 10280822327

Build Type

push

github

Committed by

web-flow

Commit Message

Implement Accounts creation rate limit (#1800)

Adds a rate limitation controlled by a cache key before proceeding with account creation

Run Details

468 of 2872 branches covered (16.3%)

Branch coverage included in aggregate %.

5 of 17 new or added lines in 3 files covered. (29.41%)

2 existing lines in 2 files now uncovered.

4546 of 7813 relevant lines covered (58.19%)

12.56 hits per line

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

10.53

/src/domain/accounts/accounts.repository.ts

import { IAccountsRepository } from '@/domain/accounts/accounts.repository.interface';
import { AccountDataSetting } from '@/domain/accounts/entities/account-data-setting.entity';
import { AccountDataType } from '@/domain/accounts/entities/account-data-type.entity';
import {
  Account,
  AccountSchema,
} from '@/domain/accounts/entities/account.entity';
import { UpsertAccountDataSettingsDto } from '@/domain/accounts/entities/upsert-account-data-settings.dto.entity';
import { AuthPayload } from '@/domain/auth/entities/auth-payload.entity';
import { IAccountsDatasource } from '@/domain/interfaces/accounts.datasource.interface';
import { Inject, Injectable, UnauthorizedException } from '@nestjs/common';

@Injectable()
export class AccountsRepository implements IAccountsRepository {
  constructor(
    @Inject(IAccountsDatasource)
    private readonly datasource: IAccountsDatasource,
  ) {}

  async createAccount(args: {
    authPayload: AuthPayload;
    address: `0x${string}`;
    clientIp: string;
  }): Promise<Account> {
    if (!args.authPayload.isForSigner(args.address)) {
      throw new UnauthorizedException();
    }
    const account = await this.datasource.createAccount({
      address: args.address,
      clientIp: args.clientIp,
    });
    return AccountSchema.parse(account);
  }

  async getAccount(args: {
    authPayload: AuthPayload;
    address: `0x${string}`;
  }): Promise<Account> {
    if (!args.authPayload.isForSigner(args.address)) {
      throw new UnauthorizedException();
    }
    const account = await this.datasource.getAccount(args.address);
    return AccountSchema.parse(account);
  }

  async deleteAccount(args: {
    authPayload: AuthPayload;
    address: `0x${string}`;
  }): Promise<void> {
    if (!args.authPayload.isForSigner(args.address)) {
      throw new UnauthorizedException();
    }
    return this.datasource.deleteAccount(args.address);
  }

  async getDataTypes(): Promise<AccountDataType[]> {
    return this.datasource.getDataTypes();
  }

  async getAccountDataSettings(args: {
    authPayload: AuthPayload;
    address: `0x${string}`;
  }): Promise<AccountDataSetting[]> {
    if (!args.authPayload.isForSigner(args.address)) {
      throw new UnauthorizedException();
    }

    return this.datasource.getAccountDataSettings(args.address);
  }

  async upsertAccountDataSettings(args: {
    authPayload: AuthPayload;
    address: `0x${string}`;
    upsertAccountDataSettingsDto: UpsertAccountDataSettingsDto;
  }): Promise<AccountDataSetting[]> {
    const { address, upsertAccountDataSettingsDto } = args;
    if (!args.authPayload.isForSigner(args.address)) {
      throw new UnauthorizedException();
    }
    if (upsertAccountDataSettingsDto.accountDataSettings.length === 0) {
      return [];
    }

    return this.datasource.upsertAccountDataSettings({
      address,
      upsertAccountDataSettingsDto,
    });
  }
}

1	import { IAccountsRepository } from '@/domain/accounts/accounts.repository.interface';
2	import { AccountDataSetting } from '@/domain/accounts/entities/account-data-setting.entity';
3	import { AccountDataType } from '@/domain/accounts/entities/account-data-type.entity';
4	import {	16✔
5	Account,
6	AccountSchema,
7	} from '@/domain/accounts/entities/account.entity';
8	import { UpsertAccountDataSettingsDto } from '@/domain/accounts/entities/upsert-account-data-settings.dto.entity';
9	import { AuthPayload } from '@/domain/auth/entities/auth-payload.entity';
10	import { IAccountsDatasource } from '@/domain/interfaces/accounts.datasource.interface';	16✔
11	import { Inject, Injectable, UnauthorizedException } from '@nestjs/common';	16✔
12
13	@Injectable()
14	export class AccountsRepository implements IAccountsRepository {	16✔
15	constructor(
16	@Inject(IAccountsDatasource)
17	private readonly datasource: IAccountsDatasource,	×
18	) {}
19
20	async createAccount(args: {
21	authPayload: AuthPayload;
22	address: `0x${string}`;
23	clientIp: string;
24	}): Promise<Account> {
25	if (!args.authPayload.isForSigner(args.address)) {	×
26	throw new UnauthorizedException();	×
27	}
NEW 28	const account = await this.datasource.createAccount({	×
29	address: args.address,
30	clientIp: args.clientIp,
31	});
UNCOV 32	return AccountSchema.parse(account);	×
33	}
34
35	async getAccount(args: {
36	authPayload: AuthPayload;
37	address: `0x${string}`;
38	}): Promise<Account> {
39	if (!args.authPayload.isForSigner(args.address)) {	×
40	throw new UnauthorizedException();	×
41	}
42	const account = await this.datasource.getAccount(args.address);	×
43	return AccountSchema.parse(account);	×
44	}
45
46	async deleteAccount(args: {
47	authPayload: AuthPayload;
48	address: `0x${string}`;
49	}): Promise<void> {
50	if (!args.authPayload.isForSigner(args.address)) {	×
51	throw new UnauthorizedException();	×
52	}
53	return this.datasource.deleteAccount(args.address);	×
54	}
55
56	async getDataTypes(): Promise<AccountDataType[]> {
57	return this.datasource.getDataTypes();	×
58	}
59
60	async getAccountDataSettings(args: {
61	authPayload: AuthPayload;
62	address: `0x${string}`;
63	}): Promise<AccountDataSetting[]> {
64	if (!args.authPayload.isForSigner(args.address)) {	×
65	throw new UnauthorizedException();	×
66	}
67
68	return this.datasource.getAccountDataSettings(args.address);	×
69	}
70
71	async upsertAccountDataSettings(args: {
72	authPayload: AuthPayload;
73	address: `0x${string}`;
74	upsertAccountDataSettingsDto: UpsertAccountDataSettingsDto;
75	}): Promise<AccountDataSetting[]> {
76	const { address, upsertAccountDataSettingsDto } = args;	×
77	if (!args.authPayload.isForSigner(args.address)) {	×
78	throw new UnauthorizedException();	×
79	}
80	if (upsertAccountDataSettingsDto.accountDataSettings.length === 0) {	×
81	return [];	×
82	}
83
84	return this.datasource.upsertAccountDataSettings({	×
85	address,
86	upsertAccountDataSettingsDto,
87	});
88	}
89	}

safe-global / safe-client-gateway / 10280822327

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