0xHaM-dGnosis Inflow
    Updated 2023-03-17
    with ethereumTb AS (
    SELECT
    'Ethereum' as chain,
    'INflow' as direction,
    BLOCK_TIMESTAMP,
    TX_HASH,
    SYMBOL_IN as token,
    AMOUNT_IN * b.price as volume
    FROM ethereum.sushi.ez_swaps a JOIN ethereum.core.fact_hourly_token_prices b ON (a.BLOCK_TIMESTAMP::date = b.hour::date AND a.SYMBOL_IN = b.SYMBOL)
    WHERE SYMBOL_IN IN ('USDC', 'USDT', 'BUSD', 'TUSD', 'DAI', 'FRAX', 'sUSD')

    UNION ALL

    SELECT
    'Ethereum' as chain,
    'OUTflow' as direction,
    BLOCK_TIMESTAMP,
    TX_HASH,
    SYMBOL_OUT AS token,
    AMOUNT_OUT * b.price as volume
    FROM ethereum.sushi.ez_swaps a JOIN ethereum.core.fact_hourly_token_prices b ON (a.BLOCK_TIMESTAMP::date = b.hour::date AND a.SYMBOL_OUT = b.SYMBOL)
    WHERE SYMBOL_OUT IN ('USDC', 'USDT', 'BUSD', 'TUSD', 'DAI', 'FRAX', 'sUSD')
    )
    , bscTb AS (
    SELECT
    'BSC' as chain,
    'INflow' as direction,
    BLOCK_TIMESTAMP,
    TX_HASH,
    SYMBOL_IN as token,
    AMOUNT_IN * b.price as volume
    FROM bsc.sushi.ez_swaps a JOIN ethereum.core.fact_hourly_token_prices b ON (a.BLOCK_TIMESTAMP::date = b.hour::date AND a.SYMBOL_IN = b.SYMBOL)
    WHERE SYMBOL_IN IN ('USDC', 'USDT', 'BUSD', 'TUSD', 'DAI', 'FRAX', 'sUSD')

    UNION ALL

    Run a query to Download Data