From d85aa2fd9ed8fe3904d278269521191fd30c8856 Mon Sep 17 00:00:00 2001
From: San Yong <22216004+SanYongxie@users.noreply.github.com>
Date: Thu, 20 Mar 2025 15:56:48 +0800
Subject: [PATCH] add ccip seed and send req

---
 data/silver_bridge__ccip_chain_seed.csv       |  75 +++++++++++
 .../silver_bridge__ccip_send_request.sql      | 123 ++++++++++++++++++
 2 files changed, 198 insertions(+)
 create mode 100644 data/silver_bridge__ccip_chain_seed.csv
 create mode 100644 models/silver/defi/bridge/chainlink/silver_bridge__ccip_send_request.sql

diff --git a/data/silver_bridge__ccip_chain_seed.csv b/data/silver_bridge__ccip_chain_seed.csv
new file mode 100644
index 0000000..a3c6554
--- /dev/null
+++ b/data/silver_bridge__ccip_chain_seed.csv
@@ -0,0 +1,75 @@
+chain_name,chain_selector
+apechain,14894068710063348487
+arbitrum,4949039107694359620
+l3x,3162193654116181371
+treasure,1010349088906777999
+areon,1939936305787790600
+astar-zkevm,1540201334317828111
+avalanche,6433500567565415381
+dexalot,5463201557265485081
+base,15971525489660198786
+berachain,1294465214383781161
+bsc,11344663589394136015
+opbnb,465944652040885897
+bitcichain,4874388048629246000
+bitlayer,7937294810946806131
+bittorrent,3776006016387883143
+blast,4411394078118774322
+bob,3849287863852499584
+botanix,4560701533377838164
+bsquared,5406759801798337480
+celo,1346049177634351622
+coinex_smart_chain,1761333065194157300
+core,1224752112135636129
+corn,9043146809313071210
+cronos,1456215246176062136
+cronos-zkevm,8788096068760390840
+ethereum,5009297550715157269
+fantom,3768048213127883732
+filecoin,4561443241176882990
+fraxtal,1462016016387883143
+gnosis,465200170687744372
+hashkey,7613811247471741961
+hedera,3229138320728879060
+immutable-zkevm,1237925231416731909
+ink,3461204551265785888
+kava,7550000543357438061
+kroma,3719320017875267166
+moonriver,1355020143337428062
+lens,5608378062013572713
+linea,4627098889531055414
+mantle,1556008542357238666
+merlin,241851231317828981
+metis,8805746078405598895
+mind,11690709103138290329
+mode,7264351850409363825
+morph,18164309074156128038
+near,2039744413822257700
+neonlink,8239338020728974000
+optimism,3734403246176062136
+plume,3208172210661564830
+astar-polkadot,6422105447186081193
+centrifuge,8175830712062617656
+darwinia,8866418665544333000
+moonbeam,1252863800116739621
+polygon,4051577828743386545
+polygon-zkevm,4348158687435793198
+private-testnet-mica,4489326297382772450
+ronin,6916147374840168594
+rootstock,11964252391146578476
+scroll,13204309965629103672
+sei,9027416829622342829
+shibarium,3993510008929295315
+soneium,12505351618335765396
+sonic,1673871237479749969
+taiko,16468599424800719238
+telos-evm,1477345371608778000
+treasure,5214452172935136222
+unichain,1923510103922296319
+velas,374210358663784372
+wemix,5142893604156789321
+worldchain,2049429975587534727
+xlayer,3016212468291539606
+zircuit,17198166215261833993
+zklink_nova,4350319965322101699
+zksync,1562403441176082196
\ No newline at end of file
diff --git a/models/silver/defi/bridge/chainlink/silver_bridge__ccip_send_request.sql b/models/silver/defi/bridge/chainlink/silver_bridge__ccip_send_request.sql
new file mode 100644
index 0000000..b71a0cf
--- /dev/null
+++ b/models/silver/defi/bridge/chainlink/silver_bridge__ccip_send_request.sql
@@ -0,0 +1,123 @@
+{{ config(
+    materialized = 'incremental',
+    incremental_strategy = 'delete+insert',
+    unique_key = "block_number",
+    cluster_by = ['block_timestamp::DATE'],
+    tags = ['curated','reorg']
+) }}
+
+WITH on_ramp_set AS (
+
+    SELECT
+        block_timestamp,
+        tx_hash,
+        event_name,
+        -- decoded_log,
+        TRY_TO_NUMBER(
+            decoded_log :destChainSelector :: STRING
+        ) AS destChainSelector,
+        chain_name,
+        decoded_log :onRamp :: STRING AS onRampAddress,
+        modified_timestamp
+    FROM
+        {{ ref('core__ez_decoded_event_logs') }}
+        INNER JOIN arbitrum_dev.silver_bridge.ccip_chain_seed
+        ON destChainSelector = chain_selector
+    WHERE
+        contract_address = LOWER('0x141fa059441E0ca23ce184B6A78bafD2A517DdE8') -- ccip router
+        AND topic_0 = '0x1f7d0ec248b80e5c0dde0ee531c4fc8fdb6ce9a2b3d90f560c74acd6a7202f23' -- onrampset
+        AND tx_succeeded
+        AND event_removed = FALSE
+
+{% if is_incremental() %}
+AND modified_timestamp >= (
+    SELECT
+        MAX(modified_timestamp) - INTERVAL '12 hours'
+    FROM
+        {{ this }}
+)
+AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
+{% endif %}
+),
+ccip_sent AS (
+    SELECT
+        l.block_timestamp,
+        l.tx_hash,
+        contract_address,
+        l.event_name,
+        regexp_substr_all(SUBSTR(DATA, 3, len(DATA)), '.{64}') AS segmented_data,
+        CONCAT(
+            '0x',
+            segmented_data [13] :: STRING
+        ) AS message_id,
+        l.decoded_log,
+        decoded_log :message :feeToken :: STRING AS fee_token,
+        TRY_TO_NUMBER(
+            decoded_log :message :feeTokenAmount :: STRING
+        ) AS fee_token_amount,
+        TRY_TO_NUMBER(
+            decoded_log :message :gasLimit :: STRING
+        ) AS gas_limit,
+        TRY_TO_NUMBER(
+            decoded_log :message :nonce :: STRING
+        ) AS nonce,
+        decoded_log :message :receiver :: STRING AS receiver,
+        decoded_log :message :sender :: STRING AS sender,
+        TRY_TO_NUMBER(
+            decoded_log :message :sequenceNumber :: STRING
+        ) AS sequence_number,
+        TRY_TO_NUMBER(
+            decoded_log :message :sourceChainSelector :: STRING
+        ) AS source_chain_selector,
+        destChainSelector AS dest_chain_selector,
+        decoded_log :message :tokenAmounts AS token_amounts,
+        ARRAY_SIZE(
+            decoded_log :message :tokenAmounts
+        ) AS token_amounts_count,
+        l.modified_timestamp
+    FROM
+        {{ ref('core__ez_decoded_event_logs') }}
+        l
+        INNER JOIN on_ramp_set
+        ON onRampAddress = contract_address
+    WHERE
+        topic_0 = '0xd0c3c799bf9e2639de44391e7f524d229b2b55f5b1ea94b2bf7da42f7243dddd' -- CCIPSendRequested
+        AND tx_succeeded
+        AND event_removed = FALSE
+
+{% if is_incremental() %}
+AND modified_timestamp >= (
+    SELECT
+        MAX(modified_timestamp) - INTERVAL '12 hours'
+    FROM
+        {{ this }}
+)
+AND modified_timestamp >= SYSDATE() - INTERVAL '7 day'
+{% endif %}
+)
+SELECT
+    C.block_timestamp,
+    C.tx_hash,
+    C.contract_address,
+    C.message_id,
+    C.nonce,
+    C.receiver,
+    C.sender,
+    C.sequence_number,
+    C.source_chain_selector,
+    C.dest_chain_selector,
+    C.gas_limit,
+    C.fee_token,
+    -- Divide the fee by the number of tokens in the array
+    C.fee_token_amount / C.token_amounts_count AS fee_token_amount_per_token,
+    C.token_amounts_count,
+    TRY_TO_NUMBER(
+        tokens.value :amount :: STRING
+    ) AS token_amount,
+    tokens.value :token :: STRING AS token,
+    C.modified_timestamp
+FROM
+    ccip_sent C,
+    LATERAL FLATTEN(
+        input => C.token_amounts
+    ) AS tokens