From 582e1c77b57ee097e94e3c40559b5477695b0fc6 Mon Sep 17 00:00:00 2001
From: stanz <gstanleytejakusuma@gmail.com>
Date: Mon, 8 Dec 2025 21:44:39 +0700
Subject: [PATCH] add macro

---
 macros/get_missing_verified_tokens.sql | 11 +++++++++++
 macros/unverify_tokens.sql             |  6 +++---
 2 files changed, 14 insertions(+), 3 deletions(-)
 create mode 100644 macros/get_missing_verified_tokens.sql

diff --git a/macros/get_missing_verified_tokens.sql b/macros/get_missing_verified_tokens.sql
new file mode 100644
index 0000000..e9c6229
--- /dev/null
+++ b/macros/get_missing_verified_tokens.sql
@@ -0,0 +1,11 @@
+{% macro get_missing_verified_tokens(column_name='token_address') %}
+  SELECT DISTINCT LOWER(p.token_address) AS token_address
+  FROM {{ ref('price__ez_prices_hourly') }} p
+  WHERE p.is_verified = TRUE
+    AND p.token_address IS NOT NULL
+    AND NOT EXISTS (
+        SELECT 1
+        FROM {{ this }} t
+        WHERE LOWER(t.{{ column_name }}) = LOWER(p.token_address)
+    )
+{% endmacro %}
diff --git a/macros/unverify_tokens.sql b/macros/unverify_tokens.sql
index 48ba5d3..051c3e8 100644
--- a/macros/unverify_tokens.sql
+++ b/macros/unverify_tokens.sql
@@ -1,10 +1,10 @@
-{% macro unverify_tokens() %}
+{% macro unverify_tokens(column_name='token_address') %}
   {% if var('HEAL_MODEL', false) and is_incremental() %}
     DELETE FROM {{ this }}
-    WHERE LOWER(token_address) NOT IN (
+    WHERE LOWER({{ column_name }}) NOT IN (
         SELECT DISTINCT LOWER(token_address)
         FROM {{ ref('price__ez_prices_hourly') }}
-        WHERE 
+        WHERE
           is_verified = TRUE
           AND token_address IS NOT NULL
     );