Added Burn & Sync events

Author: gurjotd23

services/decoder/protocols/uniswap-v2/abis/uniswap-v2.factory.abi.json

@@ -0,0 +1,4 @@
+[
+    {
+        "inputs":[{"internalType":"address","name":"_feeToSetter","type":"address"}],
+        "payable":false,"stateMutability":"nonpayable","type":"constructor"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"token0","type":"address"},{"indexed":true,"internalType":"address","name":"token1","type":"address"},{"indexed":false,"internalType":"address","name":"pair","type":"address"},{"indexed":false,"internalType":"uint256","name":"","type":"uint256"}],"name":"PairCreated","type":"event"},{"constant":true,"inputs":[{"internalType":"uint256","name":"","type":"uint256"}],"name":"allPairs","outputs":[{"internalType":"address","name":"","type":"address"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":true,"inputs":[],"name":"allPairsLength","outputs":[{"internalType":"uint256","name":"","type":"uint256"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":false,"inputs":[{"internalType":"address","name":"tokenA","type":"address"},{"internalType":"address","name":"tokenB","type":"address"}],"name":"createPair","outputs":[{"internalType":"address","name":"pair","type":"address"}],"payable":false,"stateMutability":"nonpayable","type":"function"},{"constant":true,"inputs":[],"name":"feeTo","outputs":[{"internalType":"address","name":"","type":"address"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":true,"inputs":[],"name":"feeToSetter","outputs":[{"internalType":"address","name":"","type":"address"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":true,"inputs":[{"internalType":"address","name":"","type":"address"},{"internalType":"address","name":"","type":"address"}],"name":"getPair","outputs":[{"internalType":"address","name":"","type":"address"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":false,"inputs":[{"internalType":"address","name":"_feeTo","type":"address"}],"name":"setFeeTo","outputs":[],"payable":false,"stateMutability":"nonpayable","type":"function"},{"constant":false,"inputs":[{"internalType":"address","name":"_feeToSetter","type":"address"}],"name":"setFeeToSetter","outputs":[],"payable":false,"stateMutability":"nonpayable","type":"function"}]

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

@@ -3,11 +3,28 @@ import { type Configs } from "../../decoder.types";
 const configs: Configs = [
     {
         protocol_name: "uniswap-v2",
-        // ? only for testing
         address: "0xaf31fd9c3b0350424bf96e551d2d1264d8466205",
         is_factory: false,
         network: "eth-mainnet",
     },
+    {
+        address: "0xb4e16d0168e52d35cacd2c6185b44281ec28c9dc",
+        is_factory: false,
+        protocol_name: "uniswap-v2",
+        network: "eth-mainnet",
+    },
+    {
+        address: "0x0d4a11d5eeaac28ec3f61d100daf4d40471f1852",
+        is_factory: false,
+        protocol_name: "uniswap-v2",
+        network: "eth-mainnet",
+    },
+    {
+        address: "0x5c69bee701ef814a2b6a3edd4b1652cb9cc5aa6f",
+        is_factory: true,
+        protocol_name: "uniswap-v2",
+        network: "eth-mainnet",
+    },
 ];
 
 export default configs;

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

@@ -4,6 +4,7 @@ import { GoldRushDecoder } from "../../decoder";
 import { TimestampParser } from "../../../../utils/functions";
 import { type EventType } from "../../decoder.types";
 import PairABI from "./abis/uniswap-v2.pair.abi.json";
+import FactoryABI from "./abis/uniswap-v2.factory.abi.json";
 import {
     DECODED_ACTION,
     DECODED_EVENT_CATEGORY,
@@ -45,8 +46,6 @@ GoldRushDecoder.on(
             inputDecimals: number = 0,
             outputDecimals: number = 0;
 
-        const prices: number[] = [];
-
         const { data } = await covalent_client.XykService.getPoolByAddress(
             chain_name,
             "uniswap_v2",
@@ -70,33 +69,6 @@ GoldRushDecoder.on(
                     decoded.amount0Out,
                 ];
             }
-
-            inputDecimals = +inputToken.contract_decimals;
-            outputDecimals = +outputToken.contract_decimals;
-
-            const date = TimestampParser(block_signed_at, "YYYY-MM-DD");
-            const pricesData = await Promise.all(
-                [inputToken, outputToken].map(
-                    ({ contract_address: token_address }) =>
-                        covalent_client.PricingService.getTokenPrices(
-                            chain_name,
-                            "USD",
-                            token_address,
-                            {
-                                from: date,
-                                to: date,
-                            }
-                        )
-                )
-            );
-            pricesData.forEach(({ data }) => {
-                const price = data?.[0]?.items;
-                if (price?.[0]?.price) {
-                    prices.push(price[0].price);
-                } else {
-                    prices.push(1);
-                }
-            });
         }
 
         return {
@@ -112,27 +84,31 @@ GoldRushDecoder.on(
                     ticker_logo: inputToken?.logo_url ?? null,
                     ticker_symbol: inputToken?.contract_ticker_symbol ?? null,
                     value: inputValue.toString(),
-                    decimals: inputDecimals,
+                    decimals: +(inputToken?.contract_decimals ?? 18),
                     pretty_quote: prettifyCurrency(
                         inputToken?.quote_rate ??
                             0 *
                                 (Number(inputValue) /
-                                    Math.pow(10, inputDecimals))
+                                    Math.pow(10, 
+                                        +(inputToken?.contract_decimals ?? 18)
+                                    ))
                     ),
-                    heading: "Input",
+                    heading: "Token In",
                 },
                 {
                     ticker_logo: outputToken?.logo_url ?? null,
                     ticker_symbol: outputToken?.contract_ticker_symbol ?? null,
                     value: outputValue.toString(),
-                    decimals: outputDecimals,
+                    decimals: +(outputToken?.contract_decimals ?? 18),
                     pretty_quote: prettifyCurrency(
                         outputToken?.quote_rate ??
                             0 *
                                 (Number(outputValue) /
-                                    Math.pow(10, outputDecimals))
+                                    Math.pow(10, 
+                                        +(outputToken?.contract_decimals ?? 18)
+                                    ))
                     ),
-                    heading: "Output",
+                    heading: "Token Out",
                 },
             ],
         };
@@ -207,7 +183,7 @@ GoldRushDecoder.on(
                                         +(token0?.contract_decimals ?? 18)
                                     ))
                     ),
-                    heading: "Input",
+                    heading: "Token 0 Deposited",
                 },
                 {
                     ticker_logo: token1?.logo_url ?? null,
@@ -223,9 +199,263 @@ GoldRushDecoder.on(
                                         +(token1?.contract_decimals ?? 18)
                                     ))
                     ),
-                    heading: "Output",
+                    heading: "Token 1 Deposited",
+                },
+            ],
+        };
+    }
+);
+
+GoldRushDecoder.on(
+    "uniswap-v2:Burn",
+    ["eth-mainnet"],
+    PairABI as Abi,
+    async (log_event, tx, chain_name, covalent_client): Promise<EventType> => {
+        const {
+            sender_address: exchange_contract,
+            block_signed_at,
+            raw_log_data,
+            raw_log_topics
+        } = log_event;
+
+        const { args: decoded } = decodeEventLog({
+            abi: PairABI,
+            topics: raw_log_topics as [],
+            data: raw_log_data as '0x${string}',
+            eventName: "Burn"
+        }) as {
+            eventName: "Burn";
+            args: {
+                sender: string;
+                amount0: bigint;
+                amount1: bigint;
+                to: string;
+            };
+        };
+
+        let token0: Token | null = null,
+            token1: Token | null = null,
+            value0: bigint = BigInt(0),
+            value1: bigint = BigInt(0);
+
+        const { data } = await covalent_client.XykService.getPoolByAddress(
+            chain_name,
+            "uniswap_v2",
+            exchange_contract
+        );
+        const { token_0, token_1 } = data?.items?.[0];
+        if (token_0 && token_1) {
+            [token0, token1, value0, value1] = [
+                token_0,
+                token_1,
+                decoded.amount0,
+                decoded.amount1,
+            ];
+        }
+
+        return {
+            action: DECODED_ACTION.SWAPPED,
+            category: DECODED_EVENT_CATEGORY.DEX,
+            name: "Burn",
+            protocol: {
+                logo: log_event.sender_logo_url as string,
+                name: log_event.sender_name as string,
+            },
+            tokens: [
+                {
+                    ticker_logo: token0?.logo_url ?? null,
+                    ticker_symbol: token0?.contract_ticker_symbol ?? null,
+                    value: value0.toString(),
+                    decimals: +(token0?.contract_decimals ?? 18),
+                    pretty_quote: prettifyCurrency(
+                        token0?.quote_rate ??
+                        0 *
+                            (Number(value0) / 
+                            Math.pow(
+                                10,
+                                +(token0?.contract_decimals ?? 18)
+                                ))
+                    ),
+                    heading: "Token 0 Redeemed",
+                },
+                {
+                    ticker_logo: token1?.logo_url ?? null,
+                    ticker_symbol: token1?.contract_ticker_symbol ?? null,
+                    value: value1.toString(),
+                    decimals: +(token1?.contract_decimals ?? 18),
+                    pretty_quote: prettifyCurrency(
+                        token1?.quote_rate ??
+                        0 *
+                            (Number(value0) / 
+                            Math.pow(
+                                10,
+                                +(token1?.contract_decimals ?? 18)
+                                ))
+                    ),
+                    heading: "Token 1 Redeemed",
+                },
+            ],
+        };
+
+    }
+);
+
+GoldRushDecoder.on(
+    "uniswap-v2:Sync",
+    ["eth-mainnet"],
+    PairABI as Abi,
+    async (log_event, tx, chain_name, covalent_client): Promise<EventType> => {
+        const {
+            sender_address: exchange_contract,
+            block_signed_at,
+            raw_log_data,
+            raw_log_topics
+        } = log_event;
+
+        const { args: decoded } = decodeEventLog({
+            abi: PairABI,
+            topics: raw_log_topics as [],
+            data: raw_log_data as '0x${string}',
+            eventName: "Sync"
+        }) as {
+            eventName: "Sync";
+            args: {
+                reserve0: bigint;
+                reserve1: bigint;
+            };
+        };
+
+        let token0: Token | null = null,
+            token1: Token | null = null,
+            value0: bigint = BigInt(0),
+            value1: bigint = BigInt(0);
+
+        const { data } = await covalent_client.XykService.getPoolByAddress(
+            chain_name,
+            "uniswap_v2",
+            exchange_contract
+        );
+        const { token_0, token_1 } = data?.items?.[0];
+        if (token_0 && token_1) {
+            [token0, token1, value0, value1] = [
+                token_0,
+                token_1,
+                decoded.reserve0,
+                decoded.reserve1,
+            ];
+        }
+
+        return {
+            action: DECODED_ACTION.SWAPPED,
+            category: DECODED_EVENT_CATEGORY.DEX,
+            name: "Sync",
+            protocol: {
+                logo: log_event.sender_logo_url as string,
+                name: log_event.sender_name as string,
+            },
+            tokens: [
+                {
+                    ticker_logo: token0?.logo_url ?? null,
+                    ticker_symbol: token0?.contract_ticker_symbol ?? null,
+                    value: value0.toString(),
+                    decimals: +(token0?.contract_decimals ?? 18),
+                    pretty_quote: prettifyCurrency(
+                        token0?.quote_rate ??
+                        0 *
+                            (Number(value0) / 
+                            Math.pow(
+                                10,
+                                +(token0?.contract_decimals ?? 18)
+                                ))
+                    ),
+                    heading: "Reserve 0",
+                },
+                {
+                    ticker_logo: token1?.logo_url ?? null,
+                    ticker_symbol: token1?.contract_ticker_symbol ?? null,
+                    value: value1.toString(),
+                    decimals: +(token1?.contract_decimals ?? 18),
+                    pretty_quote: prettifyCurrency(
+                        token1?.quote_rate ??
+                        0 *
+                            (Number(value0) / 
+                            Math.pow(
+                                10,
+                                +(token1?.contract_decimals ?? 18)
+                                ))
+                    ),
+                    heading: "Reserve 1",
                 },
             ],
         };
+
     }
 );
+
+GoldRushDecoder.on(
+    "uniswap-v2:Pair Created",
+    ["eth-mainnet"],
+    FactoryABI as Abi,
+    async (log_event, tx, chain_name, covalent_client): Promise<EventType> => {
+        const {
+            sender_address: exchange_contract,
+            block_signed_at,
+            raw_log_data,
+            raw_log_topics
+        } = log_event;
+
+        const { args: decoded } = decodeEventLog({
+            abi: FactoryABI,
+            topics: raw_log_topics as [],
+            data: raw_log_data as '0x${string}',
+            eventName: "Pair Created"
+        }) as {
+            eventName: "Pair Created";
+            args: {
+                token0: string;
+                token1: string;
+                pair: string;
+                noname: bigint;
+            };
+        };
+
+        let token0: Token | null = null,
+            token1: Token | null = null,
+            pair: Token | null = null;
+
+        const { data } = await covalent_client.XykService.getPoolByAddress(
+            chain_name,
+            "uniswap_v2",
+            exchange_contract
+        );
+        const { token_0, token_1 } = data?.items?.[0];
+        if (token_0 && token_1) {
+            [token0, token1] = [
+                token_0,
+                token_1,
+            ];
+        }
+
+        return {
+            action: DECODED_ACTION.SWAPPED,
+            category: DECODED_EVENT_CATEGORY.DEX,
+            name: "Pair Created",
+            protocol: {
+                logo: log_event.sender_logo_url as string,
+                name: log_event.sender_name as string,
+            },
+            tokens: [
+                {
+                    ticker_logo: token0?.logo_url ?? null,
+                    ticker_symbol: token0?.contract_ticker_symbol ?? null,
+                    heading: "Token 0",
+                },
+                {
+                    
+                    heading: "Token 1",
+                },
+            ],
+        };
+
+    }
+);