2023-12-22 12:50:38 -08:00
|
|
|
import { HandleEvmLogsConfig } from "./HandleEvmLogs";
|
2024-01-30 07:19:44 -08:00
|
|
|
import { EvmTransaction } from "../../entities";
|
2023-12-22 12:50:38 -08:00
|
|
|
|
|
|
|
/**
|
|
|
|
* Handling means mapping and forward to a given target.
|
|
|
|
* As of today, we have mapped this event evmFailedRedeemed, evmStandardRelayDelivered and evmTransferRedeemed.
|
|
|
|
*/
|
|
|
|
export class HandleEvmTransactions<T> {
|
|
|
|
cfg: HandleEvmLogsConfig;
|
|
|
|
mapper: (log: EvmTransaction) => T;
|
|
|
|
target: (parsed: T[]) => Promise<void>;
|
|
|
|
|
|
|
|
constructor(
|
|
|
|
cfg: HandleEvmLogsConfig,
|
|
|
|
mapper: (log: EvmTransaction) => T,
|
|
|
|
target: (parsed: T[]) => Promise<void>
|
|
|
|
) {
|
|
|
|
this.cfg = this.normalizeCfg(cfg);
|
|
|
|
this.mapper = mapper;
|
|
|
|
this.target = target;
|
|
|
|
}
|
|
|
|
|
|
|
|
public async handle(transactions: EvmTransaction[]): Promise<T[]> {
|
|
|
|
const mappedItems = transactions.map((transaction) => {
|
|
|
|
return this.mapper(transaction);
|
2024-01-30 07:19:44 -08:00
|
|
|
}) as T[];
|
2023-12-22 12:50:38 -08:00
|
|
|
|
2024-01-30 07:19:44 -08:00
|
|
|
await this.target(mappedItems);
|
2023-12-22 12:50:38 -08:00
|
|
|
|
|
|
|
// TODO: return a result specifying failures if any
|
2024-01-30 07:19:44 -08:00
|
|
|
return mappedItems;
|
2023-12-22 12:50:38 -08:00
|
|
|
}
|
|
|
|
|
|
|
|
private normalizeCfg(cfg: HandleEvmLogsConfig): HandleEvmLogsConfig {
|
|
|
|
return {
|
|
|
|
filter: {
|
|
|
|
addresses: cfg.filter.addresses.map((addr) => addr.toLowerCase()),
|
|
|
|
topics: cfg.filter.topics.map((topic) => topic.toLowerCase()),
|
|
|
|
},
|
|
|
|
abi: cfg.abi,
|
|
|
|
};
|
|
|
|
}
|
|
|
|
}
|