Convert timestamp to UTC

Signed-off-by: Matthias Wende <[email protected]>

Author: matthias-wende-frequenz

src/frequenz/client/electricity_trading/_client.py

@@ -12,6 +12,7 @@
 from datetime import datetime, timedelta, timezone
 from decimal import Decimal, InvalidOperation
 from typing import Any, AsyncIterator, Awaitable, Callable, cast
+from zoneinfo import ZoneInfo
 
 import grpc
 from frequenz.api.common.v1.pagination.pagination_params_pb2 import PaginationParams
@@ -53,6 +54,7 @@
     UpdateOrder,
 )
 
+
 _logger = logging.getLogger(__name__)
 
 
@@ -1002,10 +1004,29 @@ def receive_public_order_book(
             grpc.RpcError: If an error occurs while streaming public orders.
         """
 
-        def dt_to_pb_timestamp(dt: datetime) -> Timestamp:
-            ts = Timestamp()
-            ts.FromDatetime(dt)
-            return ts
+        def dt_to_pb_timestamp_utc(dt: datetime.datetime) -> Timestamp:
+            """
+            Converts a Python datetime object to a UTC Protobuf Timestamp.
+
+            The input datetime 'dt' MUST be timezone-aware.
+
+            Args:
+                dt: The Python datetime object to convert.
+
+            Returns:
+                A Protobuf Timestamp object representing the time in UTC.
+
+            Raises:
+                TypeError: If dt is not a datetime.datetime object.
+                ValueError: If the input datetime object is naive (lacks timezone info).
+            """
+            if not isinstance(dt, datetime.datetime):
+                raise TypeError("Input must be a datetime.datetime object")
+
+            if dt.tzinfo is None or dt.tzinfo.utcoffset(dt) is None:
+                raise ValueError("Input datetime object must be timezone-aware.")
+
+            return Timestamp().FromDatetime(dt.astimezone(ZoneInfo("UTC")))
 
         public_order_filter = PublicOrderBookFilter(
             delivery_period=delivery_period,
@@ -1025,12 +1046,12 @@ def dt_to_pb_timestamp(dt: datetime) -> Timestamp:
                             electricity_trading_pb2.ReceivePublicOrderBookStreamRequest(
                                 filter=public_order_filter.to_pb(),
                                 start_time=(
-                                    dt_to_pb_timestamp(start_time)
+                                    dt_to_pb_timestamp_utc(start_time)
                                     if start_time
                                     else None
                                 ),
                                 end_time=(
-                                    dt_to_pb_timestamp(end_time) if end_time else None
+                                    dt_to_pb_timestamp_utc(end_time) if end_time else None
                                 ),
                             ),
                             metadata=self._metadata,