From 83a8e016f1afe06fa33e5df623a51893c36422a1 Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Thu, 4 Apr 2024 17:19:10 -0400 Subject: [PATCH] updae for hex encoding --- .../silver__bridge_wormhole_chain_id_seed.csv | 3 ++- .../silver__bridge_wormhole_transfers.sql | 27 ++++++++++++++++--- 2 files changed, 25 insertions(+), 5 deletions(-) diff --git a/data/silver__bridge_wormhole_chain_id_seed.csv b/data/silver__bridge_wormhole_chain_id_seed.csv index f1fda5f..ab0e740 100644 --- a/data/silver__bridge_wormhole_chain_id_seed.csv +++ b/data/silver__bridge_wormhole_chain_id_seed.csv @@ -33,4 +33,5 @@ acala,12 kujira,4002 pythnet,26 evmos,4001 -wormchain,3104 \ No newline at end of file +wormchain,3104 +wormchain,8204 \ No newline at end of file diff --git a/models/silver/defi/bridge/silver__bridge_wormhole_transfers.sql b/models/silver/defi/bridge/silver__bridge_wormhole_transfers.sql index afeeaf5..c9d000d 100644 --- a/models/silver/defi/bridge/silver__bridge_wormhole_transfers.sql +++ b/models/silver/defi/bridge/silver__bridge_wormhole_transfers.sql @@ -10,7 +10,11 @@ WITH txs AS ( SELECT - * + block_timestamp, + tx_hash, + sender, + payload_function, + payload FROM {{ ref('silver__transactions') }} WHERE @@ -33,7 +37,14 @@ AND _inserted_timestamp >= ( ), events AS ( SELECT - * + block_number, + block_timestamp, + version, + tx_hash, + event_data, + event_index, + event_resource, + _inserted_timestamp FROM {{ ref('silver__events') }} WHERE @@ -113,10 +124,18 @@ wormhole_transfers AS ( ) AS receiver, 22 AS source_chain_id, 'aptos' AS source_chain_name, - payload :arguments [1] :: INT AS destination_chain_id, + CASE + WHEN A.block_number < 165050375 + AND A.block_timestamp :: DATE <= '2024-04-04' THEN payload :arguments [1] + ELSE utils.udf_hex_to_int(RTRIM(payload :arguments [1] :: STRING, '0')) + END :: INT AS destination_chain_id, chain_name AS destination_chain_name, payload :type_arguments [0] :: STRING AS token_address, - payload :arguments [0] :: INT AS amount_unadj, + CASE + WHEN A.block_number < 165050375 + AND A.block_timestamp :: DATE <= '2024-04-04' THEN payload :arguments [0] + ELSE event_data :amount + END :: INT AS amount_unadj, A.event_index, A._inserted_timestamp FROM