Yousefi_1994Swaps Totals
Updated 2023-12-05
999
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
›
⌄
WITH CREATED_POOLS AS (
SELECT TX_ID, EVENT_DATA:pairAddress AS PAIR_ADDRESS
FROM flow.core.fact_events
WHERE EVENT_CONTRACT = 'A.b063c16cac85dbd1.SwapFactory'
AND EVENT_TYPE = 'PairCreated'
),
CREATED_POOLS_DETAILS AS (
SELECT TX_ID, DEPLOYMENT_TIMESTAMP, TOKEN0_CONTRACT,
TOKEN1_CONTRACT, POOL_ID, PAIR_ADDRESS, SWAP_CONTRACT
FROM CREATED_POOLS JOIN flow.defi.dim_swap_pool_labels ON (PAIR_ADDRESS = VAULT_ADDRESS)
),
SWAPS AS (
SELECT SWAPS.*
FROM flow.defi.ez_swaps SWAPS JOIN CREATED_POOLS_DETAILS USING(SWAP_CONTRACT)
),
-- START_ROUTE AS(
-- SELECT BLOCK_TIMESTAMP, TX_ID, TRADER, TOKEN_OUT_CONTRACT, IFF(TOKEN_OUT_CONTRACT = 'A.b19436aae4d94622.FiatToken', 'USDC', SPLIT(TOKEN_OUT_CONTRACT, '.')[2]) AS "Swap from", TOKEN_OUT_AMOUNT
-- FROM SWAPS
-- WHERE SWAP_INDEX = 0
-- ),
-- LAST_ROUTE_INDEX AS(
-- SELECT TX_ID, MAX(SWAP_INDEX) AS SWAP_INDEX
-- FROM SWAPS
-- GROUP BY TX_ID
-- ),
-- LAST_ROUTE AS(
-- SELECT BLOCK_TIMESTAMP, LAST_ROUTE_INDEX.TX_ID, TOKEN_IN_CONTRACT, IFF(TOKEN_IN_CONTRACT = 'A.b19436aae4d94622.FiatToken', 'USDC', SPLIT(TOKEN_IN_CONTRACT, '.')[2]) AS "Swap to" ,TOKEN_IN_AMOUNT, LAST_ROUTE_INDEX.SWAP_INDEX
-- FROM LAST_ROUTE_INDEX JOIN SWAPS ON (LAST_ROUTE_INDEX.TX_ID = SWAPS.TX_ID AND LAST_ROUTE_INDEX.SWAP_INDEX = SWAPS.SWAP_INDEX)
-- ),
SWAPS_FIXED AS (
Run a query to Download Data