add amount_usd column

lequangphu · Nov 28, 2024 · 44883fb · 44883fb
1 parent 02c8aee
commit 44883fb
Show file tree

Hide file tree

Showing 9 changed files with 91 additions and 9 deletions.
diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/arbitrum/lifi_arbitrum_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/arbitrum/lifi_arbitrum_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('arbitrum') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'arbitrum'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'arbitrum'
         , columns = ['from']
     )

diff --git a/...projects/daily_spellbook/models/_projects/lifi/avalanche_c/lifi_avalanche_c_transfers.sql b/...projects/daily_spellbook/models/_projects/lifi/avalanche_c/lifi_avalanche_c_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('avalanche_c') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'avalanche_c'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'avalanche_c'
         , columns = ['from']
     )

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/bnb/lifi_bnb_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/bnb/lifi_bnb_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('bnb') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'bnb'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'bnb'
         , columns = ['from']
     )

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/ethereum/lifi_ethereum_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/ethereum/lifi_ethereum_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('ethereum') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'ethereum'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'ethereum'
         , columns = ['from']
     )

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/fantom/lifi_fantom_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/fantom/lifi_fantom_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('fantom') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'fantom'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'fantom'
         , columns = ['from']
     )

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/gnosis/lifi_gnosis_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/gnosis/lifi_gnosis_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('gnosis') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'gnosis'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'gnosis'
         , columns = ['from']
     )

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/lifi_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/lifi_transfers.sql
@@ -36,6 +36,7 @@ with chain_transfers as (
         destinationChainId,
         source_chain,
         transfer_id,
+        amount_usd,
         tx_from
     from {{ ref('lifi_' ~ chain ~ '_transfers') }}
     {% if not loop.last %}

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/schema.yml b/dbt_subprojects/daily_spellbook/models/_projects/lifi/schema.yml
@@ -35,10 +35,14 @@ models:
       - name: tx_from
         description: "Address that initiated the transaction"
       - name: transfer_id
-        description: "Unique identifier for the transfer"
-        data_tests:
+        description: "Unique identifier for each transfer"
+        tests:
           - unique
           - not_null
+      - name: amount_usd
+        description: "USD value of the transfer amount at the time of transfer"
+        tests:
+          - not_null: false
 
   - name: lifi_arbitrum_transfers
     description: "Arbitrum LiFi transfer events"

diff --git a/dbt_subprojects/daily_spellbook/models/_projects/lifi/zksync/lifi_zksync_transfers.sql b/dbt_subprojects/daily_spellbook/models/_projects/lifi/zksync/lifi_zksync_transfers.sql
@@ -11,11 +11,22 @@
 
 with source_data as (
     {{ lifi_extract_bridge_data('zksync') }}
+),
+
+price_data as (
+    select 
+        source_data.*,
+        p.price * cast(source_data.minAmount as double) / power(10, p.decimals) as amount_usd
+    from source_data
+    left join {{ source('prices', 'usd') }} p 
+        on cast(p.contract_address as varchar) = source_data.sendingAssetId
+        and p.blockchain = 'zksync'
+        and p.minute = date_trunc('minute', source_data.block_time)
 )
 
 {{
     add_tx_columns(
-        model_cte = 'source_data'
+        model_cte = 'price_data'
         , blockchain = 'zksync'
         , columns = ['from']
     )