Mass decoding non dynamic

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/decoding_base.sql

@@ -0,0 +1,27 @@
+{% macro evm_event_decoding_base(
+    logs = null,
+    abi = null,
+    topic0 = null
+    )
+%}
+
+SELECT
+*
+
+FROM TABLE (
+    decode_evm_event (
+      abi => '{{abi}}',
+      input => TABLE (
+        SELECT l.* 
+        FROM {{logs}} l
+        WHERE topic0 = {{topic0}}
+            {% if is_incremental() %}
+            AND {{ incremental_predicate('block_time') }}
+            {% else %}
+            AND block_date >= (SELECT MIN(block_date) FROM {{logs}} WHERE topic0 = {{topic0}})
+            {% endif %}
+      )
+    )
+  )
+
+{% endmacro %}

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/uniswap_v2/uniswap_v2_factory_mass_decoding.sql

@@ -0,0 +1,39 @@
+{% macro uniswap_v2_factory_mass_decoding(logs) %}
+
+{% set abi = '{
+    "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": "pair_index",
+            "type": "uint256"
+        }
+    ],
+    "name": "PairCreated",
+    "type": "event"
+}' %}
+
+{% set topic0 = '0x0d3648bd0f6ba80134a33ba9275ac585d9d315f0ad8355cddefde31afa28d0e9' %}
+
+{{ evm_event_decoding_base(logs, abi, topic0) }}
+
+{% endmacro %}

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/uniswap_v2/uniswap_v2_pool_mass_decoding.sql

@@ -0,0 +1,51 @@
+{% macro uniswap_v2_pool_mass_decoding(logs) %}
+
+{% set abi = '{
+    "anonymous": false,
+    "inputs": [
+        {
+            "indexed": true,
+            "internalType": "address",
+            "name": "sender",
+            "type": "address"
+        },
+        {
+            "indexed": false,
+            "internalType": "uint256",
+            "name": "amount0In",
+            "type": "uint256"
+        },
+        {
+            "indexed": false,
+            "internalType": "uint256",
+            "name": "amount1In",
+            "type": "uint256"
+        },
+        {
+            "indexed": false,
+            "internalType": "uint256",
+            "name": "amount0Out",
+            "type": "uint256"
+        },
+        {
+            "indexed": false,
+            "internalType": "uint256",
+            "name": "amount1Out",
+            "type": "uint256"
+        },
+        {
+            "indexed": true,
+            "internalType": "address",
+            "name": "to",
+            "type": "address"
+        }
+    ],
+    "name": "Swap",
+    "type": "event"
+}' %}
+
+{% set topic0 = '0xd78ad95fa46c994b6551d0da85fc275fe613ce37657fb8d5e3d130840159d822' %}
+
+{{ evm_event_decoding_base(logs, abi, topic0) }}
+
+{% endmacro %}

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/uniswap_v2/uniswap_v2_trades.sql

@@ -0,0 +1,78 @@
+{% macro uniswap_v2_forks_trades(
+    blockchain = null
+    , dex_type = 'uni-v2'
+    , project = null
+    , version = null
+    , Pair_evt_Swap = null
+    , Factory_evt_PairCreated = null
+    , pair_column_name = 'pair'
+    )
+%}
+
+WITH evt_swap AS (
+    SELECT
+        block_number
+        , block_time
+        , to
+        , contract_address
+        , tx_hash
+        , index
+        , amount0In
+        , amount0Out
+        , amount1In
+        , amount1Out
+    FROM {{ Pair_evt_Swap }}
+    {% if is_incremental() %}
+    WHERE {{ incremental_predicate('block_time') }}
+    {% endif %}
+)
+
+, dexs AS
+(
+    SELECT
+        t.block_number
+        , t.block_time
+        , t.to AS taker
+        , t.contract_address AS maker
+        , CASE WHEN amount0Out = UINT256 '0' THEN amount1Out ELSE amount0Out END AS token_bought_amount_raw
+        , CASE WHEN amount0In = UINT256 '0' OR amount1Out = UINT256 '0' THEN amount1In ELSE amount0In END AS token_sold_amount_raw
+        , CASE WHEN amount0Out = UINT256 '0' THEN f.token1 ELSE f.token0 END AS token_bought_address
+        , CASE WHEN amount0In = UINT256 '0' OR amount1Out = UINT256 '0' THEN f.token1 ELSE f.token0 END AS token_sold_address
+        , t.contract_address AS project_contract_address
+        , t.tx_hash
+        , t.index AS evt_index
+        , f.contract_address as factory_address
+    FROM
+        evt_swap t
+    INNER JOIN
+        {{ Factory_evt_PairCreated }} f
+        ON f.{{ pair_column_name }} = t.contract_address
+    --some scammers emitted events with established pair addresses, joining in the the creation trace to resolve correct factory
+    INNER JOIN {{ source(blockchain, 'creation_traces') }} ct 
+        ON f.{{ pair_column_name }} = ct.address 
+        AND f.contract_address = ct."from"
+)
+
+SELECT
+    '{{ blockchain }}' AS blockchain
+    , '{{project}}' AS project
+    , '{{ version }}' AS version
+    , '{{dex_type}}' AS dex_type
+    , CAST(date_trunc('month', dexs.block_time) AS date) AS block_month
+    , CAST(date_trunc('day', dexs.block_time) AS date) AS block_date
+    , dexs.block_time
+    , dexs.block_number
+    , dexs.token_bought_amount_raw
+    , dexs.token_sold_amount_raw
+    , dexs.token_bought_address
+    , dexs.token_sold_address
+    , dexs.taker
+    , dexs.maker
+    , dexs.project_contract_address
+    , dexs.tx_hash
+    , dexs.evt_index
+    , dexs.factory_address
+FROM
+    dexs
+
+{% endmacro %}

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/uniswap_v3/uniswap_v3_factory_mass_decoding.sql

@@ -0,0 +1,12 @@
+{% macro uniswap_v3_factory_mass_decoding(logs) %}
+
+{% set abi = '
+{"name":"PoolCreated","type":"event","inputs":[{"name":"token0","type":"address","indexed":true,"internalType":"address"},{"name":"token1","type":"address","indexed":true,"internalType":"address"},{"name":"fee","type":"uint24","indexed":true,"internalType":"uint24"},{"name":"tickSpacing","type":"int24","indexed":false,"internalType":"int24"},{"name":"pool","type":"address","indexed":false,"internalType":"address"}],"anonymous":false}
+' %}
+
+{% set topic0 = '0x783cca1c0412dd0d695e784568c96da2e9c22ff989357a2e8b1d9b2b4e6b7118' %}
+
+{{ evm_event_decoding_base(logs, abi, topic0) }}
+
+{% endmacro %}
+

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/uniswap_v3/uniswap_v3_pool_mass_decoding.sql

@@ -0,0 +1,12 @@
+{% macro uniswap_v3_pool_mass_decoding(logs) %}
+
+{% set abi = '
+{"name":"Swap","type":"event","inputs":[{"name":"sender","type":"address","indexed":true,"internalType":"address"},{"name":"recipient","type":"address","indexed":true,"internalType":"address"},{"name":"amount0","type":"int256","indexed":false,"internalType":"int256"},{"name":"amount1","type":"int256","indexed":false,"internalType":"int256"},{"name":"sqrtPriceX96","type":"uint160","indexed":false,"internalType":"uint160"},{"name":"liquidity","type":"uint128","indexed":false,"internalType":"uint128"},{"name":"tick","type":"int24","indexed":false,"internalType":"int24"}],"anonymous":false}
+' %}
+
+{% set topic0 = '0xc42079f94a6350d7e6235f29174924f928cc2ac818eb64fed8004e115fbcca67' %}
+
+{{ evm_event_decoding_base(logs, abi, topic0) }}
+
+{% endmacro %}
+

dbt_subprojects/dex/macros/models/_project/in-flight-decoding/uniswap_v3/uniswap_v3_trades.sql

@@ -0,0 +1,85 @@
+
+{% macro uniswap_v3_forks_trades(
+    blockchain = null
+    , dex_type = 'uni-v3'
+    , project = null
+    , version = null
+    , Pair_evt_Swap = null
+    , Factory_evt_PoolCreated = null
+    , pair_column_name = 'pool'
+    , taker_column_name = 'recipient'
+    , maker_column_name = null
+    )
+%}
+
+WITH evt_swap AS (
+    SELECT
+        block_number
+        , block_time
+        , {{ taker_column_name }}
+        {% if maker_column_name %}
+        , {{ maker_column_name }}
+        {% endif %}
+        , amount0
+        , amount1
+        , contract_address
+        , tx_hash
+        , index
+    FROM {{ Pair_evt_Swap }}
+    {% if is_incremental() %}
+    WHERE {{ incremental_predicate('block_time') }}
+    {% endif %}
+)
+
+, dexs AS
+(
+    SELECT
+        t.block_number
+        ,t.block_time
+        , t.{{ taker_column_name }} AS taker
+        , {% if maker_column_name %}
+                t.{{ maker_column_name }}
+            {% else %}
+                cast(null as varbinary)
+            {% endif %} as maker
+        , CASE WHEN amount0 < INT256 '0' THEN abs(amount0) ELSE abs(amount1) END AS token_bought_amount_raw -- when amount0 is negative it means trader_a is buying token0 from the pool
+        , CASE WHEN amount0 < INT256 '0' THEN abs(amount1) ELSE abs(amount0) END AS token_sold_amount_raw
+        , CASE WHEN amount0 < INT256 '0' THEN f.token0 ELSE f.token1 END AS token_bought_address
+        , CASE WHEN amount0 < INT256 '0' THEN f.token1 ELSE f.token0 END AS token_sold_address
+        , t.contract_address as project_contract_address
+        , t.tx_hash
+        , t.index as evt_index
+        , f.contract_address as factory_address
+    FROM
+        evt_swap t
+    INNER JOIN
+        {{ Factory_evt_PoolCreated }} f
+        ON f.{{ pair_column_name }} = t.contract_address
+    --some scammers emitted events with established pair addresses, joining in the the creation trace to resolve to correct factory
+    INNER JOIN {{ source(blockchain, 'creation_traces') }} ct 
+        ON f.{{ pair_column_name }} = ct.address 
+        AND f.contract_address = ct."from"
+)
+
+SELECT
+    '{{ blockchain }}' AS blockchain
+    , '{{ project }}' AS project
+    , '{{ version }}' AS version
+    , '{{dex_type}}' AS dex_type
+    , CAST(date_trunc('month', dexs.block_time) AS date) AS block_month
+    , CAST(date_trunc('day', dexs.block_time) AS date) AS block_date
+    , dexs.block_time
+    , dexs.block_number
+    , CAST(dexs.token_bought_amount_raw AS UINT256) AS token_bought_amount_raw
+    , CAST(dexs.token_sold_amount_raw AS UINT256) AS token_sold_amount_raw
+    , dexs.token_bought_address
+    , dexs.token_sold_address
+    , dexs.taker
+    , dexs.maker
+    , dexs.project_contract_address
+    , dexs.tx_hash
+    , dexs.evt_index
+    , dexs.factory_address
+FROM
+    dexs
+{% endmacro %}