feat(decoders): add tx to decoding function

Author: jagnani73

README.md

@@ -41,7 +41,7 @@ This repository contains the logic for decoding a `raw_log_event` of a transacti
             "<protocol-name>:<EventName>",
             ["<network_1>", "<network_2>"],
             ABI as Abi,
-            async (log, chain_name, covalent_client): Promise<EventType> => {
+            async (log, chain_name, covalent_client, tx): Promise<EventType> => {
                 <!-- decoding logic -->
             }
         );
@@ -55,6 +55,7 @@ This repository contains the logic for decoding a `raw_log_event` of a transacti
             1. `log`: The raw log event that is being decoded.
             2. `chain_name`: Network to which the log belongs to.
             3. `covalent_client`: The covalent client created with your covalent API key.
+            4. `tx`: The transaction object that generated this log.
 
     3.  `decode`: The function that chooses which decoding function needs to be called for which log event. It collects all the decoded events for a transaction and returns them in an array of structured data. It is run when the API server receives a request.
 

microservices/tx/tx.routes.ts

@@ -11,7 +11,7 @@ import {
     decodeTXHeadersSchema,
     type DecodeTXHeaders,
 } from "./tx.schema";
-import { fetchEventsFromLogs, fetchDataFromTx } from "./tx.service";
+import { fetchEventsFromTx, fetchTxDataFromHash } from "./tx.service";
 import { type Chain } from "@covalenthq/client-sdk";
 
 export const txRouter = Router();
@@ -26,24 +26,32 @@ const handleDecode = async (
             "x-covalent-api-key"
         ];
         const { network, tx_hash } = req.body as DecodeTXRequest;
-        const { log_events, metadata } = await fetchDataFromTx(
+        const tx = await fetchTxDataFromHash(
             network as Chain,
             tx_hash,
             covalentApiKey
         );
-        const data = await fetchEventsFromLogs(
+        const events = await fetchEventsFromTx(
             network as Chain,
-            log_events,
+            tx,
             covalentApiKey
         );
+        const {
+            log_events,
+            dex_details,
+            nft_sale_details,
+            lending_details,
+            safe_details,
+            ...metadata
+        } = tx;
         const parsedMetadata = JSON.parse(
             JSON.stringify(metadata, (_key, value) => {
                 return typeof value === "bigint" ? value.toString() : value;
             })
         );
         res.json({
             success: true,
-            events: data,
+            events: events,
             metadata: parsedMetadata,
         });
     } catch (error) {

microservices/tx/tx.service.ts

@@ -2,10 +2,10 @@ import { GoldRushDecoder } from "../../services";
 import {
     CovalentClient,
     type Chain,
-    type LogEvent,
+    type Transaction,
 } from "@covalenthq/client-sdk";
 
-export const fetchDataFromTx = async (
+export const fetchTxDataFromHash = async (
     network: Chain,
     tx_hash: string,
     covalentApiKey: string
@@ -24,19 +24,9 @@ export const fetchDataFromTx = async (
                 withSafe: false,
             }
         );
-    if (data) {
-        const {
-            log_events,
-            dex_details,
-            nft_sale_details,
-            lending_details,
-            safe_details,
-            ...metadata
-        } = data.items[0];
-        return {
-            log_events: log_events,
-            metadata: metadata,
-        };
+    const tx = data?.items?.[0];
+    if (tx) {
+        return tx;
     } else {
         throw {
             errorCode: error_code,
@@ -45,15 +35,11 @@ export const fetchDataFromTx = async (
     }
 };
 
-export const fetchEventsFromLogs = async (
+export const fetchEventsFromTx = async (
     network: Chain,
-    logs: LogEvent[],
+    tx: Transaction,
     covalentApiKey: string
 ) => {
-    const events = await GoldRushDecoder.decode(
-        network,
-        logs.reverse(),
-        covalentApiKey
-    );
+    const events = await GoldRushDecoder.decode(network, tx, covalentApiKey);
     return events;
 };

services/decoder/decoder.ts

@@ -3,7 +3,7 @@ import { join } from "path";
 import {
     CovalentClient,
     type Chain,
-    type LogEvent,
+    type Transaction,
 } from "@covalenthq/client-sdk";
 import {
     type Configs,
@@ -109,12 +109,13 @@ export class GoldRushDecoder {
 
     public static decode = async (
         network: Chain,
-        logs: LogEvent[],
+        tx: Transaction,
         covalent_api_key: string
     ) => {
         try {
-            const covalentClient = new CovalentClient(covalent_api_key);
+            const covalent_client = new CovalentClient(covalent_api_key);
             const events: EventType[] = [];
+            const logs = tx.log_events.reverse();
             for (const log of logs) {
                 const {
                     raw_log_topics: [topic0_hash],
@@ -130,7 +131,8 @@ export class GoldRushDecoder {
                     const event = await this.decoding_functions[function_index](
                         log,
                         network,
-                        covalentClient
+                        covalent_client,
+                        tx
                     );
                     events.push(event);
                 }

services/decoder/decoder.types.ts

@@ -2,6 +2,7 @@ import {
     type CovalentClient,
     type Chain,
     type LogEvent,
+    type Transaction,
 } from "@covalenthq/client-sdk";
 import {
     type DECODED_ACTION,
@@ -59,7 +60,8 @@ export interface EventType {
 export type DecodingFunction = (
     log: LogEvent,
     chain_name: Chain,
-    covalent_client: CovalentClient
+    covalent_client: CovalentClient,
+    tx: Transaction
 ) => Promise<EventType>;
 
 export type DecoderConfig =

services/decoder/protocols/4337-entry-point/4337-entry-point.decoders.ts

@@ -11,7 +11,7 @@ GoldRushDecoder.on(
     "4337-entry-point:UserOperationEvent",
     ["matic-mainnet"],
     ABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const { raw_log_data, raw_log_topics, sender_contract_decimals } = log;
 
         const { args: decoded } = decodeEventLog({

services/decoder/protocols/covalent-network/covalent-network.decoders.ts

@@ -11,7 +11,7 @@ GoldRushDecoder.on(
     "covalent-network:BlockSpecimenProductionProofSubmitted",
     ["moonbeam-mainnet"],
     TransparentUpgradeableProxyABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const { raw_log_data, raw_log_topics } = log;
 
         const { args: decoded } = decodeEventLog({

services/decoder/protocols/grindery-one/grindery-one.decoders.ts

@@ -11,7 +11,7 @@ GoldRushDecoder.on(
     "grindery-one:Transfer",
     ["matic-mainnet"],
     ABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const { raw_log_data, raw_log_topics } = log;
 
         const { args: decoded } = decodeEventLog({

services/decoder/protocols/opensea/opensea.decoders.ts

@@ -18,7 +18,7 @@ GoldRushDecoder.on(
     "opensea:OrderFulfilled",
     ["eth-mainnet", "matic-mainnet"],
     Seaport as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const { block_signed_at, raw_log_data, raw_log_topics } = log;
 
         enum ITEM_TYPE {

services/decoder/protocols/paraswap-v5/paraswap-v5.decoders.ts

@@ -19,7 +19,7 @@ GoldRushDecoder.on(
     "paraswap-v5:SwappedV3",
     ["eth-mainnet", "matic-mainnet"],
     SimpleSwapABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const { raw_log_data, raw_log_topics } = log;
 
         const { args: decoded } = decodeEventLog({

services/decoder/protocols/source-zorb/source-zorb.decoders.ts

@@ -11,7 +11,7 @@ GoldRushDecoder.on(
     "source-zorb:Transfer",
     ["zora-mainnet"],
     SourceZorbABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const { raw_log_data, raw_log_topics, sender_address } = log;
 
         const { args: decoded } = decodeEventLog({

services/decoder/protocols/uniswap-v2/uniswap-v2.decoders.ts

@@ -13,7 +13,7 @@ GoldRushDecoder.on(
     "uniswap-v2:Swap",
     ["eth-mainnet"],
     PairABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const {
             sender_address: exchange_contract,
             block_signed_at,
@@ -143,7 +143,7 @@ GoldRushDecoder.on(
     "uniswap-v2:Mint",
     ["eth-mainnet"],
     PairABI as Abi,
-    async (log, chain_name, covalent_client): Promise<EventType> => {
+    async (log, chain_name, covalent_client, tx): Promise<EventType> => {
         const {
             sender_address: exchange_contract,
             raw_log_data,