Add arbswap to dex.trades_beta

[tomfutago]

linked to #4759

[dune-eng]

Workflow run id 6972573753 approved.

[dune-eng]

Workflow run id 6972574012 approved.

[Hosuke]

LGTM.✅
Thank you @tomfutago

Sample arbswap_arbitrum_base_trades

[dune-eng]

Workflow run id 7017377274 approved.

[dune-eng]

Workflow run id 7017377186 approved.

[Hosuke]

We may start trying to replace the part before UNION ALL with the macro.

[dune-eng]

Workflow run id 7018126055 approved.

[dune-eng]

Workflow run id 7018126165 approved.

[tomfutago]

Combo of macro + straight select applied, but as macro already contains cte (and already returns final list of columns) - it can't be a direct replacement of current select, but needs to go as a separate nested cte and then union outputs together.

If there's better way to go about it - lmk.

[Hosuke]

I just checked the compiled code of arbswap_arbitrum_base_trades.sql, and it looks good:

WITH 

dexs_macro AS (
    -- Arbswap AMM
    
WITH dexs AS
(
    SELECT
        t.evt_block_number AS block_number
        , t.evt_block_time AS block_time
        , t.to AS taker
        , t.contract_address AS maker
        , CASE WHEN amount0Out = UINT256 '0' THEN amount1Out ELSE amount0Out END AS token_bought_amount_raw
        , CASE WHEN amount0In = UINT256 '0' OR amount1Out = UINT256 '0' THEN amount1In ELSE amount0In END AS token_sold_amount_raw
        , CASE WHEN amount0Out = UINT256 '0' THEN f.token1 ELSE f.token0 END AS token_bought_address
        , CASE WHEN amount0In = UINT256 '0' OR amount1Out = UINT256 '0' THEN f.token1 ELSE f.token0 END AS token_sold_address
        , t.contract_address AS project_contract_address
        , t.evt_tx_hash AS tx_hash
        , t.evt_index AS evt_index
    FROM
        delta_prod.arbswap_arbitrum.SwapPair_evt_Swap t
    INNER JOIN
        delta_prod.arbswap_arbitrum.SwapFactory_evt_PairCreated f
        ON f.pair = t.contract_address
    
)

SELECT
    'arbitrum' AS blockchain
    , 'arbswap' AS project
    , '1' AS version
    , CAST(date_trunc('month', dexs.block_time) AS date) AS block_month
    , CAST(date_trunc('day', dexs.block_time) AS date) AS block_date
    , dexs.block_time
    , dexs.block_number
    , dexs.token_bought_amount_raw
    , dexs.token_sold_amount_raw
    , dexs.token_bought_address
    , dexs.token_sold_address
    , dexs.taker
    , dexs.maker
    , dexs.project_contract_address
    , dexs.tx_hash
    , dexs.evt_index
FROM
    dexs

),

dexs AS (
    -- Arbswap Stableswap
    SELECT
        t.evt_block_number AS block_number,
        t.evt_block_time AS block_time,
        t.buyer AS taker,
        CAST(NULL AS VARBINARY) AS maker,
        tokens_bought AS token_bought_amount_raw,
        tokens_sold AS token_sold_amount_raw,
        CASE WHEN bought_id = UINT256 '0' THEN f.tokenA ELSE f.tokenB END AS token_bought_address,
        CASE WHEN sold_id = UINT256 '0' THEN f.tokenA ELSE f.tokenB END AS token_sold_address,
        t.contract_address AS project_contract_address,
        t.evt_tx_hash AS tx_hash,
        t.evt_index
    FROM
        delta_prod.arbswap_arbitrum.ArbswapStableSwapTwoPool_evt_TokenExchange t
    INNER JOIN delta_prod.arbswap_arbitrum.ArbswapStableSwapFactory_evt_NewStableSwapPair f
        ON f.swapContract = t.contract_address
    
)

SELECT
    dexs_macro.blockchain,
    dexs_macro.project,
    dexs_macro.version,
    dexs_macro.block_month,
    dexs_macro.block_date,
    dexs_macro.block_time,
    dexs_macro.block_number,
    dexs_macro.token_bought_amount_raw,
    dexs_macro.token_sold_amount_raw,
    dexs_macro.token_bought_address,
    dexs_macro.token_sold_address,
    dexs_macro.taker,
    dexs_macro.maker,
    dexs_macro.project_contract_address,
    dexs_macro.tx_hash,
    dexs_macro.evt_index
FROM dexs_macro
UNION ALL
SELECT
    'arbitrum' AS blockchain,
    'arbswap' AS project,
    '1' AS version,
    CAST(date_trunc('month', dexs.block_time) AS date) AS block_month,
    CAST(date_trunc('day', dexs.block_time) AS date) AS block_date,
    dexs.block_time,
    dexs.block_number,
    dexs.token_bought_amount_raw,
    dexs.token_sold_amount_raw,
    dexs.token_bought_address,
    dexs.token_sold_address,
    dexs.taker,
    dexs.maker,
    dexs.project_contract_address,
    dexs.tx_hash,
    dexs.evt_index
FROM dexs

[Hosuke]

LGTM.✅ for the macro-hybrid spell
Sample macro-hybrid arbswap_arbitrum_base_trades

[jeff-dude]

i'm good with this approach -- thank you for finding a solution!

@Hosuke let's keep in mind for other projects moving forward.