select

'Maya' as protocol,

block_timestamp,

tx_id,

BLOCKCHAIN,

pool_name,

from_address,

NATIVE_TO_ADDRESS,

TO_POOL_ADDRESS,

AFFILIATE_ADDRESS,

AFFILIATE_FEE_BASIS_POINTS,

FROM_ASSET,

to_asset,

from_amount,

to_amount,

from_amount_usd,

to_amount_usd,

SWAP_SLIP_BP,

LIQ_FEE_ASSET_USD,

STREAMING_COUNT,

STREAMING_QUANTITY

from maya.defi.fact_swaps

where tx_id not in (select tx_id from maya.defi.fact_refund_events)

, data as (

select

block_timestamp,

case when contains(pool_name,'-') then split(pool_name,'-')[0] else pool_name end as pool_name_,

split(pool_name_ ,'.')[0] as chain,

tx_id,

from_address,

from_amount_usd,

to_amount_usd

from maya_data