From 68f25187d6d2ba6881ea8442d1899edb53c70916 Mon Sep 17 00:00:00 2001
From: eric-laurello <102970824+eric-laurello@users.noreply.github.com>
Date: Wed, 18 Jun 2025 13:27:09 -0400
Subject: [PATCH] add stargate to complete (#457)

---
 .../transfers/silver__bridge_complete.sql     | 36 ++++++++++++++++++-
 ...ilver_evm__bridge_stargate_create_pool.sql |  2 +-
 2 files changed, 36 insertions(+), 2 deletions(-)

diff --git a/models/silver/transfers/silver__bridge_complete.sql b/models/silver/transfers/silver__bridge_complete.sql
index a248ad1..1c66e4b 100644
--- a/models/silver/transfers/silver__bridge_complete.sql
+++ b/models/silver/transfers/silver__bridge_complete.sql
@@ -47,7 +47,7 @@ celer AS (
         amount AS gross_amount,
         NULL AS amount_fee,
         amount AS net_amount,
-        IFF(direction = 'inbound', flow_wallet_address, counterparty) AS destination_address,
+         IFF(direction = 'inbound', flow_wallet_address, counterparty) AS destination_address,
         IFF(direction = 'outbound', flow_wallet_address, counterparty) AS source_address,
         IFF(direction = 'inbound', 'flow', blockchain) AS destination_chain,
         IFF(direction = 'outbound', 'flow', blockchain) AS source_chain,
@@ -66,6 +66,35 @@ WHERE modified_timestamp >= (
 )
 {% endif %}
 ),
+stargate AS (
+    SELECT
+        tx_id,
+        block_timestamp,
+        block_height,
+        bridge_address,
+        token_address,
+        gross_amount,
+        amount_fee,
+        net_amount,
+        IFF(direction = 'inbound', flow_wallet_address, null) AS destination_address,
+        IFF(direction = 'outbound', flow_wallet_address, null) AS source_address,
+        IFF(direction = 'inbound', 'flow', destination_chain) AS destination_chain,
+        IFF(direction = 'outbound', 'flow', source_chain) AS source_chain,
+        platform,
+        inserted_timestamp,
+        modified_timestamp,
+        bridge_startgate_id AS bridge_complete_id
+    FROM
+        {{ ref('silver_evm__bridge_stargate_s') }}
+{% if is_incremental() %}
+WHERE modified_timestamp >= (
+    SELECT
+        MAX(modified_timestamp)
+    FROM
+        {{ this }}
+)
+{% endif %}
+),
 combo AS (
     SELECT
         *
@@ -76,6 +105,11 @@ combo AS (
         *
     FROM
         celer
+        UNION ALL
+    SELECT
+        *
+    FROM
+        stargate
 )
 SELECT
     tx_id,
diff --git a/models/silver/transfers/silver_evm__bridge_stargate_create_pool.sql b/models/silver/transfers/silver_evm__bridge_stargate_create_pool.sql
index bd4ce32..853a0f6 100644
--- a/models/silver/transfers/silver_evm__bridge_stargate_create_pool.sql
+++ b/models/silver/transfers/silver_evm__bridge_stargate_create_pool.sql
@@ -2,7 +2,7 @@
     materialized = 'incremental',
     incremental_strategy = 'delete+insert',
     unique_key = "block_number",
-    tags = ['silver_bridge','defi','bridge','curated']
+    tags = ['silver_bridge','defi','bridge','curated','scheduled_non_core']
 ) }}
 
 WITH base_contracts AS (