WITH velo_swaps AS

(SELECT BLOCK_TIMESTAMP, FROM_ADDRESS,

tokenflow_eth.hextoint(SUBSTR(INPUT_DATA,11,64)) AS amountIn,

tokenflow_eth.hextoint(SUBSTR(INPUT_DATA,75,64)) AS amountOutMin,

'0x' || SUBSTR(INPUT_DATA,163,40) tokenFrom,

'0x' || SUBSTR(INPUT_DATA,227,40) tokenTo,

TX_HASH, 'velodrome' AS DEX

FROM optimism.core.fact_transactions

WHERE 1=1

AND STATUS = 'SUCCESS'

AND TO_ADDRESS = LOWER('0xa132DAB612dB5cB9fC9Ac426A0Cc215A3423F9c9')

AND ORIGIN_FUNCTION_SIGNATURE = '0x13dcfc59'

UNION ALL

SELECT BLOCK_TIMESTAMP, FROM_ADDRESS,

tokenflow_eth.hextoint(SUBSTR(INPUT_DATA,11,64)) AS amountIn,

tokenflow_eth.hextoint(SUBSTR(INPUT_DATA,75,64)) AS amountOutMin,

'0x' || SUBSTR(INPUT_DATA,419,40) tokenFrom,

'0x' || SUBSTR(INPUT_DATA,483,40) tokenTo,

TX_HASH, 'velodrome' AS DEX

FROM optimism.core.fact_transactions

WHERE 1=1

AND STATUS = 'SUCCESS'

AND TO_ADDRESS = LOWER('0xa132DAB612dB5cB9fC9Ac426A0Cc215A3423F9c9')

AND ORIGIN_FUNCTION_SIGNATURE = '0xf41766d8'),

rubicon AS

(SELECT BLOCK_TIMESTAMP, ORIGIN_FROM_ADDRESS FROM_ADDRESS,

tokenflow_eth.hextoint(SUBSTR(data,3,64)) AS amountIn,

tokenflow_eth.hextoint(SUBSTR(data,LEN(DATA)-127,64)) AS amountOutMin,

'0x' || SUBSTR(data,91,40) tokenFrom,

'0x' || SUBSTR(data,LEN(DATA)-167,40) tokenTo,

TX_HASH, 'rubicon' AS DEX

FROM optimism.core.fact_event_logs

WHERE 1=1