Add opx_finance to dex.trades_beta (#5106)

* init * Update _schema.yml * Add opx_finance_optimism_sources.yml --------- Co-authored-by: Huang Geyang <Sukebeta@outlook.com>
duneanalytics · Jan 9, 2024 · b26d994 · b26d994
1 parent 5c7107d
commit b26d994
Show file tree

Hide file tree

Showing 5 changed files with 49 additions and 6 deletions.
diff --git a/models/_sector/dex/trades/optimism/_schema.yml b/models/_sector/dex/trades/optimism/_schema.yml
@@ -247,6 +247,7 @@ models:
               - elastic
               - elastic_2
 
+
   - name: velodrome_optimism_base_trades
     meta:
       blockchain: optimism
@@ -267,7 +268,8 @@ models:
             version:
               - 1
               - 2
-
+
+
   - name: synthetix_optimism_base_trades
     meta:
       blockchain: optimism
@@ -284,7 +286,8 @@ models:
             - evt_index
       - check_dex_base_trades_seed:
           seed_file: ref('synthetix_optimism_base_trades_seed')
-
+
+
   - name: openxswap_optimism_base_trades
     meta:
       blockchain: optimism
@@ -301,7 +304,8 @@ models:
             - evt_index
       - check_dex_base_trades_seed:
           seed_file: ref('openxswap_optimism_base_trades_seed')
-
+
+
   - name: openocean_optimism_base_trades
     meta:
       blockchain: optimism
@@ -318,3 +322,21 @@ models:
             - evt_index
       - check_dex_base_trades_seed:
           seed_file: ref('openocean_optimism_base_trades_seed')
+
+
+  - name: opx_finance_optimism_base_trades
+    meta:
+      blockchain: optimism
+      sector: dex
+      project: opx_finance
+      contributors: kaiblade, tomfutago
+    config:
+      tags: [ 'optimism', 'dex', 'trades', 'opx_finance' ]
+    description: "OPX Finance optimism base trades"
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('opx_finance_optimism_base_trades_seed')
diff --git a/models/_sector/dex/trades/optimism/_sources.yml b/models/_sector/dex/trades/optimism/_sources.yml
@@ -36,6 +36,9 @@ sources:
       - name: ClipperPackedExchange_evt_Swapped
       - name: ClipperPackedVerifiedExchange_evt_Swapped
       - name: ClipperCove_evt_CoveSwapped
+  - name: opx_finance_optimism
+    tables:
+      - name: Router_evt_Swap
   - name: velodrome_optimism
     tables:
       - name: Pair_evt_Swap

diff --git a/models/_sector/dex/trades/optimism/dex_optimism_base_trades.sql b/models/_sector/dex/trades/optimism/dex_optimism_base_trades.sql
@@ -18,6 +18,7 @@
     , ref('dodo_optimism_base_trades')
     , ref('kyberswap_optimism_base_trades')
     , ref('clipper_optimism_base_trades')
+    , ref('opx_finance_optimism_base_trades')
     , ref('velodrome_optimism_base_trades')
     , ref('synthetix_optimism_base_trades')
     , ref('openxswap_optimism_base_trades')

diff --git a/models/_sector/dex/trades/optimism/platforms/opx_finance_optimism_base_trades.sql b/models/_sector/dex/trades/optimism/platforms/opx_finance_optimism_base_trades.sql
@@ -0,0 +1,20 @@
+{{
+    config(
+        schema = 'opx_finance_optimism',
+        alias = 'base_trades',
+        materialized = 'incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['tx_hash', 'evt_index'],
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+{{
+    generic_spot_compatible_trades(
+        blockchain = 'optimism',
+        project = 'opx_finance',
+        version = '1',
+        source_evt_swap = source('opx_finance_optimism', 'Router_evt_Swap')
+    )
+}}
diff --git a/models/opx_finance/optimism/opx_finance_optimism_sources.yml b/models/opx_finance/optimism/opx_finance_optimism_sources.yml
@@ -7,9 +7,6 @@ sources:
     description: >
       Decoded event table for swaps on opx_finance
     tables:
-      - name: Router_evt_Swap
-        loaded_at_field: evt_block_time
-
       - name: Vault_evt_CollectMarginFees
         loaded_at_field: evt_block_time