Add wagmi sonic trades (#7510)

* Add wagmi source * Add wagmi_sonic_base_trades * Add wagmi_sonic_base_trades_seed and test * Fix seed blank
duneanalytics · Jan 22, 2025 · b0d7614 · b0d7614
1 parent ddda8db
commit b0d7614
Show file tree

Hide file tree

Showing 6 changed files with 65 additions and 1 deletion.
diff --git a/dbt_subprojects/dex/models/trades/sonic/_schema.yml b/dbt_subprojects/dex/models/trades/sonic/_schema.yml
@@ -20,4 +20,21 @@ models:
             - tx_hash
             - evt_index
       - check_dex_base_trades_seed:
-          seed_file: ref('beets_sonic_base_trades_seed')
+          seed_file: ref('beets_sonic_base_trades_seed')
+
+  - name: wagmi_sonic_base_trades
+    meta:
+      blockchain: sonic
+      sector: dex
+      project: wagmi
+      contributors: hosuke
+    config:
+      tags: ['sonic', 'dex', 'trades', 'wagmi']
+    description: "wagmi sonic base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+      - check_dex_base_trades_seed:
+          seed_file: ref('wagmi_sonic_base_trades_seed')
diff --git a/dbt_subprojects/dex/models/trades/sonic/dex_sonic_base_trades.sql b/dbt_subprojects/dex/models/trades/sonic/dex_sonic_base_trades.sql
@@ -7,6 +7,7 @@
 
 {% set base_models = [
     ref('beets_sonic_base_trades')
+    , ref('wagmi_sonic_base_trades')
 ] %}
 
 WITH base_union AS (

diff --git a/dbt_subprojects/dex/models/trades/sonic/platforms/wagmi_sonic_base_trades.sql b/dbt_subprojects/dex/models/trades/sonic/platforms/wagmi_sonic_base_trades.sql
@@ -0,0 +1,21 @@
+{{
+    config(
+        schema = 'wagmi_sonic',
+        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')]
+    )
+}}
+
+{{
+    uniswap_compatible_v3_trades(
+        blockchain = 'sonic',
+        project = 'wagmi',
+        version = '3',
+        Pair_evt_Swap = source('wagmi_sonic', 'UniswapV3Pool_evt_Swap'),
+        Factory_evt_PoolCreated = source('wagmi_sonic', 'UniswapV3Factory_evt_PoolCreated')
+    )
+}}
diff --git a/dbt_subprojects/dex/seeds/trades/_schema.yml b/dbt_subprojects/dex/seeds/trades/_schema.yml
@@ -4731,6 +4731,21 @@ seeds:
         block_date: timestamp
 
   - name: camelot_corn_base_trades_seed
+    config:
+      column_types:
+        blockchain: varchar
+        project: varchar
+        version: varchar
+        tx_hash: varbinary
+        evt_index: uint256
+        block_number: uint256
+        token_bought_address: varbinary
+        token_sold_address: varbinary
+        token_bought_amount_raw: uint256
+        token_sold_amount_raw: uint256
+        block_date: timestamp
+
+  - name: wagmi_sonic_base_trades_seed
     config:
       column_types:
         blockchain: varchar

diff --git a/dbt_subprojects/dex/seeds/trades/wagmi_sonic_base_trades_seed.csv b/dbt_subprojects/dex/seeds/trades/wagmi_sonic_base_trades_seed.csv
@@ -0,0 +1,3 @@
+blockchain,project,version,block_date,tx_hash,evt_index,token_bought_address,token_sold_address,block_number,token_bought_amount_raw,token_sold_amount_raw
+sonic,wagmi,3,2025-01-21,0x8c447cc48a4488870ac0a5a39f42e764a50f159fa9fbadace10a2dca77640f1a,2,0x50c42deacd8fc9773493ed674b675be577f2634b,0x039e2fb66102314ce7b64ce5ce3e5183bc94ad38,4847335,50421632945765830,271700000000000000000
+sonic,wagmi,3,2025-01-21,0x38155f722ac19c89b6b9798d11467bcd9e2ec9ac463dbb09ad3e8b95d0e03cdd,8,0x039e2fb66102314ce7b64ce5ce3e5183bc94ad38,0x50c42deacd8fc9773493ed674b675be577f2634b,4848299,2397204077986245906501,450000000000000000
diff --git a/sources/_sector/dex/trades/sonic/_sources.yml b/sources/_sector/dex/trades/sonic/_sources.yml
@@ -0,0 +1,7 @@
+version: 2
+
+sources:
+  - name: wagmi_sonic
+    tables:
+      - name: UniswapV3Factory_evt_PoolCreated
+      - name: UniswapV3Pool_evt_Swap