cj&dZddlZddlZddlmZddlmZddlmZeje Z edz Z e dz Z dd e d e d e d e dee dee de defdZ dd e d e dee dee dee f dZde deddfdZdS)a} Session mirroring for cross-platform message delivery. When a message is sent to a platform (via send_message or cron delivery), this module appends a "delivery-mirror" record to the target session's transcript so the receiving-side agent has context about what was sent. Standalone -- works from CLI, cron, and gateway contexts without needing the full SessionStore machinery. N)datetime)Optional)get_hermes_homesessionsz sessions.jsoncli assistantplatformchat_id message_text source_label thread_iduser_idrolereturnc  t|t|||}|s td||||dS||t jd|d}t||td||dS#t$r*} td||||| Yd} ~ dSd} ~ wwxYw) u[ Append a delivery-mirror message to the target session's transcript. Finds the gateway session that matches the given platform + chat_id, then writes a mirror entry to both the JSONL transcript and SQLite DB. ``role`` defaults to ``"assistant"`` — correct for the interactive ``send_message`` mirror, where the mirrored text is the agent's own outgoing reply (a genuine assistant turn). Callers mirroring text that is NOT the agent speaking — e.g. a cron brief delivered out-of-band — must pass ``role="user"``: the ``mirror``/``mirror_source`` metadata is dropped at the SQLite boundary (only role+content persist), so on replay an assistant-role mirror is indistinguishable from a real assistant turn and produces ``assistant → assistant`` pairs that break strict-alternation providers (issue #2221). A user-role mirror collapses safely via ``repair_message_sequence``'s consecutive-user merge on every provider. Returns True if mirrored successfully, False if no matching session or error. All errors are caught -- this is never fatal. )r rz(Mirror: no session found for %s:%s:%s:%sFT)rcontent timestampmirror mirror_sourcez%Mirror: wrote to session %s (from %s)z!Mirror failed for %s:%s:%s:%s: %sN) _find_session_idstrloggerdebugrnow isoformat_append_to_sqlite Exception) r r r r r rr session_id mirror_msges -/usr/local/lib/hermes-agent/gateway/mirror.pymirror_to_sessionr"s:'%  LL      LL:    5#!1133)    *j111 |d pi}|d p|d d }|| krt |d d }|t |krP|d}|$t |pd t |kr | |!| sdSr)fd| D}|r|} nJt+| dkrdSn4t+| dkr!d| D}t+|dkrdSt-| d}|dS)a3 Find the active session_id for a platform + chat_id pair. Queries state.db gateway session rows (primary source since #9006); falls back to scanning sessions.json for pre-migration databases. DM session keys don't embed the chat_id (e.g. "agent:main:telegram:dm"), so we match on the persisted chat origin, not the key. When *user_id* is provided, prefer exact sender matches. If multiple same-chat candidates exist and none matches the user, return None instead of guessing and contaminating another participant's session. r SessionDBfind_session_by_originN)r r r rz)Mirror state.db session lookup failed: %szutf-8)encoding_originr r r cg|]N}t|dpidpdtkL|OSr)rr*)rget).0entryrs r! z$_find_session_id..s`   EIIh''-2229==CDDG TT TTTc:h|]}t|dpidpdMt|dpidpdSr,)rr-strip)r.r/s r! z#_find_session_id..s   EIIh''-2229==CDDJJLL 8$$*// ::@b A A G G I I   r1c.|ddS)N updated_atr*)r-)r/s r!z"_find_session_id..s599\23N3Nr1)keyr) hermes_stater%getattrcallablercloserrr_SESSIONS_INDEXexistsopenjsonloadloweritems startswith isinstancedictr-appendlenmax)r r r rr%dbfinderrr fdataplatform_lower candidates_keyr/r)entry_platformorigin_chat_idorigin_thread_idexact_user_matchesdistinct_user_ids best_entrys ` r!rr`s&E****** Y[[ R!94@@F +#V%#'#  +z?? HHJJJJBHHJJJJBHHJJJJJ EEE @!DDDDDDDDE  ! ! # #t /G 4 4 4 9Q<>, ' ''sjB?A=B(B=BB C!CC%D(;D D(D  D(#D $D(( D65D6rmessagecxd} ddlm}|}|||dd|dn2#t$r%}t d|Yd}~nd}~wwxYw||dSdS#||wwxYw) z0Append a message to the SQLite session database.Nrr$rrr)rrrzMirror SQLite write failed: %s)r:r%append_messager-rrrr=)rrXrKr%r s r!rrs B ****** Y[[ !V[11KK **     ::: 5q99999999: > HHJJJJJ >2> HHJJJJ s0AAB  BA>9B >BB B9)rNNr)NN)__doc__rAloggingrtypingrhermes_cli.configr getLogger__name__r _SESSIONS_DIRr>rboolr"rrGrr1r!rds   ------  8 $ $!!J. /1#!DDD DD D } D c] D D DDDDT $! [([([( [(}[(c] [( c] [([([([(~#r1