Updated 2025-05-06
    with

    main as (
    select
    tx_id,
    block_timestamp,
    iff(f.value:from in ('CCLWL5NYSV2WJQ3VBU44AMDHEVKEPA45N2QP2LL62O3JVKPGWWAQUVAG', 'CCISQOPKNNNBIDN2KQA6ULDKRIKUX5OQOT2W64PCPMXFN5BS2WFD6OWZ'), f.value:to, f.value:from) as user,
    f.value:asset_code as symbol,
    f.value:amount as amount,
    iff(f.value:from in ('CCLWL5NYSV2WJQ3VBU44AMDHEVKEPA45N2QP2LL62O3JVKPGWWAQUVAG', 'CCISQOPKNNNBIDN2KQA6ULDKRIKUX5OQOT2W64PCPMXFN5BS2WFD6OWZ'), 'Bridge To Stellar', 'Bridge From Stellar') as bridge_type
    from
    stellar.core.ez_operations
    join
    lateral flatten (input => asset_balance_changes) as f
    where
    ('CCLWL5NYSV2WJQ3VBU44AMDHEVKEPA45N2QP2LL62O3JVKPGWWAQUVAG' in (f.value:from, f.value:to) or 'CCISQOPKNNNBIDN2KQA6ULDKRIKUX5OQOT2W64PCPMXFN5BS2WFD6OWZ' in (f.value:from, f.value:to))
    and successful
    and f.value:asset_type != 'native'
    )

    select
    count(*) as transactions,
    sum(iff(bridge_type = 'Bridge To Stellar', amount, 0)) as inflow_volume_usd,
    sum(iff(bridge_type = 'Bridge From Stellar', amount, 0)) as outflow_volume_usd,
    inflow_volume_usd - outflow_volume_usd as netflow_volume_usd
    from
    main


    QueryRunArchived: QueryRun has been archived