From e34cc680b764db0042ab751a09ee65b8846645c1 Mon Sep 17 00:00:00 2001 From: Boxer Date: Tue, 28 Jan 2025 11:26:54 +0100 Subject: [PATCH] moar chains --- .../dex_automated_base_trades.sql | 1 - .../ink/dex_ink_automated_base_trades.sql | 1 + .../uniswap_v3_ink_automated_base_trades.sql | 20 ++++++ .../uniswap_v3_ink_decoded_factory_evt.sql} | 6 +- .../uniswap_v3_ink_decoded_pool_evt_swap.sql} | 6 +- .../kava/dex_kava_automated_base_trades.sql | 64 ------------------- .../linea/dex_linea_automated_base_trades.sql | 1 + ...uniswap_v3_linea_automated_base_trades.sql | 20 ++++++ .../uniswap_v3_linea_decoded_factory_evt.sql | 15 +++++ ...uniswap_v3_linea_decoded_pool_evt_swap.sql | 15 +++++ .../dex_mantle_automated_base_trades.sql | 1 + ...niswap_v3_mantle_automated_base_trades.sql | 20 ++++++ .../uniswap_v3_mantle_decoded_factory_evt.sql | 15 +++++ ...niswap_v3_mantle_decoded_pool_evt_swap.sql | 15 +++++ .../nova/dex_nova_automated_base_trades.sql | 1 + ...uniswap_v3_nova_automated_base_trades.sql} | 12 ++-- .../uniswap_v3_nova_decoded_factory_evt.sql | 15 +++++ .../uniswap_v3_nova_decoded_pool_evt_swap.sql | 15 +++++ 18 files changed, 166 insertions(+), 77 deletions(-) create mode 100644 dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_automated_base_trades.sql rename dbt_subprojects/dex/models/automated_trades/{kava/projects/uniswap/uniswap_v2_kava_decoded_factory_evt.sql => ink/projects/uniswap/uniswap_v3_ink_decoded_factory_evt.sql} (75%) rename dbt_subprojects/dex/models/automated_trades/{kava/projects/uniswap/uniswap_v2_kava_decoded_pool_evt_swap.sql => ink/projects/uniswap/uniswap_v3_ink_decoded_pool_evt_swap.sql} (76%) delete mode 100644 dbt_subprojects/dex/models/automated_trades/kava/dex_kava_automated_base_trades.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_automated_base_trades.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_factory_evt.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_pool_evt_swap.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_automated_base_trades.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_factory_evt.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_pool_evt_swap.sql rename dbt_subprojects/dex/models/automated_trades/{kava/projects/uniswap/uniswap_v2_kava_automated_base_trades.sql => nova/projects/uniswap/uniswap_v3_nova_automated_base_trades.sql} (61%) create mode 100644 dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_factory_evt.sql create mode 100644 dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_pool_evt_swap.sql diff --git a/dbt_subprojects/dex/models/automated_trades/dex_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/dex_automated_base_trades.sql index 3ade89ac3f0..3c430a342d8 100644 --- a/dbt_subprojects/dex/models/automated_trades/dex_automated_base_trades.sql +++ b/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') diff --git a/dbt_subprojects/dex/models/automated_trades/ink/dex_ink_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/ink/dex_ink_automated_base_trades.sql index 81a27d5c4d8..26e32395e78 100644 --- a/dbt_subprojects/dex/models/automated_trades/ink/dex_ink_automated_base_trades.sql +++ b/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 ( diff --git a/dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_automated_base_trades.sql new file mode 100644 index 00000000000..3719106726d --- /dev/null +++ b/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') + ) +}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_factory_evt.sql b/dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_decoded_factory_evt.sql similarity index 75% rename from dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_factory_evt.sql rename to dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_decoded_factory_evt.sql index e4d7c141c5d..9741ae1c33f 100644 --- a/dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_factory_evt.sql +++ b/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') )}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_pool_evt_swap.sql b/dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_decoded_pool_evt_swap.sql similarity index 76% rename from dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_pool_evt_swap.sql rename to dbt_subprojects/dex/models/automated_trades/ink/projects/uniswap/uniswap_v3_ink_decoded_pool_evt_swap.sql index 3820c7c751f..a7b5cb43578 100644 --- a/dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_decoded_pool_evt_swap.sql +++ b/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') )}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/kava/dex_kava_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/kava/dex_kava_automated_base_trades.sql deleted file mode 100644 index 7f18d05dead..00000000000 --- a/dbt_subprojects/dex/models/automated_trades/kava/dex_kava_automated_base_trades.sql +++ /dev/null @@ -1,64 +0,0 @@ -{{ config( - schema = 'dex_kava' - , 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')] - ) -}} - -{% set models = [ - ref('uniswap_v2_kava_automated_base_trades') -] %} - -with base_union as ( - SELECT * - FROM - ( - {% for model in models %} - SELECT - blockchain - , project - , project_status - , version - , factory_address - , dex_type - , block_month - , block_date - , block_time - , block_number - , cast(token_bought_amount_raw as uint256) as token_bought_amount_raw - , cast(token_sold_amount_raw as uint256) as token_sold_amount_raw - , token_bought_address - , token_sold_address - , taker - , maker - , project_contract_address - , tx_hash - , evt_index - , tx_from - , tx_to - FROM - {{ model }} - WHERE - token_sold_amount_raw >= 0 and token_bought_amount_raw >= 0 - {% if is_incremental() %} - AND {{ incremental_predicate('block_time') }} - {% endif %} - {% if not loop.last %} - UNION ALL - {% endif %} - {% endfor %} - ) -) - -{{ - add_tx_columns( - model_cte = 'base_union' - , blockchain = 'kava' - , columns = ['from', 'to', 'index'] - ) -}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/linea/dex_linea_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/linea/dex_linea_automated_base_trades.sql index 715f2bacf61..22876bad12a 100644 --- a/dbt_subprojects/dex/models/automated_trades/linea/dex_linea_automated_base_trades.sql +++ b/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 ( diff --git a/dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_automated_base_trades.sql new file mode 100644 index 00000000000..a66805783a4 --- /dev/null +++ b/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') + ) +}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_factory_evt.sql b/dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_factory_evt.sql new file mode 100644 index 00000000000..abe6292c2c3 --- /dev/null +++ b/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') +)}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_pool_evt_swap.sql b/dbt_subprojects/dex/models/automated_trades/linea/projects/uniswap/uniswap_v3_linea_decoded_pool_evt_swap.sql new file mode 100644 index 00000000000..e50c561755b --- /dev/null +++ b/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') +)}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/mantle/dex_mantle_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/mantle/dex_mantle_automated_base_trades.sql index 3fa5b7f7304..32e2e0d2f86 100644 --- a/dbt_subprojects/dex/models/automated_trades/mantle/dex_mantle_automated_base_trades.sql +++ b/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 ( diff --git a/dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_automated_base_trades.sql new file mode 100644 index 00000000000..4aae1190eda --- /dev/null +++ b/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') + ) +}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_factory_evt.sql b/dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_factory_evt.sql new file mode 100644 index 00000000000..23c167b922f --- /dev/null +++ b/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') +)}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_pool_evt_swap.sql b/dbt_subprojects/dex/models/automated_trades/mantle/projects/uniswap/uniswap_v3_mantle_decoded_pool_evt_swap.sql new file mode 100644 index 00000000000..6ba9eedbfc5 --- /dev/null +++ b/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') +)}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/nova/dex_nova_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/nova/dex_nova_automated_base_trades.sql index 15c8c41e655..8dc996292cc 100644 --- a/dbt_subprojects/dex/models/automated_trades/nova/dex_nova_automated_base_trades.sql +++ b/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 ( diff --git a/dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_automated_base_trades.sql b/dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_automated_base_trades.sql similarity index 61% rename from dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_automated_base_trades.sql rename to dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_automated_base_trades.sql index a442a9afc64..dc0d8edc284 100644 --- a/dbt_subprojects/dex/models/automated_trades/kava/projects/uniswap/uniswap_v2_kava_automated_base_trades.sql +++ b/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') ) }} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_factory_evt.sql b/dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_factory_evt.sql new file mode 100644 index 00000000000..ac3d4bed827 --- /dev/null +++ b/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') +)}} \ No newline at end of file diff --git a/dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_pool_evt_swap.sql b/dbt_subprojects/dex/models/automated_trades/nova/projects/uniswap/uniswap_v3_nova_decoded_pool_evt_swap.sql new file mode 100644 index 00000000000..381353f60f7 --- /dev/null +++ b/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') +)}} \ No newline at end of file