moar chains

dbt_subprojects/dex/models/automated_trades/dex_automated_base_trades.sql

@@ -18,7 +18,6 @@
     , ref('dex_fantom_automated_base_trades')
     , ref('dex_gnosis_automated_base_trades')
     , ref('dex_ink_automated_base_trades')
-    , ref('dex_kava_automated_base_trades')
     , ref('dex_linea_automated_base_trades')
     , ref('dex_mantle_automated_base_trades')
     , ref('dex_nova_automated_base_trades')

dbt_subprojects/dex/models/automated_trades/ink/dex_ink_automated_base_trades.sql

@@ -12,6 +12,7 @@
 
 {% set models = [
     ref('uniswap_v2_ink_automated_base_trades')
+    , ref('uniswap_v3_ink_automated_base_trades')
 ] %}
 
 with base_union as (

dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_automated_base_trades.sql

@@ -0,0 +1,20 @@
+{{ config(
+        schema = 'uniswap_v3_ink',
+        alias = 'automated_base_trades',
+        partition_by = ['block_month'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'evt_index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{
+    uniswap_v3_forks_trades(
+        blockchain = 'ink'
+        , version = '3'
+        , Pair_evt_Swap = ref('uniswap_v3_ink_decoded_pool_evt_swap')
+        , Factory_evt_PoolCreated = ref('uniswap_v3_ink_decoded_factory_evt')
+    )
+}} 

dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_factory_evt.sql → dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_decoded_factory_evt.sql

@@ -1,5 +1,5 @@
 {{ config(
-        schema = 'uniswap_v2_kava',
+        schema = 'uniswap_v3_ink',
         alias = 'decoded_factory_evt',
         partition_by = ['block_date'],
         materialized = 'incremental',
@@ -10,6 +10,6 @@
         )
 }}
 
-{{uniswap_v2_factory_event_decoding(
-        logs = source('kava', 'logs')
+{{uniswap_v3_factory_event_decoding(
+        logs = source('ink', 'logs')
 )}} 

dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_pool_evt_swap.sql → dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_decoded_pool_evt_swap.sql

@@ -1,5 +1,5 @@
 {{ config(
-        schema = 'uniswap_v2_kava',
+        schema = 'uniswap_v3_ink',
         alias = 'decoded_pool_evt_swap',
         partition_by = ['block_date'],
         materialized = 'incremental',
@@ -10,6 +10,6 @@
         )
 }}
 
-{{uniswap_v2_pool_event_decoding(
-        logs = source('kava', 'logs')
+{{uniswap_v3_pool_event_decoding(
+        logs = source('ink', 'logs')
 )}} 

dbt_subprojects/dex/models/automated_trades/linea/dex_linea_automated_base_trades.sql

@@ -12,6 +12,7 @@
 
 {% set models = [
     ref('uniswap_v2_linea_automated_base_trades')
+    , ref('uniswap_v3_linea_automated_base_trades')
 ] %}
 
 with base_union as (

dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_automated_base_trades.sql

@@ -0,0 +1,20 @@
+{{ config(
+        schema = 'uniswap_v3_linea',
+        alias = 'automated_base_trades',
+        partition_by = ['block_month'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'evt_index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{
+    uniswap_v3_forks_trades(
+        blockchain = 'linea'
+        , version = '3'
+        , Pair_evt_Swap = ref('uniswap_v3_linea_decoded_pool_evt_swap')
+        , Factory_evt_PoolCreated = ref('uniswap_v3_linea_decoded_factory_evt')
+    )
+}} 

dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_factory_evt.sql

@@ -0,0 +1,15 @@
+{{ config(
+        schema = 'uniswap_v3_linea',
+        alias = 'decoded_factory_evt',
+        partition_by = ['block_date'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{uniswap_v3_factory_event_decoding(
+        logs = source('linea', 'logs')
+)}} 

dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_pool_evt_swap.sql

@@ -0,0 +1,15 @@
+{{ config(
+        schema = 'uniswap_v3_linea',
+        alias = 'decoded_pool_evt_swap',
+        partition_by = ['block_date'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{uniswap_v3_pool_event_decoding(
+        logs = source('linea', 'logs')
+)}} 

dbt_subprojects/dex/models/automated_trades/mantle/dex_mantle_automated_base_trades.sql

@@ -12,6 +12,7 @@
 
 {% set models = [
     ref('uniswap_v2_mantle_automated_base_trades')
+    , ref('uniswap_v3_mantle_automated_base_trades')
 ] %}
 
 with base_union as (

dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_automated_base_trades.sql

@@ -0,0 +1,20 @@
+{{ config(
+        schema = 'uniswap_v3_mantle',
+        alias = 'automated_base_trades',
+        partition_by = ['block_month'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'evt_index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{
+    uniswap_v3_forks_trades(
+        blockchain = 'mantle'
+        , version = '3'
+        , Pair_evt_Swap = ref('uniswap_v3_mantle_decoded_pool_evt_swap')
+        , Factory_evt_PoolCreated = ref('uniswap_v3_mantle_decoded_factory_evt')
+    )
+}} 

dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_factory_evt.sql

@@ -0,0 +1,15 @@
+{{ config(
+        schema = 'uniswap_v3_mantle',
+        alias = 'decoded_factory_evt',
+        partition_by = ['block_date'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{uniswap_v3_factory_event_decoding(
+        logs = source('mantle', 'logs')
+)}} 

dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_pool_evt_swap.sql

@@ -0,0 +1,15 @@
+{{ config(
+        schema = 'uniswap_v3_mantle',
+        alias = 'decoded_pool_evt_swap',
+        partition_by = ['block_date'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{uniswap_v3_pool_event_decoding(
+        logs = source('mantle', 'logs')
+)}} 

dbt_subprojects/dex/models/automated_trades/nova/dex_nova_automated_base_trades.sql

@@ -12,6 +12,7 @@
 
 {% set models = [
     ref('uniswap_v2_nova_automated_base_trades')
+    , ref('uniswap_v3_nova_automated_base_trades')
 ] %}
 
 with base_union as (

dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_automated_base_trades.sql → dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_automated_base_trades.sql

@@ -1,5 +1,5 @@
 {{ config(
-        schema = 'uniswap_v2_kava',
+        schema = 'uniswap_v3_nova',
         alias = 'automated_base_trades',
         partition_by = ['block_month'],
         materialized = 'incremental',
@@ -11,10 +11,10 @@
 }}
 
 {{
-    uniswap_v2_forks_trades(
-        blockchain = 'kava'
-        , version = '2'
-        , Pair_evt_Swap = ref('uniswap_v2_kava_decoded_pool_evt_swap')
-        , Factory_evt_PairCreated = ref('uniswap_v2_kava_decoded_factory_evt')
+    uniswap_v3_forks_trades(
+        blockchain = 'nova'
+        , version = '3'
+        , Pair_evt_Swap = ref('uniswap_v3_nova_decoded_pool_evt_swap')
+        , Factory_evt_PoolCreated = ref('uniswap_v3_nova_decoded_factory_evt')
     )
 }} 

dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_factory_evt.sql

@@ -0,0 +1,15 @@
+{{ config(
+        schema = 'uniswap_v3_nova',
+        alias = 'decoded_factory_evt',
+        partition_by = ['block_date'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{uniswap_v3_factory_event_decoding(
+        logs = source('nova', 'logs')
+)}} 

dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_pool_evt_swap.sql

@@ -0,0 +1,15 @@
+{{ config(
+        schema = 'uniswap_v3_nova',
+        alias = 'decoded_pool_evt_swap',
+        partition_by = ['block_date'],
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+        )
+}}
+
+{{uniswap_v3_pool_event_decoding(
+        logs = source('nova', 'logs')
+)}}