Skip to content

Commit 6587c0e

Browse files
committed
feat: delta v2 - more columns to conform DEX trades shape
1 parent cf91b64 commit 6587c0e

1 file changed

Lines changed: 34 additions & 19 deletions

File tree

  • dbt_subprojects/dex/macros/models/_project/paraswap/delta/v2

dbt_subprojects/dex/macros/models/_project/paraswap/delta/v2/master.sql

Lines changed: 34 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -16,28 +16,43 @@ with
1616
select
1717

1818
-- SELECT
19-
blockchain,
19+
delta_v2_master.blockchain,
2020
'velora_delta' as project,
2121
'v2' as version,
2222
block_month,
2323
DATE_TRUNC('day', call_block_time) as block_date,
24-
call_block_time as block_time,
25-
token_pair,
26-
token_bought_amount,
27-
token_sold_amount,
28-
token_bought_amount_raw,
29-
token_sold_amount_raw,
30-
amount_usd,
31-
token_bought_address,
32-
token_sold_address,
33-
taker,
34-
maker,
35-
project_contract_address,
36-
tx_hash,
37-
tx_from,
38-
tx_to,
39-
trace_address,
40-
evt_index
24+
call_block_time as block_time,
25+
CASE
26+
WHEN lower(t_dest_token.symbol) > lower(t_src_token.symbol)
27+
THEN concat(t_src_token.symbol, '-', t_dest_token.symbol)
28+
ELSE concat(t_dest_token.symbol, '-', t_src_token.symbol)
29+
END as token_pair
30+
-- token_bought_amount,
31+
-- token_sold_amount,
32+
-- token_bought_amount_raw,
33+
-- token_sold_amount_raw,
34+
-- amount_usd,
35+
-- token_bought_address,
36+
-- token_sold_address,
37+
-- taker,
38+
-- maker,
39+
-- project_contract_address,
40+
-- tx_hash,
41+
-- tx_from,
42+
-- tx_to,
43+
-- trace_address,
44+
-- evt_index
4145
-- FROM {{ dex_model }}
42-
from delta_v2_master
46+
from delta_v2_master
47+
LEFT JOIN
48+
{{ source('tokens', 'erc20') }} t_src_token
49+
ON t_src_token.blockchain = '{{blockchain}}'
50+
AND t_src_token.contract_address = src_token
51+
LEFT JOIN
52+
{{ source('tokens', 'erc20') }} t_dest_token
53+
ON t_dest_token.blockchain = '{{blockchain}}'
54+
AND t_dest_token.contract_address = dest_token
55+
56+
order by block_time desc
57+
limit 1
4358
{% endmacro %}

0 commit comments

Comments
 (0)