adding rest of the wave1 v4 deployment to dex.trades (fingers crossed…

… dbt run works!)
duneanalytics · Jan 24, 2025 · 8c11cce · 8c11cce
1 parent 355ac53
commit 8c11cce
Show file tree

Hide file tree

Showing 44 changed files with 416 additions and 4 deletions.
diff --git a/dbt_subprojects/dex/models/trades/arbitrum/_schema.yml b/dbt_subprojects/dex/models/trades/arbitrum/_schema.yml
@@ -8,6 +8,25 @@ models:
           column_name: amount_usd
           max_value: 1000000000
 
+  - name: uniswap_v4_arbitrum_base_trades
+    meta:
+      blockchain: arbitrum
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'arbitrum', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap arbitrum v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_arbitrum_base_trades_seed')
+          filter:
+            version: 4
+
   - name: uniswap_v3_arbitrum_base_trades
     meta:
       blockchain: arbitrum

diff --git a/dbt_subprojects/dex/models/trades/arbitrum/dex_arbitrum_base_trades.sql b/dbt_subprojects/dex/models/trades/arbitrum/dex_arbitrum_base_trades.sql
@@ -7,6 +7,7 @@
 
 {% set base_models = [
     ref('uniswap_v3_arbitrum_base_trades')
+    , ref('uniswap_v4_arbitrum_base_trades')
     , ref('camelot_v2_arbitrum_base_trades')
     , ref('camelot_v3_arbitrum_base_trades')
     , ref('airswap_arbitrum_base_trades')

diff --git a/dbt_subprojects/dex/models/trades/arbitrum/platforms/uniswap_v4_arbitrum_base_trades.sql b/dbt_subprojects/dex/models/trades/arbitrum/platforms/uniswap_v4_arbitrum_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_arbitrum'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'arbitrum'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_arbitrum', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_arbitrum', 'PoolManager_evt_Initialize')
+    )
+}}
diff --git a/dbt_subprojects/dex/models/trades/avalanche_c/_schema.yml b/dbt_subprojects/dex/models/trades/avalanche_c/_schema.yml
@@ -8,6 +8,25 @@ models:
           column_name: amount_usd
           max_value: 1000000000
 
+  - name: uniswap_v4_avalanche_c_base_trades
+    meta:
+      blockchain: avalanche_c
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'avalanche_c', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap avalanche_c v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_avalanche_c_base_trades_seed')
+          filter:
+            version: 4
+
   - name: uniswap_v3_avalanche_c_base_trades
     meta:
       blockchain: avalanche_c

diff --git a/dbt_subprojects/dex/models/trades/avalanche_c/dex_avalanche_c_base_trades.sql b/dbt_subprojects/dex/models/trades/avalanche_c/dex_avalanche_c_base_trades.sql
@@ -7,6 +7,7 @@
 
 {% set base_models = [
     ref('uniswap_v3_avalanche_c_base_trades')
+    , ref('uniswap_v4_avalanche_c_base_trades')
     , ref('airswap_avalanche_c_base_trades')
     , ref('sushiswap_v1_avalanche_c_base_trades')
     , ref('sushiswap_v2_avalanche_c_base_trades')

diff --git a/...ubprojects/dex/models/trades/avalanche_c/platforms/uniswap_v4_avalanche_c_base_trades.sql b/...ubprojects/dex/models/trades/avalanche_c/platforms/uniswap_v4_avalanche_c_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_avalanche_c'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'avalanche_c'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_avalanche_c', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_avalanche_c', 'PoolManager_evt_Initialize')
+    )
+}}
diff --git a/dbt_subprojects/dex/models/trades/blast/_schema.yml b/dbt_subprojects/dex/models/trades/blast/_schema.yml
@@ -8,6 +8,25 @@ models:
           column_name: amount_usd
           max_value: 1000000000
 
+  - name: uniswap_v4_blast_base_trades
+    meta:
+      blockchain: blast
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'blast', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap blast v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_blast_base_trades_seed')
+          filter:
+            version: 4
+
   - name: uniswap_v3_blast_base_trades
     meta:
       blockchain: blast

diff --git a/dbt_subprojects/dex/models/trades/blast/dex_blast_base_trades.sql b/dbt_subprojects/dex/models/trades/blast/dex_blast_base_trades.sql
@@ -7,6 +7,7 @@
 
 {% set base_models = [
     ref('uniswap_v3_blast_base_trades')
+    , ref('uniswap_v4_blast_base_trades')
     , ref('uniswap_v2_blast_base_trades')
     , ref('thruster_blast_base_trades')
     , ref('blasterswap_blast_base_trades')

diff --git a/dbt_subprojects/dex/models/trades/blast/platforms/uniswap_v4_blast_base_trades.sql b/dbt_subprojects/dex/models/trades/blast/platforms/uniswap_v4_blast_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_blast'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'blast'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_blast', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_blast', 'PoolManager_evt_Initialize')
+    )
+}}
diff --git a/dbt_subprojects/dex/models/trades/bnb/_schema.yml b/dbt_subprojects/dex/models/trades/bnb/_schema.yml
@@ -8,6 +8,25 @@ models:
           column_name: amount_usd
           max_value: 1000000000
 
+  - name: uniswap_v4_bnb_base_trades
+    meta:
+      blockchain: bnb
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'bnb', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap bnb v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_bnb_base_trades_seed')
+          filter:
+            version: 4
+
   - name: uniswap_v3_bnb_base_trades
     meta:
       blockchain: bnb

diff --git a/dbt_subprojects/dex/models/trades/bnb/dex_bnb_base_trades.sql b/dbt_subprojects/dex/models/trades/bnb/dex_bnb_base_trades.sql
@@ -9,6 +9,7 @@
 -- (blockchain, project, project_version, model)
 {% set base_models = [
     ref('uniswap_v3_bnb_base_trades')
+    , ref('uniswap_v4_arbitrum_base_trades')
     , ref('apeswap_bnb_base_trades')
     , ref('airswap_bnb_base_trades')
     , ref('sushiswap_v1_bnb_base_trades')

diff --git a/dbt_subprojects/dex/models/trades/bnb/platforms/uniswap_v4_bnb_base_trades.sql b/dbt_subprojects/dex/models/trades/bnb/platforms/uniswap_v4_bnb_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_bnb'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'bnb'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_bnb', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_bnb', 'PoolManager_evt_Initialize')
+    )
+}}
diff --git a/dbt_subprojects/dex/models/trades/ethereum/_schema.yml b/dbt_subprojects/dex/models/trades/ethereum/_schema.yml
@@ -65,6 +65,25 @@ models:
           filter:
             version: 3
 
+  - name: uniswap_v4_ethereum_base_trades
+    meta:
+      blockchain: ethereum
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'ethereum', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap ethereum v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_ethereum_base_trades_seed')
+          filter:
+            version: 4
+
   - name: defiswap_ethereum_base_trades
     meta:
       blockchain: ethereum

diff --git a/dbt_subprojects/dex/models/trades/ethereum/dex_ethereum_base_trades.sql b/dbt_subprojects/dex/models/trades/ethereum/dex_ethereum_base_trades.sql
@@ -10,6 +10,7 @@
     , ref('uniswap_v1_ethereum_base_trades')
     , ref('uniswap_v2_ethereum_base_trades')
     , ref('uniswap_v3_ethereum_base_trades')
+    , ref('uniswap_v4_ethereum_base_trades')
     , ref('apeswap_ethereum_base_trades')
     , ref('carbon_defi_ethereum_base_trades')
     , ref('airswap_ethereum_base_trades')

diff --git a/dbt_subprojects/dex/models/trades/ethereum/platforms/uniswap_v4_ethereum_base_trades.sql b/dbt_subprojects/dex/models/trades/ethereum/platforms/uniswap_v4_ethereum_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_ethereum'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'ethereum'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_ethereum', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_ethereum', 'PoolManager_evt_Initialize')
+    )
+}}
diff --git a/dbt_subprojects/dex/models/trades/optimism/_schema.yml b/dbt_subprojects/dex/models/trades/optimism/_schema.yml
@@ -8,6 +8,25 @@ models:
           column_name: amount_usd
           max_value: 1000000000
 
+  - name: uniswap_v4_optimism_base_trades
+    meta:
+      blockchain: optimism
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'optimism', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap optimism v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_optimism_base_trades_seed')
+          filter:
+            version: 4
+
   - name: uniswap_v3_optimism_base_trades
     meta:
       blockchain: optimism

diff --git a/dbt_subprojects/dex/models/trades/optimism/dex_optimism_base_trades.sql b/dbt_subprojects/dex/models/trades/optimism/dex_optimism_base_trades.sql
@@ -7,6 +7,7 @@
 
 {% set base_models = [
     ref('uniswap_v3_optimism_base_trades')
+    , ref('uniswap_v4_optimism_base_trades')
     , ref('woofi_optimism_base_trades')
     , ref('mummy_finance_optimism_base_trades')
     , ref('sushiswap_v1_optimism_base_trades')

diff --git a/dbt_subprojects/dex/models/trades/optimism/platforms/uniswap_v4_optimism_base_trades.sql b/dbt_subprojects/dex/models/trades/optimism/platforms/uniswap_v4_optimism_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_optimism'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'optimism'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_optimism', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_optimism', 'PoolManager_evt_Initialize')
+    )
+}}
diff --git a/dbt_subprojects/dex/models/trades/polygon/_schema.yml b/dbt_subprojects/dex/models/trades/polygon/_schema.yml
@@ -7,6 +7,25 @@ models:
       - test_acceptable_usd_amount:
           column_name: amount_usd
           max_value: 1000000000
+
+  - name: uniswap_v4_polygon_base_trades
+    meta:
+      blockchain: polygon
+      sector: dex
+      project: uniswap
+      contributors: agaperste
+    config:
+      tags: [ 'polygon', 'dex', 'trades', 'uniswap', 'v4' ]
+    description: "uniswap polygon v4 base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('uniswap_polygon_base_trades_seed')
+          filter:
+            version: 4
 
   - name: uniswap_v3_polygon_base_trades
     meta:

diff --git a/dbt_subprojects/dex/models/trades/polygon/dex_polygon_base_trades.sql b/dbt_subprojects/dex/models/trades/polygon/dex_polygon_base_trades.sql
@@ -7,6 +7,7 @@
 
 {% set base_models = [
     ref('uniswap_v3_polygon_base_trades')
+    , ref('uniswap_v4_polygon_base_trades')
     , ref('apeswap_polygon_base_trades')
     , ref('airswap_polygon_base_trades')
     , ref('sushiswap_v1_polygon_base_trades')

diff --git a/dbt_subprojects/dex/models/trades/polygon/platforms/uniswap_v4_polygon_base_trades.sql b/dbt_subprojects/dex/models/trades/polygon/platforms/uniswap_v4_polygon_base_trades.sql
@@ -0,0 +1,20 @@
+{{ config(
+    schema = 'uniswap_v4_polygon'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    uniswap_compatible_v4_trades(
+        blockchain = 'polygon'
+        , project = 'uniswap'
+        , version = '4'
+        , PoolManager_evt_Swap = source('uniswap_v4_polygon', 'PoolManager_evt_Swap') 
+        , PoolManager_evt_Initialize = source('uniswap_v4_polygon', 'PoolManager_evt_Initialize')
+    )
+}}