`gjdZddlZddlZddlmZddlmZddlmZeje Z edz Z e dz Z dde d e d e d e d ee d ee de defdZ dde d e d ee d ee dee f dZde deddfdZy)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.jsonplatformchat_id message_text source_label thread_iduser_idrolereturnc d t|t|||}|stjd||||y||t j j d|d}t||tjd||y#t$r$} tjd||||| Yd} ~ yd} ~ 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 r z(Mirror: no session found for %s:%s:%s:%sFT)r content 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) rrr r r r r session_id mirror_msges A/root/.hermes/venv/lib/python3.12/site-packages/gateway/mirror.pymirror_to_sessionr s:'%  L   LL:  #!113)   *j1 z"_find_session_id..s599\23N)keyr) hermes_stater#getattrcallablercloserrr_SESSIONS_INDEXexistsopenjsonloadloweritems startswith isinstancedictr,appendlenstripmax)rrr r r#dbfinderrrfdataplatform_lower candidates_keyr-r'entry_platformorigin_chat_idorigin_thread_idexact_user_matchesdistinct_user_ids best_entrys rrr`s&E* [ R!94@F#%#'#  z? HHJBHHJ  ! ! # /G 4 99Q>, ''s HHJ E @!DDE  8  sl K50K K5K58L/ L"L/=AL>+BM K22K55 L>LL"L,'L// L;:L;rmessagec8d} ddlm}|}|j||jdd|jd||jyy#t$r }t j d|Yd}~8d}~wwxYw#||jwwxYw) z0Append a message to the SQLite session database.Nrr"r assistantr)rr rzMirror SQLite write failed: %s)r1r#append_messager,rrrr4)rrPrCr#rs rrrs B * [ !V[1KK *   > HHJ  : 5q99: > HHJ s*AA B!A<7B<BBB)cliNNrR)NN)__doc__r8loggingrtypingrhermes_cli.configr getLogger__name__r _SESSIONS_DIRr5rboolr rr>rr/rr^s  -   8 $!J. /1#!DD DD D } D c] D D DT $! [([( [(}[(c] [( c] [(~#r/