Skip to content

Commit

Permalink
Fix odos_v2_optimism_trades.sql (#5404)
Browse files Browse the repository at this point in the history
  • Loading branch information
@amalashkevich
amalashkevich authored Feb 27, 2024
1 parent 3463339 commit d3d2c26
Showing 1 changed file with 52 additions and 44 deletions.
96 changes: 52 additions & 44 deletions models/odos/optimism/odos_v2_optimism_trades.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,19 +9,27 @@
)
}}

{% set project_start_date = '2023-07-28' %}
{% set project_start_date = '2023-07-13' %}

with dexs AS (
with event_data AS (
SELECT
evt_block_number AS block_number,
evt_block_time AS block_time,
evt_block_number AS block_number,
sender AS taker,
contract_address AS maker,
CASE WHEN inputAmount < INT256 '0' THEN abs(inputAmount) ELSE abs(amountOut) END AS token_bought_amount_raw,
CASE WHEN inputAmount < INT256 '0' THEN abs(amountOut) ELSE abs(inputAmount) END AS token_sold_amount_raw,
CAST(NULL as double) as amount_usd,
CASE WHEN inputAmount < INT256 '0' THEN inputToken ELSE outputToken END AS token_bought_address,
CASE WHEN inputAmount < INT256 '0' THEN outputToken ELSE inputToken END AS token_sold_address,
inputAmount AS token_sold_amount_raw,
amountOut AS token_bought_amount_raw,
CAST(NULL as double) as amount_usd,
CASE
WHEN inputToken = 0x0000000000000000000000000000000000000000
THEN 0x4200000000000000000000000000000000000006 -- WETH
ELSE inputToken
END AS token_sold_address,
CASE
WHEN outputToken = 0x0000000000000000000000000000000000000000
THEN 0x4200000000000000000000000000000000000006 -- WETH
ELSE outputToken
END AS token_bought_address,
contract_address AS project_contract_address,
evt_tx_hash AS tx_hash,
evt_index,
Expand All @@ -36,64 +44,64 @@ with dexs AS (
)

SELECT
'optimism' AS blockchain,
'odos' AS project,
'2' AS version,
TRY_CAST(date_trunc('DAY', dexs.block_time) AS date) AS block_date,
TRY_CAST(date_trunc('MONTH', dexs.block_time) AS date) AS block_month,
dexs.block_time,
erc20a.symbol AS token_bought_symbol,
erc20b.symbol AS token_sold_symbol,
'optimism' AS blockchain,
'odos' AS project,
'2' AS version,
TRY_CAST(date_trunc('DAY', e.block_time) AS date) AS block_date,
TRY_CAST(date_trunc('MONTH', e.block_time) AS date) AS block_month,
e.block_time,
erc20a.symbol AS token_bought_symbol,
erc20b.symbol AS token_sold_symbol,
CASE
WHEN lower(erc20a.symbol) > lower(erc20b.symbol)
THEN concat(erc20b.symbol, '-', erc20a.symbol)
ELSE concat(erc20a.symbol, '-', erc20b.symbol)
END AS token_pair,
dexs.token_bought_amount_raw / power(10, erc20a.decimals) AS token_bought_amount,
dexs.token_sold_amount_raw / power(10, erc20b.decimals) AS token_sold_amount,
dexs.token_bought_amount_raw AS token_bought_amount_raw,
dexs.token_sold_amount_raw AS token_sold_amount_raw,
END AS token_pair,
e.token_bought_amount_raw / power(10, erc20a.decimals) AS token_bought_amount,
e.token_sold_amount_raw / power(10, erc20b.decimals) AS token_sold_amount,
e.token_bought_amount_raw AS token_bought_amount_raw,
e.token_sold_amount_raw AS token_sold_amount_raw,
COALESCE(
dexs.amount_usd,
(dexs.token_bought_amount_raw / power(10, erc20a.decimals)) * p_bought.price,
(dexs.token_sold_amount_raw / power(10, erc20b.decimals)) * p_sold.price
) AS amount_usd,
CAST(dexs.token_bought_address AS varbinary) AS token_bought_address,
dexs.token_sold_address,
CAST(dexs.taker AS varbinary) AS taker,
dexs.maker,
dexs.project_contract_address,
dexs.tx_hash,
tx."from" AS tx_from,
tx.to AS tx_to,
dexs.evt_index,
dexs.trace_address
FROM dexs
e.amount_usd,
(e.token_bought_amount_raw / power(10, erc20a.decimals)) * p_bought.price,
(e.token_sold_amount_raw / power(10, erc20b.decimals)) * p_sold.price
) AS amount_usd,
CAST(e.token_bought_address AS varbinary) AS token_bought_address,
e.token_sold_address,
CAST(e.taker AS varbinary) AS taker,
e.maker,
e.project_contract_address,
e.tx_hash,
tx."from" AS tx_from,
tx.to AS tx_to,
e.evt_index,
e.trace_address
FROM event_data e
INNER JOIN {{ source('optimism', 'transactions') }} tx
ON dexs.tx_hash = tx.hash
ON e.tx_hash = tx.hash
{% if not is_incremental() %}
AND tx.block_time >= DATE '{{project_start_date}}'
{% else %}
AND {{ incremental_predicate('tx.block_time') }}
{% endif %}
LEFT JOIN {{ source('tokens', 'erc20') }} erc20a
ON erc20a.contract_address = dexs.token_bought_address
LEFT JOIN {{ source('tokens', 'erc20') }} erc20a
ON erc20a.contract_address = e.token_bought_address
AND erc20a.blockchain = 'optimism'
LEFT JOIN {{ source('tokens', 'erc20') }} erc20b
ON erc20b.contract_address = dexs.token_sold_address
ON erc20b.contract_address = e.token_sold_address
AND erc20b.blockchain = 'optimism'
LEFT JOIN {{ source('prices', 'usd') }} p_bought
ON p_bought.minute = date_trunc('minute', dexs.block_time)
AND p_bought.contract_address = dexs.token_bought_address
ON p_bought.minute = date_trunc('minute', e.block_time)
AND p_bought.contract_address = e.token_bought_address
AND p_bought.blockchain = 'optimism'
{% if not is_incremental() %}
AND p_bought.minute >= DATE '{{project_start_date}}'
{% else %}
AND {{ incremental_predicate('p_bought.minute') }}
{% endif %}
LEFT JOIN {{ source('prices', 'usd') }} p_sold
ON p_sold.minute = date_trunc('minute', dexs.block_time)
AND p_sold.contract_address = dexs.token_sold_address
ON p_sold.minute = date_trunc('minute', e.block_time)
AND p_sold.contract_address = e.token_sold_address
AND p_sold.blockchain = 'optimism'
{% if not is_incremental() %}
AND p_sold.minute >= DATE '{{project_start_date}}'
Expand Down

0 comments on commit d3d2c26

Please sign in to comment.