SELECT DISTINCT -- Added DISTINCT to avoid duplicates

d.ADDRESS

FROM ethereum.core.ez_decoded_traces tr

JOIN ethereum.core.dim_contracts d

ON d.CREATED_TX_HASH = tr.TX_HASH

WHERE FROM_ADDRESS = '0xd2c82f2e5fa236e114a81173e375a73664610998'

AND TO_ADDRESS = '0xffa397285ce46fb78c588a9e993286aac68c37cd'

AND TYPE = 'CALL'

AND IDENTIFIER = 'CALL_ORIGIN'

AND TRACE_STATUS = 'SUCCESS'

AND FUNCTION_NAME = 'createForwarder'

-- Consider adding: AND tr.BLOCK_TIMESTAMP >= DATEADD(month, -1, CURRENT_TIMESTAMP())

),

transfers_in AS (

SELECT

TO_ADDRESS,

SUM(COALESCE(amount, 0)) AS sum_tin -- Added COALESCE for NULL handling

FROM arbitrum.core.ez_token_transfers

WHERE TO_ADDRESS IN (SELECT ADDRESS FROM eth_addresses)

AND CONTRACT_ADDRESS = lower('0xFd086bC7CD5C481DCC9C85ebE478A1C0b69FCbb9') -- USDT

GROUP BY TO_ADDRESS

),

transfers_out AS (

SELECT

FROM_ADDRESS,

SUM(COALESCE(amount, 0)) AS sum_tout -- Added COALESCE for NULL handling

FROM arbitrum.core.ez_token_transfers

WHERE FROM_ADDRESS IN (SELECT ADDRESS FROM eth_addresses)

AND CONTRACT_ADDRESS = lower('0xFd086bC7CD5C481DCC9C85ebE478A1C0b69FCbb9') -- USDT

GROUP BY FROM_ADDRESS