Skip to content

Commit de1d2e2

Browse files
tomfutagotomfutago
authored
CUR2-548: monad more dexes (#9068)
1 parent 3a9c865 commit de1d2e2

File tree

11 files changed

+219
-0
lines changed

11 files changed

+219
-0
lines changed

‎dbt_subprojects/dex/models/dex_info.sql‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,4 +242,6 @@ FROM (VALUES
242242
, ('story_hunt', 'Story Hunt', 'Direct', 'story_hunt')
243243
, ('piperx', 'PiperX', 'Direct', 'piperx')
244244
, ('mezo_swap', 'Mezo Swap', 'Direct', 'mezoswap')
245+
, ('kuru', 'Kuru', 'Direct', 'kuru')
246+
, ('pinot', 'Pinot', 'Direct', 'pinot')
245247
) AS temp_table (project, name, marketplace_type, x_username)

‎dbt_subprojects/dex/models/trades/monad/_schema.yml‎

Lines changed: 76 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,3 +24,79 @@ models:
2424
- evt_index
2525
- check_dex_base_trades_seed:
2626
seed_file: ref('kuru_monad_base_trades_seed')
27+
28+
- name: pinot_v2_monad_base_trades
29+
meta:
30+
blockchain: monad
31+
sector: dex
32+
project: pinot
33+
contributors: tomfutago
34+
config:
35+
tags: [ 'monad', 'dex', 'trades', 'pinot' ]
36+
description: "pinot monad base trades"
37+
data_tests:
38+
- dbt_utils.unique_combination_of_columns:
39+
combination_of_columns:
40+
- tx_hash
41+
- evt_index
42+
- check_dex_base_trades_seed:
43+
seed_file: ref('pinot_monad_base_trades_seed')
44+
filter:
45+
version: 2
46+
47+
- name: pinot_v3_monad_base_trades
48+
meta:
49+
blockchain: monad
50+
sector: dex
51+
project: pinot
52+
contributors: tomfutago
53+
config:
54+
tags: [ 'monad', 'dex', 'trades', 'pinot' ]
55+
description: "pinot v3 monad base trades"
56+
data_tests:
57+
- dbt_utils.unique_combination_of_columns:
58+
combination_of_columns:
59+
- tx_hash
60+
- evt_index
61+
- check_dex_base_trades_seed:
62+
seed_file: ref('pinot_monad_base_trades_seed')
63+
filter:
64+
version: 3
65+
66+
- name: uniswap_v2_monad_base_trades
67+
meta:
68+
blockchain: monad
69+
sector: dex
70+
project: uniswap
71+
contributors: tomfutago
72+
config:
73+
tags: [ 'monad', 'dex', 'trades', 'uniswap', 'v2' ]
74+
description: "uniswap monad v2 base trades"
75+
data_tests:
76+
- dbt_utils.unique_combination_of_columns:
77+
combination_of_columns:
78+
- tx_hash
79+
- evt_index
80+
- check_dex_base_trades_seed:
81+
seed_file: ref('uniswap_monad_base_trades_seed')
82+
filter:
83+
version: 2
84+
85+
- name: uniswap_v3_monad_base_trades
86+
meta:
87+
blockchain: monad
88+
sector: dex
89+
project: uniswap
90+
contributors: tomfutago
91+
config:
92+
tags: [ 'monad', 'dex', 'trades', 'uniswap', 'v3' ]
93+
description: "uniswap monad v3 base trades"
94+
data_tests:
95+
- dbt_utils.unique_combination_of_columns:
96+
combination_of_columns:
97+
- tx_hash
98+
- evt_index
99+
- check_dex_base_trades_seed:
100+
seed_file: ref('uniswap_monad_base_trades_seed')
101+
filter:
102+
version: 3

‎dbt_subprojects/dex/models/trades/monad/dex_monad_base_trades.sql‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,10 @@
1212

1313
{% set base_models = [
1414
ref('kuru_monad_base_trades')
15+
, ref('pinot_v2_monad_base_trades')
16+
, ref('pinot_v3_monad_base_trades')
17+
, ref('uniswap_v2_monad_base_trades')
18+
, ref('uniswap_v3_monad_base_trades')
1519
] %}
1620
with base_union as (
1721
SELECT *

‎dbt_subprojects/dex/models/trades/monad/platforms/pinot_v2_monad_base_trades.sql‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
{{
2+
config(
3+
schema = 'pinot_v2_monad_base_trades',
4+
alias = 'base_trades',
5+
materialized = 'incremental',
6+
file_format = 'delta',
7+
incremental_strategy = 'merge',
8+
unique_key = ['tx_hash', 'evt_index'],
9+
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
10+
)
11+
}}
12+
13+
{{
14+
uniswap_compatible_v2_trades(
15+
blockchain = 'monad',
16+
project = 'pinot',
17+
version = '2',
18+
Pair_evt_Swap = source('pinot_monad', 'uniswapv2pair_evt_swap'),
19+
Factory_evt_PairCreated = source('pinot_monad', 'uniswapv2factory_evt_paircreated')
20+
)
21+
}}

‎dbt_subprojects/dex/models/trades/monad/platforms/pinot_v3_monad_base_trades.sql‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
{{
2+
config(
3+
schema = 'pinot_v3_monad_base_trades',
4+
alias = 'base_trades',
5+
materialized = 'incremental',
6+
file_format = 'delta',
7+
incremental_strategy = 'merge',
8+
unique_key = ['tx_hash', 'evt_index'],
9+
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
10+
)
11+
}}
12+
13+
{{
14+
uniswap_compatible_v3_trades(
15+
blockchain = 'monad',
16+
project = 'pinot',
17+
version = '3',
18+
Pair_evt_Swap = source('pinot_monad', 'uniswapv3pool_evt_swap'),
19+
Factory_evt_PoolCreated = source('pinot_monad', 'uniswapv3factory_evt_poolcreated')
20+
)
21+
}}

‎dbt_subprojects/dex/models/trades/monad/platforms/uniswap_v2_monad_base_trades.sql‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
{{
2+
config(
3+
schema = 'uniswap_v2_monad',
4+
alias = 'base_trades',
5+
materialized = 'incremental',
6+
file_format = 'delta',
7+
incremental_strategy = 'merge',
8+
unique_key = ['tx_hash', 'evt_index'],
9+
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
10+
)
11+
}}
12+
13+
{{
14+
uniswap_compatible_v2_trades(
15+
blockchain = 'monad',
16+
project = 'uniswap',
17+
version = '2',
18+
Pair_evt_Swap = source('uniswap_v2_monad', 'uniswapv2pair_evt_swap'),
19+
Factory_evt_PairCreated = source('uniswap_v2_monad', 'uniswapv2factory_evt_paircreated')
20+
)
21+
}}

‎dbt_subprojects/dex/models/trades/monad/platforms/uniswap_v3_monad_base_trades.sql‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
{{
2+
config(
3+
schema = 'uniswap_v3_monad',
4+
alias = 'base_trades',
5+
materialized = 'incremental',
6+
file_format = 'delta',
7+
incremental_strategy = 'merge',
8+
unique_key = ['tx_hash', 'evt_index'],
9+
incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
10+
)
11+
}}
12+
13+
{{
14+
uniswap_compatible_v3_trades(
15+
blockchain = 'monad',
16+
project = 'uniswap',
17+
version = '3',
18+
Pair_evt_Swap = source('uniswap_v3_monad', 'uniswapv3pool_evt_swap'),
19+
Factory_evt_PoolCreated = source('uniswap_v3_monad', 'uniswapv3factory_evt_poolcreated')
20+
)
21+
}}

‎dbt_subprojects/dex/seeds/trades/_schema.yml‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6084,3 +6084,31 @@ seeds:
60846084
token_bought_amount_raw: uint256
60856085
token_sold_amount_raw: uint256
60866086
block_date: timestamp
6087+
- name: pinot_monad_base_trades_seed
6088+
config:
6089+
column_types:
6090+
blockchain: varchar
6091+
project: varchar
6092+
version: varchar
6093+
tx_hash: varbinary
6094+
evt_index: uint256
6095+
block_number: uint256
6096+
token_bought_address: varbinary
6097+
token_sold_address: varbinary
6098+
token_bought_amount_raw: uint256
6099+
token_sold_amount_raw: uint256
6100+
block_date: timestamp
6101+
- name: uniswap_monad_base_trades_seed
6102+
config:
6103+
column_types:
6104+
blockchain: varchar
6105+
project: varchar
6106+
version: varchar
6107+
tx_hash: varbinary
6108+
evt_index: uint256
6109+
block_number: uint256
6110+
token_bought_address: varbinary
6111+
token_sold_address: varbinary
6112+
token_bought_amount_raw: uint256
6113+
token_sold_amount_raw: uint256
6114+
block_date: timestamp

‎dbt_subprojects/dex/seeds/trades/pinot_monad_base_trades_seed.csv‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
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
2+
monad,pinot,2,2025-11-28,0x9581580bc70b3cefe6ebace589cbf62cf85a0ed1d232db4227b50fb1aa1877ed,93,0x39b9e06f226ff6d7500c870b82333aacbd2f7777,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,38555196,282033440207035071393,1978293780625668023
3+
monad,pinot,2,2025-11-28,0x17c129d19c6bcf47330ae5110dd226bbb1b30a2bc566eb9fd343fec8f5c67813,41,0x39b9e06f226ff6d7500c870b82333aacbd2f7777,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,38554639,289578466120857430918,1929979183051333406
4+
monad,pinot,2,2025-11-28,0xc7e07d141a38d54814002b3babc36471832793c34a530aa6da3a1b31ac48a9d6,6,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,0xa7b3f394b9aaba67f2543a8c1a0f753cc68d7777,38554504,2780820898972002481,1550851282339065665429
5+
monad,pinot,3,2025-11-28,0x94a4dd65957c92c580788676f2ea3c51bfe43222cf6234c5db130edb87fa6a02,4,0x1b68626dca36c7fe922fd2d55e4f631d962de19c,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,38557559,19195749078252593828,27740119442258714875
6+
monad,pinot,3,2025-11-28,0x915a080097a9d83992ed6495462f0c6e00db9b92569d8a5f8aa1c3829bf0e548,9,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,0x1b68626dca36c7fe922fd2d55e4f631d962de19c,38557555,37180198866775447486,25732966268825137094
7+
monad,pinot,3,2025-11-28,0x78b5f715e22cacb0d6c80ff3089c620a9f152e3eae5c4a6816e863865a8e8f60,4,0x754704bc059f8c67012fed69bc8a327a5aafb603,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,38557540,300012,8554850365786495539

‎dbt_subprojects/dex/seeds/trades/uniswap_monad_base_trades_seed.csv‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
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
2+
monad,uniswap,3,2025-11-28,0x30198a8b13c286277c37ba0e1b86ea9d23f76d98d5706b66784b3bf9f65ba273,4,0x754704bc059f8c67012fed69bc8a327a5aafb603,0x1f80c65cc2c37af84abbe1ea03183a624a6f8888,38557569,122683903,469198233454000000000000
3+
monad,uniswap,3,2025-11-28,0x933c5b5bd845c5313a62a1349f9e372f2033f35e9a86e46afa6dc94f26ab415d,36,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,0x754704bc059f8c67012fed69bc8a327a5aafb603,38557567,456661040348958461251,15991550
4+
monad,uniswap,3,2025-11-28,0x00cfd24bb6679d9f3e0bee5f21037f2f5b34585fe7171cfa05b9437323cca4d7,89,0x3bd359c1119da7da1d913d1c4d2b7c461115433a,0x754704bc059f8c67012fed69bc8a327a5aafb603,38557564,315322612357940710710,11040000

0 commit comments

Comments
 (0)