Merge branch 'main' into cowprotocol/add_base_2

dbt_subprojects/daily_spellbook/macros/project/bungee/bungee_SocketBridge_macro.sql

@@ -0,0 +1,23 @@
+{% macro bungee_SocketBridge(blockchain) %}
+
+select
+    contract_address,
+    evt_tx_hash,
+    evt_index,
+    evt_block_time,
+    evt_block_number,
+    amount,
+    token,
+    toChainId,
+    bridgeName,
+    sender,
+    receiver,
+    metadata,
+    '{{ blockchain }}' as source_chain,
+    {{ dbt_utils.generate_surrogate_key(['evt_tx_hash', 'evt_index']) }} as transfer_id
+from {{ source('socket_v2_' ~ blockchain, 'SocketGateway_evt_SocketBridge') }}
+{% if is_incremental() %}
+where {{ incremental_predicate('evt_block_time') }}
+{% endif %}
+
+{% endmacro %}

dbt_subprojects/daily_spellbook/models/_projects/bungee/arbitrum/bungee_arbitrum_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_arbitrum',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('arbitrum') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0x82af49447d8a07e3bd95bd0d56f35241523fbab1 -- WETH on Arbitrum
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'arbitrum'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data 

dbt_subprojects/daily_spellbook/models/_projects/bungee/avalanche_c/bungee_avalanche_c_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_avalanche_c',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('avalanche_c') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0xb31f66aa3c1e785363f0875a1b74e27b85fd66c7 -- WAVAX
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'avalanche_c'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data 

dbt_subprojects/daily_spellbook/models/_projects/bungee/base/bungee_base_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_base',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('base') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0x4200000000000000000000000000000000000006 -- WETH on Base
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'base'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data 

dbt_subprojects/daily_spellbook/models/_projects/bungee/blast/bungee_blast_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_blast',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('blast') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0x4300000000000000000000000000000000000004 -- WETH on Blast
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'blast'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data 

dbt_subprojects/daily_spellbook/models/_projects/bungee/bnb/bungee_bnb_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_bnb',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('bnb') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0xbb4cdb9cbd36b01bd1cbaebf2de08d9173bc095c -- WBNB
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'bnb'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data 

dbt_subprojects/daily_spellbook/models/_projects/bungee/bungee_bridges.sql

@@ -0,0 +1,46 @@
+{{
+    config(
+        schema = 'bungee',
+        alias = 'bridges',
+        materialized = 'view',
+        post_hook = '{{ expose_spells(\'[
+            "ethereum", "zkevm", "scroll", "blast", "linea", "mantle", "optimism",
+            "gnosis", "arbitrum", "zksync", "base", "bnb", "polygon",
+            "avalanche_c", "fantom"
+        ]\',
+        "project", "bungee", \'["lequangphu"]\') }}'
+    )
+}}
+
+{% set chains = [
+    'ethereum', 'zkevm', 'scroll', 'blast', 'linea', 'mantle', 'optimism',
+    'gnosis', 'arbitrum', 'zksync', 'base', 'bnb', 'polygon',
+    'avalanche_c', 'fantom'
+] %}
+
+with bungee_bridges as (
+    {% for chain in chains %}
+    select
+        contract_address,
+        evt_tx_hash,
+        evt_index,
+        evt_block_time,
+        evt_block_number,
+        amount,
+        token,
+        toChainId,
+        bridgeName,
+        sender,
+        receiver,
+        metadata,
+        source_chain,
+        transfer_id
+    from {{ ref( 'bungee_' ~ chain ~ '_bridges' ) }}
+    {% if not loop.last %}
+    union all
+    {% endif %}
+    {% endfor %}
+)
+
+select *
+from bungee_bridges

dbt_subprojects/daily_spellbook/models/_projects/bungee/ethereum/bungee_ethereum_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_ethereum',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('ethereum') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2 -- WETH
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'ethereum'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data 

dbt_subprojects/daily_spellbook/models/_projects/bungee/fantom/bungee_fantom_bridges.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        schema = 'bungee_fantom',
+        alias = 'bridges',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['transfer_id'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.evt_block_time')]
+    )
+}}
+
+with source_data as (
+    {{ bungee_SocketBridge('fantom') }}
+),
+
+tokens_mapped as (
+    select
+        *,
+        case
+            when token = 0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
+            then 0x21be370d5312f44cb42ce377bc9b8a0cef1a4c83 -- WFTM
+            else token
+        end as token_adjusted
+    from source_data
+),
+
+price_data as (
+    select 
+        tokens_mapped.*,
+        p.price * amount / power(10, p.decimals) as amount_usd
+    from tokens_mapped
+    left join {{ source('prices', 'usd') }} p 
+        on p.contract_address = tokens_mapped.token_adjusted
+        and p.blockchain = 'fantom'
+        and p.minute = date_trunc('minute', tokens_mapped.evt_block_time)
+        {% if is_incremental() %}
+        and {{ incremental_predicate('p.minute') }}
+        {% endif %}
+)
+
+select * from price_data