SocioCryptoAvalanche - CEX
    Updated 2023-07-28
    SELECT x.date,
    x.flow_in,
    y.flow_out,
    y.flow_out-x.flow_in as net_flow,
    sum(net_flow)over(ORDER BY x.date) as cum,
    CASE when net_flow >=0 then 'pos' else 'neg' end as colour
    FROM
    (SELECT date_trunc('{{interval}}',a.block_timestamp) as date,
    sum(CASE WHEN b.label_type = 'cex' THEN a.raw_amount/pow(10,6) ELSE 0 end) as flow_in
    FROM avalanche.core.fact_token_transfers a
    LEFT JOIN avalanche.core.dim_labels b
    ON a.from_address = b.address
    WHERE contract_address = '0xb97ef9ef8734c71904d8002f8b6bc66dd9c48a6e'
    GROUP BY date
    ) x
    LEFT JOIN
    (SELECT date_trunc('{{interval}}',a.block_timestamp) as date,
    sum(CASE WHEN b.label_type = 'cex' THEN a.raw_amount/pow(10,6) ELSE 0 end) as flow_out
    FROM avalanche.core.fact_token_transfers a
    LEFT JOIN avalanche.core.dim_labels b
    ON a.to_address = b.address
    WHERE contract_address = '0xb97ef9ef8734c71904d8002f8b6bc66dd9c48a6e'
    GROUP BY date
    ) y
    ON x.date = y.date
    WHERE x.date >= DATEADD('month', -1*{{last_n_month}}, CURRENT_DATE)
    AND x.date <= CURRENT_DATE-1
    ORDER BY x.date DESC
    Run a query to Download Data