optimism: uniswap pools balances (duneanalytics#7434)

* added optimism: uniswap pools dex balances * update sql file * Update _schema.yml * update files * Resolved merge conflicts in _schema.yml * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * updated sql file * Update uniswap_pools_optimism_balances.sql * updated sql file * updated sql file * updated sql file * updated sql file
viniabussafi · Jan 17, 2025 · de9c7a0 · de9c7a0
1 parent a54015f
commit de9c7a0
Show file tree

Hide file tree

Showing 3 changed files with 66 additions and 0 deletions.
diff --git a/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/uniswap/_schema.yml b/dbt_subprojects/daily_spellbook/models/_sector/dex/pools/optimism/uniswap/_schema.yml
@@ -0,0 +1,17 @@
+version: 2
+
+models:
+  - name:  uniswap_pools_optimism_balances
+    description: "Tracks OP token balances in Uniswap pools on Optimism."
+    meta:
+      blockchain: optimism
+      sector: DEX
+      project: uniswap
+      contributors: jason
+    config:
+      tags: ['optimism', 'op_token', 'balances', 'uniswap','pools']
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - pool_address
+            - snapshot_day
diff --git a/...y_spellbook/models/_sector/dex/pools/optimism/uniswap/uniswap_pools_optimism_balances.sql b/...y_spellbook/models/_sector/dex/pools/optimism/uniswap/uniswap_pools_optimism_balances.sql
@@ -0,0 +1,47 @@
+{{
+  config(
+    schema = 'uniswap_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      
+    pool as address,  
+    token0,          
+    token1,
+    0x4200000000000000000000000000000000000042 as token_address,       
+    fee as fee_tier,
+    creation_block_time as creation_time
+  from 
+    {{ source('uniswap_v3_optimism', 'pools') }}
+  where
+    token0 = 0x4200000000000000000000000000000000000042
+    or token1 = 0x4200000000000000000000000000000000000042
+),
+
+filtered_balances as (
+  {{ balances_incremental_subset_daily(
+       blockchain='optimism',
+       start_date='2021-11-11',
+        address_token_list = 'op_addresses'         
+  ) }}
+)
+
+select 
+  p.address as pool_address, 
+  p.token0 as token0,         
+  p.token1 as token1, 
+  p.fee_tier,
+  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    
diff --git a/sources/_sector/dex/trades/optimism/_sources.yml b/sources/_sector/dex/trades/optimism/_sources.yml
@@ -2,6 +2,8 @@ version: 2
 
 sources:
   - name: uniswap_v3_optimism
+    tables:
+      - name: pools
   - name: sushi_optimism
     tables:
       - name: ConstantProductPool_evt_Swap