From 89b7e671de3882274e52983dd7a11c2a62a7ea54 Mon Sep 17 00:00:00 2001 From: tarikceric Date: Tue, 23 Sep 2025 15:17:00 -0700 Subject: [PATCH] update nft sales --- .../nft/sales/silver__nft_sales_bluemove.sql | 3 +- .../sales/silver__nft_sales_bluemove_view.sql | 35 +++++++++++++++++++ .../sales/silver__nft_sales_combined_view.sql | 11 +++++- .../nft/sales/silver__nft_sales_mercato.sql | 20 ++++++++--- .../nft/sales/silver__nft_sales_okx.sql | 3 +- .../nft/sales/silver__nft_sales_okx_view.sql | 34 ++++++++++++++++++ .../nft/sales/silver__nft_sales_seashrine.sql | 3 +- .../silver__nft_sales_seashrine_view.sql | 34 ++++++++++++++++++ .../nft/sales/silver__nft_sales_souffl3.sql | 3 +- .../sales/silver__nft_sales_souffl3_view.sql | 34 ++++++++++++++++++ .../nft/sales/silver__nft_sales_topaz.sql | 3 +- .../sales/silver__nft_sales_topaz_view.sql | 34 ++++++++++++++++++ models/sources.yml | 5 +++ 13 files changed, 212 insertions(+), 10 deletions(-) create mode 100644 models/silver/nft/sales/silver__nft_sales_bluemove_view.sql create mode 100644 models/silver/nft/sales/silver__nft_sales_okx_view.sql create mode 100644 models/silver/nft/sales/silver__nft_sales_seashrine_view.sql create mode 100644 models/silver/nft/sales/silver__nft_sales_souffl3_view.sql create mode 100644 models/silver/nft/sales/silver__nft_sales_topaz_view.sql diff --git a/models/silver/nft/sales/silver__nft_sales_bluemove.sql b/models/silver/nft/sales/silver__nft_sales_bluemove.sql index d11425a..ce4ead4 100644 --- a/models/silver/nft/sales/silver__nft_sales_bluemove.sql +++ b/models/silver/nft/sales/silver__nft_sales_bluemove.sql @@ -4,7 +4,8 @@ incremental_strategy = 'merge', cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'], merge_exclude_columns = ["inserted_timestamp"], - tags = ['noncore'] + full_refresh = false, + enabled = false, ) }} WITH evnts AS ( diff --git a/models/silver/nft/sales/silver__nft_sales_bluemove_view.sql b/models/silver/nft/sales/silver__nft_sales_bluemove_view.sql new file mode 100644 index 0000000..08be1df --- /dev/null +++ b/models/silver/nft/sales/silver__nft_sales_bluemove_view.sql @@ -0,0 +1,35 @@ +{{ config( + materialized = 'view' +) }} + +SELECT + block_timestamp, + block_number, + version, + tx_hash, + event_index, + event_type, + buyer_address, + seller_address, + nft_address, + token_version, + platform_address, + project_name, + tokenid, + platform_name, + platform_exchange_version, + total_price_raw, + platform_fee_raw, + creator_fee_raw, + total_fees_raw, + nft_sales_bluemove_id, + inserted_timestamp, + modified_timestamp, + _inserted_timestamp, + _invocation_id +FROM + {{ source( + 'aptos_silver', + 'nft_sales_bluemove' + ) }} + diff --git a/models/silver/nft/sales/silver__nft_sales_combined_view.sql b/models/silver/nft/sales/silver__nft_sales_combined_view.sql index 8920c4c..4f3b953 100644 --- a/models/silver/nft/sales/silver__nft_sales_combined_view.sql +++ b/models/silver/nft/sales/silver__nft_sales_combined_view.sql @@ -3,7 +3,16 @@ tags = ['noncore'] ) }} -{% set models = [ ('a',ref('silver__nft_sales_bluemove')),('a',ref('silver__nft_sales_bluemove_v2')),('a',ref('silver__nft_sales_mercato')),('a',ref('silver__nft_sales_okx')),('a',ref('silver__nft_sales_seashrine')),('a',ref('silver__nft_sales_souffl3')),('a',ref('silver__nft_sales_topaz')),('a',ref('silver__nft_sales_wapal'))] %} +{% set models = [ + ('a',ref('silver__nft_sales_bluemove_view')), + ('a',ref('silver__nft_sales_bluemove_v2')), + ('a',ref('silver__nft_sales_mercato')), + ('a',ref('silver__nft_sales_okx_view')), + ('a',ref('silver__nft_sales_seashrine_view')), + ('a',ref('silver__nft_sales_souffl3_view')), + ('a',ref('silver__nft_sales_topaz_view')), + ('a',ref('silver__nft_sales_wapal')) +] %} SELECT block_timestamp, diff --git a/models/silver/nft/sales/silver__nft_sales_mercato.sql b/models/silver/nft/sales/silver__nft_sales_mercato.sql index 6a3f47f..d69a58b 100644 --- a/models/silver/nft/sales/silver__nft_sales_mercato.sql +++ b/models/silver/nft/sales/silver__nft_sales_mercato.sql @@ -46,6 +46,11 @@ WITH evnts AS ( event_resource = 'DepositEvent' AND event_module = 'coin' ) + OR ( + event_resource = 'Deposit' + and event_module = 'fungible_asset' + and event_data:store::string = '0xbd29051e8eac1ade043a2f9fe1d54be3fe5e706494ca6e2456f12921741c95d7' + ) ) AND success @@ -57,7 +62,12 @@ AND _inserted_timestamp >= GREATEST( FROM {{ this }} ), - SYSDATE() :: DATE - 3 + ( + SELECT + MAX(_inserted_timestamp) + FROM + {{ this }} + ) ) {% endif %} ), @@ -397,8 +407,9 @@ deposit_events_mercator AS ( ) b ON A.tx_hash = b.tx_hash WHERE - event_resource = 'DepositEvent' - AND event_module = 'coin' + (event_resource = 'DepositEvent' + AND event_module = 'coin') + or (event_resource = 'Deposit' and event_module = 'fungible_asset') ), main_with_creator_fees_raw AS ( SELECT @@ -480,7 +491,8 @@ FROM AND platform.account_address IN ( '0x6a03eb973cd9385d62fc2842d02a4dd6b70e52f5da77a0689e57e48d93fae1b4', '0x41699a1297fba9645eae628d909966659d2da5a425911c3d7bccd54ffce6606a', - '0xe11c12ec495f3989c35e1c6a0af414451223305b579291fc8f3d9d0575a23c26' + '0xe11c12ec495f3989c35e1c6a0af414451223305b579291fc8f3d9d0575a23c26', + '0x0' ) qualify ROW_NUMBER() over ( PARTITION BY main.tx_hash, main.event_index diff --git a/models/silver/nft/sales/silver__nft_sales_okx.sql b/models/silver/nft/sales/silver__nft_sales_okx.sql index aa1bc15..a8b2cae 100644 --- a/models/silver/nft/sales/silver__nft_sales_okx.sql +++ b/models/silver/nft/sales/silver__nft_sales_okx.sql @@ -4,7 +4,8 @@ incremental_strategy = 'merge', cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'], merge_exclude_columns = ["inserted_timestamp"], - tags = ['noncore'] + full_refresh = false, + enabled = false, ) }} WITH evnts AS ( diff --git a/models/silver/nft/sales/silver__nft_sales_okx_view.sql b/models/silver/nft/sales/silver__nft_sales_okx_view.sql new file mode 100644 index 0000000..1c08c2b --- /dev/null +++ b/models/silver/nft/sales/silver__nft_sales_okx_view.sql @@ -0,0 +1,34 @@ +{{ config( + materialized = 'view' +) }} + +SELECT + block_timestamp, + block_number, + version, + tx_hash, + event_index, + event_type, + buyer_address, + seller_address, + nft_address, + token_version, + platform_address, + project_name, + tokenid, + platform_name, + platform_exchange_version, + total_price_raw, + platform_fee_raw, + creator_fee_raw, + total_fees_raw, + nft_sales_okx_id, + inserted_timestamp, + modified_timestamp, + _inserted_timestamp, + _invocation_id +FROM + {{ source( + 'aptos_silver', + 'nft_sales_okx' + ) }} diff --git a/models/silver/nft/sales/silver__nft_sales_seashrine.sql b/models/silver/nft/sales/silver__nft_sales_seashrine.sql index b454822..40576b3 100644 --- a/models/silver/nft/sales/silver__nft_sales_seashrine.sql +++ b/models/silver/nft/sales/silver__nft_sales_seashrine.sql @@ -4,7 +4,8 @@ incremental_strategy = 'merge', cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'], merge_exclude_columns = ["inserted_timestamp"], - tags = ['noncore'] + full_refresh = false, + enabled = false, ) }} WITH evnts AS ( diff --git a/models/silver/nft/sales/silver__nft_sales_seashrine_view.sql b/models/silver/nft/sales/silver__nft_sales_seashrine_view.sql new file mode 100644 index 0000000..f027f94 --- /dev/null +++ b/models/silver/nft/sales/silver__nft_sales_seashrine_view.sql @@ -0,0 +1,34 @@ +{{ config( + materialized = 'view' +) }} + +SELECT + block_timestamp, + block_number, + version, + tx_hash, + event_index, + event_type, + buyer_address, + seller_address, + nft_address, + token_version, + platform_address, + project_name, + tokenid, + platform_name, + platform_exchange_version, + total_price_raw, + platform_fee_raw, + creator_fee_raw, + total_fees_raw, + nft_sales_seashrine_id, + inserted_timestamp, + modified_timestamp, + _inserted_timestamp, + _invocation_id +FROM + {{ source( + 'aptos_silver', + 'nft_sales_seashrine' + ) }} diff --git a/models/silver/nft/sales/silver__nft_sales_souffl3.sql b/models/silver/nft/sales/silver__nft_sales_souffl3.sql index ac318cd..e1741e1 100644 --- a/models/silver/nft/sales/silver__nft_sales_souffl3.sql +++ b/models/silver/nft/sales/silver__nft_sales_souffl3.sql @@ -4,7 +4,8 @@ incremental_strategy = 'merge', cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'], merge_exclude_columns = ["inserted_timestamp"], - tags = ['noncore'] + full_refresh = false, + enabled = false, ) }} WITH evnts AS ( diff --git a/models/silver/nft/sales/silver__nft_sales_souffl3_view.sql b/models/silver/nft/sales/silver__nft_sales_souffl3_view.sql new file mode 100644 index 0000000..c1e9c35 --- /dev/null +++ b/models/silver/nft/sales/silver__nft_sales_souffl3_view.sql @@ -0,0 +1,34 @@ +{{ config( + materialized = 'view' +) }} + +SELECT + block_timestamp, + block_number, + version, + tx_hash, + event_index, + event_type, + buyer_address, + seller_address, + nft_address, + token_version, + platform_address, + project_name, + tokenid, + platform_name, + platform_exchange_version, + total_price_raw, + platform_fee_raw, + creator_fee_raw, + total_fees_raw, + nft_sales_souffl3_id, + inserted_timestamp, + modified_timestamp, + _inserted_timestamp, + _invocation_id +FROM + {{ source( + 'aptos_silver', + 'nft_sales_souffl3' + ) }} diff --git a/models/silver/nft/sales/silver__nft_sales_topaz.sql b/models/silver/nft/sales/silver__nft_sales_topaz.sql index 36c45b5..12c0f5a 100644 --- a/models/silver/nft/sales/silver__nft_sales_topaz.sql +++ b/models/silver/nft/sales/silver__nft_sales_topaz.sql @@ -4,7 +4,8 @@ incremental_strategy = 'merge', cluster_by = ['block_timestamp::DATE','_inserted_timestamp::DATE'], merge_exclude_columns = ["inserted_timestamp"], - tags = ['noncore'] + full_refresh = false, + enabled = false, ) }} WITH evnts AS ( diff --git a/models/silver/nft/sales/silver__nft_sales_topaz_view.sql b/models/silver/nft/sales/silver__nft_sales_topaz_view.sql new file mode 100644 index 0000000..caa3720 --- /dev/null +++ b/models/silver/nft/sales/silver__nft_sales_topaz_view.sql @@ -0,0 +1,34 @@ +{{ config( + materialized = 'view' +) }} + +SELECT + block_timestamp, + block_number, + version, + tx_hash, + event_index, + event_type, + seller_address, + buyer_address, + nft_address, + token_version, + platform_address, + project_name, + tokenid, + platform_name, + platform_exchange_version, + total_price_raw, + creator_fee_raw, + platform_fee_raw, + total_fees_raw, + nft_sales_topaz_id, + inserted_timestamp, + modified_timestamp, + _inserted_timestamp, + _invocation_id +FROM + {{ source( + 'aptos_silver', + 'nft_sales_topaz' + ) }} diff --git a/models/sources.yml b/models/sources.yml index 160558f..1bb5397 100644 --- a/models/sources.yml +++ b/models/sources.yml @@ -50,4 +50,9 @@ sources: tables: - name: bridge_mover_transfers - name: bridge_celer_transfers + - name: nft_sales_bluemove + - name: nft_sales_okx + - name: nft_sales_seashrine + - name: nft_sales_souffl3 + - name: nft_sales_topaz \ No newline at end of file