swaps_marinade as (

select distinct

block_timestamp,

tx_id,

array_agg(tx_to),

array_agg(amount),

case

when array_agg(tx_to)[1] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[1] * 2

when array_agg(tx_to)[2] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[2] * 2

when array_agg(tx_to)[0] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[0] * 2

when array_agg(tx_to)[2] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[2] * 2

when array_agg(tx_to)[0] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[0] * 2

when array_agg(tx_to)[1] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[1] * 2

end as fee,

case

when array_agg(tx_to)[0] = 'EyaSjUtSgo9aRD1f8LWXwdvkpDTmXAW54yoSHZRF14WL' and array_agg(tx_to)[1] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[0] + (array_agg(amount)[1] * 2)

when array_agg(tx_to)[0] = 'EyaSjUtSgo9aRD1f8LWXwdvkpDTmXAW54yoSHZRF14WL' and array_agg(tx_to)[2] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[0] + (array_agg(amount)[2] * 2)

when array_agg(tx_to)[1] = 'EyaSjUtSgo9aRD1f8LWXwdvkpDTmXAW54yoSHZRF14WL' and array_agg(tx_to)[0] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[1] + (array_agg(amount)[0] * 2)

when array_agg(tx_to)[1] = 'EyaSjUtSgo9aRD1f8LWXwdvkpDTmXAW54yoSHZRF14WL' and array_agg(tx_to)[2] = '89SrbjbuNyqSqAALKBsKBqMSh463eLvzS4iVWCeArBgB'

then array_agg(amount)[1] + (array_agg(amount)[2] * 2)