From 603b89584ba1e8c77525d6e856170cbb356eb069 Mon Sep 17 00:00:00 2001
From: San Yong <22216004+SanYongxie@users.noreply.github.com>
Date: Fri, 11 Apr 2025 13:33:26 +0800
Subject: [PATCH] updated complete and gold table

---
 models/gold/defi/defi__ez_bridge_activity.sql |  2 +-
 ...ilver_bridge__complete_bridge_activity.sql | 47 ++++++++++++++++++-
 2 files changed, 46 insertions(+), 3 deletions(-)

diff --git a/models/gold/defi/defi__ez_bridge_activity.sql b/models/gold/defi/defi__ez_bridge_activity.sql
index 9c4b7a1..3c9d482 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, ALLBRIDGE, AXELAR, CELER, CBRIDGE, DLN, DEBRIDGE, EYWA, HOP, MESON, MULTICHAIN, STARGATE, SYMBIOSIS, SYNAPSE, WORMHOLE',
+                'PROTOCOL': 'ACROSS, ALLBRIDGE, 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 95bffa8..808a5fa 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 %}
+ ),
 dln_debridge AS (
     SELECT
         block_number,
@@ -616,6 +652,11 @@ all_protocols AS (
         *
     FROM
         celer_cbridge
+    UNION ALL 
+    SELECT 
+        *
+    FROM 
+        ccip
     UNION ALL
     SELECT
         *
@@ -688,7 +729,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
@@ -698,7 +740,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(