fix(decoder): log sequence + execution

Author: jagnani73

services/decoder/decoder.ts

@@ -167,30 +167,36 @@ export class GoldRushDecoder {
     ) => {
         const covalent_client = new CovalentClient(covalent_api_key);
         const events: EventType[] = [];
-        const logs = (tx.log_events ?? []).reverse();
         if (tx.value) {
             const nativeEvent = this.native_decoder(tx);
             events.push(nativeEvent);
         }
-        for (const log of logs) {
-            const {
-                raw_log_topics: [topic0_hash],
-                sender_address: contract_address,
-                // !ERROR: add factory_contract_address in the log_event(s)
-                // factory_contract_address,
-            } = log;
-            const decoding_index =
-                // !ERROR: add factory_contract_address in the log_event(s)
-                // factory_contract_address ||
-                this.decoders[chain_name]?.[contract_address]?.[topic0_hash];
-            const fallback_index = this.fallbacks[topic0_hash];
-            if (decoding_index !== undefined || fallback_index !== undefined) {
-                const logEvent = await this.decoding_functions[
-                    decoding_index ?? fallback_index
-                ](log, tx, chain_name, covalent_client);
-                events.push(logEvent);
-            }
-        }
-        return events;
+        const decodedEvents = await Promise.all(
+            (tx.log_events ?? []).map((log) => {
+                const {
+                    raw_log_topics: [topic0_hash],
+                    sender_address: contract_address,
+                    // !ERROR: add factory_contract_address in the log_event(s)
+                    // factory_contract_address,
+                } = log;
+                const decoding_index =
+                    // !ERROR: add factory_contract_address in the log_event(s)
+                    // factory_contract_address ||
+                    this.decoders[chain_name]?.[contract_address]?.[
+                        topic0_hash
+                    ];
+                const fallback_index = this.fallbacks[topic0_hash];
+                if (
+                    decoding_index !== undefined ||
+                    fallback_index !== undefined
+                ) {
+                    return this.decoding_functions[
+                        decoding_index ?? fallback_index
+                    ](log, tx, chain_name, covalent_client);
+                }
+                return null;
+            })
+        );
+        return events.concat(decodedEvents.filter(Boolean) as EventType[]);
     };
 }