Bridges of LI.FI across chains, the contract is LiFiDiamond_v2

dbt_subprojects/daily_spellbook/macros/project/lifi/lifi_extract_bridge_data_macro.sql

@@ -0,0 +1,37 @@
+{% macro lifi_extract_bridge_data(blockchain) %}
+
+{% set bridge_data_fields = [
+    'transactionId',
+    'bridge',
+    'integrator',
+    'referrer',
+    'sendingAssetId',
+    'receiver',
+    'minAmount',
+    'destinationChainId'
+] %}
+
+select
+    contract_address,
+    evt_tx_hash as tx_hash,
+    evt_index,
+    evt_block_time as block_time,
+    evt_block_number as block_number,
+    cast(date_trunc('day', evt_block_time) as date) as block_date,
+    {% for field in bridge_data_fields %}
+    {% if field in ['transactionId', 'referrer', 'sendingAssetId', 'receiver'] %}
+    from_hex(json_extract_scalar(bridgedata, '$.{{ field }}')) as {{ field }},
+    {% elif field == 'minAmount' %}
+    cast(json_extract_scalar(bridgedata, '$.{{ field }}') as double) as {{ field }},
+    {% else %}
+    json_extract_scalar(bridgedata, '$.{{ field }}') as {{ field }},
+    {% endif %}
+    {% endfor %}
+    '{{ blockchain }}' as source_chain,
+    {{ dbt_utils.generate_surrogate_key(['evt_tx_hash', 'evt_index']) }} as transfer_id
+from {{ source('lifi_' ~ blockchain, 'LiFiDiamond_v2_evt_LiFiTransferStarted') }}
+{% if is_incremental() %}
+where {{ incremental_predicate('evt_block_time') }}
+{% endif %}
+
+{% endmacro %}

dbt_subprojects/daily_spellbook/models/_projects/lifi/arbitrum/lifi_arbitrum_transfers.sql

@@ -0,0 +1,49 @@
+{{ config(
+    schema = 'lifi_arbitrum',
+    alias = 'transfers',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['transfer_id'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+with source_data as (
+    {{ lifi_extract_bridge_data('arbitrum') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when sendingAssetId = 0x0000000000000000000000000000000000000000
+            then 0x82af49447d8a07e3bd95bd0d56f35241523fbab1 -- WETH
+            when sendingAssetId = 0x3405a1bd46b85c5c029483fbecf2f3e611026e45
+            then 0xff970a61a04b1ca14834a43f5de4533ebddb5cc8 -- USDC
+            else sendingAssetId
+        end as sendingAssetId_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * minAmount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.sendingAssetId_adjusted
+        and p.blockchain = 'arbitrum'
+        and p.minute = date_trunc('minute', tokens_mapped.block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'price_data'
+        , blockchain = 'arbitrum'
+        , columns = ['from']
+    )
+}}

dbt_subprojects/daily_spellbook/models/_projects/lifi/avalanche_c/lifi_avalanche_c_transfers.sql

@@ -0,0 +1,47 @@
+{{ config(
+    schema = 'lifi_avalanche_c',
+    alias = 'transfers',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['transfer_id'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+with source_data as (
+    {{ lifi_extract_bridge_data('avalanche_c') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when sendingAssetId = 0x0000000000000000000000000000000000000000
+            then 0xb31f66aa3c1e785363f0875a1b74e27b85fd66c7 -- WAVAX
+            else sendingAssetId
+        end as sendingAssetId_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * minAmount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.sendingAssetId_adjusted
+        and p.blockchain = 'avalanche_c'
+        and p.minute = date_trunc('minute', tokens_mapped.block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'price_data'
+        , blockchain = 'avalanche_c'
+        , columns = ['from']
+    )
+}}

dbt_subprojects/daily_spellbook/models/_projects/lifi/bnb/lifi_bnb_transfers.sql

@@ -0,0 +1,47 @@
+{{ config(
+    schema = 'lifi_bnb',
+    alias = 'transfers',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['transfer_id'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+with source_data as (
+    {{ lifi_extract_bridge_data('bnb') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when sendingAssetId = 0x0000000000000000000000000000000000000000
+            then 0xbb4CdB9CBd36B01bD1cBaEBF2De08d9173bc095c -- WBNB
+            else sendingAssetId
+        end as sendingAssetId_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * minAmount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.sendingAssetId_adjusted
+        and p.blockchain = 'bnb'
+        and p.minute = date_trunc('minute', tokens_mapped.block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'price_data'
+        , blockchain = 'bnb'
+        , columns = ['from']
+    )
+}}

dbt_subprojects/daily_spellbook/models/_projects/lifi/ethereum/lifi_ethereum_transfers.sql

@@ -0,0 +1,47 @@
+{{ config(
+    schema = 'lifi_ethereum',
+    alias = 'transfers',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['transfer_id'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+with source_data as (
+    {{ lifi_extract_bridge_data('ethereum') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when sendingAssetId = 0x0000000000000000000000000000000000000000
+            then 0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2 -- WETH
+            else sendingAssetId
+        end as sendingAssetId_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * minAmount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.sendingAssetId_adjusted
+        and p.blockchain = 'ethereum'
+        and p.minute = date_trunc('minute', tokens_mapped.block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'price_data'
+        , blockchain = 'ethereum'
+        , columns = ['from']
+    )
+}}

dbt_subprojects/daily_spellbook/models/_projects/lifi/fantom/lifi_fantom_transfers.sql

@@ -0,0 +1,47 @@
+{{ config(
+    schema = 'lifi_fantom',
+    alias = 'transfers',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['transfer_id'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+with source_data as (
+    {{ lifi_extract_bridge_data('fantom') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when sendingAssetId = 0x0000000000000000000000000000000000000000
+            then 0x21be370d5312f44cb42ce377bc9b8a0cef1a4c83 -- WFTM
+            else sendingAssetId
+        end as sendingAssetId_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * minAmount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.sendingAssetId_adjusted
+        and p.blockchain = 'fantom'
+        and p.minute = date_trunc('minute', tokens_mapped.block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'price_data'
+        , blockchain = 'fantom'
+        , columns = ['from']
+    )
+}}

dbt_subprojects/daily_spellbook/models/_projects/lifi/gnosis/lifi_gnosis_transfers.sql

@@ -0,0 +1,47 @@
+{{ config(
+    schema = 'lifi_gnosis',
+    alias = 'transfers',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['transfer_id'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+with source_data as (
+    {{ lifi_extract_bridge_data('gnosis') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when sendingAssetId = 0x0000000000000000000000000000000000000000
+            then 0xe91d153e0b41518a2ce8dd3d7944fa863463a97d -- WXDAI
+            else sendingAssetId
+        end as sendingAssetId_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * minAmount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.sendingAssetId_adjusted
+        and p.blockchain = 'gnosis'
+        and p.minute = date_trunc('minute', tokens_mapped.block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'price_data'
+        , blockchain = 'gnosis'
+        , columns = ['from']
+    )
+}}

dbt_subprojects/daily_spellbook/models/_projects/lifi/lifi_transfers.sql

@@ -0,0 +1,61 @@
+{{
+    config(
+        schema = 'lifi',
+        alias = 'transfers',
+        materialized = 'view',
+        post_hook='{{ expose_spells(\'[
+                                        "arbitrum"
+                                        , "avalanche_c"
+                                        , "bnb"
+                                        , "ethereum"
+                                        , "fantom"
+                                        , "gnosis"
+                                        , "zksync"
+                                    ]\',
+                                    "project",
+                                    "lifi",
+                                    \'["lequangphu"]\') }}'
+    )
+}}
+
+{% set chains = [
+    'ethereum',
+    'arbitrum',
+    'avalanche_c',
+    'bnb',
+    'fantom',
+    'gnosis',
+    'zksync'
+] %}
+
+with chain_transfers as (
+    {% for chain in chains %}
+    select 
+        contract_address,
+        tx_hash,
+        evt_index,
+        block_time,
+        block_number,
+        block_date,
+        transactionId,
+        bridge,
+        integrator,
+        referrer,
+        sendingAssetId,
+        receiver,
+        minAmount,
+        destinationChainId,
+        source_chain,
+        transfer_id,
+        sendingAssetId_adjusted,
+        amount_usd,
+        tx_from
+    from {{ ref('lifi_' ~ chain ~ '_transfers') }}
+    {% if not loop.last %}
+    union all
+    {% endif %}
+    {% endfor %}
+)
+
+select *
+from chain_transfers