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
@@ -1002,10 +1003,32 @@ 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):
+                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.")
+
+            timestamp = Timestamp()
+            timestamp.FromDatetime(dt.astimezone(ZoneInfo("UTC")))
+
+            return timestampo
 
         public_order_filter = PublicOrderBookFilter(
             delivery_period=delivery_period,
@@ -1025,12 +1048,14 @@ 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,