6651220842

Committed 26 Oct 2023 08:05AM UTC coverage: 91.302% (+0.05%) from 91.254%

Build # 6651220842

Build Type

Pull #793

github

Committed by

iamacook

Commit Message

feat: parse alerts

Pull Request Pull Request #793: feat: add `/alerts` route

Run Details

1345 of 1599 branches covered (0.0%)

Branch coverage included in aggregate %.

65 of 68 new or added lines in 8 files covered. (95.59%)

1 existing line in 1 file now uncovered.

4911 of 5253 relevant lines covered (93.49%)

162.61 hits per line

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

82.86

/src/routes/alerts/alerts.service.ts

import { Inject, Injectable } from '@nestjs/common';
import { parseAbi, decodeEventLog, Hex, decodeFunctionData } from 'viem';
import { LoggingService, ILoggingService } from '@/logging/logging.interface';
import { Alert, AlertLog } from '@/routes/alerts/entities/alerts.entity';

const DELAY_MODIFIER_ABI = parseAbi([
  'event TransactionAdded(uint256 indexed queueNonce, bytes32 indexed txHash, address to, uint256 value, bytes data, uint8 operation)',
]);

const SAFE_ABI = parseAbi([
  'function addOwnerWithThreshold(address owner, uint256 _threshold)',
]);
@Injectable()
export class AlertsService {
  constructor(
    @Inject(LoggingService) private readonly loggingService: ILoggingService,
  ) {}

  onAlert(alert: Alert): void {
    for (const log of alert.transaction.logs) {
      const event = this.parseAlertLog(log);

      switch (event?.eventName) {
        case 'TransactionAdded': {
          const transactionAdded = this.parseTransactionAdded(event.args.data);

          if (!transactionAdded) {
            continue;
          }

          this.notifyOfTransactionAdded({
            safeAddress: event.args.to,
            ...transactionAdded,
          });
        }
      }
    }
  }

  private parseAlertLog(log: AlertLog) {
    try {
      return decodeEventLog({
        abi: DELAY_MODIFIER_ABI,
        data: log.data as Hex,
        topics: log.topics as [signature: Hex, ...args: Hex[]],
      });
    } catch {
      this.loggingService.warn({
        type: 'invalid_alert_log',
        ...log,
      });
    }
  }

  private parseTransactionAdded(data: Hex) {
    try {
      return decodeFunctionData({
        abi: SAFE_ABI,
        data,
      });
    } catch {
      this.loggingService.warn({
        type: 'invalid_alert_data',
        data,
      });
    }
  }

  private notifyOfTransactionAdded(
    args: ReturnType<typeof this.parseTransactionAdded> & { safeAddress: Hex },
  ) {
    switch (args.functionName) {
      case 'addOwnerWithThreshold': {
        const [owner, _threshold] = args.args;

        console.log(
          args.safeAddress,
          `addOwnerWithThreshold(${owner}, ${_threshold}) transaction added`,
        );

        break;
      }

      default: {
        console.log(args.safeAddress, 'Unknown transaction added');
      }
    }
  }
}

1	import { Inject, Injectable } from '@nestjs/common';	56✔
2	import { parseAbi, decodeEventLog, Hex, decodeFunctionData } from 'viem';	56✔
3	import { LoggingService, ILoggingService } from '@/logging/logging.interface';	56✔
4	import { Alert, AlertLog } from '@/routes/alerts/entities/alerts.entity';
5
6	const DELAY_MODIFIER_ABI = parseAbi([	56✔
7	'event TransactionAdded(uint256 indexed queueNonce, bytes32 indexed txHash, address to, uint256 value, bytes data, uint8 operation)',
8	]);
9
10	const SAFE_ABI = parseAbi([	56✔
11	'function addOwnerWithThreshold(address owner, uint256 _threshold)',
12	]);
13	@Injectable()
14	export class AlertsService {	56✔
15	constructor(
16	@Inject(LoggingService) private readonly loggingService: ILoggingService,	462✔
17	) {}
18
19	onAlert(alert: Alert): void {
20	for (const log of alert.transaction.logs) {	4✔
21	const event = this.parseAlertLog(log);	8✔
22
23	switch (event?.eventName) {	8✔
24	case 'TransactionAdded': {
25	const transactionAdded = this.parseTransactionAdded(event.args.data);	2✔
26
27	if (!transactionAdded) {	2!
NEW 28	continue;	×
29	}
30
31	this.notifyOfTransactionAdded({	2✔
32	safeAddress: event.args.to,
33	...transactionAdded,
34	});
35	}
36	}
37	}
38	}
39
40	private parseAlertLog(log: AlertLog) {
41	try {	8✔
42	return decodeEventLog({	8✔
43	abi: DELAY_MODIFIER_ABI,
44	data: log.data as Hex,
45	topics: log.topics as [signature: Hex, ...args: Hex[]],
46	});
47	} catch {
48	this.loggingService.warn({	6✔
49	type: 'invalid_alert_log',
50	...log,
51	});
52	}
53	}
54
55	private parseTransactionAdded(data: Hex) {
56	try {	2✔
57	return decodeFunctionData({	2✔
58	abi: SAFE_ABI,
59	data,
60	});
61	} catch {
NEW 62	this.loggingService.warn({	×
63	type: 'invalid_alert_data',
64	data,
65	});
66	}
67	}
68
69	private notifyOfTransactionAdded(
70	args: ReturnType<typeof this.parseTransactionAdded> & { safeAddress: Hex },
71	) {
72	switch (args.functionName) {	2!
73	case 'addOwnerWithThreshold': {
74	const [owner, _threshold] = args.args;	2✔
75
76	console.log(	2✔
77	args.safeAddress,
78	`addOwnerWithThreshold(${owner}, ${_threshold}) transaction added`,
79	);
80
81	break;	2✔
82	}
83
84	default: {
NEW 85	console.log(args.safeAddress, 'Unknown transaction added');	×
86	}
87	}
88	}
89	}

safe-global / safe-client-gateway / 6651220842

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