From af43dffea2fcc58f67f7e006205d66dabf7b9a66 Mon Sep 17 00:00:00 2001
From: Jack Forgash <58153492+forgxyz@users.noreply.github.com>
Date: Mon, 11 Aug 2025 11:18:36 -0400
Subject: [PATCH] fix data type

---
 .gitignore                                        | 3 +++
 models/silver/defi/silver__dex_swaps_v2.sql       | 8 ++++----
 models/silver/defi/swaps/silver__swap_intents.sql | 4 ++--
 3 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/.gitignore b/.gitignore
index e6186bb..dbbfc77 100644
--- a/.gitignore
+++ b/.gitignore
@@ -24,3 +24,6 @@ local*
 .cursorignore
 .cursorrules
 .cursor/mcp.json
+
+CLAUDE.local.md
+__pycache__/
\ No newline at end of file
diff --git a/models/silver/defi/silver__dex_swaps_v2.sql b/models/silver/defi/silver__dex_swaps_v2.sql
index 9c5c4c2..d1ddbbb 100644
--- a/models/silver/defi/silver__dex_swaps_v2.sql
+++ b/models/silver/defi/silver__dex_swaps_v2.sql
@@ -149,7 +149,7 @@ swap_outcome AS (
             LOG,
             '.*Swapped (\\d+) (.*) for (\\d+) (.*)',
             '\\1'
-        ) :: INT AS amount_in_raw,
+        ) :: NUMERIC(38,0) AS amount_in_raw,
         REGEXP_REPLACE(
             LOG,
             '.*Swapped \\d+ (\\S+) for (\\d+) (.*)',
@@ -159,7 +159,7 @@ swap_outcome AS (
             LOG,
             '.*Swapped \\d+ \\S+ for (\\d+) (.*)',
             '\\1'
-        ) :: INT AS amount_out_raw,
+        ) :: NUMERIC(38,0) AS amount_out_raw,
         REGEXP_REPLACE(
             LOG,
             '.*Swapped \\d+ \\S+ for \\d+ (.*)',
@@ -187,9 +187,9 @@ rhea_swap_outcome AS (
                 log_index ASC
         ) - 1 AS swap_index, -- keeping this as fallback but Rhea logs typically contain single swap / receipt
         clean_log AS LOG,
-        TRY_PARSE_JSON(clean_log):data[0]:amount_in::INT AS amount_in_raw,
+        TRY_PARSE_JSON(clean_log):data[0]:amount_in::NUMERIC(38,0) AS amount_in_raw,
         TRY_PARSE_JSON(clean_log):data[0]:token_in::STRING AS token_in,
-        TRY_PARSE_JSON(clean_log):data[0]:amount_out::INT AS amount_out_raw,
+        TRY_PARSE_JSON(clean_log):data[0]:amount_out::NUMERIC(38,0) AS amount_out_raw,
         TRY_PARSE_JSON(clean_log):data[0]:token_out::STRING AS token_out,
         _partition_by_block_number,
         modified_timestamp,
diff --git a/models/silver/defi/swaps/silver__swap_intents.sql b/models/silver/defi/swaps/silver__swap_intents.sql
index 645e6f7..d1dc6e8 100644
--- a/models/silver/defi/swaps/silver__swap_intents.sql
+++ b/models/silver/defi/swaps/silver__swap_intents.sql
@@ -394,9 +394,9 @@ intents_mapped AS (
         account_id,
         referral,
         ROW_NUMBER() OVER (PARTITION BY tx_hash ORDER BY intent_hash, receipt_id) - 1 AS swap_index,
-        amount_out_raw::STRING AS amount_out_raw,
+        amount_out_raw::NUMERIC(38,0) AS amount_out_raw,
         token_out,
-        amount_in_raw::STRING AS amount_in_raw,
+        amount_in_raw::NUMERIC(38,0) AS amount_in_raw,
         token_in,
         swap_input_data,
         log,