BLOCK_DATE,

pair,

count(distinct transaction_id) as txn_count,

count(distinct wallet_address) as user_cnt

from

(

SELECT

msgs.block_timestamp :: DATE as BLOCK_DATE,

msgs.block_timestamp as block_timestamp,

msgs.tx_id as transaction_id,

msgs.msg_value : sender as wallet_address,

labels.address as contract_address,

labels.address_name as pair,

msg_events.inp_amount,

msg_events.inp_currency,

msg_events.fee_amount,

msg_events.fee_currency,

msg_events.tgt_amount,

msg_events.tgt_currency

from

(

SELECT

*

from

terra.msgs msgs,

lateral flatten(input => msg_value : execute_msg) fl

) msgs

inner JOIN terra.labels labels on msgs.msg_value : contract = labels.address

AND upper(label)= 'TERRASWAP'

and UPPER(label_subtype) = 'POOL'

AND upper(msgs.key)= 'SWAP'

AND UPPER(msgs.tx_status)= 'SUCCEEDED'

INNER JOIN (

SELECT

tx_id,