[OPENSEA] add OS in-app swaps / token trading (#9044)

Author: BroderickBonelli

dbt_subprojects/daily_spellbook/models/_projects/opensea/evm/opensea_evm_token_trades.sql

@@ -0,0 +1,66 @@
+{{
+    config(
+        schema = 'opensea',
+        alias = 'evm_token_trades',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'generatedIndex', 'blockchain'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+    )
+}}
+
+WITH opensea_evm_hashs AS (
+    SELECT 
+        blockchain
+        , hash
+    FROM {{ source('evms', 'transactions') }}
+    WHERE SUBSTR("data", varbinary_length("data") - 3, 4) = 0x865d8597
+        AND block_time > TRY_CAST('2025-03-12 23:42' AS TIMESTAMP)
+        AND blockchain IN (
+            'ethereum'
+            , 'abstract'
+            , 'apechain'
+            , 'arbitrum'
+            , 'avalanche_c'
+            , 'b3'
+            , 'base'
+            , 'berachain'
+            , 'blast'
+            , 'flow'
+            , 'optimism'
+            , 'polygon'
+            , 'unichain'
+            , 'ronin'
+            , 'sei'
+            , 'shape'
+            , 'zora'
+        )
+        {% if is_incremental() %}
+            AND {{ incremental_predicate('block_time') }}
+        {% endif %}
+)
+
+SELECT 
+    det.blockchain
+    , det.project
+    , det."version"
+    , det.project_contract_address
+    , det.tx_from
+    , det.block_time
+    , det.token_bought_symbol
+    , det.token_bought_address
+    , det.token_sold_symbol
+    , det.token_sold_address 
+    , det.token_sold_amount
+    , det.amount_usd
+    , det.tx_hash
+    , det.block_number * POW(10,5) + evt_index AS generatedIndex
+FROM dex.trades det
+INNER JOIN opensea_evm_hashs oeh 
+    ON det.tx_hash = oeh.hash 
+    AND det.blockchain = oeh.blockchain
+WHERE det.block_time  > TRY_CAST('2025-03-12 23:42' AS TIMESTAMP)
+    {% if is_incremental() %}
+        AND {{ incremental_predicate('det.block_time') }}
+    {% endif %}

dbt_subprojects/daily_spellbook/models/_projects/opensea/solana/opensea_solana_token_trades.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'opensea',
+        alias = 'solana_token_trades',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['blockchain', 'project', 'trader_id', 'block_time', 'token_bought_symbol', 'token_bought_mint_address', 'token_sold_symbol', 'token_sold_mint_address', 'token_sold_amount', 'amount_usd', 'tx_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+    )
+}}
+
+WITH opensea_tx_ids AS (
+    SELECT DISTINCT(tx_id) AS tx_id
+    FROM {{ source('solana', 'instruction_calls') }}
+    WHERE CONTAINS(log_messages, 'Program log: Memo (len 8): "865d8597"')
+        AND executing_account = 'MemoSq4gqABAXKb96qnH8TysNcWxMyWCqXgDLGmfcHr'
+        AND block_time > TRY_CAST('2025-05-26 00:00' AS TIMESTAMP)
+        {% if is_incremental() %}
+            AND {{ incremental_predicate('block_time') }}
+        {% endif %}
+)
+
+SELECT 
+    dst.blockchain
+    , dst.project
+    , dst.trader_id
+    , dst.block_time
+    , dst.token_bought_symbol
+    , dst.token_bought_mint_address
+    , dst.token_sold_symbol
+    , dst.token_sold_mint_address
+    , dst.token_sold_amount
+    , dst.amount_usd
+    , dst.tx_id 
+FROM {{ source('dex_solana', 'trades') }} dst
+INNER JOIN opensea_tx_ids oti 
+    ON dst.tx_id = oti.tx_id
+WHERE dst.block_time  > TRY_CAST('2025-05-26 00:00' AS TIMESTAMP)
+{% if is_incremental() %}
+    AND {{ incremental_predicate('dst.block_time') }}
+{% endif %}