diff --git a/models/gold/defi/defi__ez_bridge_activity.sql b/models/gold/defi/defi__ez_bridge_activity.sql index b86c26f4..6323f819 100644 --- a/models/gold/defi/defi__ez_bridge_activity.sql +++ b/models/gold/defi/defi__ez_bridge_activity.sql @@ -5,7 +5,7 @@ meta ={ 'database_tags':{ 'table':{ - 'PROTOCOL': 'ACROSS, AXELAR, CELER, CBRIDGE, DLN, DEBRIDGE, EYWA, HOP, MESON, MULTICHAIN, STARGATE, SYMBIOSIS, SYNAPSE, WORMHOLE', + 'PROTOCOL': 'ACROSS, AXELAR, CELER, CBRIDGE, DLN, DEBRIDGE, EYWA, HOP, MESON, MULTICHAIN, STARGATE, SYMBIOSIS, SYNAPSE, WORMHOLE, CCIP', 'PURPOSE': 'BRIDGE' } } } ) }} 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 8e2e3b3d..16bca883 100644 --- a/models/silver/defi/bridge/silver_bridge__complete_bridge_activity.sql +++ b/models/silver/defi/bridge/silver_bridge__complete_bridge_activity.sql @@ -226,6 +226,42 @@ 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') }} + + {% 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 %} + ), eywa AS ( SELECT block_number, @@ -625,6 +661,11 @@ all_protocols AS ( * FROM wormhole + UNION ALL + SELECT + * + FROM + ccip ), complete_bridge_activity AS ( SELECT @@ -647,7 +688,8 @@ complete_bridge_activity AS ( 'stargate-v1', 'wormhole-v1', 'meson-v1', - 'allbridge-v2' + 'allbridge-v2', + 'chainlink-ccip-v1' ) THEN destination_chain_id :: STRING WHEN d.chain_id IS NULL THEN destination_chain_id :: STRING ELSE d.chain_id :: STRING @@ -657,7 +699,8 @@ complete_bridge_activity AS ( 'stargate-v1', 'wormhole-v1', 'meson-v1', - 'allbridge-v2' + 'allbridge-v2', + 'chainlink-ccip-v1' ) THEN LOWER(destination_chain) WHEN d.chain IS NULL THEN LOWER(destination_chain) ELSE LOWER(