1414import uuid
1515from collections .abc import Awaitable , Callable
1616from dataclasses import dataclass
17- from datetime import UTC , datetime
17+ from datetime import datetime , timezone
1818from typing import Any
1919
2020from chat_sdk .channel import ChannelImpl
@@ -1143,7 +1143,7 @@ async def _handle_action_event(self, event: ActionEvent) -> None:
11431143 formatted = {"type" : "root" , "children" : []},
11441144 raw = event .raw ,
11451145 author = event .user ,
1146- metadata = MessageMetadata (date_sent = datetime .now (tz = UTC ), edited = False ),
1146+ metadata = MessageMetadata (date_sent = datetime .now (tz = timezone . utc ), edited = False ),
11471147 attachments = [],
11481148 )
11491149 thread = self ._create_thread (event .adapter , event .thread_id , dummy_message , is_subscribed )
@@ -1175,7 +1175,7 @@ async def _open_modal(modal: Any) -> dict[str, str] | None:
11751175 metadata = getattr (
11761176 raw_fetched ,
11771177 "metadata" ,
1178- MessageMetadata (date_sent = datetime .now (tz = UTC ), edited = False ),
1178+ MessageMetadata (date_sent = datetime .now (tz = timezone . utc ), edited = False ),
11791179 ),
11801180 )
11811181 except Exception :
@@ -1253,7 +1253,7 @@ async def _handle_reaction_event(self, event: ReactionEvent) -> None:
12531253 formatted = {"type" : "root" , "children" : []},
12541254 raw = None ,
12551255 author = event .user ,
1256- metadata = MessageMetadata (date_sent = datetime .now (tz = UTC ), edited = False ),
1256+ metadata = MessageMetadata (date_sent = datetime .now (tz = timezone . utc ), edited = False ),
12571257 ),
12581258 is_subscribed ,
12591259 )
@@ -1314,7 +1314,7 @@ async def open_dm(self, user: str | Author) -> ThreadImpl:
13141314 formatted = {"type" : "root" , "children" : []},
13151315 raw = None ,
13161316 author = Author (user_id = "" , user_name = "" , full_name = "" , is_bot = False , is_me = False ),
1317- metadata = MessageMetadata (date_sent = datetime .now (tz = UTC ), edited = False ),
1317+ metadata = MessageMetadata (date_sent = datetime .now (tz = timezone . utc ), edited = False ),
13181318 ),
13191319 False ,
13201320 )
@@ -1559,7 +1559,7 @@ async def _handle_queue_or_debounce(
15591559 )
15601560 return
15611561
1562- now = int (datetime .now (tz = UTC ).timestamp () * 1000 )
1562+ now = int (datetime .now (tz = timezone . utc ).timestamp () * 1000 )
15631563 entry = QueueEntry (
15641564 message = message ,
15651565 enqueued_at = now ,
@@ -1577,7 +1577,7 @@ async def _handle_queue_or_debounce(
15771577
15781578 try :
15791579 if strategy == "debounce" :
1580- now = int (datetime .now (tz = UTC ).timestamp () * 1000 )
1580+ now = int (datetime .now (tz = timezone . utc ).timestamp () * 1000 )
15811581 await self ._state_adapter .enqueue (
15821582 lock_key ,
15831583 QueueEntry (message = message , enqueued_at = now , expires_at = now + queue_entry_ttl_ms ),
@@ -1634,7 +1634,7 @@ async def _debounce_loop(
16341634 break
16351635
16361636 msg = self ._rehydrate_message (entry .message )
1637- now = int (datetime .now (tz = UTC ).timestamp () * 1000 )
1637+ now = int (datetime .now (tz = timezone . utc ).timestamp () * 1000 )
16381638 if now > entry .expires_at :
16391639 self ._logger .info ("message-expired" , {"thread_id" : thread_id , "message_id" : msg .id })
16401640 continue
@@ -1664,7 +1664,7 @@ async def _drain_queue(
16641664 if entry is None :
16651665 break
16661666 msg = self ._rehydrate_message (entry .message )
1667- now = int (datetime .now (tz = UTC ).timestamp () * 1000 )
1667+ now = int (datetime .now (tz = timezone . utc ).timestamp () * 1000 )
16681668 if now <= entry .expires_at :
16691669 pending .append ((msg , entry .expires_at ))
16701670 else :
@@ -1869,7 +1869,7 @@ def _rehydrate_message(self, raw: Any) -> Message:
18691869 if isinstance (date_sent , str ):
18701870 date_sent = datetime .fromisoformat (date_sent )
18711871 elif not isinstance (date_sent , datetime ):
1872- date_sent = datetime .now (tz = UTC )
1872+ date_sent = datetime .now (tz = timezone . utc )
18731873
18741874 edited_at = metadata_raw .get ("edited_at" )
18751875 if isinstance (edited_at , str ):
@@ -1930,7 +1930,7 @@ def _message_from_json(data: dict[str, Any]) -> Message:
19301930 if isinstance (date_sent , str ):
19311931 date_sent = datetime .fromisoformat (date_sent )
19321932 elif not isinstance (date_sent , datetime ):
1933- date_sent = datetime .now (tz = UTC )
1933+ date_sent = datetime .now (tz = timezone . utc )
19341934
19351935 edited_at = metadata_raw .get ("editedAt" ) or metadata_raw .get ("edited_at" )
19361936 if isinstance (edited_at , str ):
0 commit comments