WITH relevant_swaps AS (

SELECT

SWAPPER,

BLOCK_TIMESTAMP

FROM solana.defi.ez_dex_swaps

WHERE BLOCK_TIMESTAMP >= DATEADD('day', -1, CURRENT_TIMESTAMP)

AND BLOCK_TIMESTAMP < CURRENT_TIMESTAMP

),

high_frequency_bursts AS (

SELECT DISTINCT SWAPPER

FROM (

SELECT

SWAPPER,

COUNT(*) OVER (

PARTITION BY SWAPPER

ORDER BY BLOCK_TIMESTAMP

RANGE BETWEEN INTERVAL '5 SECONDS' PRECEDING AND CURRENT ROW

) AS txn_count_5sec

FROM relevant_swaps

)

WHERE txn_count_5sec > 4 -- Threshold for short-term bursts

),

sustained_high_activity AS (

SELECT SWAPPER

FROM relevant_swaps

GROUP BY SWAPPER

HAVING COUNT(*) > 100 -- Threshold for sustained activity over the last day

),

excluded_swappers AS (

SELECT DISTINCT SWAPPER

FROM high_frequency_bursts

UNION

SELECT DISTINCT SWAPPER

FROM sustained_high_activity

),