update nft sales

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 (

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'
+  ) }}
+

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,

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

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 (

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'
+  ) }}

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 (

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'
+  ) }}

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 (

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'
+  ) }}

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 (

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'
+  ) }}

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