+ kHjzbRt^RIt^RIt^RIHtHt]P !R4t!RR4tR#)aRoute a client-created Telegram DM topic's thread-less opener into that topic (#136567). Telegram for Android (13.0.x) delivers the opening message of a topic created from the "All messages" view with no ``message_thread_id``. The ``Message`` carrying ``forum_topic_created`` is then the only update that names the new topic (``ForumTopicCreated`` itself has only name/icon fields). Recording authorized, non-bot private-chat creations lets the thread-less messages that follow adopt the new topic instead of arriving lobby-shaped, where gateway topic recovery would pin them to the most recently bound topic. Adoption follows time and per-chat order, never message-id adjacency: private-chat message ids come from one sequence shared by every private chat of the bot account (bot replies included), so a send elsewhere between the creation and the opener breaks ``creation + 1``. Per-chat FIFO update processing guarantees nothing from this chat lands in between. N)AnyOptionalz"plugins.platforms.telegram.adapterca]tRt^toRtRtRtRt]V3RlRl4t ]V3RlRl4t V3R lR lt V3R lR lt R t VtR#)TelegramTopicRoutingMixinzgTopic-creation bookkeeping for ``TelegramAdapter`` (relies on its ``_chat_type_str``/``_chat_id_str``).g@g@c <V^8dQhRS[/#return)str)format __classdict__s"V/home/ubuntu/.hermes/hermes-agent/plugins/platforms/telegram/telegram_topic_routing.py __annotate__&TelegramTopicRoutingMixin.__annotate__%sKKKc D\\\VRR4RR44#) from_userNid)r getattr)messages&r _creator_key&TelegramTopicRoutingMixin._creator_key$s777K>bIJJrc0<V^8dQhRS[S[,/#r)rfloat)r r s"rrr)sHHXe_Hrc d\VRR4p\VR4'dVP4#R#)zUTelegram's send stamp (whole seconds); an edit keeps its message's original ``date``.dateN timestamp)rhasattrr)rrs& r_sent_at"TelegramTopicRoutingMixin._sent_at(s0w-#*4#=#=t~~G4Grc*<V^8dQhRS[RS[RR/#)r updatecontextr N)r)r r s"rrr.s'eeecederc ja "\VRR4pVe\VRR4fR#VP\VRR44R8wdR#\VRR4p\VRR4pVPV4pVeVeVe\VRR 4R JdR#VPV4'gR#VPP R /4o \ P!4pS P4UU u.uF'wrWy^,, VP8gK%VNK) up pFp S V K \S 4VP8dS \S V 3R lR 7K.VPV4p \V4Wg3S WPV43&\ P#RVP$WK4R#uup pi5i)zRecord an authorized, non-bot private-chat topic creation (#136567). Routing signal only, never an agent turn. The user-chosen name is NOT cached in ``_dm_topics``: entries there mark operator-declared topics, which session-title auto-rename skips. effective_messageNforum_topic_createdchatprivatemessage_thread_idris_botFT_pending_created_topicsc$<SV,^,#)r )kpendings&rGTelegramTopicRoutingMixin._handle_forum_topic_created..Fs 71:a=r)keyz-[%s] Recorded new Telegram topic %s (chat=%s))r_chat_type_strr _is_user_authorized_from_message__dict__ setdefaulttime monotonicitems_NEW_TOPIC_RECORD_TTL_SECONDSlen_NEW_TOPIC_OPENER_MAX_PENDINGmin _chat_id_strr rloggerdebugname) selfr#r$r thread_idsendersent_atnowr/recr3chat_idr0s &&& @r_handle_forum_topic_created5TelegramTopicRoutingMixin._handle_forum_topic_created.s &"5t< ?gg/DdKS    ww= >) K G%8$? +t4--(  6>WVU]_dEeimEm 44W== --**+DbInn$+MMOiO&!sV|dFhFh7hAAOiC j'ld@@@G)@AB##G,:=i.'9W++G456 DdiiQZd js B&F3*AF30"F-F-BF3c R<V^8dQhRS[RS[RS[S[,RS[S[,/#)r r chat_typerDr )rr r)r r s"rrrKs7!!3!3!S[\_S`!emnqer!rc  VPPR4pVR8wg V'gV#VPV4VPV43pVPV4pVP V4pVeVeWv^,8dV#WEVf\ VRR4eV#Vwrp Wy, VP 8dV#W\P!43WE&\PRVP\ VRR4W^,4V#)a*Thread id of the topic this sender just created, for its thread-less follow-up messages. A threaded message (the topic now routes normally) or a send gap longer than ``_NEW_TOPIC_FOLLOW_SECONDS`` ends the follow; each adoption extends it, so every chunk of a split opener lands in the same topic. r,dmNr*zF[%s] Thread-less message %s adopted by new Telegram topic %s (chat=%s) message_id?) r6getr?rr r_NEW_TOPIC_FOLLOW_SECONDSr8r9r@inforB) rCrrMrDr0r3recordrFcreated_thread_id last_sent_at _recordeds &&&& r_adopt_created_topic_thread5TelegramTopicRoutingMixin._adopt_created_topic_threadKs--##$=>  G   )4+<+W_)0C  L  GG5H$$O$[ 5;2  !D$B$B B )DNN4DE  \IIww cBDU[\W] _  rr.N)__name__ __module__ __qualname____firstlineno____doc__rSr=r; staticmethodrr rJrY__static_attributes____classdictcell__)r s@rrrs\q!$$'!$)!KKHH ee:!!rr) r_loggingr8typingrr getLoggerr@rr.rrrfs2    ? @O!O!r