diff --git a/transaction_processor.py b/transaction_processor.py index 1106d47..ceaedd4 100644 --- a/transaction_processor.py +++ b/transaction_processor.py @@ -736,6 +736,14 @@ class LamassuTransactionProcessor: """Send Bitcoin payments to DCA clients""" try: transaction_id = transaction["transaction_id"] + transaction_time = transaction.get("transaction_time") + + # Normalize transaction_time to UTC if present + if transaction_time is not None: + if transaction_time.tzinfo is None: + transaction_time = transaction_time.replace(tzinfo=timezone.utc) + elif transaction_time.tzinfo != timezone.utc: + transaction_time = transaction_time.astimezone(timezone.utc) for client_id, distribution in distributions.items(): try: