From 22d3f2cbb1a5cd62ad6a5260c142b34dae4e17f3 Mon Sep 17 00:00:00 2001
From: jason <jasonreddy4276@gmail.com>
Date: Sat, 18 Jan 2025 14:08:46 +0530
Subject: [PATCH] added openxswap balances

---
 .../dex/pools/optimism/aave/_schema.yml       |  2 +-
 .../dex/pools/optimism/openxswap/_schema.yml  | 17 +++++++
 .../openxswap_pools_optimism_balances.sql     | 46 +++++++++++++++++++
 .../_sector/dex/trades/optimism/_sources.yml  |  1 +
 4 files changed, 65 insertions(+), 1 deletion(-)
 create mode 100644 dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/_schema.yml
 create mode 100644 dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/openxswap_pools_optimism_balances.sql

diff --git a/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/aave/_schema.yml b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/aave/_schema.yml
index 2b7ec3fa2c3..7fb0c29db91 100644
--- a/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/aave/_schema.yml
+++ b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/aave/_schema.yml
@@ -5,7 +5,7 @@ models:
     description: "Tracks OP token balances in Aave pools on Optimism."
     meta:
       blockchain: optimism
-      sector: DEX
+      sector: Leding
       project: aave
       contributors: jason
     config:
diff --git a/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/_schema.yml b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/_schema.yml
new file mode 100644
index 00000000000..7eb55d88ebb
--- /dev/null
+++ b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/_schema.yml
@@ -0,0 +1,17 @@
+version: 2
+
+models:
+  - name:  openxswap_pools_optimism_balances
+    description: "Tracks OP token balances in openxswap pools on Optimism."
+    meta:
+      blockchain: optimism
+      sector: DEX
+      project: openxswap
+      contributors: jason
+    config:
+      tags: ['optimism', 'op_token', 'balances', 'openxswap']
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - pool_address
+            - snapshot_day
\ No newline at end of file
diff --git a/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/openxswap_pools_optimism_balances.sql b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/openxswap_pools_optimism_balances.sql
new file mode 100644
index 00000000000..82d5f7984c3
--- /dev/null
+++ b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/openxswap/openxswap_pools_optimism_balances.sql
@@ -0,0 +1,46 @@
+{{
+  config(
+    schema = 'openxswap_pools_optimism',
+    alias = 'balances',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['pool_address', 'snapshot_day'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.snapshot_day')]
+  )
+}}
+
+with op_addresses as (
+  select      
+    pair as address,  
+    token0,          
+    token1,
+    0x4200000000000000000000000000000000000042 as token_address,
+    evt_block_date as creation_time
+  from 
+    {{ source('openxswap_optimism', 'UniswapV2Factory_evt_PairCreated') }}
+  where
+    token0 = 0x4200000000000000000000000000000000000042
+    or token1 = 0x4200000000000000000000000000000000000042
+),
+
+filtered_balances as (
+  {{ balances_incremental_subset_daily(
+       blockchain='optimism',
+       start_date='2022-09-14',
+        address_token_list = 'op_addresses'         
+  ) }}
+)
+
+select 
+  p.address as pool_address, 
+  'openxswap' AS protocol_name,
+  p.token0 as token0,         
+  p.token1 as token1, 
+  p.creation_time,
+  coalesce(b.balance, 0) as op_balance,
+  coalesce(b.day, current_date) as snapshot_day
+from 
+  filtered_balances b
+left join
+  op_addresses p on b.address = p.address 
\ No newline at end of file
diff --git a/sources/_sector/dex/trades/optimism/_sources.yml b/sources/_sector/dex/trades/optimism/_sources.yml
index 97a9df553a8..5c9a917be1c 100644
--- a/sources/_sector/dex/trades/optimism/_sources.yml
+++ b/sources/_sector/dex/trades/optimism/_sources.yml
@@ -53,6 +53,7 @@ sources:
   - name: openxswap_optimism
     tables:
       - name: Aggregator_evt_Swap
+      - name: UniswapV2Factory_evt_PairCreated
   - name: openocean_v2_optimism
     tables:
       - name: OpenOceanExchangeProxy_evt_Swapped