diff --git a/dbt_project.yml b/dbt_project.yml index 5fea367..73aa354 100644 --- a/dbt_project.yml +++ b/dbt_project.yml @@ -100,6 +100,12 @@ models: +enabled: true curated_package: +enabled: false + protocols: + +enabled: false + layerzero: + +enabled: true + stargate: + +enabled: true stats: +enabled: true scores_package: diff --git a/models/silver/defi/bridge/silver_bridge__complete_bridge_activity.sql b/models/silver/defi/bridge/silver_bridge__complete_bridge_activity.sql index 4f936df..5f86235 100644 --- a/models/silver/defi/bridge/silver_bridge__complete_bridge_activity.sql +++ b/models/silver/defi/bridge/silver_bridge__complete_bridge_activity.sql @@ -118,7 +118,6 @@ WHERE {% endif %} ), allbridge_v2 AS ( - SELECT block_number, block_timestamp, @@ -227,41 +226,41 @@ WHERE {% endif %} ), ccip AS ( - SELECT - block_number, - block_timestamp, - origin_from_address, - origin_to_address, - origin_function_signature, - tx_hash, - event_index, - bridge_address, - event_name, - platform, - 'v1' AS version, - sender, - receiver, - destination_chain_receiver, - destination_chain_id :: STRING AS destination_chain_id, - destination_chain, - token_address, - NULL AS token_symbol, - amount_unadj, - _log_id AS _id, - modified_timestamp AS _inserted_timestamp - FROM - {{ ref('silver_bridge__ccip_send_requested') }} + SELECT + block_number, + block_timestamp, + origin_from_address, + origin_to_address, + origin_function_signature, + tx_hash, + event_index, + bridge_address, + event_name, + platform, + 'v1' AS version, + sender, + receiver, + destination_chain_receiver, + destination_chain_id :: STRING AS destination_chain_id, + destination_chain, + token_address, + NULL AS token_symbol, + amount_unadj, + _log_id AS _id, + modified_timestamp AS _inserted_timestamp + FROM + {{ ref('silver_bridge__ccip_send_requested') }} - {% if is_incremental() and 'ccip' not in var('HEAL_MODELS') %} - WHERE - _inserted_timestamp >= ( - SELECT - MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "4 hours") }}' - FROM - {{ this }} - ) - {% endif %} - ), +{% if is_incremental() and 'ccip' not in var('HEAL_MODELS') %} +WHERE + _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "4 hours") }}' + FROM + {{ this }} + ) +{% endif %} +), dln_debridge AS ( SELECT block_number, @@ -370,6 +369,42 @@ WHERE ) {% endif %} ), +layerzero_v2 AS ( + SELECT + block_number, + block_timestamp, + origin_from_address, + origin_to_address, + origin_function_signature, + tx_hash, + event_index, + bridge_address, + event_name, + platform, + version, + sender, + receiver, + destination_chain_receiver, + destination_chain_id :: STRING AS destination_chain_id, + destination_chain, + token_address, + NULL AS token_symbol, + amount_unadj, + _log_id AS _id, + inserted_timestamp AS _inserted_timestamp + FROM + {{ ref('silver_bridge__layerzero_v2') }} + +{% if is_incremental() and 'layerzero_v2' not in var('HEAL_MODELS') %} +WHERE + _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "4 hours") }}' + FROM + {{ this }} + ) +{% endif %} +), meson AS ( SELECT block_number, @@ -478,6 +513,42 @@ WHERE ) {% endif %} ), +stargate_v2 AS ( + SELECT + block_number, + block_timestamp, + origin_from_address, + origin_to_address, + origin_function_signature, + tx_hash, + event_index, + bridge_address, + event_name, + platform, + version, + sender, + receiver, + destination_chain_receiver, + destination_chain_id :: STRING AS destination_chain_id, + destination_chain, + token_address, + NULL AS token_symbol, + amount_unadj, + _log_id AS _id, + inserted_timestamp AS _inserted_timestamp + FROM + {{ ref('silver_bridge__stargate_v2') }} + +{% if is_incremental() and 'stargate_v2' not in var('HEAL_MODELS') %} +WHERE + _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) - INTERVAL '{{ var("LOOKBACK", "4 hours") }}' + FROM + {{ this }} + ) +{% endif %} +), symbiosis AS ( SELECT block_number, @@ -638,7 +709,7 @@ all_protocols AS ( FROM allbridge UNION ALL - SELECT + SELECT * FROM allbridge_v2 @@ -652,10 +723,10 @@ all_protocols AS ( * FROM celer_cbridge - UNION ALL - SELECT + UNION ALL + SELECT * - FROM + FROM ccip UNION ALL SELECT @@ -673,6 +744,11 @@ all_protocols AS ( FROM hop UNION ALL + SELECT + * + FROM + layerzero_v2 + UNION ALL SELECT * FROM @@ -688,6 +764,11 @@ all_protocols AS ( FROM stargate UNION ALL + SELECT + * + FROM + stargate_v2 + UNION ALL SELECT * FROM @@ -707,6 +788,11 @@ all_protocols AS ( * FROM wormhole + UNION ALL + SELECT + * + FROM + layerzero_v2 ), complete_bridge_activity AS ( SELECT @@ -725,23 +811,35 @@ complete_bridge_activity AS ( receiver, destination_chain_receiver, CASE - WHEN CONCAT(platform, '-', version) IN ( + WHEN CONCAT( + platform, + '-', + version + ) IN ( 'stargate-v1', 'wormhole-v1', 'meson-v1', 'allbridge-v2', - 'chainlink-ccip-v1' + 'chainlink-ccip-v1', + 'stargate-v2', + 'layerzero-v2' ) THEN destination_chain_id :: STRING WHEN d.chain_id IS NULL THEN destination_chain_id :: STRING ELSE d.chain_id :: STRING END AS destination_chain_id, CASE - WHEN CONCAT(platform, '-', version) IN ( + WHEN CONCAT( + platform, + '-', + version + ) IN ( 'stargate-v1', 'wormhole-v1', 'meson-v1', 'allbridge-v2', - 'chainlink-ccip-v1' + 'chainlink-ccip-v1', + 'stargate-v2', + 'layerzero-v2' ) THEN LOWER(destination_chain) WHEN d.chain IS NULL THEN LOWER(destination_chain) ELSE LOWER( diff --git a/packages.yml b/packages.yml index 0c44d2d..7cef8ab 100644 --- a/packages.yml +++ b/packages.yml @@ -1,3 +1,3 @@ packages: - git: https://github.com/FlipsideCrypto/fsc-evm.git - revision: v4.0.0-beta.104 \ No newline at end of file + revision: layerzero-curation \ No newline at end of file