+ kHj Rt^RIHt^RIt^RIt^RIt^RIt^RIHt^RI t ^RI t ^RI t ^RI t ^RI t ^RIt^RIt^RIt^RIHtHtHt^RIHtHt^RIHt^RIHt^RIHt^R IH t H!t!H"t"H#t#^R I$H%t%^R I&H't'^R I(H)t*H+t,H-t.H/t/^R I0H1t1H2t2H3t3H4t4H5t5H6t6H7t7H8t8^R(It>^R)I?H@t@HAtAHBtBHCtCHDtDHEtEHFtF^R*I?HGtG^R+IHHItIHJtJHKtK^R,ILHMtM^R-INHOtOHPtPHQtQHRtR] P!]T4tU^tVR.R//R0R1lltWR2R3ltX] P!R4] P4t[R5R6lt\R7R8lt]] P!R94t^R:R;lt_R<R=lt`]a!0Rm4tbR>R?ltcR@RAltd!RBRC]4te]!RDRE7!RFRG44tf]!RHRI44tg]!RJRK44th]h;titjRLtk]k^,tl]ltmRMRNltnRORPltoRQRRltp^RSIqHrts^tt] P!RT4tuRUtv]a!0Rm4tw]a!0Rm4tx]y;QJd.RVRW4FNK 5M !RVRW44R,tz]zR,t{RXRYlt|RRZR[llt}R\R]lt~R^R_ltR`RaltRbRcltRdReltRfRgltRRhRilltRRjRklltRlRmltRnRoltRpRqltRrRsltRtRultRvRwltRxRyltRzR{ltR|R}lt] P!R~4tRtRtRRltRRltRRltRRltRRltRRltRRltRRlt!RR]A4tRRRRRR//RltRRltRRltRtRRltRRltRRltR# ]9dM]:;t1;t2;t6t8];!RRRRRRRRRR/4t3];!RRRRRRRR/4t4];!RRRR R!R"R#R$/4t5];!R%RR&^R'^/4t7ELi;i)uPMatrix gateway adapter (any homeserver, via mautrix; optional E2EE with ``mautrix[encryption]``). Env vars (config.yaml ``matrix:`` keys alias several — env wins): MATRIX_HOMESERVER, MATRIX_ACCESS_TOKEN (preferred) | MATRIX_USER_ID + MATRIX_PASSWORD; MATRIX_E2EE_MODE off|optional|required (legacy MATRIX_ENCRYPTION=true => required); MATRIX_DEVICE_ID (stable E2EE device), MATRIX_RECOVERY_KEY (cross-signing after key rotation), MATRIX_RECOVERY_KEY_OUTPUT_FILE (one-time 0600 write of a bootstrapped key), MATRIX_PROXY; MATRIX_ALLOWED_USERS, MATRIX_ALLOWED_ROOMS (whitelist; DMs exempt), MATRIX_IGNORE_USER_PATTERNS (regexes for bridge ghosts), MATRIX_HOME_ROOM (cron delivery), MATRIX_REACTIONS (default true); MATRIX_REQUIRE_MENTION (default true), MATRIX_THREAD_REQUIRE_MENTION, MATRIX_FREE_RESPONSE_ROOMS, MATRIX_PROCESS_NOTICES, MATRIX_ALLOW_ROOM_MENTIONS, MATRIX_ALLOW_PUBLIC_ROOMS (all default false); MATRIX_AUTO_THREAD (default true), MATRIX_DM_AUTO_THREAD, MATRIX_DM_MENTION_THREADS, MATRIX_SESSION_SCOPE auto|room|thread; MATRIX_MAX_MESSAGE_LENGTH (UTF-8 bytes, default/max 15000), MATRIX_MAX_MEDIA_BYTES, MATRIX_ROOM_IDENTITY_TTL_SECONDS; MATRIX_APPROVAL_REQUIRE_SENDER (default true), MATRIX_APPROVAL_TIMEOUT_SECONDS (default 300). Note: any room with <=2 joined members is auto-classified as a DM (see ``_resolve_room_identity``), regardless of ``m.direct`` account data or an explicit room name — clients auto-name DMs like "Alice & Bot", so name alone can't be trusted. A DM-classified room therefore bypasses MATRIX_ALLOWED_ROOMS, MATRIX_FREE_RESPONSE_ROOMS, and MATRIX_REQUIRE_MENTION, and follows MATRIX_DM_AUTO_THREAD / MATRIX_DM_MENTION_THREADS instead of MATRIX_AUTO_THREAD / MATRIX_SESSION_SCOPE. To make a deliberately-created 2-person room behave like a regular room, add a third member so it has >2 joined members. ) annotationsN)suppress)urljoinurlsplit urlunsplit) dataclassfield)escape) HTMLParser)Path)AnyDictOptionalSett) get_secret)apply_yaml_bridgeextra_or_secretget_scoped_secret send_error ContentURIEventID EventType PresenceStateRoomCreatePresetRoomID TrustStateUserID_EventTypeStub ROOM_MESSAGEzm.room.messageREACTIONz m.reactionROOM_ENCRYPTEDm.room.encrypted ROOM_NAME m.room.name_PresenceStateStubONLINEonlineOFFLINEoffline UNAVAILABLE unavailable_RoomCreatePresetStubPRIVATE private_chatPUBLIC public_chatTRUSTED_PRIVATEtrusted_private_chat_TrustStateStub UNVERIFIEDVERIFIED)PlatformPlatformConfig)gateway_trust_envBasePlatformAdapterExecApprovalPrompt SendResultresolve_proxy_urlproxy_kwargs_for_aiohttpssrf_redirect_guard)transcode_to_ogg_opus) MessageEvent MessageTypeProcessingOutcome)ThreadParticipationTracker) ParkedVoices VoiceGatehas_voice_markeris_voice_eventtextFc$V^8dQhRRRRRR/#)cmdlisttimeoutintrJbool)formats"E/home/ubuntu/.hermes/hermes-agent/plugins/platforms/matrix/adapter.py __annotate__rUYs&www3wdwc T\P!VRW!\PRR7#)z5Run ffmpeg/ffprobe with captured output and no stdin.TF)capture_outputrJrOstdincheck) subprocessrunDEVNULL)rMrOrJs&$$rT_run_media_toolr^Ys! >>#dV`VhVhpu vvrVc V^8dQhRRRR/#)rLpathr returndict[str, Any]rR)rSs"rTrUrU^s##$#>#rVc/p\P!R4pV'd\VRRRRRR\V4.^ RR 7pVP^8XdT\ VP ;'gR P4;'g^4pV^8d\VR ,4VR &\P!R4pV'EdL\VRRR\V4RRRRRRR. ^R7pVP^8XEdVP 'Ed\P!R4pVPVP 4\PR8wdVP!4V'd\#V4\$r.p \'V4F~p W,V,p \)RWk\)V ^,V ^,V,V,444p V P+\-R\V R, R,444K WR&V#V# \d\PR TRR7ELi;i \d\PRTRR7T#i;i) z\Best-effort duration + MSC1767 waveform for voice bubbles; must work without ffprobe/ffmpeg.ffprobez-verrorz -show_entrieszformat=durationz-ofz"default=noprint_wrappers=1:nokey=1T)rOrJdurationz-Matrix: failed to probe voice duration for %sexc_infoffmpegz-iz-ac1z-ar8000z-fs16le-rOhlittlec38"TFp\V4xK R#5iN)abs).0vs& rT 2_matrix_voice_metadata_for_file..|s"l3ka3q663ksiiwaveformz-Matrix: failed to build voice waveform for %s)shutilwhichr^str returncodefloatstdoutstriprP Exceptionloggerdebugarray frombytessys byteorderbyteswaplen_MATRIX_VOICE_WAVEFORM_BINSrangemaxappendmin) r`metadatardresultrhrksamplescountbinsrzidxstartpeaks & rT_matrix_voice_metadata_for_filer^s !Hll9%G _$$:KU5s4yBKMTXZF  A% &--"5"52!!C!C!Da<+.x$+?HZ(\\( #F v _$wc$iUFTXZacfgqsuF  A%&---++c*!!&--0==H,$$&"%g,0K4!H$T{ # t 3""l7UQYQTWXQX\aPaeiPiAj3k"ll D#dUlT6I2J(KL +,4Z( O8O- _ LLH$Y]L ^ _( _ LLH$Y]L ^ O _s?AH*H#HAH; AH;*B#H;#H87H8;#I"!I"z'^!([A-Za-z][A-Za-z0-9_-]*)(?=$|\s)(.*)$c V^8dQhRRRR/#)rLnamer}ra str | NonerR)rSs"rTrUrUsszrVc V'gR#\\PVP4VP4P RR4344p^RIHpVFpV!V4'gKVu# ^RI H pV!4;'g/pVFpR V 2V9gKVu# R# \d\PRTRR7LVi;i \d\PR TRR7R#i;i) uFResolve a ``!command`` token (Matrix clients reserve ``/``) to a dispatchable token. Only known gateway/skill commands resolve, so ordinary exclamations stay chat text. Returns whichever candidate resolved — raw lowercased first, then ``_``→``-`` — never a forced canonical form: aliases pass through for the dispatcher.N_ro)is_gateway_known_commandz.Matrix: is_gateway_known_command failed for %rTri)get_skill_commands/z(Matrix: get_skill_commands failed for %r) rNdictfromkeyslowerreplacehermes_cli.commandsrrrragent.skill_commandsr)r candidatesr candidaterskill_commandss& rT_resolve_matrix_bang_commandrs dmmTZZ\4::<3G3GS3Q$RSTJ\@#I' 22  $ V;+-33#I9+.0  $  \ EtVZ [\ V ?PT U VsBB*3B*7B*:CC"C&C*#CC#C:9C:c V^8dQhRRRR/#rLrJr}rarR)rSs"rTrUrUs0000rVcV'dVPR4'gV#\PV4pV'd\VP ^44MRpVfV#RT VP ^4;'gR 2#)zGConvert Matrix ``!command`` aliases to normal Hermes ``/command`` text.!Nrrf) startswith_MATRIX_BANG_COMMAND_REmatchrgroup)rJrresolveds& rT_normalize_matrix_bang_commandrsl ts++ # ) )$ /E?D+EKKN;$H xjQ--2. //rVz^>\s*<(@[^>]+)>\s*(.*)$c V^8dQhRRRR/#)rLbodyr}raz#tuple[Optional[str], Optional[str]]rR)rSs"rTrUrUs""#"*M"rVcV'dVPR4'gR#.pRpVPR4FypVPR4'gMaVR,pVf@\PV4pV'd#VP ^4pVP ^4pVP V4K{ RP V4P4;'gRpWb3#)zbReturn (quoted_text, author_mxid) from the inline reply fallback; author from the first-line pill.> N rLNNNN)rsplit_MATRIX_REPLY_FALLBACK_PILL_RErrrjoinr)r quoted_lines author_idlinecontent pill_match quoted_texts& rT_extract_reply_fallbackrs tt,, L#I 4 t$$ r(  7==dCJ&,,Q/ $**1-G$!))L)//199TK  !!rVc V^8dQhRRRR/#rLrr}rarR)rSs"rTrUrUs5555rVc:V'dVPR4'gV#.pRpVPR4FGpV'g,VPR4'gVR8XdK+RpVR8XdK6VPV4KI V'dRPV4#T#)zKStrip the inline ``> quote\n\nreply`` fallback prefix; unchanged if absent.rFr>Trf)rrrr)rstripped past_fallbackrs& rT_strip_reply_fallbackrs tt,, HM 4 t$$  Mrz!#+499X 44rVc V^8dQhRRRR/#)rLexc BaseExceptionrarQrR)rSs"rTrUrUs<<<4 quote\n\nreply`` into ``(quote_block, reply_text)``; ``("", body)`` when absent. The two halves always concatenate back to *body* verbatim (``quote + reply == body``), so callers can transform one half and rebuild the body without disturbing the other. The blank separator line belongs to the quote block. Used to keep the ``> <@user:srv>`` reply pill — the only mention text in a reply-to-the-bot — out of whole-body rewrites. rrfrrN)rrrr)rlinesrheads& rT_split_reply_fallbackrs tt,,4x JJt E C E  5 5d ; ;uzS?P q SZEJ", q 99U4C[ !DE *D":Udiid >T0UUrVca]tRtRtRt0RmtRR0tRV3Rllt]RRl4t R R lt R R lt R Rlt RRlt RRltRRltRRltRRltRtV;t#)_MatrixHtmlSanitizeriz9Allowlist sanitizer for Matrix-compatible formatted HTML.brhrcV^8dQhRR/#rLraNonerR)rSs"rTrU!_MatrixHtmlSanitizer.__annotate__s$rVc D<\SV`RR7.Vn^VnR#)F)convert_charrefsN)super__init___parts _skip_depth)self __class__s&rTr_MatrixHtmlSanitizer.__init__s" %0!# rVc V^8dQhRRRR/#)rLvaluer}rarR)rSs"rTrUrsrVc \P!RRT;'gR4P4p\P!RV4pV'd VP ^4P 4MRpV'd VR9dR#V#)z[\x00-\x1f\x7f]+rfz^([A-Za-z][A-Za-z0-9+.-]*):>httphttpsmailtomatrix)resubrrrr)rrrschemes& rT _safe_url_MatrixHtmlSanitizer._safe_urlsb66-r5;;B?EEG7B+0Q%%'b f$IIrVc$V^8dQhRRRRRR/#)rLtagr}attrslist[tuple[str, str | None]]rarR)rSs"rTrUrs"  s +G C rVc  .pVFwrE\T;'gR4P4pVfRM \V4pVR8XdEVR8Xd>VPV4pV'd#VPR\ VRR7 R24KKVR8XgKVR8XgK\ P !R V4'gKVPR \ VRR7 R24K RPV4#) rfahrefz href="Tquote"codeclasszlanguage-[A-Za-z0-9_+.-]{1,64}z class=")r}rrr _html_escaper fullmatchr) rrrsafekeyrattr raw_valuers &&& rT _safe_attrs _MatrixHtmlSanitizer._safe_attrssJCsyyb>'')D#mUIczdfn~~i0KK',t4*H)I KL47?r||Degp7q7q h|IT'J&K1MN wwt}rVc$V^8dQhRRRRRR/#)rLrr}rrrarrR)rSs"rTrUr)s(ss3s/KsPTsrVc BVP4pVR9dV;P^, unR#VP'g[WP9dIVPP WP 9dRV R2MRV VP W4 R24R#R#R#)scriptstyler)rr _ALLOWED_TAGSrr _VOID_TAGSr )rrrs&&&rThandle_starttag$_MatrixHtmlSanitizer.handle_starttag)siik % %    ! !!!c-?-?&? KK  SOO-C3%qz1SERVRbRbcfRnQoopIq r'@!rVc V^8dQhRRRR/#)rLrr}rarrR)rSs"rTrUr0s((((rVc 4VP4pVR9d.VP'dV;P^,unR#VP'g!WP9gWP9dR#VPP RV R24R#)rNrr)rrrrrr)rrs&&rT handle_endtag"_MatrixHtmlSanitizer.handle_endtag0sriik % %$*:*:*:    !      s*<*<<@V  RuA;'rVc V^8dQhRRRR/#)rLrJr}rarrR)rSs"rTrUr9s%%#%$%rVc dVP'gVPPV4R#R#rt)rrr)rrJs&&rT_emit_MatrixHtmlSanitizer._emit9s% KK  t $ rVc V^8dQhRRRR/#)rLdatar}rarrR)rSs"rTrUr=s''''rVc :VP\V44R#rt)rr)rr"s&&rT handle_data _MatrixHtmlSanitizer.handle_data=s <%&rVc V^8dQhRRRR/#rLrr}rarrR)rSs"rTrUr@s  S T rVc 0VPRV R24R#)&;Nrrrs&&rThandle_entityref%_MatrixHtmlSanitizer.handle_entityref@s QtfA;rVc V^8dQhRRRR/#r'rR)rSs"rTrUrCs!!3!4!rVc 0VPRV R24R#)z&#r*Nr+r,s&&rThandle_charref#_MatrixHtmlSanitizer.handle_charrefCs RvQ< rVcV^8dQhRR/#rLrar}rR)rSs"rTrUrFs$$#$rVc 8RPVP4#rf)rrrs&rTget_html_MatrixHtmlSanitizer.get_htmlFswwt{{##rV)rr>rbipsremh1h2h3h4h5h6rlioltdthtruldelprertabletbodytheadstrikestrong blockquote)__name__ __module__ __qualname____firstlineno____doc__rrr staticmethodrr rrrr$r-r1r8__static_attributes__ __classcell__rs@rTrrseC`MJ  s(%' !$$rVrT)frozenc]tRtRt$RtR]R&R]R&R]R&R]R&R]R &R ]R &R ]R &R]R&R ]R&R]R&RtR ]R&RtR#)MatrixRoomIdentityiJz=Resolved Matrix room identity for routing and prompt context.r}room_idr room_name room_topiccanonical_alias server_namez int | Nonejoined_member_countrQis_direct_account_data display_namehas_explicit_name chat_typeFconflictrRN)rSrTrUrVrW__annotations__rirYrRrVrTr^r^JsIG L##  NHdrVr^c]tRtRt$RtR]R&R]R&R]R&RtR]R &R tR ]R &R tR ]R&] !] RR7t R]R&Rt R #)_MatrixApprovalPromptiZz,Pending reaction-based exec approval prompt.r} session_keychat_id message_idFrQrNrrequester_user_id float | None expires_at)default_factoryinitdict[str, str]bot_reaction_eventsrR) rSrTrUrVrWrjrrprrrrrvrYrRrVrTrlrlZsF6 LOHd$(z(#J #*/5*QQrVrlc]tRtRt$RtR]R&R]R&R]R&R]R&R ]R &R tR ]R &R tR]R&RtR]R&] !] R7t R]R&Rt R #)_MatrixPickerPromptifzdPending reaction-based picker; ``choices`` maps emoji -> selection, ``on_selected`` is the callback.r}rnrormrchoicesr on_selectedNrrprqrrFrQr)rsrurvrR) rSrTrUrVrWrjrprrrrrrvrYrRrVrTrxrxfsOn LO M$(z(#J #Hd*/*EErVrxiȯc V^8dQhRRRR/#)rLrJr}rarPrR)rSs"rTrUrUs%%C%C%rVc6\VPR44#)utf-8)rencoderJs&rT _utf8_lenrs t{{7# $$rVc V^8dQhRRRR/#)rLrrbrarPrR)rSs"rTrUrUsUUNUsUrVcF\\P!VRRR74#)z\Size of event content as the homeserver counts it (canonical JSON is UTF-8, not \u-escaped).F) ensure_ascii separators),:)rjsondumps)rs&rT_content_bytesrs TZZe S TTrVcV^8dQhRR/#)rLrarPrR)rSs"rTrUrUs C C3 CrVc\\VRR4RRR4pVe \V4P4'g^\ \ 4;_uu_4^RIHpVPR4pV'dVP'd VPpRRR4\V4p\R\T\ 44# +'giL6;i \\3d \u#i;i)zAResolve outbound chunk size from config, env, or plugin registry.extraNmax_message_lengthMATRIX_MAX_MESSAGE_LENGTH)platform_registryri)_extra_or_secretrr}rrrgateway.platform_registryrgetrrP TypeError ValueErrorDEFAULT_MAX_MESSAGE_LENGTHrr!MATRIX_MAX_MESSAGE_LENGTH_CEILING)configrawrentryrs& rT_resolve_max_message_lengthrs 767D9;OQlnr sC {#c(..** i C%))(3E111.. ! *C sC@A BB!  z "*))*s$1C C C C C-,C-)get_hermes_dirz6(?.s>IbZZ\\IsT) r}rendswithanyr rsuffixr mimetypes guess_typerQr)rJ mime_prefixesrrrr guessed_typers&&&& rTrrsDJJB%%'I  )Y-?-?-D-D>I>>I>>> Iy( )_ # # ) ) +F **95OL  GG!8!8!G H Z ZFNZrVc V^8dQhRRRR/#rrR)rSs"rTrUrUsiiCiDirVc&\VR\R4#)zTTrue when an m.audio/m.file/m.video body is just the uploaded filename (no caption).T)zaudio/zvideo/)r_MATRIX_MEDIA_FILENAME_EXTSrs&rT!_looks_like_matrix_media_filenamers )$0DFacg hhrVc$V^8dQhRRRRRR/#)rLmsgtyper}rrarQrR)rSs"rTrUrUs&ccScccrVcVVR8Xd \V4#VR9;'d \V4#)zKTrue when a media event body is only the uploaded filename for its msgtype.m.image)m.audiom.filem.video)rr)rrs&&rT_is_bare_media_filenamers0)066 6 6 b b;\]a;bbrVc V^8dQhRRRR/#)rLeventr rarrR)rSs"rTrUrUs663656rVc\\VRR4;'g\VRR4;'g^4pTR8d TR, #T# \\3dR#i;i)zGReturn a Matrix event timestamp in seconds, accepting ms or sec values. timestampNserver_timestampld( g@@)rrrr)rtss& rT_matrix_event_timestamp_secondsrsg 75+t4eeGY[_8`eede f~-2;525 z "sA A A AAcV^8dQhRR/#)rL proxy_urlrrR)rSs"rTrUrUs22j2rVc^RIpV'gVP\4R7#VPR4^,P 4P R4'd+^RIHpVPVPVRR7R7#VPVR 7# \d4\PR T4TP\4R7u#i;i) aClientSession whose proxy applies to *all* requests: mautrix's ``HTTPAPI._send()`` never forwards per-request ``proxy=``, so it must be session-level (``proxy=`` for HTTP(S), ``ProxyConnector`` for SOCKS); with no proxy, ``trust_env`` honours HTTP(S)_PROXY.N) trust_envz://socks)ProxyConnectorT)rdns) connectoruVaiohttp_socks not installed — SOCKS proxy %s ignored. Run: pip install aiohttp-socks)proxy) aiohttp ClientSessionr:rrr aiohttp_socksrfrom_url ImportErrorrwarning)rrrs& rT_create_matrix_sessionrs $$/@/B$CCua &&(33G<< H 4((>3J3J9[_3J3`(a a  y 11  H NNhjs u((3D3F(G G Hs#(B;CCcV^8dQhRR/#rLrarQrR)rSs"rTrUrUs$rVc`^RIHp^RIHp^RIp^RIpR# \ \3dR#i;i)uPTrue if all four E2EE deps import: olm, PgCryptoStore (also drives sqlite), asyncpg, aiosqlite. Without all four, encrypted rooms fail at connect with ``No module named 'asyncpg'``. Verifies python-olm (via mautrix.crypto.OlmMachine), the SQLite crypto store backend (mautrix.crypto.store.asyncpg.PgCryptoStore — yes, the PgCryptoStore class also drives the sqlite backend in mautrix 0.21), and the database drivers actually used at connect time (``asyncpg`` for the underlying upgrade_table machinery, ``aiosqlite`` for the ``sqlite:///`` URL we pass to ``Database.create``). See #31116.  OlmMachine PgCryptoStoreNTF)mautrix.cryptormautrix.crypto.store.asyncpgrasyncpg aiosqliterAttributeError)rrrrs rT_check_e2ee_depsrs-->  (s --c V^8dQhRRRR/#)rLrr rar}rR)rSs"rTrUrUsrVc\T;'gR4P4P4pVR9dR#VR9dR#R#)rfrequiredoptionaloff)rrequiretruerlyeson)rprefer preferred)r}rr)rrs& rT_normalize_e2ee_moders? ekkr  " ( ( *C ?? 11 rVc V^8dQhRRRR/#)rLrOptional[dict[str, Any]]rar}rR)rSs"rTrUrU s3363#3rVcT;'g/pVPR4;'g \RR4pV'd \V4#VPR\R44pV'dR#R#)zAResolve E2EE mode with MATRIX_ENCRYPTION backwards compatibility. e2ee_modeMATRIX_E2EE_MODErf encryptionMATRIX_ENCRYPTIONrr)r_get_scoped_secretr _env_truthy)rexplicitlegacy_enableds& rT_resolve_e2ee_moder s^ KKREyy%SS);1s1v||~A >>"3x~~c2 @2!ggiIAGGI2 @@? @s!B0B0=B5B5c V^8dQhRRRR/#)rL relates_torra Optional[str]rR)rSs"rTrUrU's\\T\m\rVcTVPR4R8XdVPR4#R#)z:The m.thread root event_id an event belongs to, else None.rel_typem.threadevent_idN)r)r s&rT _thread_rootr's')3 )Cz)Q:>>* %[W[[rVc$V^8dQhRRRRRR/#)rLr r}env_namerarrR)rSs"rTrUrU,s&]]]s]x]rVc F\\VPWRRR74#)uIResolve a room/user list: scoped env var → config.extra[key] → empty.rfF)blank_is_unset)r rr)rr rs&&&rT_extra_csv_setr,s $V\\3"UZ[ \\rVcV^8dQhRR/#)rLraOptional[Path]rR)rSs"rTrUrU1sCC>CrVc|\RR4P4pV'd\V4P4#R#)zMATRIX_RECOVERY_KEY_OUTPUT_FILE via the profile-scoped reader: a bare os.getenv under multiplex resolves the default profile's path, writing/finding the wrong profile's file.MATRIX_RECOVERY_KEY_OUTPUT_FILErfN)rrr expanduser) output_files rT_recovery_key_output_pathr1s5%%FKQQSK-84  ' ' )BdBrVc V^8dQhRRRR/#)rL recovery_keyr}rarrR)rSs"rTrUrU8srVct\4pVfR#VPPRRR7\P!V\P \P ,\P,R4p\P!VRRR7;_uu_4pVPV4VPR4RRR4V# +'giT#;i \dL\\4;_uu_4\P!T4RRR4h +'gih;ii;i) z\Write a generated recovery key to MATRIX_RECOVERY_KEY_OUTPUT_FILE (0600, never overwritten).NTparentsexist_okiwr})encodingr)rparentmkdirosopenO_WRONLYO_CREATO_EXCLfdopenwriterrOSErrorclose)r!r`fdfhs& rT&_write_matrix_recovery_key_output_filer58s $ &D |KKdT2 r{{RZZ/"));U CB YYr3 1 1R HH\ " HHTN2 K2 1 K  g   HHRL   sB?!C! #C C! C C!C!!"D7D# D7# D3 . D7cV^8dQhRR/#)rLraztuple[Optional[Path], str]rR)rSs"rTrUrUJs  0J rVc\4pVfR#VP4'dR#VPPRRR7VR3# \dpRRT 23uRp?#Rp?ii;i)zHReturn a usable one-time recovery-key output path, or a redacted reason.NTr#z unusable: rf)Nnot_configured)Nexists)rr9r(r)r)r`rs rT&_get_matrix_recovery_key_output_targetr:Jsq $ &D |%% {{}}( $6 8O (z#'''(sA A'A"A'"A'c$V^8dQhRRRRRR/#)rLmxidr}r!rarrR)rSs"rTrUrUXs!34rVc.\V4pT'd\PRY4R#\PRT4R# \d\PRT4R#\d"p\PRY4Rp?R#Rp?ii;i)zBHandle a freshly generated Matrix recovery key without logging it.zMatrix: bootstrapped cross-signing for %s. Recovery key output file already exists; refusing to overwrite. Store the generated key securely and set MATRIX_RECOVERY_KEY for future restarts.NzMatrix: bootstrapped cross-signing for %s, but failed to write MATRIX_RECOVERY_KEY_OUTPUT_FILE: %s. Store the generated key securely and set MATRIX_RECOVERY_KEY for future restarts.zMatrix: bootstrapped cross-signing for %s. A new recovery key was written to %s with mode 0600. Move it to your secret store and set MATRIX_RECOVERY_KEY for future restarts.zMatrix: bootstrapped cross-signing for %s. A new recovery key was generated but will not be logged. Set MATRIX_RECOVERY_KEY_OUTPUT_FILE to write it once with mode 0600, or configure MATRIX_RECOVERY_KEY from your Matrix client before future restarts.)r5FileExistsErrorrrr)r<r! output_pathrs&& rT%_handle_generated_matrix_recovery_keyr@Xs <\J  T    _   %  HIM O   HIM T  s# A!B)B2B3BBcV^8dQhRR/#r4rR)rSs"rTrUrUusAAcArVc6\RR4P4#)zMATRIX_RECOVERY_KEY via the profile-scoped reader: a bare os.getenv under multiplex resolves the default profile's key and verification fails with "Key MAC does not match".MATRIX_RECOVERY_KEYrf)rrrRrVrT_scoped_recovery_keyrDus 3R 8 > > @@rVz,HERMESTEX(?:DISPLAY|INLINE)(\d+)HERMESTEXENDzHERMESTEXDISPLAY%dHERMESTEXENDzHERMESTEXINLINE%dHERMESTEXENDc V^8dQhRRRR/#)rLrJr}raz!tuple[str, list[tuple[str, str]]]rR)rSs"rTrUrUs3#DrVcaV'dRV9dV.3#.oRV3RllpRV3Rllp\P!RW4p\P!RW 4pVS3#)aReplace ``$$...$$``/``$...$`` with sentinel tokens. Returns the tokenized text plus an ordered ``(tag, tex)`` store, where tag is ``div`` for display math and ``span`` for inline math. Dollars that do not form a pair (prices, literals) are left untouched. $c V^8dQhRRRR/#rLrz re.Match[str]rar}rR)rSs"rTrU&_latex_to_tokens..__annotate__s55M5c5rVc<SPRVP^4P434\\ S4^, ,#)div)rrr_TEX_DISPLAY_TOKENrrstores&rT _sub_display&_latex_to_tokens.._sub_displays8 eU[[^11345!SZ!^44rVc V^8dQhRRRR/#rIrR)rSs"rTrUrJs44=4S4rVc<SPRVP^4P434\\ S4^, ,#)span)rrr_TEX_INLINE_TOKENrrNs&rT _sub_inline%_latex_to_tokens.._sub_inlines8 fekk!n22456 CJN33rVz\$\$([^\n$]+?)\$\$z (?.__annotate__sEE}EErVc <\VP^44pV\S48dVP^4#SV,wr#\VRR7pRV RV RV RV R2 #)Trrz data-mx-maths="">rr)rPrrr)rrrtexescapedrOs& rT_expand$_tokens_to_mx_maths.._expandsj%++a.! #e* ;;q> !:s$/3%'y7)2cU!DDrV) _TEX_TOKEN_REr)r[rOres&f rT_tokens_to_mx_mathsrhs"EE   W ++rVc V^8dQhRRRR/#)rLr[r}rarR)rSs"rTrUrUs((((rVc\4pTPT;'gR4VP4VP4# \d\ T;'gR4u#i;ir6)rfeedr2r8rr)r[ sanitizers& rT_sanitize_matrix_htmlrmsZ$&I(tzzr"!!## (DJJB''(sA&AA* A*)A*c V^8dQhRRRR/#rLurlr}rarR)rSs"rTrUrUsSSrVcf\\V44pVP'gLVP'g:\V4P R^4^,P R^4^,#\ VPVPVP RR34# \dR#i;i)zAStrip query/fragment from URLs before logging signed media links.?#rfz)rr}rnetlocrrr`r)rppartss& rT_redact_url_for_logrvsS"|||ELLLs8>>#q)!,223:1= =5<<uzz2rJKK s7B!8B!3-B!! B0/B0c V^8dQhRRRR/#rrR)rSs"rTrUrUsrVc\P!RRT;'gR4p\P!RRV4p\P!RRV4#)z@Remove unsafe raw HTML before Markdown conversion can escape it.z0(?is)<\s*(script|style)\b[^>]*>.*?<\s*/\s*\1\s*>rfz5(?is)\s+on[a-z0-9_-]+\s*=\s*("[^"]*"|'[^']*'|[^\s>]+)z(?is)\s+(href|src)\s*=\s*("[^"]*(?:javascript|data|vbscript):[^"]*"|'[^']*(?:javascript|data|vbscript):[^']*'|[^\s>]*(?:javascript|data|vbscript):[^\s>]*)rX)rJrs& rT_pre_sanitize_matrix_markdownrysM VVGTZZUW XF VVPRTV\ ]F 66 j F rVcV^8dQhRR/#rrR)rSs"rTrUrUs  T rVcD^RIHpV!R4# \dR#i;i)upPASSIVE registry ``check_fn`` — must never install; ``ensure_matrix_deps`` is the installer. Registry ``check_fn`` — called from status displays and config loading, so it must never install anything. The ACTIVE lazy-installer (``check_matrix_requirements``) is registered as ``ensure_deps_fn`` and runs from ``create_adapter()`` when this returns False (#79812). ) availablerF)pmr|r) is_availables rTmatrix_deps_presentrs'0H%% s  cV^8dQhRR/#rrR)rSs"rTrUrUs   4  rVc>\RR4P4p\RR4P4p\RR4P4pV'g V'g\PR4R#V'g\P R4R#\ 4#)z]Credentials + deps answer for setup/status callers (credentials must NOT gate the installer).MATRIX_ACCESS_TOKENrfMATRIX_PASSWORDMATRIX_HOMESERVERz;Matrix: neither MATRIX_ACCESS_TOKEN nor MATRIX_PASSWORD setFz!Matrix: MATRIX_HOMESERVER not set)rrrrrensure_matrix_deps)tokenpassword homeservers rTcheck_matrix_requirementsrsu 4b 9 ? ? AE!"3R8>>@H#$7<BBDJ  RS :;  rVcV^8dQhRR/#rrR)rSs"rTrUrUs..D.rVc^RIHpRpVPR4'd9VPRV\ 44'g\ P R4R#\4pVR8Xd-\4'g\ PR\4R#VR8Xd+\4'g\ P R \4R #) uACTIVE deps-only installer (registry ``ensure_deps_fn``); rebinds the type globals. Installs the whole ``platform.matrix`` group when ANY declared package is missing — short-circuiting on ``import mautrix`` left asyncpg/aiosqlite uninstalled forever. Lazy-installs the full ``platform.matrix`` feature group via ``pm.extras.ensure_and_bind`` whenever any of the declared packages (mautrix, Markdown, aiosqlite, asyncpg, aiohttp-socks) is missing — not just mautrix itself. Previously this short-circuited on ``import mautrix``, which left the other four packages uninstalled forever and broke E2EE connect with ``No module named 'asyncpg'`` (#31116). Rebinds module-level type globals on success. )extrascN^RIHpHpHpHpHpHpHpHpRVRVRVRVRVRVRVR V/#) rrrrrrrrr) mautrix.typesrrrrrrrrrs rT_import#ensure_matrix_deps.._importsI i i i * w  ]  0 f * f  rVrzhMatrix: required packages not installed or need a restart. Run `hermes pm install`, then restart Hermes.FrzMatrix: E2EE is required but dependencies are missing. %s. Without this, encrypted rooms will not work. Set MATRIX_E2EE_MODE=off to disable E2EE.rz6Matrix: E2EE optional but dependencies are missing. %sT) r}rmissingensure_and_bindglobalsrrrrre_E2EE_INSTALL_HINT)rrrs rTrrs  ~~h(>(>xRYR[(\(\ < "$IJ'7'9'9  M  J'7'9'9OQcd rVc:a]tRtRtRtRtRtRtRt] t ] ^d, t ] R4t RRlt] RR l4tR V3R lltR R lt]RRl4t]RRl4t]RRl4t]RRl4t]RRl4t]RRl4tRRltRRltRRltR R!ltR"R#lt]ERR%R&ll4tR'R(ltR)R*lt R+R,lt!R-R.lt"R/R0lt#R1R2/R3R4llt$R5R6lt%ER R7R8llt&R9R:lt'R;R<lt(R=R>lt)R?R@lt*RARBlt+ERRCRDllt,RERFlt-RGR2/RHRIllt.ER!RJV3RKlllt/RLRMlt0ER!RNROllt1ER"RPRQllt2ER#RRRSllt3ER#RTRUllt4ER!RVRWllt5RXt6] RYRZl4t7R[R\lt8R]R^R_R`RaRbRcRd/t9R]ReR_RfRaRgRcRh/t:R]RiR_RjRaRk/t;RlRmltERRrRsllt?RtRult@ER$RvRwlltARxRyltBRzR{ltCR|R}ltDER%R~RlltERRltFRR2/RRlltGRRltHRRltIRRltJ]RRl4tKRRltLRRltMRRltNRRltOER&RRlltPRRltQERRRlltRRRltSER'RRlltT]RRl4tURRltVRRltWRRltXRR2RR/RRlltYRRltZRRlt[RRlt\ER(RRllt]ER(RRllt^RRlt_RRlt`RRltaERRRlltbRRltcRRltdRRlteRR2/RRlltfRRltgERRRllthRRltiRRltjRRltkRRltlRRltmRRltnRRltoRRltpRR/RRlltqER(RRlltrER)RRlltsRRltt]u!ER*4tvER+RRlltw]RRl4txRRltyRRltzERRRllt{RR2/RRllt|RRlt}RR2RR2/RRllt~RRltRRltER,RRlltRR$RR$/ERERlltERERltERERltERERltERER ltER ER ER lltER ER ltERERltERERltERERltERERltERERltERERlt]ERERl4t]ERERl4tERtV;t#(- MatrixAdapteriz,Gateway adapter for Matrix (any homeserver).Trc \#)zOUTF-8 bytes, the unit of the homeserver's event cap (a CJK character is three).)rr7s&rTmessage_len_fnMatrixAdapter.message_len_fn$s rVcV^8dQhRR/#rLrar rR)rSs"rTrUMatrixAdapter.__annotate__)sDrVc <\RR4VnVP#)zPin the crypto-store dir to the active profile (connect() runs inside the profile scope); cached so later out-of-scope reads report the store actually in use.platforms/matrix/store matrix/store)_get_hermes_dir _store_dirr7s&rT_resolve_store_dir MatrixAdapter._resolve_store_dir)s**BNSrVcV^8dQhRR/#rrR)rSs"rTrUr0slllrVc PVP;'g \RR4R, #)rrz crypto.db)rrr7s&rT_crypto_db_pathMatrixAdapter._crypto_db_path/s"\\?3K^#\`kkkrVcV^8dQhRR/#)rLrr9rR)rSs"rTrUr3sVrVr~VrrVc <\SV`V\P4\ V4VnVP Vn\^dVP ^d, 4VnVPPRR4;'g\RR4P4PR4VnVP;'g\RR4P4VnVPPRR4;'g\RR4P4VnVPPRR4;'g\R R4P4Vn\'VP4VnVP(R 8gVnVPPR R4;'g\R R4P4TnR VnRVnRVnRVnRVn/VnR VnRVnVP?4RVn /Vn!/Vn"/Vn#\IRR\J4Vn&RVn'\Q4Vn)^RI*H+pV!RR7Vn,\Q4Vn-\Q4Vn.\_R4Vn0\c4Vn2VPgV4Vn4VPkV4Vn6\oVRR4Vn8\oVRR4Vn9\uRR4Vn;VPyVRRR4Vn=\uR R4Vn>VPyVR!R"R4Vn?\\VPR#R$R%44P4P4pVRE9dTMR%VnCVPyVR&R'R4VnD\\VPR(R)R44P4RF9VnE/VnFR*VnG\Q4VnH\R+R,7VnJVP'd!\PR-VP4\IR.RG\4VnN\K\P!R/R044VnQ\K\P!R1R244VnRR3R4R5R6R7R8R9R8R7R8R9R8R:R;RR?\4VnW/VnX/VnY\oVR@RA4VnZ\QVPr4Vn[.Vn\\\VPRBRCR44F3pVPP\P!V44K5 R# \Pd"p\PRDYE4Rp?KjRp?ii;i)Hdrrfrrruser_idMATRIX_USER_IDrrr device_idMATRIX_DEVICE_IDFNr MATRIX_ROOM_IDENTITY_TTL_SECONDSgN@)dequerg)maxlenrfree_response_roomsMATRIX_FREE_RESPONSE_ROOMS allowed_roomsMATRIX_ALLOWED_ROOMSMATRIX_ALLOW_ROOM_MENTIONSfalse auto_threadMATRIX_AUTO_THREADrMATRIX_DM_AUTO_THREADdm_mention_threadsMATRIX_DM_MENTION_THREADS session_scopeMATRIX_SESSION_SCOPEautoprocess_noticesMATRIX_PROCESS_NOTICES reactionsMATRIX_REACTIONSg@ MATRIX_PROXY)platform_env_varuMatrix: proxy configured — %sMATRIX_MAX_MEDIA_BYTES&HERMES_MATRIX_TEXT_BATCH_DELAY_SECONDSz0.6,HERMES_MATRIX_TEXT_BATCH_SPLIT_DELAY_SECONDSz2.0✅once🌀session♾️alwaysu♾❌denyu❎MATRIX_APPROVAL_REQUIRE_SENDERMATRIX_APPROVAL_TIMEOUT_SECONDSi, allowed_usersMATRIX_ALLOWED_USERSignore_user_patternsMATRIX_IGNORE_USER_PATTERNSzAMatrix: ignoring invalid MATRIX_IGNORE_USER_PATTERNS entry %r: %s>rroomthread>0nori@)crrr8MATRIXrrMAX_MESSAGE_LENGTHr_SPLIT_THRESHOLDrrrrrstrip _homeserverr _access_token_user_id _passwordr _e2ee_mode _encryption _device_id_device_id_unverified_client _crypto_dbr _sync_task_invite_join_tasks_closing _startup_ts_reset_clock_skew_detector _last_sync_ts _dm_rooms_room_identities_room_identity_cached_atrr_room_identity_ttl_seconds_room_identity_cache_maxset _joined_rooms collectionsr_processed_events_processed_events_set_warned_encrypted_drop_roomsrE_threadsrF_parked_voices_parse_require_mention_require_mention_parse_thread_require_mention_thread_require_mentionr _free_rooms_allowed_roomsr_allow_room_mentions _extra_truthy _auto_thread_dm_auto_thread_dm_mention_threadsr}rr_matrix_session_scope_process_notices_reactions_enabled_pending_reactions!_reaction_redaction_delay_seconds_reaction_redaction_tasksr> _proxy_urlrinforP_max_media_bytesr*getenv_text_batch_delay_seconds_text_batch_split_delay_seconds_approval_reaction_map_approval_prompts_by_event_approval_prompt_by_session_approval_require_sender_approval_timeout_seconds_model_picker_prompts_by_event_choice_picker_prompts_by_event_allowed_user_ids_allowed_room_ids_ignored_user_patternsr rrcompilerer)rrrraw_session_scopepatternrrs&& rTrMatrixAdapter.__init__3s! 1"=f"E"&"9"9 #C)@)@3)F G "(!1!1,!C!z!zGYZmoqGrGxGxGz!C!CDG!H"(,,"g"g2DEZ\^2_2e2e2g#\\--i<pp@RSceg@h@n@n@p $ll..z2>ssBTUfhjBkBqBqBs1&,,?!%E!9%||// R@vvDVWikmDnDtDtDv+0"  #*.26;= "% '')$'*,?A:<%*56XZ^`e*f'(+%'*u%(-T(:*-%"69e)28< *n&*&A&A&&I-1-O-OPV-W$%3F@25.#MO';=(.9:Z\b.c%)45VX[]`)a&NP+OQ,,:&/Si+j+.t/B/B+C=?# 0?UWtvx yzG r++222::g3FG{88 rbdkqq rs3/V((W=WWcV^8dQhRR/#rrR)rSs"rTrUrs  t rVc ^V'gR#WP9dR#\VP4VPP8Xd-VPP VP^,4VPP V4VPP V4R#)zIReturn True if this event was already processed. Tracks the ID otherwise.FT)rrrrdiscardradd)rrs&&rT_is_duplicate_event!MatrixAdapter._is_duplicate_events 11 1 t%% &$*@*@*G*G G  & & . .t/E/Ea/H I %%h/ ""&&x0rVc(V^8dQhRRRRRRRR/#)rLr r}rrrarQrR)rSs"rTrUrs.oo3o#ooorVc \VPWV4p\V\4'dV#\ V4P 4R9#)ucScoped env var → ``config.extra[key]`` (YAML, per profile) → ``default``; true/1/yes semantics.rrrrrQr}r)rr rr configureds&&&& rTrMatrixAdapter._extra_truthys@&fllC7K ' D99zns:?T?T?VZn?nnrVc V^8dQhRRRR/#)rLr r}raOptional[bool]rR)rSs"rTrUrs   c  n  rVc VPPV4pVfR#\V\4'dV#\V\4'dVP 4R9#\V4#)zOParse a YAML bool / "true"/"off"-style string from config.extra; None if unset.N>rrrr)rrrrQr}r)rr r,s&& rT_configured_boolMatrixAdapter._configured_boolsa\\%%c*   j$ ' '  j# & &##%-HH HJrVcV^8dQhRR/#rrR)rSs"rTrUrszz$zrVc \VPRRR4p\V\4'dV#\ V4P 4R9#)uQMATRIX_REQUIRE_MENTION (scoped) → ``require_mention`` in config.extra → true.require_mentionMATRIX_REQUIRE_MENTIONT>rrrrr+rr,s& rTr$MatrixAdapter._parse_require_mentionsE&fll4EG_aef ' D99zys:?T?T?V^y?yyrVcV^8dQhRR/#rrR)rSs"rTrUrszzzrVc \VPRRR4p\V\4'dV#\ V4P 4R9#)u`MATRIX_THREAD_REQUIRE_MENTION (scoped) → ``thread_require_mention`` in config.extra → false.thread_require_mentionMATRIX_THREAD_REQUIRE_MENTIONF>rrrrr+r7s& rTr+MatrixAdapter._parse_thread_require_mentionsE&fll4LNmotu ' D99zys:?T?T?V^y?yyrVc V^8dQhRRRR/#)rLdevice_keys_objr rarrR)rSs"rTrUrsrVc \VR/4;'g/P4F2wr\V4PR4'gK'\V4u# R#)keyszed25519:N)ritemsr}r)r?kidkvals& rT_extract_server_ed25519%MatrixAdapter._extract_server_ed25519sM!/62>DD"KKMIC3x"":..4y NrVcV^8dQhRR/#)rLclientr rR)rSs"rTrUrs;;S;rVc <"VPVPVP./4GRjxL p\VR/4;'g/P \ VP44;'g/pVP \ VP44#Lk5i)z %s) — resetting local Olm account so fresh identity keys are generated for this deviceT) get_device_idrrrdelete)rrWrstored_device_idrs&&& rT%_reset_crypto_store_if_device_changed3MatrixAdapter._reset_crypto_store_if_device_changeds %1%?%?%AA  #3#@ CDT a!!### B  NNH# N  $sN BA(A&A(B1BB B&A(( B3B BBBc ,V^8dQhRRRRRRRRRR/#) rLrWr crypto_dbacct_idr} pickle_keyrarQrR)rSs"rTrUrs4$$ #$03$>A$OR$W[$rVc "\\4;_uu_4VP4GRjxL RRR4R#L +'giM;i^RIHpT R2T3FpYd8XdK T!Y6TR7P4GRjxL pM \dRpMi;iTfKGTP Y#Yd4GRjxL M0 \d#p\ PRT4Rp?R#Rp?ii;iTPT4GRjxL \ PR4R# \ PR 4R#5i) a7Re-pickle the Olm account under the current pickle key when it changed. The key embeds the device ID; an account created before MATRIX_DEVICE_ID was set lives under ``:default`` and later fails with BAD_ACCOUNT_KEY (silently disabling optional E2EE). False only when an account exists but no key opens it.NTrz:default account_idradbuMatrix: pickle key migration failed while re-pickling sessions (%s) — leaving the account under the legacy key so the migration is retried on the next start.FzMatrix: re-pickled crypto store account and sessions under the current pickle key (device ID was configured after the account was created)zMatrix: crypto store account exists but cannot be unpickled with the current or any legacy pickle key. If MATRIX_DEVICE_ID was changed manually, restore its previous value.) rr get_accountrr_repickle_crypto_sessionsrre put_accountr) rrWr_r`rar legacy_keyaccountrs &&&&& rT_migrate_legacy_crypto_pickle+MatrixAdapter._migrate_legacy_crypto_pickles* i **, , ,! ,!  ?%Yh/9J'  -\e f r r ttt   44Y```  fgjl   **73 3 3 KKK L-:.   g hsD?A>A D?A A D?,BB B D? BD?B D?(C=C>CD? C1C,%D?,C11D?D  6D?c ,V^8dQhRRRRRRRRRR/#) rLr_r r`r}rirararrR)rSs"rTrUr s9LLLsLX[LilLquLrVc "^RIpRVPRVPRVP/pVP 4F}wrxVP RV R2V4GRjxL p V FTp V R,fK\ V R,4p \\4;_uu_4VPW4RRR4KV K R#Ld +'giM;iTPY4p M7 \d*p \PRYzR ,T 4Rp ? KRp ? ii;iTPR T R 2T PT4Y*R ,4GRjxL K5i) uZRe-pickle olm/megolm sessions too — they share the key; account-only breaks key sharing.Ncrypto_olm_sessioncrypto_megolm_inbound_sessioncrypto_megolm_outbound_sessionz SELECT session_id, session FROM z WHERE account_id=$1rz}Matrix: %s row %s cannot be unpickled with the current or legacy key; leaving it in place, its sessions are unrecoverable: %s session_idzUPDATE z5 SET session=$1 WHERE account_id=$2 AND session_id=$3)olmSessionInboundGroupSessionOutboundGroupSessionrBfetchbytesrr from_picklerrexecutepickle)rr_r`riraolm_libtablesrM session_clsrowsrowpickledrrs&&&&& rTrg'MatrixAdapter._repickle_crypto_sessions s? '//3RT[ToTo ,g.J.JL#),,. E"+KE7Rf)gipqqDy>)I/i((++G@)( #1q )()55gJG NNJKPVbRcehj   ''eW$YZNN:.\9JLLLs`AEC?EC .E C EC('E( D3DED3EEEc$V^8dQhRRRRRR/#)rLrHr rsrarQrR)rSs"rTrUr(s!&&#&C&D&rVc aaaa"SP'dSP'd\PR4R#SP S4GRjxL pSPPPR4oRTTTT3R llpT'g7\PR 4RSPn T!R 4GRjxL #SPT4S8XdR#SPP'd7\P R SP\SP44R#\PR SP4\\ 4;_uu_4SPP!\#SPR4'd!SPP$P&MRRSP 24GRjxL \P)RSP4RRR4T!RSP4GRjxL #EL \ d$p\P RTRR7Rp?R#Rp?ii;iELL~ +'giLd;iLP5i)uWTrue if our device keys are on the server (or were re-uploaded); False ⇒ refuse E2EE.uJMatrix: skipping device key verification — device_id not yet establishedTNuAMatrix: cannot verify device keys on server: %s — refusing E2EEriFed25519c V^8dQhRRRR/#)rL error_fmtr}rarQrR)rSs"rTrUAMatrixAdapter._verify_device_keys_on_server..__annotate__4s Q Qs QD QrVc<"SP4GRjxL SP SS4GRjxL #L \d(p\P!T.TOTN5RR/Rp?R#Rp?ii;iL;5i)NrjTF) share_keysrrrerT)r error_argsrrHrQrsrs&* rT _reupload>MatrixAdapter._verify_device_keys_on_server.._reupload4sl nn&&&99&-PP P '  YHHSH4H QsAA0979A0A.A09 A+A& A0&A++A0u8Matrix: device keys missing from server — re-uploadingz+Matrix: failed to re-upload device keys: %supMatrix: server has different identity keys for device %s — local crypto state is stale. Delete %s and restart.uDMatrix: server has stale keys for device %s — attempting re-uploadMethodDELETEz/_matrix/client/v3/devices/z+Matrix: deleted stale device %s from serverzfMatrix: cannot upload device keys for %s: %s. Try generating a new access token to get a fresh device.)rrrrrNrrerj identity_keysrsharedrEr}rrapirequesthasattrrrr)rrHrsour_keysrrrQsfff @rT_verify_device_keys_on_server+MatrixAdapter._verify_device_keys_on_server(s4#=#=#= NNg h !88@@H 1155i@  Q Q NNU V!&CKK "#PQQ Q  ' ' 1] B ;;    LL0171A1A3tG[G[C\ ^]_e_o_op i **$$,3FJJ,I,I !!((x-f.>.>-?@B B B KKEvGWGW X !  t    =A  LL\^alpL q R B! s$I+I+H HH 8I+1I+I7I+?A-I+,A)II$I:I+I)I+H I+I I+ II+I I& ! I+Nc$V^8dQhRRRRRR/#)rLrr r_rarQrR)rSs"rTrUrQs!##rVc "VeVP4GRjxL VPP4GRjxL R#L(L5i)zQClose what connect() opened so far; always False so callers can ``return await``.NF)stoprr2)rr_s&&rT_abort_connectMatrixAdapter._abort_connectPs>  .." " "kk!!! #!sAA!AAAAc$V^8dQhRRRRRR/#)rLrHr rrarQrR)rSs"rTrUrXs!>>#>C>D>rVc D"VP'Ed[VPVnVP4GRjxL p\VRR4;'g VPp\ \VRR4;'gR4pV'd+\ V4Vn\ VP4VnV'dQVP'd?WPP8wd/\PRVPWPP4TpMVP;'gTpV'dWan VP'gVPVP./4GRjxL p\VR/4;'g/P\ VP44;'g/p\V4^8Xd\\!V44Vn M(V'g!\P#RVP4VP'g(\P#R VP4R Vn\P)R VP;'gR V'dR V R2MR4R #VP,'dVP'dTP/VPVP,RVP;'gRR7GRjxL pV'd$\1VR4'dVPVn \P)RVP4R #\PR4VP+V4GRjxL #ELEL \$d"p \P#RT 4Rp ? ELRp ? ii;i \$d=p \PRT R R7TP+T4GRjxL uRp ? #Rp ? ii;iL \$d;p \PRT 4TP+T4GRjxL uRp ? #Rp ? ii;iL5i)zRAuthenticate via access token (whoami) or password login; resolve user/device IDs.NrrfrzMatrix: MATRIX_DEVICE_ID=%s does not match the device this access token belongs to (%s). A token can only upload keys for its own device, so the configured value is being ignored. Unset MATRIX_DEVICE_ID, or use a token issued for %s.rJuDMatrix: no devices found for %s — key verification will be skippedz$Matrix: device list query failed: %szMatrix: device_id could not be resolved for %s. Set MATRIX_DEVICE_ID for full key verification. E2EE will proceed without server-side device key confirmation.Tz#Matrix: using access token for %s%sz(unknown user)z (device )uMMatrix: whoami failed — check MATRIX_ACCESS_TOKEN and MATRIX_HOMESERVER: %sriz Hermes Agent) identifierr device_namerzMatrix: logged in as %suMatrix: login failed — %szDMatrix: need MATRIX_ACCESS_TOKEN or MATRIX_USER_ID + MATRIX_PASSWORD)rrwhoamirrr}rr<rrrerrKrrnextiterrrrrrrloginr) rrHrrLresolved_user_idresolved_device_ideffective_device_iddev_resp all_devicesrs &&& rT_connect_authenticate#MatrixAdapter._connect_authenticateXsM    **CI+ 6#]]_,#*4B#?#P#P4== %({B)G)M)M2%N"#$'(8$9DM"("7FK&$///>PTcTc>cLL)+///;M ` +='*.//*O*O=O'&':$''' T)/):):FKK;L)M#M'.x'K'Q'Qr&V&VWZ[a[f[fWg&h&n&nln {+q0/3D4E/FF,!,"NN fhnhshsu'''NNk %26D. 94==;\;\L\:Mi 34A6SUW*^^^  6#\\#}}t~~Sa"oo55*77GD+66'+~~F$ 5t}}E LL_ `,,S11 1q-*$N%T'MsSST 6 cehswy!005555 6 7  6 :C@!005555 6 2sU%P N MN %N :N 1N ;N AN  N )N  M"M#M;+M',MN M M<N A N  N " N .P P 4O OO O"AO%+P PP N M N&N<N NN O,O OO OP  OP O P!*P P PPP PP c(V^8dQhRRRRRRRR/#)rLrHr r state_storerarQrR)rSs"rTrUrs/DDD#DCDTXDrVc "\4'ggVPR8Xd#\PR\4RVnM3\P R\4VPV4GRjxL #VP 'gR#Rp^RIH p^R I H p^R I H pVPPRRR 7R pVPR , P!4'd7\P#R4VPR , P%4VP'RVP( 2VP*R7pVP-4GRjxL WnVP0;'gRp T RVP2;'gVP4;'gR 2p V!WVR7p V P74GRjxL Rp VP2'dGVP9WP24GRjxL p V P;VP24GRjxL V 'g6VP=WW4GRjxL 'g\PR4^RIH p V !W0PBV4pV!WV4p\DPFVn$\DPFVn%VPM4GRjxL VPOW4GRjxL 'gVPW(4GRjxL #VPQ4GRjxL VPWW4GRjxL Wn,\P#R\UVP(4VP2'dRVP2 2MR4R#ELEL-ELELELoELPLLLL \RdppR\UT49d@\P RTP24TPY(4GRjxL uRp?#\PRT4Rp?LRp?ii;iL \Rd'pTP[TTT4GRjxL uRp?#Rp?ii;i5i)zMSet up the Olm machine + crypto store. Returns False when connect must abort.rzaMatrix: E2EE optional but dependencies are missing. Continuing without encrypted-room support. %sFuwMatrix: E2EE is required but dependencies are missing. %s. Refusing to connect — encrypted rooms would silently fail.NTimportrr)Databaser#createzcrypto_store.picklez@Matrix: removing legacy crypto_store.pickle (migrated to SQLite)z sqlite:///) upgrade_tablehermesrrrcuFMatrix: crypto pickle migration failed — E2EE may not work correctly)_CryptoStateStorezalready existszMatrix: device %s has stale one-time keys on the server signed with a previous identity key. Delete the device from the homeserver and restart, or generate a new access token to get a fresh device ID.z/Matrix: share_keys() warning during startup: %sz"Matrix: E2EE enabled (store: %s%s)z , device_id=rf).rrrrrrrerrrrrmautrix.util.async_dbrrr)r9runlinkrrrrrrrrr+r\ put_device_idrk'plugins.platforms.matrix.adapter_cryptorrrr6share_keys_min_trustsend_keys_min_trustloadrrrr}"_verify_or_bootstrap_cross_signingcrypto_e2ee_setup_failed)rrHrrphaserrrr__acct_id _pickle_keyrW_store_was_resetr crypto_statersrs&&&& rT_connect_setup_e2ee!MatrixAdapter._connect_setup_e2ees!!*,12DF$)  ;E"77??AA ^_#88@@B T1123=C^C^(`I//# # #'O}}00H&Ja(8(8(X(XDOO(X(Xy'YZK(HYbcL##% % %$ )-)S)ST`brbr)s#s "001A1ABBB#$2T2T X3D-D-Dgh Q,[:L:LfULV<@C'1'<'NP`a!!A TMsSS TJ S LcRR S$,M$E?@CEEEsFC6C4C6FD'D%D'AF9E E #E0F4C66 D"DFD""F%D'' E2E FEFE F$F:FFFc V^8dQhRRRR/#)rLrHr rarrR)rSs"rTrUrs B B# B$ BrVc "VPRRR7GRjxL p\V\4'd8VPP 4VP WRR7GRjxL R#\ PR\V4P4R#L|L3 \d"p\ PRT4Rp?R#Rp?ii;i5i)zUFull initial sync: seed joined rooms, DM cache, and dispatch queued to-device events.i'T)rO full_stateN)initialz0Matrix: initial sync returned unexpected type %szMatrix: initial sync error: %s) syncrrrclear _absorb_syncrrtyperSr)rrH sync_datars&& rT_connect_initial_sync#MatrixAdapter._connect_initial_syncs B$kk%DkIII)T**""((*''4'HHHQSWXaSbSkSkl JI B NN;S A A Bs]C BBA B%B&B*C ,)BC BB C&C<C CC  is_reconnectFc V^8dQhRRRR/#)rLrrQrarR)rSs"rTrUrs--T-d-rVc "RVnVPeVP4GRjxL ^RIHp^RIH p^RI H pH pVP'g\PR4R#VP4P!RRR7\#VP$4pT!VPVP&;'gR VR 7pV!4p V!4p T!VP('d\+VP(4M \+R 4VP,;'gRWV R 7p WnVP/W4GRjxL 'gR#VP0'd#VP3WV 4GRjxL 'gR#^R IHp ^R IHp V P;V 4V P=\>P@VPBRR7V P=\>PDVPFRR7V P=V PHVPJRR7\LPL!4Vn'VPQ4RVn)VPUV 4GRjxL VP0'd7\WV RR4'd$V PXP[4GRjxL \\P^!VPa44Vn1VPe4VPgVP4R#EL \d"p\P RT4Rp?ELRp?ii;iELELLL \d!p\P RT4Rp?LRp?ii;i5i)FNz0Matrix: error disconnecting before reconnect: %s)HTTPAPI)Client)MemoryStateStoreMemorySyncStorez%Matrix: homeserver URL not configuredTr#rf)base_urlrclient_session)r<rrr sync_store)InternalEventType)MembershipEventDispatcher) wait_syncrz$Matrix: initial key share failed: %s)4rr disconnectrrr mautrix.apirmautrix.clientrmautrix.client.state_storerrrrerr)rrrrrrrrrrmautrix.client.dispatcherradd_dispatcheradd_event_handlerrr!_on_room_messager" _on_reactionINVITE _on_invitetimerrrrrrrasyncio create_task _sync_loopr_mark_connected_wire_plugin_handlers)rrrrrrrrrrrrHIntEvtrs&$ rTconnectMatrixAdapter.connects%*" << # Xoo''' ()P LL@ A !''t'D/@t//t7I7I7O7OR`no&( $& *.--- &VBZSWSbSbSjSjfjE //<<<    $*B*B6P[*\$\$\>G78  !7!79N9NZ^ _  !3!3T5F5FRV W  4 P99; '') ((000    $ ? ? Lmm..000"--doo.?@  ""4<<0S( XQSVWW X$=$\ 11 LEsKK LsM5LL L%M5A,M5*M5/1M5!$M5L= M5M5$M59M: M5C$M5(M)M5?M5M0M1M5AM5 L L:L5/M55L::M5M5M5M M2M-(M5-M22M5cV^8dQhRR/#rrR)rSs"rTrUrLs,,$,rVc "RVnVP'dPVPP4'g0VPP4VPGRjxL VPP4VP3Fgp\V4pVF+pVP4'dKVP4K- V'gKI\P!VRR/GRjxL Ki VPP4VPP4\VRR4'd$VPP4GRjxL VP$'d^\'\ 4;_uu_4VP$P(P*P-4GRjxL RRR4RVn\ P/R4R#EL \P \ 3dELi;iELL \ d!p\ P#RT4Rp?LRp?ii;iL +'giL;i5i)TNreturn_exceptionsrz3Matrix: could not close crypto DB on disconnect: %szMatrix: disconnected)rrdonecancelrCancelledErrorrrvaluesrrNgatherrrrrrrrrrrr2r)rtaskspendingtaskrs& rTrMatrixAdapter.disconnectLs ???4??#7#7#9#9 OO " " $ oo%%--4468V8VWE5kGyy{{KKM wnngFFFF X %%' &&,,. 4t , , Yoo**,,, <<<)$$ll&&..44666%DL *++&**I6  G - Y RTWXX Y7%$s9IIG/&G,'G/+A I<II3H4AIH!H"H&I8I2III&I,G//H I HIH I!H<7I<III I Ic ,V^8dQhRRRRRRRRRR /#) rLrnr}rreply_torrrrar=rR)rSs"rTrUrhs;BBB%(B4AB*B6@BrVc "V'g \RR7#RpVPVPV4VPVPR7FWpVP V4pVP WsVR7VPW4GRjxL p\PRWQ4KY \RVR 7#L+ \EdpTP'd\TPRR4'g4\PRY4\R\T4R 7uRp?u#TPP P#4GRjxL TPY4GRjxL p\PR YQ4Rp?EK= \d>p \PR Y4\R\T 4R 7uRp ? uRp?u#Rp ? ii;iRp?ii;i5i) T)successN)len_fnrrzMatrix: sent event %s to %srz Matrix: failed to send to %s: %sFrrez-Matrix: sent event %s to %s (after key share)z,Matrix: failed to send to %s after retry: %srro)r=truncate_messageformat_messagerr_build_text_message_content_apply_relation_metadata_send_room_messagerrrrrrrer}rr) rrnrrr last_event_idchunk msg_contentr retry_excs &&&&& rTsendMatrixAdapter.sendhsd+ + **##G,d.E.EdNaNa+cE::5AK  ) )+S[ ) \ K&*&=&=g&S S  9=R c$$=AA!T K(((WT\\8T-R-RLL!CWR%e3s8DDK,,--88:::*.*A*A'*W$W$WMKK OQ^hh KLL!OQXd%e3y>JJJK KsA5G 8B: B8 B:'G 8B:: GAG G!G )'F EF *E-+F G  G+GGGG G GGGG c$V^8dQhRRRRRR/#)rLrnr}rrbrarR)rSs"rTrUrs".UXrVc "\P!VPP\ V4\ P V4^-R7GRjxL p\V4#L5i)zGSend one m.room.message event (45s cap) and return its event ID as str.rpN)rwait_forrsend_message_eventrrr!r})rrnrrs&&& rTr MatrixAdapter._send_room_messagesP )) LL + +F7OY=S=SU` akmoo8}osAA"A A"c$V^8dQhRRRRRR/#)rLparent_chat_idr}rrarrR)rSs"rTrUrs!#S]rVc |"VPfR#TPY;'gRP4;'g \R44GRjxL pVP'd VP MRpV'gR#VP P\V44GRjxL \V4#LeL5i)u Post a seed message and return its ``event_id`` as the handoff ``thread_id``. Matrix has no create-thread API: a thread is the events whose ``m.relates_to``/``rel_type: m.thread`` point at a root event (Slack-style), and ``_apply_relation_metadata`` already threads later sends off a supplied ``thread_id``. ``None`` when disconnected or the seed send failed. In-thread replies keep the ROOM's chat_type (``dm``/``group``) in the session key — the handoff watcher and the cron seeder mirror that shape rather than the shared ``thread`` slot.Nrfz$platform.matrix.handoff.default_name) rrrrrror mark_asyncr})rr&rrroots&&& rTcreate_handoff_thread#MatrixAdapter.create_handoff_threads << yy**"1C1C1E1r1rKqIrss$*NNNv  mm&&s4y1114y t 2s9$B<B<B<B8B<)B<?)B<(B:)B<:B<c V^8dQhRRRR/#)rLrnr}rarbrR)rSs"rTrUrshh3h>hrVc "VPV4GRjxL pRVPRVPR8XdR/#R/#L(5i)Nrrdmr)_resolve_room_identityrfrh)rrnidentitys&& rT get_chat_infoMatrixAdapter.get_chat_infosI44W==--vx?Q?QUY?Ytgg_fgg>sAA)AcV^8dQhRR/#)rLrarbrR)rSs"rTrUrsAAArVc \P!4p\VP4pVP;'g"\ VP RR4;'gRpVP ;'g"\ VP RR4;'gRpRRRVPRRTR\VP4R V'dR MRR TR \V4R \T;'gR4P4'dR MR/RRVP RJR\VP4RVP'd\RWP, 4MR/RRVPR\VP 4R\#4R\VP$4R\\'4P44/RR\VP(4R\VP*4R\VP,4RVP.R\VP04R VP2R!VP4R"\7R#4/R$R%VP8//#)&r<rfrplatformrrauthaccess_token_presentpassword_present token_previewz***rdevice_id_presentdevice_id_previewr connectedNjoined_room_countlast_sync_age_secondsre2eemodeenableddeps_availablecrypto_store_pathrecovery_key_configuredpolicyallowed_user_countallowed_room_countignored_user_pattern_countr5free_response_room_countallow_room_mentionsrallow_public_roomsMATRIX_ALLOW_PUBLIC_ROOMSmediamax_media_bytes)rrQrrrrrrrr}rrrrrrrrrrDrrrrrrr rr)rnow token_presentrrs& rTget_diagnosticsMatrixAdapter.get_diagnosticssiikT//0 --JJ74<<#DJJOOSSwt||["'MSSQS ,0@0@ & 7I4PTP^P^K_-RG#T)_6ITWXaXgXgegThTnTnTpTp5vxz T\\57JCPTPbPbLc'tOaOaOaS#8J8J2J)Kgkm D9I9I4JL\^n^p#S)=)=%>)40D0F0L0L0N+OQ $c$*@*@&ACWY\]a]s]sYt,c$2M2M.N!4#8#8:TVYZ^ZjZjVk%t'@'@BSUYUjUj$k2M&N P ')>)>?'A ArVc$V^8dQhRRRRRR/#)rLrnr}rOrPrarrR)rSs"rTrUrs&PPPsPtPrVc "VP'dQ\\4;_uu_4VPP\ V4VR7GRjxL RRR4R#R#L +'giR#;i5i)rpN)rrr set_typingr)rrnrOs&&&rT _set_typingMatrixAdapter._set_typingsU <<<)$$ll--fWow-OOO%$ O%$$s.*A=*A)A'A) A='A)) A: 4 A=c$V^8dQhRRRRRR/#)rLrnr}rrrarrR)rSs"rTrUrs#///8P/\`/rVc F"VPVR4GRjxL R#L5i)0uNrV)rrnrs&&&rT send_typingMatrixAdapter.send_typingsw... !!c V^8dQhRRRR/#)rLrnr}rarrR)rSs"rTrUrs++++rVc F"VPV^4GRjxL R#L5i)rNr[)rrns&&rT stop_typingMatrixAdapter.stop_typingsw***r^finalizec ,V^8dQhRRRRRRRRRR/#) rLrnr}rorrcrQrar=rR)rSs"rTrUrs8DD#D3DD[_DlvDrVc v"VPV4pVPV4pRRRRV 2RV/pRV9d VR,VR&RV9dRVR&RVR, 2VR&R R R V/VR &\V4\8dVP RR 4VP RR 4RVR&\V4\8dVP RR 4\\V4, pVP R4R \ ^V^,4PRR4p RV R2VR&VPW4GR jxL #L5i)rm.textrz* z m.new_content m.mentionsformatted_bodyorg.matrix.custom.htmlrSr m.replacer m.relates_toNrfr}ignoreu…) rrr_MAX_CONTENT_BYTESpopr~rdecode_send_content_event) rrnrorrc formatted new_contentrrfallbacks &&&&$ rT edit_messageMatrixAdapter.edit_messagesT''0 66yA '0(Fb DTVegr&s ; &(3L(AK % { *$L& \dSp \PR\T4T 4\R4p TPYY4TR7GRjxL uRp ? #Rp ? ii;iLh5i) r is_safe_urlz2Matrix: blocked unsafe image URL (SSRF protection)rNz'Matrix: failed to download image %s: %sz+platform.matrix.media.image_download_failedrxrrr) tools.url_safetyr{rrr send_image!_download_external_media_with_caprrvremit_media_warning_upload_and_send) rrnrwrxrrr{r"ctfnamerrsrs &&&&&& rTrMatrixAdapter.send_images 19%% NNO P+G\d+ee e {$($J$J9$UUODe **7%YPWcklllfU { NNDFYZcFdfi jFGH00Gqy0zzz z {msl?C'BC'BBB$C'<C%=C'B C"ACCCC"C'C""C'c V^8dQhRRRR/#)rLrpr}raztuple[bytes, str, str]rR)rSs"rTrUrs<+<+3<+CY<+rVc 6a"^RIHpV!V4'g \R4hRV3RllpVPR^4R,P R4^,;'gRp^RIp\ SP4wrgVP!R/VB;_uu_4GRjxL pTp \^4EFDp VP!V 3R VP^R 7R R /VB;_uu_4GRjxL p V PR9dfV PPR 4p V 'g \R4h\W4p V!V 4'g \R4hRRR4GRjxL KV P4T!YP P#R4\%V RR4;'gV PPRR44GRjxL wrWV3uuRRR4GRjxL uuuRRR4GRjxL # \R4hELfEL LLEL0L +GRjxL 'giEK};i +GRjxL 'giR#;i \&Ed=^RIHpSP'dRSP/M/pR\*./TR&T!R/TB;_uu_4GRjxL pTP-RTR^R7;_uu_4GRjxL p T P4T!YP/4T PPRR44GRjxL wrYT3uuRRR4GRjxL uuRRR4GRjxL u# +GRjxL 'giM;iRRR4GRjxL R# +GRjxL 'giR#;ii;i5i)zFDownload external media while enforcing redirect safety and size caps.rzzblocked unsafe media URLcV^8dQhRR/#)rLraztuple[bytes, str]rR)rSs"rTrUEMatrixAdapter._download_external_media_with_cap..__annotate__s 1 1>O 1rVc<"\VPPR4;'gVPPR44pVe.VSP8d\ RV RSP R24h.p^pVRjxL pV\ V4, pVSP8d\ RSP R24hVP\V44Kb \dRpLi;iLpDq\T;'gR4PR ^4^,P4P4pTPR 4'g \ R 4hR PT4T3#5i) zJEnforce Content-Length + streamed size caps, then require an image/* type.zContent-Lengthzcontent-lengthNzmedia exceeds Matrix limit ( >  bytes)zmedia exceeds Matrix limit (> rfr*rzexternal media is not an imagerV)rPheadersrrrrrrrxr}rrrrr)rLchunks content_typesizerutotalrrs&&& rT _read_cappedEMatrixAdapter._download_external_media_with_cap.._read_cappeds\ 4<<++,<=ccAQAQRbAcdD4+@+@$@ #?vSI^I^H__f!ghh!#EE% + +eU#4000$'EdF[F[E\\c%dee U5\*    +v |11r288a@CIIKQQSL**844 !ABB88E?L0 0s[E8AC% 7E8C:C8C: AE8% C52E84C55E88C::E8 AE8E8rrrz image.pngNrO)rallow_redirectsFLocationzredirect missing Locationzblocked unsafe redirect URLirz content-typeapplication/octet-streamztoo many redirects)create_ssrf_safe_async_clientrresponse event_hooksGETT)follow_redirectsrOrR>-./34)r~r{rrsplitrrr?rrrr ClientTimeoutrrrraise_for_statusr iter_chunkedrrrr@stream aiter_bytes)rrpr{rr_aiohttp_sess_kw_req_kwr fetch_urlrrLlocationr"rr _httpx_kwsf& rTr/MatrixAdapter._download_external_media_with_caps0378 8 1 1& 3"2&,,S1!4CC " + & 8 I H--9999T rA#xx! o+3+A+A+A+K o]b ofm o o orv;;*CC'+||'7'7 'CH#+&01L&M M)0 (DI#.y#9#9&01N&O O$ o o o--/)5 ,,";";E"B#D.$?\\#||//@Z[*]$] $# o o o:99"&!!566+: o$] o: o o o o:999, + F<@OOOw8QSI(25H4I'JIm $4AyAAAT;;ucDRT;UUUY]))+%1..0$,,2B2B>Sm2n&p p pHDU? VUUBAAUUUUBAAAAA +sAN"N&9IH I#AH1(H)H1,4H !0H  H1H H1#?H #$H H  H  H1H H1% I2H3I7N8 H1IH1 H1 H H1IH.H H.%H.' H11I 7H:8 I I I N I#N20N"J% #N'"M7 K  M7AM L M  M7+L. ,M71 N>M?NNM  M M M M7# N.M1/N4N7N =N> N N NNNNc 0V^8dQhRRRRRRRRRRR R /#) rLrnr} image_pathrxrrrrrar=rR)rSs"rTrUr)Dqqq(+q6CqVcq*q6@qrVc H"VPWRW4VR7GRjxL #L5i)rr|N_send_local_file)rrnrrxrrs&&&&&&rTsend_image_fileMatrixAdapter.send_image_file)(**7 7go*pppp " "c ,V^8dQhRRRRRRRRR R /#) rLrnr}imagesr\rr human_delayrrar=rR)rSs"rTrUr.s;ggg$9gE]gg%/grVc "V'g\RRR7#^RIHp\V4pRp\ V^R7FwpwrV^8d&V^8d\ P !V4GRjxL V 'dV^8d V RV RV R2M T ;'gRp V PR 4'd*VPW!V R ,4WR 7GRjxL p MVPWWR 7GRjxL p V P'g"\PR WV P4T;'g V PpEK \Yw'dRR7#RR7#LLLq5i)Fzno images to sendr)unquote)rNz (rrzfile://:NN)rnrrxr)rnrwrxrz&Matrix: failed to send image %d/%d: %szall images failed to send)r= urllib.parserr enumeratersleeprrrrrrre) rrnrrr_unquoter deliveredrrwalt_textrxrs &&&&& rTsend_multiple_images"MatrixAdapter.send_multiple_images.sAe3FG G4F  *3F!*D &C&)Q37mmK0007?EAI "SE5'3T\TdTd`dG##I..#33#20GQX 4 mm $w]dxx>>>GU[UaUab!33V^^I+E)94ffJeff1mysTA%E'E( E4EE)#E E E(E)E?)E).EEEc4V^8dQhRRRRRRRRRRRR R R /#) rLrnr} file_pathrxr file_namerrrrar=rR)rSs"rTrUrDsMqqq'*q5BqVcqq2JqV`qrVc F"VPWRW5WF4GRjxL #L5i)rNr)rrnrrxrrrs&&&&&&&rT send_documentMatrixAdapter.send_documentDs%**7x\epppps !!c4V^8dQhRRRRRRRRRRR R R R /#) rLrnr} audio_pathrxrrrris_voicer/rar=rR)rSs"rTrUrIsD...(+.6C.Vc.*.=K.Wa.rVc "VRJdVPWRW4VRR7GRjxL #Rp\V4P4PR 4'g'\P !\ VR^R7GRjxL pTPY;'gTRY4V'd%\V4PR4PMRVRR 7GRjxL V'd8\\4;_uu_4\P!V4RRR4##LLLG +'gi#;i T'dK\\4;_uu_4\P!T4RRR4i +'gii;ii;i5i) u.Upload audio. The base media dispatch calls this with ``is_voice``: True for a voice-tagged attachment → MSC3245 voice bubble; False for an audio-ext MEDIA attachment → plain ``m.audio`` in the original format. Voice bubbles need Ogg/Opus but callers pass any format (e.g. TTS output), so transcode there — best-effort: without ffmpeg the original is sent. Callers that don't pass the flag (``play_audio``) keep the voice-bubble behavior this method was written for (#116776: the dispatch always passes ``is_voice``, and rejecting it dropped the file).Fr)rrN.ogg48k)bitraterOT)rrr)r.oga.opus)rr}rrr to_threadrAr with_suffixrrr1r*r)rrnrrxrrrconverted_paths&&&&&&& rT send_voiceMatrixAdapter.send_voiceIs= u ..YH_d/ff f(,:$$&//0IJJ#*#4#45JJ`eoq#rrN ...55:y'HV4 +77?DD\`!D /22 g&&IIn-'&f s2'&g&&IIn-'&&&s FDAF8D9F>D+.s(Ivnuij!DL`L`abLcJdJdnus),c3J<"TFpSPV,xK R#5irt) _EA_REACTIONSrs& rTrxrsAA$,,Q//s #c<SPPS4pV'dSPPVR4VSPS&\ SSWVR7#)N)rmrnrorprr)rrrrnrl)ro requesterrr old_eventrnrrms&&& rT_make7MatrixAdapter._send_exec_approval_prompt.._makesY88<<[II//33ItD@D IvnuIv@v w EAAEEAAA %116>> W '// T??E43R3RT]_ikk kks?D8C,D81D62D8c4V^8dQhRRRRRRRRRRRR R R /#) rLrnr} providersrN current_modelcurrent_providerrmrrrar=rR)rSs"rTrUrsD'+#SS S . 6&'78N D=F__"_M_AEE&M//R0!3_ M:C//r/`/QUUS^M_0+/0/ `-. , -q1W_l_w_wpw/x /.:S:SG T5Wa5ce5 2 35/1?BCaco?p ;E;Hm]& 6GEN&|'7'7 'FQF LLE7"XJf]OD[a$vhgij k@q&& UG[XOrOr  1NS  .-N .N`s(J&J&I= ,I=:"I=I=6I=,MatrixAdapter._send_picker..s6IJKY`'97]rVN)rr) rrnrryrmrzrrrs &f&fff&&&rTrMatrixAdapter._send_pickersD// TYYu%x ] gu && &&s 1><>c 0V^8dQhRRRRRRRRRRR R /#) rLrnr}titleryrNrmrrrar=rR)rSs"rTrUrsDCCC#&C15CDGC*C6@CrVc 6"VP'g\RRR7#/pVR.p\\V4Fwr\ V P R4;'gR4p \ V P R4;'gT 4p V P R4'd\ RV R 7p WV &VPV R V 24K V'g\RR R7#VR\ R 4., pVPWWtWVVPR 4GRjxL #L5i)zVReaction-based choice picker (/reasoning, /fast); choice = {value, label, is_current}.Frrrfrr is_currentz%platform.matrix.picker.current_suffix)r z No choicesz#platform.matrix.picker.react_choice choice pickerN) rr=r_MATRIX_CHOICE_PICKER_REACTIONSr}rrrrr) rrnr,ryrmon_choice_selectedr emoji_choicesrrchoicerrs &&&&&&& rTsend_choice_picker MatrixAdapter.send_choice_pickers |||e?C C(*   !@'JME 7+11r2E 7+44u5Ezz,''AO#(% LLE7!E7+ , Ke<@ @ "a=>??&& M8J  0 0/CC CCs%A;D>D2DADDDc V^8dQhRRRR/#)rLrr}rarR)rSs"rTrUrsCCcCcCrVc 2\P!RRV4#)zMMarkdown passes through; strip image markdown (media is uploaded separately).z!\[([^\]]*)\]\(([^)]+)\)z\2rX)rrs&&rTrMatrixAdapter.format_messagesvv15'BBrVcDV^8dQhRRRRRRRRRRRR R R R R R RRR RR/ #)rLr_r}r"rxfilenamerrrxrrrrrrQvoice_metadatarar=rR)rSs"rTrUrsz$D$D$D"'$D36$DFI$DTW$D$D1>$DQi$D$D1I$DU_$DrVc 4"\V4VP8dVP\V44#Tp Rp VPV4GRjxL 'd^RIHp V !V4wrVPPWV\V 4R7GRjxL pRTRT;'gTR R TR \T4//pT e$/T P4CR \T4/CTR &M\T4TR &T 'd`/TR&RUu/uF'pT ;'g/PT4;pfK$TTbK) ppRT9dTR,TR ,R&T'dTTR&TPTYxR7TP!TT4GRjxL #EL4 \ d7p\PRT4\R\T4R7uRp?#Rp?ii;iEL4 \ d7p\PRT4\R\T4R7uRp?#Rp?ii;iuupiL5i)N)encrypt_attachmentz(Matrix: attachment encryption failed: %sFr) mime_typer;rzMatrix: upload failed: %srrrmimetyperrpfilezorg.matrix.msc3245.voicerhzorg.matrix.msc1767.audior)rhrz)rr_media_too_large_room_needs_encrypted_uploadmautrix.crypto.attachmentsr>rrrer=r}r upload_media serializerrrp)rr_r"r;rrrxrrrr< upload_dataencrypted_filer>rmxc_urlrkrwaudio_metadatas&&&&&&&&&&& rTrMatrixAdapter._upload_and_sends t9t,, ,((T3 3 227; ; ; AI.@.F+  = LL55hSQ\M]6__G w(;(;8VjR^`fhklphqEr't  %"U^%=%=%?"UG "UK !$WK  68K2 36l6AUAUSU@Z@Z[\@];]116 l^+2@2L F#J/:H 67 %%kH%X--g{CCC9 < A GM!%s3x@@ A_ = LL4c :e3s8< < =lDsA HF HF,*G G G  H'AH7 H HH&H-#H-H>H?H G+G<G=HGH G H+H HH H Hc V^8dQhRRRR/#rLr_r}rarQrR)rSs"rTrUrs  # $ rVc ."VP'd\VPRR4'gR#\VPRR4pV'gR#\VP \ V44GRjxL 4#L \ dR#i;i5i)zLE2EE on, Olm machine loaded, and the state store says the room is encrypted.rNFr)rrrrQ is_encryptedrr)rr_rs&& rTrC*MatrixAdapter._room_needs_encrypted_uploadst   WT\\8T%J%JdllM4@  k66vgGGH HG  s<AB"B8B9BBB BBBBc V^8dQhRRRR/#)rLrrPrar=rR)rSs"rTrUr snnSnZnrVc >\RRV RVP R2R7#)Fz!Media file exceeds Matrix limit (rrr)r=r)rrs&&rTrBMatrixAdapter._media_too_large s.#DTF#dNcNcMddk!ln nrVc$V^8dQhRRRRRR/#)rLr_r}rrbrar=rR)rSs"rTrUr$s"===>=V`=rVc "VPP\V4\PV4GRjxL p\ R\ V4R7#L \d!p\ R\ T4R7uRp?#Rp?ii;i5i)zISend a prebuilt m.room.message payload, mapping exceptions to SendResult.NTrFr)rr#rrr!r=r}r)rr_rrrs&&& rTrp!MatrixAdapter._send_content_event$sg =!\\<8B9B>BBc<V^8dQhRRRRRRRRRRRRR R R R R R/ #)rLr_r}rrrxrrrrrrrQrar=rR)rSs"rTrUr,scCCC'*C58CCPCC3@CSkCC$.CrVc "\V4P4p V P4'gI\P RVP V4\ R4p VPWWEVR7GRjxL #V P4Pp WP8dVPV 4#T;'g V P p V'd$\P!\V 4GRjxL MRp TP!YP#4T \$P&!V 4^,;'gRVWEWxV 4 GRjxL #L \d^p Li;iLmL5i)z1[%s] upload fallback: media file not found for %sz'platform.shared.media.attachment_failedr}Nr)r rr9rrrrrstatst_sizer1rrBrrrr read_bytesrr)rr_rrrxrrrrr<rJ file_sizerr<s&&&&&&&&& rTrMatrixAdapter._send_local_file,s@ O & & (xxzz NNNPTPYPY[d e>?D00mu0vv v ((I ,, ,((3 3##QVVYaw001PRSTTTfj** \\^UI,@,@,G,J,h,hNhjq x>CC Cw I UCsgA3E$5E 6E$;E )E$?E$E$2E 3AE$8E$E"E$ EE$EE$"E$cV^8dQhRR/#rrR)rSs"rTrUrDs''$'rVc "VPpVPP4GRjxL pVP'g\P !VP VRR7RR7GRjxL p\V\4'dDVPW4GRjxL ;'gTp\P!^4GRjxL KKR#LLcL6L \PdR#\dpTP'dRp?R#\T4'd\PRT4Rp?R#\P!RT4\P!^4GRjxL Rp?EKLRp?ii;i5i)NrZ)sincerOF@rpz/Matrix: permanent auth error, stopping sync: %su)Matrix: sync error: %s — retrying in 5s)rrget_next_batchrrr"rrrrrrrrrrer)rrH next_batchrrs& rTrMatrixAdapter._sync_loopDs!,,;;== --- '#*"2"26;;ZY^;3_im"nn i..'+'8'8'K!K!Y!YzJ!--***/  > o!K*))  '===2377LL!RTWXJCPmmA&&&& 's*FCF,C0C1.CC C+CCC FCCCF/F2F;F<E=F'E=;F/E=0E31E=6F=FFrc(V^8dQhRRRRRRRR/#) rLrHr rrbrrQrarrR)rSs"rTrUr[s*UYfsrVc "\P!4VnVPR/4PR/4pV'g V'd:VPP VP 44VP 4VPWA4VPR4pV'd$VPPV4GRjxL V'dB\PR\VP44VP4GRjxL VPV4GRjxL VP#V4V#LzL3L \d,p\P!RT'dRMRT4Rp?LJRp?ii;i5i) zApply one sync response: joined rooms, next_batch, event dispatch, pending invites. Returns next_batch. The initial (full-state) sync also seeds the DM cache and dispatches so the OlmMachine sees to-device key shares queued while offline.roomsrrdNz.Matrix: initial sync complete, joined %d roomszMatrix: %s: %sz!initial sync event dispatch errorzsync event dispatch error)rrrrupdaterA_invalidate_room_identities_warn_encrypted_dropsrput_next_batchrrr_refresh_dm_cache_dispatch_syncrr_schedule_pending_invite_joins)rrHrr rooms_joinnbrs&&&$ rTrMatrixAdapter._absorb_sync[s9"YY[]]7B/33FB?     % %joo&7 8  , , . "":6 ]]< ( ##2226 6 6  KKH#dN`N`Ja b((* * * C%%i0 0 0 ++I6  7 + 0 C NN+T[-Pa|B C C CsmA F BF E  F .s3b[aUW:b$'PPBFF6N>P,PP[as;;TFrz2, then set MATRIX_E2EE_MODE=optional (or required)z E2EE mode is z_ but the decryptor was not set up at connect; see the earlier Matrix E2EE warning for the causeuMatrix: dropping encrypted messages in %s — this process has no E2EE decryptor. %s. Without it, messages in encrypted rooms never reach the agent.) rrBrrrr&rrrr)rrprHr_ room_datarvcauses&&& rTrk#MatrixAdapter._warn_encrypted_dropsrs 68T * 6 ","2"2"4 G;;;]]:r266xDFsb[absssb[abbb1155g>??e+122deE,T__,=>QQEU$#5rVc V^8dQhRRRR/#rLrrbrarrR)rSs"rTrUrs d dn d drVc "VPpV'd\VR4'gR#VPV4p\P!V4'd VGRjxL pV'dX\ P !VRR/GRjxL pVF1p\V\4'gK\PRV4K3 R#R#LeLA5i)z=Dispatch a sync response through the mautrix event machinery. handle_syncNrTz5Matrix: event handler failed during sync dispatch: %s) rrrinspect isawaitablerrrrrr)rrrHr resultsrs&& rTrnMatrixAdapter._dispatch_syncsWV];; ""9-   u % %KE #NNEJTJJG!fi00NN#Z\bc"  Ks6ACCC C*CCC%CCc V^8dQhRRRR/#rLsenderr}rarQrR)rSs"rTrUrs 8 8c 8d 8rVc VP;'gRP4P4pV'*;'g"VP4P4V8H#)u#True if *sender* is the bot itself (case-insensitive: homeservers vary localpart case). With no resolved user_id we can't prove a sender is NOT us, so return True — dropping our own events beats an echo loop ("hall of mirrors"). Matrix user IDs are byte-compared after trimming whitespace and lowercasing — some homeservers normalize the localpart case differently at different API surfaces, and the reply-loop tail of the "hall of mirrors" bug (#15763) has been observed with the bot's own account bypassing a case-sensitive equality check. rf)rrr)rrowns&& rT_is_self_senderMatrixAdapter._is_self_sendersK}}""))+113w77&,,...0C77rVc V^8dQhRRRR/#rrR)rSs"rTrUrs : :C :D :rVc T;'gRP4PR4PR4^,pV'*;'gVPR4#)uFTrue for appservice/bridge/system identities (``@_telegram_123:server``) or malformed IDs. Never offer these a pairing code: an approved bridge would relay every outbound message back as an "authorized user message" (echo loop). We treat these as system identities for pairing purposes: they should never be offered a pairing code, because an operator approving the code would hand the bridge itself permanent authorization — and every outbound message relayed by the bridge would then loop back into the agent as an "authorized user message", which is the root of issue #15763. rf@rr)rlstrip partitionr)r localparts& rT_is_system_or_bridge_sender)MatrixAdapter._is_system_or_bridge_sendersN\\r((*11#6@@EaH }99 4 4S 99rVc V^8dQhRRRR/#rNrR)rSs"rTrUrs34rVc "VP'dWP9dR#VPV4GRjxL #L \d"p\P RY4Rp?R#Rp?ii;i5i)zXMATRIX_ALLOWED_ROOMS gate; DMs are exempt so personal chats survive a project allowlist.TNzEMatrix: could not resolve room identity for allowlist check in %s: %sF)r _is_dm_roomrrr)rr_rs&& rT_is_allowed_matrix_room_event+MatrixAdapter._is_allowed_matrix_room_events]%%%4J4J)J ))'22 22  LL`bi o s>%A2AAAA2A A/A*$A2*A//A2cV^8dQhRR/#rrR)rSs"rTrUrs . .D .rVc 0^VnRVnRVnR#)z_State for _note_late_grace_drop: consecutive-drop count, their skew, and the once-only warning.rFN)_late_grace_drops_late_grace_skew_clock_skew_warnedr7s&rTr(MatrixAdapter._reset_clock_skew_detectors'('*(-rVc V^8dQhRRRR/#)rLevent_tsrrarrR)rSs"rTrUrs++e++rVc VP'g,\P!4VP, ^8:dR#VPV, p^Tu;8d R8gR#R#VP'd;\ W P , 4^<8dV;P^, unM W n^VnVP^8d+\ PRVPV4RVnR#R#)ulClock-skew heuristic for grace-check drops well after startup. A host clock set ahead of real time makes every live event look "older than startup" and the bot silently never replies. Warn once when drops keep happening >30s after startup with a *consistent* skew — unlike backfill from a freshly invited room, whose event ages vary widely and reset the counter.NiQu1Matrix: dropped %d consecutive live events as 'too old' more than 30s after startup (skew ≈ %.0fs). The host system clock is likely set ahead of real time, which causes the startup grace filter to silently discard every incoming message. Run `timedatectl set-ntp true` (or sync NTP) and restart the bot.T)rrrrrurrr)rrskews&& rT_note_late_grace_drop#MatrixAdapter._note_late_grace_drops  " " "diikD4D4D&D&J (*D 5 !   ! ! !c$1F1F*F&G"&L  " "a ' "$( !%&D "  ! !Q & NNPRVQgQgim  o '+D # 'rVc V^8dQhRRRR/#rLrr rarrR)rSs"rTrUrs/m/mC/mD/mrVc a "\\VRR44p\\VRR44o \PR\VRR4S V4VP S 4'dR#VP S 4'd\PRS V4R#\ ;QJd)V 3RlVP4F 'gK R M R M!V 3RlVP44'd\PR S V4R#VPV4GRjxL 'g\PR V4R#\\VRR44pVPV4'dR#\V4pV'd/W@P\, 8dVPV4R#\VR R4pVfR#\V\ 4'dYUP#RR4rvMM\%VR4'dVP'4M/p\%VR4'd\VP(4MRpVP#R/4pVP#R4R8XdR#VR8XdVP*'gR#VR9d VP-VS W4WhV4GRjxL R#VR9dVP/VS W4Wh4GRjxL R#R#ELL0L 5i)r_rfru1Matrix: callback fired — event %s from %s in %srrrNz.Matrix: ignoring system/bridge sender %s in %sc3X<"TFqPS;'gR4xK! R#5i)rfN)search)rvr!rs& rTrx1MatrixAdapter._on_room_message..s#W;V~~fll++;Vs**TFzAMatrix: ignoring sender %s in %s due to configured ignore patternz2Matrix: ignoring message from unauthorized room %srrrFrkrrjm.notice)rrrr)rfr)r}rrrrrrrrrr'rr_STARTUP_GRACE_SECONDSrrrrrrFrr _handle_media_message_handle_text_message) rrr_rrrsource_contentrr rs && @rTrMatrixAdapter._on_room_messagesQgeY34WUHb12 ?PZ\_A`bhjq s    ' '   + +F 3 3 LLI6SZ [  3W4;V;VW333W4;V;VW W W LL\^dfm n 77@@@ KKLg V wuj"56  # #H - - 259 #3#36L#LL  & &x 0 %D1 ?  gt $ $&-{{9b/IG4;G[4Q4QW..0WYN.5gy.I.Ic'//*rG#''; >>* % 4  j )>)>)>  A A,,WfhR`nuv v v . .++GVXQ_l l l/7A4 w ls[A?K#K'K'K0-KK  K(EKACGSWCGCG+/CG(CG4CCGrVc "VPV4GRjxL p VPV4GRjxL p V 'dRMRp \V4p T;'gVPWE4p V 'Eg'VP'd)WP9d\ P RW14R#WP9p\T ;'dWP94pVP'djV'gbV'gZV 'gQVPR4'g:VeVPPWWWV4\ P RW14R#MBVP'd1V'd)V'g!V 'g\ P RW<4R#V 'dbVP'dPVPR4'd(\!V4wppVVP#V4,pMVP#V4pV 'gxV 'd,VP$;'d T ;'g VP&pM:VP(R 8H;'g$VP(R 8g;'d VP*pV'dTp VeVPP-WV4VP/W4GRjxL pTP1YP2YTYP4V P6V 'dTMRVR 7 pV 'd$VPP9V 4GRjxL VP;W4WJWVV3#EL"EL LL#5i) aKShared mention/thread/DM gating. Returns (body, is_dm, chat_type, thread_id, display_name, source) or None when the message should be dropped. ``mention_claimed`` marks a parked voice claimed by the sender's follow-up bare @mention; ``voice_gate`` is the in-flight mark of a parkable voice, released once the park decision is made.Nr.ruPMatrix: ignoring message %s in %s — room not in MATRIX_ALLOWED_ROOMS whitelistru_Matrix: ignoring message %s in %s — no @mention (set MATRIX_REQUIRE_MENTION=false to disable)uVMatrix: ignoring message %s in thread %s — no @mention (thread_require_mention=true) m.in_reply_torr) rn chat_namerhr user_name thread_id chat_topicguild_idr&ro)r/rr_content_mentions_botrrrrrQrrrrparkrrr_strip_mentionrrr rrelease_get_display_name build_sourcerfrarcr(_background_read_receipt)rr_rrrrr rrr0is_dmrhr is_mentioned is_free_room in_bot_thread quote_block reply_text syntheticrfsources&&&&&&&&& rT_resolve_message_context&MatrixAdapter._resolve_message_contexts44W==&&w//!Dw  , &ZZ$*D*DT*Z u"""w6I6I'I fhp{"&6&66L !I!IyMM/IJM$$$\-#DOOC,@,@!-++00*XfsLLHIQ\ ---- ]i l) D111 ~~o..*?*E' Z"T%8%8%DD**40!55FF,__4K_K_  66(BPP..&8NNT=N=N$  !    ' ' D!33GDD ""'<'< "iDWDW))Y'TXem#o --**95 5 5 %%g8I,FFw>/dE 6sML9ML< MMM0MAM$M+M3M;MMA M&M.M6M>MM0M?MMM" M,#MM'M<6M2L?3A M?MMM<M?MMc(V^8dQhRRRRRRRR/#)rLr_r}rr rrazFtuple[str, Optional[str], Optional[str], Optional[str], Optional[str]]rR)rSs"rTrUrYs2WWW"%W37W OWrVc &"VPR4;'g/PR4pR;p;rgV'dQVPR4'd:\V4wrV\V4pV'dVP W4GRjxL pW$WVV3#L 5i)zReturn (body, reply_to, reply_to_text, reply_to_author_id, reply_to_author_name). Captures the inline reply fallback (``> <@user:srv> text\n\nreply``) BEFORE stripping it, so the prompt layer can render "[Replying to: ...]" like Signal/Slack/Telegram.rrNr)rrrrr)rr_rr r reply_to_textreply_to_author_idreply_to_author_names&&&& rT_extract_reply_context$MatrixAdapter._extract_reply_contextYs NN?399r>>zJDHH H* --0G0M -M(.D!-1-C-CG-`'`$}BVVV(asAB4BB Bc8V^8dQhRRRRRRRRRRRRR R R R /#) rLr_r}rrrrrr ctxrrazOptional[MessageEvent]rR)rSs"rTrUrisL===$'=36=>A=SW=ei= =1G=rVc "VfVPWW4WV4GRjxL pVfR#VwrIrrVPWV4GRjxL wrNpppVPRR4pVfG\V4pVP R4'd\ P M\ PVR&M\VV4'dRp\RRVRV RVR VR VR VR VR VRVRV / VB#LL5i)aLGate + normalise an inbound event into a MessageEvent (None => drop). Text body may still change (reply-fallback strip); ``extra`` carries media fields / message_type. ``ctx`` is a pre-resolved ``_resolve_message_context`` result (media path gates before downloading); resolving it twice would double the read receipt / thread mark.N media_msgtyper message_typerfrJr raw_messageroreply_to_message_idrrrrrrR) rrrnrrrCCOMMANDTEXTrrB)rr_rrrrr rr_is_dm _chat_type _thread_idrfrrrrrrs&&&&&&&&, rT_build_inbound_event"MatrixAdapter._build_inbound_eventis- ;55gxWerrC ;EHBjl--gZH H P '9;O /48  1$7D;???3;O;OK$7$7U`UeUeE. ! $]D 9 9D==$=2@=MU= (=8E=Zl="6=  = '3 = 7< = =s Is"C C%C CBC C c4V^8dQhRRRRRRRRRRR RR R /#) rLr_r}rrrrrrr rarrR)rSs"rTrUrsD111$'1361BG1Y]11!1rVc b"VPRR4;'gRpV'gR#VPPW4'dVPV4P 4'gVP Wu4'dVPP 4pVPPW4GRjxL VPPWVR7p V 'd7V wrp VPWWWRRR7GRjxL VPW4R#VPWV\V4WV4GRjxL p V fR#V P\P8Xd%VP ^8dVP#V 4R#VP%V 4GRjxL R#LLLlL 5i)rrfN)beforerT)r)rrr rrrmarksettleclaimrrrrrrCrr_enqueue_text_eventhandle_message)rr_rrrrr rlimitparkedvoice_id voice_content voice_relates msg_events&&&&&&& rTr"MatrixAdapter._handle_text_messages!!&"-33     ' ' 8 8++D17799d>X>XY]>n>n'',,.E%%,,W= = =((..wu.MF9?600XW`$(1***--g@33 X'Ed'K^ii     ! ![%5%5 5$:X:X[\:\  $ $Y /%%i0 0 0! >* i 1sV$F/AF//AF/>F'?AF/F)7F/>F+?A!F/ F-!F/)F/+F/-F/c<V^8dQhRRRRRRRRRRR RR RR R R R/ #)rLr_r}rrrrrrr rrrQrarrR)rSs"rTrUrsT;1;1;1$';136;1BG;1Y];1;1#&;19=;1JN;1rVc  4"VPRR4;'gRp VPRR4p V 'd9\V 4PR4'g\P RV4R#VPR/4p \ V \ 4'g/p V PRR4p \V PR4;'g^4p V 'd4WP8d$\P R W=VP4R#VPR /4pV 'gs\ V\ 4'd]VPRR4;'gRp V 'd9\V 4PR4'g\P R V4R#\T;'d*\ V\ 4;'dVPR44pVPW|V4wpppVPWWVV4'dVPPW4MRpVP!WW9WVVVR 7GRjxL pVeVPP#WV4TfR#RpT 'd*TP%YT'dTMRTTTT 4GRjxL pT 'dT'gTP)T 4MRpT'dT.M T'dT.MRpTP+YY9YVTTTT'dT.MRTR7 GRjxL pTeTP-T4GRjxL R#R# \\3d^p ELei;iEL TeTPP#YT4ii;iL \&d!p\P R T4Rp?LRp?ii;iLL}5i)rrfrpmxc://z4[Matrix] Rejecting inbound media %s with non-MXC URLNrr@rz=[Matrix] Rejecting oversized inbound media %s (%d > %d bytes)rAz>[Matrix] Rejecting inbound encrypted media %s with non-MXC URL)rrz"[Matrix] Failed to cache media: %s)rr media_urls media_typesr)rr}rrrrrrPrrrrQ_classify_inbound_media_voice_may_parkrbeginrr_download_and_cache_mediar _mxc_to_httprr)rr_rrrrr rrrrp content_infoevent_mimetypeevent_size_int file_contentis_encrypted_mediamsg_type media_typeis_voice_messagegater cached_pathehttp_urlrrs&&&&&&&&& rTr#MatrixAdapter._handle_media_messagesX!!&"-33  + s3x**844 NNQS[ \ %))&"5 ,--L%))*b9  !1!1&!9!>!>Q?N n/D/DD NNOQY%% ' %))&"5 z,55""5"-33C3s8..x88_aij!,"m"m:lD3Q"m"mVbVfVfglVmn151M1Mggu1v.*.>B=Q=Q >>H>Ht""((9MQ  C55]l6!!C##++GTB ;   H$($B$B3E<4QY[e$d%,, .19K4$$S)QS&1k]h TX 33 X^S_g!z |tcj4ll   %%i0 0 0 !Y:& N *!##++GTB , HCQGG H l 1s6NA4N.L! L!NA N'.N N!AN'N?A"N"L>;L;<L>/N1#M&M$M&N!N)N N,N;N<NNN!L84N7L88N;L>>#M!!N$M&& N1N N NNNc(V^8dQhRRRRRRRR/#)rLrr}rrrraztuple[MessageType, str, bool]rR)rSs"rTrUrs2 Y Y Y*- Y?C YHe YrVc ZVR8Xd\PT;'gRR3#VR8XdA\V4pV'd\PM\PT;'gRV3#VR8Xd\P T;'gRR3#\P T;'gRR3#) zIMap a Matrix media msgtype to (MessageType, mime type, is_voice_message).r image/pngFrz audio/oggrz video/mp4r)rCPHOTOrHVOICEAUDIOVIDEODOCUMENT)rrrrs&&& rTr%MatrixAdapter._classify_inbound_medias i $$n&C&C UJ J i '7H)1K%%{7H7H>KhKh]hjrr r i $$n&C&C UJ J##^%Q%Q7QSXXXrVc8V^8dQhRRRRRRRRRRR R R RR R /#)rLrpr}rrHrrrCrrrQrrarrR)rSs"rTrUrsVKKK"%K7EKQ\KjmKK&)K.;KrVc "VPP\V44GRjxL pVfR#Ve^RIHp VP R4VP R4r\ V \4'dV P R4MRp \ V \4'dV P R4MT p VP R4p V 'dV 'd V 'g\PRV4R#V !WW4p^R I H pH pH pV\P8XdER R R R RRRR/pV!VVP VR 4R7GRjxL p\P!RV4V#V\P"\P$09dF\'T;'g V'dRMR4P(;'gRpV!VVR7GRjxL #T;'gV\P*8XdRMRpV!VV4GRjxL #ELLL=L 5i)zRDownload (and decrypt, when *encrypted_file* is given) media into the local cache.N)decrypt_attachmenthashesr sha256rJivzA[Matrix] Encrypted media event missing decryption metadata for %s)cache_audio_from_bytes_asynccache_document_from_bytes_asynccache_image_from_bytes_asyncz image/jpeg.jpgr .pngz image/gif.gifz image/webp.webp)extz [Matrix] Cached user image at %sz voice.oggz audio.oggrz video.mp4document)rdownload_mediarrDrrrrrrgateway.platforms.baserrrrCr rr r r rr)rrprrHrrrr file_bytesr hashes_value key_value hash_valueiv_valuerrrext_maprrr;s&&&&&&&& rTr'MatrixAdapter._download_and_cache_medias <<66z#GG    % E&4&8&8&BNDVDVW\D])7A,PT7U7U))(3[_J.8D.I.I c*yI%))$/H*bdlm+J:XJ  {(( (#V[&+vWcelmG > NNUW^ h  F[ ""76Q6QDM[b"cs B0C3Cc V^8dQhRRRR/#rNrR)rSs"rTrUr scdrVc "V'dWP9d \V4#VPP\ V44GRjxL VPP V4VP V4\PRV4VP4GRjxL R#L`L \dp\PRY4\T4P4pRT9gRT9dx\\4;_uu_4TPP\ T44GRjxL \PRT4RRR4M +'giM;iRp?R#Rp?ii;i5i)NzMatrix: joined %sTzMatrix: error joining %s: %sz no serverszroom not foundz"Matrix: declined dead invite to %sF)rrQr join_roomrr&rjrrrmrrr}rr leave_room)rr_rmsgs&& rT_join_room_by_idMatrixAdapter._join_room_by_id s'%7%77=  ,,((9 9 9    " "7 +  , ,W 5 KK+W 5((* * * : +  NN97 Hc(.."C#)9S)@i((,,11&/BBBKK DgN)((( sx$F'B3B/AB3(B1)B3-F/B31B33 E=>AE8(E:D= ;E E8 E/ *E82F8E==Fr+r.rfc(V^8dQhRRRRRRRR/#)rLr_r}r+rQr.rarrR)rSs"rTrUr/ s0OOSOOWZOdhOrVc aaaaSPPS4pS'd0SSP9gV'dVP4'gR#RVVVV3Rllp\P !V!44SPS&R#)zCSchedule an invite join without blocking sync or gateway readiness.NcV^8dQhRR/#rrR)rSs"rTrU9MatrixAdapter._schedule_invite_join..__annotate__5 s ; ;D ;rVc<"\P!SPS4RR7GRjxL pV'd+S'd#S'dSPSS4GRjxL SPPSR4R#LTL$ \d\ P RS4LEi;i SPPSR4i;i5i)rbrpNz#Matrix: timed out joining invite %s) rr"r7_record_dm_room TimeoutErrorrrrrn)joinedr.r+r_rs rT _join_invite9MatrixAdapter._schedule_invite_join.._join_invite5 s ;&//0E0Eg0NX\]]iG..w@@@''++GT: ^@ ODgN O''++GT:sgC*BB BBB B!B"B&CBB!B,)B/+B,,B//C  C)rrrrrr)rr_r+r.existingrAsffdd rTr0#MatrixAdapter._schedule_invite_join/ sa**..w7'T%7%77HX]]__  ; ;,3+>+>|~+N(rVc V^8dQhRRRR/#r~rR)rSs"rTrUr@ s"["["[4"[rVc \V\4'dVPR/4M/PR/4p\V\4'gR#VP4Fwr4W0P9dKVP V4wrVVP V\V44'g\PRVV4Kd\PRVV4VP\V4WVR7K R#)z?Join rooms still present in rooms.invite after sync processing.rhinviteNr,z8Matrix: reconciling pending invite for %s (is_direct=%s)r-) rrrrBr_extract_invite_dm_signalr/r}rrrr0)rrinvitesr_ invited_roomr+r.s&& rTro,MatrixAdapter._schedule_pending_invite_joins@ s1;It1L1L9=="-RTYYZbdfg'4(( %,]]_ !G,,,"&!?!? !M I++GS\BBN  KKJ   & &s7|y & Z;&5rVc V^8dQhRRRR/#)rLrJr raztuple[bool, str]rR)rSs"rTrUrd s%%c%>N%rVc VP'gR #\V\4'gR #VPR/4p\V\4'gR #VPR.4p\V\4'gR #VFp\V\4'gKVPR4R8wdK3VPR4VP8wdKUVPR/4p\V\4'gKVPR4R 8wdK\ VPR 44\ VPR R443u# R #) zRead the is_direct flag and inviter from a room's invite_state. The stripped ``m.room.member`` event for our own user carries the ``is_direct`` flag from the original invite; its sender is the inviter. Returns ``(False, "")`` when the signal is absent. rf invite_statervrz m.room.member state_keyr membershiprGr+r)Frf)rrrrrNrQr})rrJrNrvrrs&& rTrH'MatrixAdapter._extract_invite_dm_signald s}}} ,-- #''; ,-- !!(B/&$'' EeT**yy O3yy%6ii 2.Ggt,,{{<(H4 K013uyy27N3OO O rVc(V^8dQhRRRRRRRR/#)rLr_r}rrrarrR)rSs"rTrUr s(  C 3 s } rVc d"VP'gR#RRRRVRV//pVPP\V4\PV4GRjxL p\ P RW24\V4#L% \d"p\ P RT4Rp?R#Rp?ii;i5i) zJSend an emoji reaction; returns the reaction event_id, or None on failure.Nrkrz m.annotationrr zMatrix: sent reaction %s to %szMatrix: reaction send error: %s) rr#rrr"rrr}r)rr_rrr resp_event_idrs&&&& rTrMatrixAdapter._send_reaction s|||!J HV[]b#cd "&,,"A"A&/S\SeSegn"ooM LL95 K}% %p  LL:C @ s@B07BA?$B>B0?B B- B("B0(B--B0c(V^8dQhRRRRRRRR/#)rLr_r}rrrarQrR)rSs"rTrUr s0MMcMcMSVM`dMrVc B"VPWV4GRjxL #L5irt)redact_message)rr_rrs&&&&rT_redact_reactionMatrixAdapter._redact_reaction s((VLLLLs c(V^8dQhRRRRRRRR/#)rLr_r}rrrarrR)rSs"rTrUr s0GGCGCGY\GfjGrVc aaaaRVVVV3Rllp\P!V!44pSPPV4VP SPP 4R#)zBRedact a reaction after a short delay so message delivery settles.cV^8dQhRR/#rrR)rSs"rTrU@MatrixAdapter._schedule_reaction_redaction..__annotate__ s m mT mrVc<"SP'd)\P!SP4GRjxL SPSSS4GRjxL 'g\P RS4R#R#L?L& \P dh\d#p\P RST4Rp?R#Rp?ii;i5i)Nz$Matrix: failed to redact reaction %sz4Matrix: delayed reaction redaction failed for %s: %s)r rrrYrrrr)rrrr_rs rT _redact_laterAMatrixAdapter._schedule_reaction_redaction.._redact_later s m999!--(N(NOOO!227A:A>A< A> A>6C:A><A>>CCB;5C;CCN)rrrr&add_done_callbackr%)rr_rrr`r sffff rT_schedule_reaction_redaction*MatrixAdapter._schedule_reaction_redaction sQ m m""=?3 &&**40 t==EEFrVc V^8dQhRRRR/#)rLrrBrarrR)rSs"rTrUr sOO|OOrVc "VPVPPr2VP'dJV'd@V'd6VP W2R4GRjxL pV'dW@P W23&R#R#R#R#R#L%5i)u👀N)rorrnr rr )rrmsg_idr_rs&& rTon_processing_start!MatrixAdapter.on_processing_start sh**ELL,@,@  " " "v'&*&9&9'<&X X  =N''(9:!3:v " Xs";BBBB B(Bc$V^8dQhRRRRRR/#)rLrrBoutcomerDrarrR)rSs"rTrUr s(ss,sIZs_csrVc "VPVPPrCVP'd&V'dV'dV\P 8XdR#VP PWC3R4pV'dVPWER4TPYCV\P8XdRMR4GRjxL R#L5i)Nzprocessing completerr) rorrnr rD CANCELLEDr rnrcrSUCCESS)rrrkrgr_ eyes_event_ids&&& rTon_processing_complete$MatrixAdapter.on_processing_complete s**ELL,@,@&&&fGwRcRmRmGm //33W4EtL   - -gF[ \!!'wJ[JcJc?c8iqrrrs;C C A:C CC c V^8dQhRRRR/#rrR)rSs"rTrUr srVc @"\\VRR44pVPV4'dR#\\VRR44pVPV4'dR#\\VRR44p\VRR4pV'gR#\ V\ 4'dVP R/4M \VR/4pR;rx\ V\ 4'd&VP RR4pVP RR4pM>\VR4'd-\\VRR44p\\VRR44p\PR WWt4VPVPVP3Fp V !WGW4GRjxL 'gKR# R#L5i) rrfNrr_rrkr r z'Matrix: reaction %s from %s on %s in %s) r}rrr'rrrrrr_handle_approval_reaction_handle_model_picker_reaction_handle_choice_picker_reaction) rrrrr_rr  reacts_tor handlers && rTrMatrixAdapter._on_reaction s]WUHb12    ' ' wuj"56  # #H - - geY34%D1 9CGT9R9Rgkk."5"7L"=  j$ ' '"z26I..+C Z , ,GJ B?@Igj%45C =sI_668Z8Z;;=GW======sFFF FFc<V^8dQhRRRRRRRRRRRRR RR R R R / #)rLrrr_r}rwr rr invalid_textryrraztuple[bool, Any, Any]rR)rSs"rTrUr sT''''*'7:'AD'NQ'Z]'mp'+'7L'rVc  "VPV4p V 'dV P'dR#W*P8wdRV R3#VPV 4'dV!W#V 4GRjxL RV R3#VP W#WZV4GRjxL 'gRV R3#V f V P MT PV4p V fVP W#V4GRjxL RW3#LrLTL 5i)aShared gate for reaction prompts: (handled, prompt, selection). handled=False => not our prompt; selection=None with handled=True => consumed without action (wrong room, expired, unauthorized reactor, or a key that is not a choice). ``choices`` defaults to ``prompt.choices``.NT)FNN)rrrn_matrix_prompt_expired_validate_matrix_prompt_reactorry_send_invalid_reaction_feedback) rrr_rwr rrr{ on_expiredryr selections &&&&&&&&&& rT_claim_reaction_prompt$MatrixAdapter._claim_reaction_prompt s i($ $ nn $% %  & &v . .W8 8 8% %99'f^cddd% %'.V^^GHHM  66w<X X XV&& 9d YsF+C!-C! C!(C)C!C C!?C!C C!C!C!c ,V^8dQhRRRRRRRRRR/#rLr_r}rwr rrarQrR)rSs"rTrUr s2ssQT^afjrVc ^"VPVPWW4R\R4VPVPR7 GRjxL wrVpVfV#^RIHpV!VPV4p V 'dRVnVPPVR4VPPVPR4\PRWPWt4VPW4GRjxL R#LL \d"p \PRT 4Rp ? R#Rp ? ii;i5i) zRResolve a pending exec-approval prompt from a reaction. True if it was the target.rz)platform.matrix.approval.invalid_reaction)ryN)resolve_gateway_approvalTzKMatrix reaction resolved %d approval(s) for session %s (choice=%s, user=%s)z;Failed to resolve gateway approval from Matrix reaction: %s)rrr_expire_matrix_approval_promptrtools.approvalrrmrrnrrr_redact_bot_approval_reactionsrre) rr_rwr rhandledrr4rrrs &&&&& rTrt'MatrixAdapter._handle_approval_reaction s(,(C(C  + +Wj 9 :D<_<_//)D)1#1 >N ] ?,V-?-?HE"&//33ItD0044V5G5GN a--v?99'JJJ'#1 K ] LLVX[ \ \ ]sUAD-C: D- C>5A>C>3C<4C>8D-<C>> D* D%D-%D**D-c ,V^8dQhRRRRRRRRRR/#rrR)rSs"rTrUr s9ee3e3eUXebeejnerVc "VPVPWW4R\R4VPRRR7 GRjxL #L5i)zNApply a model-picker reaction. True if the reaction targeted a pending picker.rz-platform.matrix.picker.invalid_model_reactionT)redact_bot_reactionsN)z switch modelz(platform.matrix.picker.verb_switch_model)_handle_picker_reactionrr"_expire_matrix_model_picker_prompt)rr_rwr rs&&&&&rTru+MatrixAdapter._handle_model_picker_reaction sR11  / /SR` = >@g@g H_c2ee ees:AAAc ,V^8dQhRRRRRRRRRR/#rrR)rSs"rTrUr s9MMCMCMVYMcfMkoMrVc a"V3RlpSPSPWW4R\R4VR4 GRjxL #L5i)zOApply a choice-picker reaction. True if the reaction targeted a pending picker.cH<"SPPVR4R#5irt)rrn)_room_idtarget_event_id_promptrs&&&rT_expire=MatrixAdapter._handle_choice_picker_reaction.._expire s  0 0 4 4_d Ks"r0z.platform.matrix.picker.invalid_choice_reactionN)z apply choicez+platform.matrix.picker.verb_apply_selection)rrr)rr_rwr rrsf&&&& rTrv,MatrixAdapter._handle_choice_picker_reaction sK L11  0 0'cSb > ? KMM MMs 4><>rc@V^8dQhRRRRRRRRRRRRR RR R R R RR / #)rLrrr_r}rwr rrr{verbsrrrQrarR)rSs"rTrUr s\'*7:ADNQZ]mp*EIVZrVc  "VPWW4WVWx4GRjxL wrp V fV #RV nVPVR4\V \4'dT MV 3pV P !V.VO5!GRjxL pV 'dVP W,4GRjxL V'dVPW/VR7GRjxL R#LLLL-L \dlp\PRT ^,T4TPT\R\T ^,4\T4R7TR7GRjxL Rp?R#Rp?ii;i5i)zClaim the picker, fire ``on_selected(room_id, *selection)`` and post its confirmation (or the error). ``verbs`` = (log verb, catalog key of the user-facing verb).NTrz%Failed to %s from Matrix reaction: %szplatform.matrix.picker.failed)actionre) rrrnrrrz"_redact_bot_model_picker_reactionsrrrrerr})rrr_rwr rrr{rrrrrrargs confirmationrs&&&&&&&&&&$ rTr%MatrixAdapter._handle_picker_reaction s* ,0+F+F yvl,X&X"  N Y%&y%88yyl 0!'!3!3G!Cd!CCL#==gNNNii iJJJ #&XDNJ 0 LL@%(C P))GQ'FqQVWXQY{befibj%k%.0 0 0  0sEB?AEC4C5 CCC C"C8C9C=ECCC D=AD8,D/-D82E8D==Ec V^8dQhRRRR/#)rLrr rarQrR)rSs"rTrUr* sOOSOTOrVc v\VRR4pVRJ;'d"\P!4\V48#)rrN)rrrr)rrrrs&& rTr}$MatrixAdapter._matrix_prompt_expired* s4V\48 %NN$..*:U:=N*NNrVc$V^8dQhRRRRRR/#)rLrr}r_rrarQrR)rSs"rTrUr. s&JJ3JJtJrVc \VRR4eVPWR7RJ#\RR4P4P 4R9;'g,\ VP ;'dWP 94#)zVResolve live gateway authorization, falling back to the startup snapshot when unwired._authorization_checkN)rnTGATEWAY_ALLOW_ALL_USERSrfr)r_is_sender_authorizedrrrrQr)rrr_s&&&rTr/!MatrixAdapter._is_authorized_user. s 4/ 6 B--g-G4O O!";R@FFHNNPThhJJlp  " " H Hw2H2H'HmJ JrVc 0V^8dQhRRRRRRRRRRRR /#) rLr_r}rrrr prompt_labelrarQrR)rSs"rTrUr6 s<-0:=GJZ]bfrVc "VPW14'g=\PRWSV4VPW\ R44GRjxL R#\ VRR4p\ VRR4'dKV'dCW68wd=\PRWSV4VPW\ R44GRjxL R#R#LrL 5i) z 43T : :yVM` KKOQ]gp q66!,T*UW W W V Ws*A CC-C>;C9C: CCc(V^8dQhRRRRRRRR/#)rLr_r}rrJrarrR)rSs"rTrUrG s1VVSVSVV^aVfjVrVc "VPWVR7GRjxL R#L \d"p\PRT4Rp?R#Rp?ii;i5i)rNz4Matrix: failed to send invalid reaction feedback: %s)rrrr)rr_rrJrs&&&& rTr-MatrixAdapter._send_invalid_reaction_feedbackG sE V))GO)D D D V LLOQT U U Vs6A#!#A# AA A AAc(V^8dQhRRRRRRRR/#rLr_r}rrr rarrR)rSs"rTrUrM s+33C3RU3_b3gk3rVc "RVnVPPVR4VPPVPR4VP W4GRjxL VP W\R44GRjxL R#L)L5i)TNz platform.matrix.approval.expired)rrrnrrmrrrrr_rrs&&&&rTr,MatrixAdapter._expire_matrix_approval_promptM s ''++OTB ((,,V-?-?F11'BBB22  0 13 3 3 C 3s$AB B !"BB B Bc(V^8dQhRRRRRRRR/#rrR)rSs"rTrUrV s1QQQVYQcfQkoQrVc "RVnVPPVR4VPW4GRjxL VP W\ R44GRjxL R#L)L5i)TNz$platform.shared.model_picker_expired)rrrnrrrrs&&&&rTr0MatrixAdapter._expire_matrix_model_picker_promptV sh ++//F55gFFF22 a(N&OQ Q Q G Qs!8A(A$"A(A&A(&A(c$V^8dQhRRRRRR/#rLr_r}rr rarrR)rSs"rTrUr] s'\\C\\QU\rVc "VPP4F-wr4VPWR4\P RW44K/ R#5i)zWRedact the bot's seeded approval reactions (delayed), leaving only the user's reaction.zapproval resolvedz0Matrix: scheduled bot reaction redaction %s (%s)N)rvrBrcrr)rr_rrevt_ids&&& rTr,MatrixAdapter._redact_bot_approval_reactions] sA#77==?ME  - -g?R S LLKU [@sAAc$V^8dQhRRRRRR/#rrR)rSs"rTrUrc s'bbbSbUYbrVc "VPP4F6wr4VPWR4GRjxL \P RW44K8 R#L \ d"p\P RY54Rp?KeRp?ii;i5i)zmodel picker resolvedNz.Matrix: redacted model picker reaction %s (%s)z5Matrix: failed to redact model picker reaction %s: %s)rvrBrXrrr)rr_rrrrs&&& rTr0MatrixAdapter._redact_bot_model_picker_reactionsc st#77==?ME b))';RSSS Mu]@S b TV[aa bs> B AAAB A B&B<B BB c$V^8dQhRRRRRR/#)rLr_r}rrarrR)rSs"rTrUrk s!'''s't'rVc XaaaRVVV3Rllp\P!V!44R#)cV^8dQhRR/#rrR)rSs"rTrU.__annotate__m s P PT PrVc<"SPSS4GRjxL R#L \d"p\PRT4Rp?R#Rp?ii;i5i)Nz*Matrix: background read receipt failed: %s)send_read_receiptrrr)rrr_rs rT_send5MatrixAdapter._background_read_receipt.._sendm sE P,,Wh??? P I3OO Ps6A#!#A# AA A AAN)r ensure_future)rr_rrsfff rTr&MatrixAdapter._background_read_receiptk s! P P eg&rVc$V^8dQhRRRRRR/#)rLr_r}rrarQrR)rSs"rTrUrt s!scdrVc "VP'gR#\V4\V4rC\VPR4'd&VPP W4V4GRjxL M\VPR4'd%VPP W44GRjxL MY\VPR4'd'VPP W4VR7GRjxL M\PR4R#\PRW!4R#LLxL8 \d"p\PR T4Rp?R#Rp?ii;i5i) Fset_fully_read_markerN send_receiptset_read_markers)fully_read_event read_receiptz)Matrix: client has no read receipt methodz&Matrix: sent read receipt for %s in %sTzMatrix: read receipt failed: %s) rrrrrrrrrr)rr_rrrrs&&& rTrMatrixAdapter.send_read_receiptt s|||  /78+<%t||%<==ll88eLLL~66ll//<<<'9::ll33D_d3eee HI LLA8 UM<e   LL:C @ srEAD%(D)?D%(D!)AD%*D#+D%ED%ED%!D%#D%% E0E E EElevelrc(V^8dQhRRRRRRRR/#)rLok_msgrerr_msgr}rrarQrR)rSs"rTrUr s*  U S TW hl rVc "VP'gR#V!4GRjxL \\VR8XdRMR4!V!R#L# \d"p\\T4!Y54Rp?R#Rp?ii;i5i)zdRun one client call when connected: log *ok_msg* and return True, or log the error and return False.FNrrT)rrrr)r coro_factoryrrrrs&&&&$ rT _client_opMatrixAdapter._client_op sd||| . Fu'7GV Df M !  FE "7 0 s>A7 AA!AA7A A4A/)A7/A44A7c(V^8dQhRRRRRRRR/#)rLr_r}rrrarQrR)rSs"rTrUr s/ZZCZ3ZZUYZrVc `aaaa"SPVVVV3RlRSS3R4GRjxL #L5i)cx<SPP\S4\S4S;'gRR7#)N)r)rredactrr)rrr_rsrTr(.MatrixAdapter.redact_message.. s.DLL''w9JSYSaSa]a'brVzMatrix: redacted %s in %szMatrix: redact error: %sNr)rr_rrsffffrTrXMatrixAdapter.redact_message s5__ b ((G <>XZZ ZZs !.,.c 0V^8dQhRRRRRRRRRRR R /#) rLrr}topicrGOptional[list]r+rQpresetrarrR)rSs"rTrUr s<%(7EY])6rVc "VP'gR#VR8Xd)\R4'g\PR4R#R\P R\P R\P/PV\P 4pVPPT;'gRT;'gRT;'g.Uu.uFp\V4NK upWFR7GRjxL p\V4p VPPV 4\PRY;'gR4V #uupiLQ \d"p \PR T 4Rp ? R#Rp ? ii;i5i) Nr2rLzMMatrix: refusing to create public room without MATRIX_ALLOW_PUBLIC_ROOMS=truer0r4)rrinviteesr+rzMatrix: created room %s (%s)unnamedzMatrix: create_room error: %s)rrrrrr/r1r3r create_roomrr}rr&rr) rrrrGr+r preset_enumur_ room_id_strrs &&&&&& rTrMatrixAdapter.create_room s@||| ] ";7R+S+S NNj k  0 8 8-IYI`I`&(8(H(HJJM#fVfVnVnJo !LL44\\T$V\VbVb`bVbAdVbPQ&)VbAd#599Gg,K    " "; / KK6 EVEVY W  Be9  NN:C @ shAE3A-E5 E E ED= $ E0E1AE4E<E3=E E0E+%E3+E00E3c$V^8dQhRRRRRR/#)rLr_r}rrarQrR)rSs"rTrUr s&XXXsXtXrVc \aaa"SPVVV3RlRSS3R4GRjxL #L5i)c`<SPP\S4\S44#rt)r invite_userrr)r_rrsrTr(+MatrixAdapter.invite_user.. sDLL,,VG_fWoNrVzMatrix: invited %s to %szMatrix: invite error: %sNr)rr_rsfffrTrMatrixAdapter.invite_user s5__ N '' :. s(DLL--|E7JS]SeSeae-frVzMatrix: presence set to %szMatrix: set_presence failed: %sr)rN) r_VALID_PRESENCE_STATESrrrr(r*r,r)rrrrsfff@rTrMatrixAdapter.set_presence s||| 33 3 NN> F m**I}7L7Lm]j]v]vx __ f )5 13T\c%ee eesBBBBc$V^8dQhRRRRRR/#)rLrr r r}rarrR)rSs"rTrUr s!#CMrVc VfR#T\V\4'dVPR4M \VRR43FKp\V\4'dVPV4M \W!R4pV'gK@\ V4u# R#)z[Extract a simple value from a Matrix state event object or dict (top-level, then .content).Nr)rrrrr})rr objrs&& rT_state_event_value MatrixAdapter._state_event_value sw =:eT3J3J599Y/PWX]_hjnPopC$.sD$9$9CGGCLwsQU?VEu5z!qrVc V^8dQhRRRR/#)rLr_r}raz Optional[int]rR)rSs"rTrUr sCMrVc "VP'd\VPRR4MRpV'dT\\4;_uu_4VP V4GRjxL pVe\ V4uuRRR4#RRR4\VRR4pVe}\ VR4'dk\\4;_uu_4VPV4GRjxL p\VRR4e \ VP4uuRRR4#RRR4R#R#L +'giL;iLT +'giR#;i5i)zCstate_store first (cached), then a direct joined_members API query.rNrjoined_membersmembers) rrrr get_membersrrr r )rr_rr rHrLs&& rT_get_room_member_count$MatrixAdapter._get_room_member_count sDHLLLgdllM4@VZ )$$ + 7 7 @@&w<%$&%y$/  '&2B"C"C)$$#227;;4D1=t||,%$=%A%$<%$sk3EE D"D#D5 EAED/D-'D/ E ED D* %E-D// E : Ec(V^8dQhRRRRRRRR/#)rLr_r} event_typer rarrR)rSs"rTrUr s)  3 C c Vc rVc X"VP'd\VPR4'gR#VPP\V4V4GRjxL pTP YC4;'gRP 4pT;'gR#L9 \dR#i;i5i)z?Fetch a stripped string field from a room state event, or None.get_state_eventNrf)rrrrrrr)rr_rr rrs&&&& rT_get_room_state_value#MatrixAdapter._get_room_state_value s|||74<<9J#K#K ,,66vg SSE((4::AAC}} T  sF1B*(BBB!B*9B*B*B B'#B*&B''B*c V^8dQhRRRR/#)rLr_rrarrR)rSs"rTrUr s==:==rVc Vf7VPP4VPP4R#VPPVR4VPPVR4R#)z>Drop one cached room identity (or all when *room_id* is None).N)rrrrnrr_s&&rTrj)MatrixAdapter._invalidate_room_identities sW ?  ! ! ' ' )  ) ) / / 1  ! ! % %gt 4  ) ) - -gt J+ J8 JAJ J JJ9 J JB+J<J?JJc V^8dQhRRRR/#rNrR)rSs"rTrUr sNNNNrVc Z"VPV4GRjxL PR8H#L5i)Nr.)r/rhrs&&rTrMatrixAdapter._is_dm_room s'11'::EEMM:s +)+ log_failure require_dictc V^8dQhRRRR/#)rLr'rQr(rR)rSs"rTrUr s 8 8D 8PT 8rVc "VPPR4GRjxL p\ TR4'd5T'd!\ TP\4'd TP#\ T\4'dT#R#Ld \d*pT'd\P RT4Rp?R#Rp?ii;i5i)zIReturn the m.direct account-data mapping, or None when absent/unreadable.m.directNz/Matrix: get_account_data('m.direct') failed: %sr) rget_account_datarrrrrrr)rr'r(rLrs&$$ rT_fetch_m_directMatrixAdapter._fetch_m_direct s 66zBBD 4 # #\Z VZ=[=[<< !$--t747C  NPST sDCB BB CACB B=B82C8B==CcV^8dQhRR/#rrR)rSs"rTrUr s+++rVc "VP'gR#VPRR7GRjxL pVfR#VP4UUu0uFGp\V\4'gKVF&p\V\ 4'gK\ V4kK( KI pppVP Uu/uFqUWT9bK upVnVP4R#Luuppiuupi5i)NT)r') rr-rrrNr}rrrj)rdm_datarhr  dm_room_idsrids& rTrmMatrixAdapter._refresh_dm_cache s||| ,,,>> ? +2>>+;|+;%z%QU?Vv`e[\istuwzi{vs1v`ev+; |?C?Q?QR?Q 22?QR ((* ?}Rs9*CCC C'CCC( C5C Cc$V^8dQhRRRRRR/#)rLr_r}r.rarrR)rSs"rTrUr* s!22S23242rVc &"VP'gR#VPRR7GRjxL ;'g/pVPV.4p\V\4'dTM.pW9dQVP V4WCV&VPP RV4GRjxL \PRW4RVPV&VPV4R#LL> \d!p\PRT4Rp?LLRp?ii;i5i)zPersist a room as DM in m.direct account data after an invite. ``m.direct`` is absent (404) until the account has had a DM; fetch the current mapping (if any), append *room_id* under *inviter*, write it back so ``_refresh_dm_cache`` sees the DM.NT)r(r+z+Matrix: recorded %s as DM room (inviter=%s)z%Matrix: failed to update m.direct: %s) rr-rrrNrset_account_datarrrrrrj)rr_r.r1rooms_for_userrs&&& rTr>MatrixAdapter._record_dm_room* s||| )-)=)=4)=)P#P#V#VTV Wb1+5nd+K+KQS  (  ! !' *-G  Mll33JHHH I7\#'w ((1$QI MFLL MsQ*DC DA DC#"C!#C#=#D!C## D.D D DDc$V^8dQhRRRRRR/#)rLrJr}rrarbrR)rSs"rTrUr? s"cQ_rVc pRVRV/pVPV4pV'dRV/VR&VP'd-VPV4'dRVPR/4R&VP VP V44pV'd*WQ8wd$RVR&WSR &\ V4\8dVRVR V#) zBBuild Matrix text content with HTML and outbound mention metadata.rruser_idsrgTrrirSrh)_extract_outbound_mentionsr_has_outbound_room_mention setdefault_markdown_to_html_inject_outbound_mention_linksrrm)rrJrrmention_user_idsr[s&&& rTr)MatrixAdapter._build_text_message_content? s'0'64&H ::4@ )35E(FK %  $ $ $)H)H)N)N?CK " "< 4V <%%d&I&I$&OP DL$.b s!_6^''!**6^s)!_protect_outbound_mention_regionsrNrr_OUTBOUND_MENTION_REfinditerrrJ protectedrs&& rTr=(MatrixAdapter._extract_outbound_mentions` s;==dC DMM!_6J6S6ST]6^!__``rVc V^8dQhRRRR/#rrR)rSs"rTrUrd sIIsItIrVc hVPV4wr#\\P!RV44#)zFReturn True when outbound text contains @room outside protected spans.z(?(MatrixAdapter._has_outbound_room_mentiond s+==dC BII;YGHHrVc V^8dQhRRRR/#rrR)rSs"rTrUri s33rVc V'gV#VPV4wr#\PRV4p\V4FwrVVP RV R2V4pK V#)zCWrap outbound Matrix mentions in markdown links outside code spans.cPRVP^4 RVP^4 R2#)[z](https://matrix.to/#/rrK)rLs&rTr(>MatrixAdapter._inject_outbound_mention_links..n s+a |CYZ[ZaZabcZdYeef4grVMENTION_PROTECTED)rNrOrrr)rrJrR placeholderslinkedroriginals&& rTrA,MatrixAdapter._inject_outbound_mention_linksi saK"&"H"H"N %))*girs&|4MC^^&;C5$ExPF5 rVc V^8dQhRRRR/#)rLrJr}raztuple[str, list[str]]rR)rSs"rTrUrs s ' 'c '>S 'rVc aa.oRV3RlloT;'gRpRFp\P!VV3RlV4pK! VS3#)zEProtect markdown regions where outbound mentions should stay literal.c V^8dQhRRRR/#)rLfragmentr}rarR)rSs"rTrUEMatrixAdapter._protect_outbound_mention_regions..__annotate__w s 5 5s 5s 5rVcH<\S4pSPV4RV R2#)r\r]rr)rerr^s& rT_protectAMatrixAdapter._protect_outbound_mention_regions.._protectw s*l#C    )*3%t4 4rVrfc2<S!VP^44#)rrK)rris&rTr(AMatrixAdapter._protect_outbound_mention_regions..} shu{{1~6NrV)z```[\s\S]*?```z `[^`\n]+`z\[[^\]]+\]\([^)]+\)rX)rrJrRr!rir^s&& @@rTrN/MatrixAdapter._protect_outbound_mention_regionss sI"$  5 5JJB PGw(NPYZIQ,&&rVc(V^8dQhRRRRRRRR/#) rLrr}rhrrBrrarQrR)rSs"rTrUr s2 k k k)6 kQ_ kko krVc V'd&VP'dVPV9dR#V'g V'gR#VP'dVPV9dR#VP4pV'dQ\P!R\P!V4,R,V\P 4'dR#\ T;'d'VP;'dRVP 2V94#)zTrue if the bot is mentioned; ``m.mentions.user_ids`` (MSC3952) is authoritative even when the body has no ``@bot`` text (pills may live only in formatted_body).TF\bz matrix.to/#/)r_user_localpartrrr IGNORECASErQ)rrrhrBrs&&&& rT_is_bot_mentionedMatrixAdapter._is_bot_mentioned s  $--CS2SN ===T]]d2((* 5299Y+?#?%#Gr}}]]Niit}}ii< 9W[i9ijjrVc 0V^8dQhRRRRRRRRRRR R/#) rLr_r}rrrr rrQrarR)rSs"rTrUr sA Z Zs Z# Z ZRV Z)- Z26 ZrVc vV'g$VP'd\V4'gR#WP9g#VP'dWP9dR#\ V4pV'dW`P 9dR#VP R4'*;'dVPW#4'*#)zSynchronous pre-check of the ``_resolve_message_context`` park branch (only DM-ness needs an await; a DM voice's mark is released as soon as that is known).Fr)rrIrrrrrr)rr_rrr rrs&&&&&& rTrMatrixAdapter._voice_may_park s $"7"7"7~g?V?V && &4+>+>+>7ReReCe , mm3??3''YY0J0J40Y,YYrVc$V^8dQhRRRRRR/#)rLrr}rrrarQrR)rSs"rTrUr s&ss#sssrVc VPR4;'g/pTPYPR4\V\4'dVPR44#R4#)z\``_is_bot_mentioned`` fed from an event's content (MSC3952 ``m.mentions`` is authoritative).rgrhr<N)rrsrr)rrrmentionss&&& rTr#MatrixAdapter._content_mentions_bot sb;;|,22%% ++./ZX`bfMgMgj1Is smqs srVcV^8dQhRR/#r4rR)rSs"rTrUr siiirVc VP'dCRVP9d2VPPR4^,PR4#R#)zF``@bot:server`` -> ``bot``; empty when the user ID has no server part.rrrf)rrrr7s&rTrqMatrixAdapter._user_localpart sC:>---CSWS`S`L`t}}""3'*11#6hfhhrVc V^8dQhRRRR/#rrR)rSs"rTrUr s  3 3 rVc V'gR#VP'dVPVPR4pVP4pV'dK\P!R\P !V4,R,RV\P R7p\P!RRV4p\P!RRV4pVP4#) uStrip explicit ``@user:server`` / ``@localpart`` tokens only — never bare localpart words, or "Hermes Agent" would become "Agent".rfz (?>FDXZXeXefDvvlC.vv&t4zz|rVc$V^8dQhRRRRRR/#)rLr_r}rrarR)rSs"rTrUr s!  s S S rVc "VP'd\VPRR4MRpV'dk\\4;_uu_4VP W4GRjxL pV'd*\VRR4'dVP uuRRR4#RRR4VP R4'd'RV9d VR,PR4^,#V#L| +'giLQ;i5i)z=Get a user's display name in a room, falling back to user_id.rN displaynamerr:raNN)rrrr get_memberrrr)rr_rrmembers&&& rTrMatrixAdapter._get_display_name sDHLLLgdllM4@VZ )$$*55gGGgfmTBB!--%$$   c " "sg~2;$$S)!, , H%$s@3C4C4 C!"C# C!/C! )C47(C4C!! C1 ,C4c V^8dQhRRRR/#)rLrIr}rarR)rSs"rTrUr sTTCTCTrVc dVPR4'gV#VP RVR, 2#)rz"/_matrix/client/v1/media/download/:NN)rr)rrIs&&rTrMatrixAdapter._mxc_to_http s5!!(++N""##Egbk]SSrVc V^8dQhRRRR/#rrR)rSs"rTrUr sllclclrVc H\V4p\V4wr\\4;_uu_4^RIpVP .ROR7pRVP 9dVP PR4VPV4pVP4VPR4^8Xd#VPRR4PRR4p\\V4V4uuRRR4# +'giM;i\\TPT44T4#)u]Markdown → org.matrix.custom.html via ``markdown`` when installed, else the regex fallback.N extensions html_blockz

rfz

) fenced_coder}nl2br sane_lists)ryrYrrmarkdownMarkdown preprocessors deregisterconvertresetrrrhrm_markdown_to_html_fallback)rrJ tex_store_mdmdr[s&& rTr@MatrixAdapter._markdown_to_html s,T2*40 k " " ")YZBr///  ++L9::d#D HHJzz% A%||E2.66vrB&'r"vbscript javascript)rrrr)rprs& rT_sanitize_link_url MatrixAdapter._sanitize_link_url sT99; (?x~~c15a8>>@FFHLnnX..rVc V^8dQhRRRR/#rrR)rSs"rTrUr sIIIIrVc  aa.oRRlpRV3Rllo\P!RV3RlV\PR7p\P!RV3R lV4p\P!R V3R lV4pR PR \P!RV444pVP R4p.p^pV\ V48EdqW5,p\P !RV4'dVPR4V^, pKR\P !RV4pV'd^\ VP^44pVPRV RVP^4P4 RV R24V^, pKV!V4'd.p V\ V48dyV!W5,4'deW5,p T PV PR4'd V R,M!V PR4'd V R,MR 4V^, pKVPRRPV 4 R24EKR(Fwr\P !W4'gK#.p V\ V48dj\P !WV,4'dGV P\P !WV,4P^44V^, pKyVPRV RR PRV 44 RV R24EKb VPV4V^, pEKRPV4pR)F,wr\P!WV\PR7pK. \P!R R!V4p\P!R"R#V4p\P!R$R%V4p\S4FwppVPR&V R'2V4pK V#)*z0Comprehensive regex Markdown-to-HTML for Matrix.c V^8dQhRRRR/#)rLlnr}rarQrR)rSs"rTrU>MatrixAdapter._markdown_to_html_fallback..__annotate__ s I IC ID IrVc>VPR4;'gVR9#)> )rr)z>r)r)rs&rT _is_bq_line=MatrixAdapter._markdown_to_html_fallback.._is_bq_line s==1HHR=5H HrVc V^8dQhRRRR/#)rL html_fragmentr}rarR)rSs"rTrUr s - - - -rVcH<\S4pSPV4RV R2#) PROTECTEDr]rh)rrr^s& rT _protect_html?MatrixAdapter._markdown_to_html_fallback.._protect_html s*l#C    ."3%t, ,rVz```(\w*)\n(.*?)```c <S!VP^4'd>R\VP^44 R\VP^44 R24#R\VP^44 R24#)raz
)rrrrrs&rTr(rsEmM<.s/O"MQ ll?;;aP"Ms33z(\x00PROTECTED\d+\x00)rz!^[\s]*([-*_])\s*\1\s*\1[\s\-*_]*$z
z^(#{1,6})\s+(.+)$zz
z
rc3."TFpRVR2xK
	R#5i)z
  • z
    • NrR)rvitems& rTrxrs6\V[ddV57IV[srz\nz
    
z0
    \n()
    rrr]))z^[\s]*[-*+]\s+(.+)$rJ)z^[\s]*\d+[.)]\s+(.+)$rF))z
\*\*(.+?)\*\*\1)z	__(.+?)__r)z	\*(.+?)\*\1)z(?\1)
rrDOTALLrrrrrrrrrr)rJrrr	out_linesr;rhdrrbq_linesritem_rerrBr!replrr`rr^s&                 @@rTr(MatrixAdapter._markdown_to_html_fallbacksL 	I	-	-
!
Z
		#(kmst&
l	
O"$((+Df"MOOT"	
#e*n8Dxx)>BOObmmG.D.DBrFTVTaTabfTgTg"R&mopFA  <H0E/Fm!TU b88G**Ec%j.RXXgQx-H-HRXXgQx%@%F%Fq%IJQ$$qQrww6\V[6\/\.]]_`c_dde%fg!c  &Q9%.MGVVG6CF	.
x0KWV\]FvV&|4MC^^mC5$=xHF5
rV)=rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr	rrrrrr
rrrr
rrrrrrrrrrrrrrrrrrtr)NNN)Nr)NNNN)NNNFN)NNNNF)FNFr6)rfrfNFr0)r)r+r-)r)rf)rf)rSrTrUrVrWserial_receive_loopsupports_code_blockssplits_long_messagestyped_command_prefixrrrpropertyrrrrr'rXrr1rrrErNrTr\rkrgrrrrrrrrrrrr*r1rQrVr\rartrrrrrrr_EA_CMD_BUDGETrrrrrrr#rr5rrrCrBrprrrrkrnrrrrrrrrrrrrrrr7r0rorHrrYrcrhrprrrtrurvrr}r/r~rrrrrrrrrXrrrrrrr
rrjr/rr-rmr>rrr=r>rArNrsrrrqrrrr@rrrYrZr[s@rTrrs5631C7
llVrVrp
oo
	 	 zz
zz
;;"&$LL6&P>@DL	.&EP
B-E-^,8BB4"hA4P
//+DbgD4
m
m<+|qq
gg,qq
..6qqN
CC*UIvx6SXYMEyR{!I6Sy{O"#M$&S#%QSk4B	&CC,C$D$DL
n=CC0'.\a.$6
d8::	.+./mbCGCGJW ==81:;1;1z
Y
YKBd*OuO]_O""[H%NMMGG"Os4''*.eMLQ0OJJ"V3Q\b'(
Zc
ZZ
.X
''KL
e
e 	==RW>N
85
8W\
8+2*"5HL5-155 aI
'
k
kZsi

T
l //IIrVrrmedia_filesforce_documentcaa
aaa"\VR/4;'g/p^RIpTP	R4;'g\RR4;'gRP
R4o\TRR4;'g\R	R4;'gRpS'd	T'g\R
4#^RIHoRR
T2RR/o
TP4;_uu_4GRjxL
oTT
TTT3Rlp	\T4FWp
\P!T	!T
4^R7GRjxL
pTP	R4'dKCTuuuRRR4GRjxL
#	XuuRRR4GRjxL
# \d\R4u#i;iLLg \d$\R4uuuuRRR4GRjxL
#i;iLlLX +GRjxL
'giR#;i \dp\RT24uRp?#Rp?ii;i5i)z_standalone_sender_fn: out-of-process delivery via the Client-Server API (cron without gateway).rNz/aiohttp not installed. Run: pip install aiohttprrrfrrrzGMatrix not configured (MATRIX_HOMESERVER, MATRIX_ACCESS_TOKEN required)r
AuthorizationzBearer zContent-Typezapplication/jsonc<"R\\P!4R,4R\P!^4P	42pSRS!SRR7RV2pS	PVSVR7;_uu_4GRjxL
pVPR9dD\R	VPR
VP4GRjxL
24uuRRR4GRjxL
#VP4GRjxL
pRRR
RRSRVPR4/uuRRR4GRjxL
#LLaLLL5L
 +GRjxL
'giR#;i5i)hermes_rgrz/_matrix/client/v3/rooms/rf)r	z/send/m.room.message/)rrNzMatrix API error (z): rTr5rrnror>)rPrr*urandomhexputrrrJrr)
payloadtxn_idrprLr"rnrrrrs
&    rT_do_send"_standalone_send.._do_send=s"3tyy{T'9#:";1RZZ]=N=N=PU=VVklrkst";;sG';JJJd{{*4),>t{{m3UYU^U^U`O`Na*bcKJJ"&,D%tZ9g($((:*>@	KJJO`K-KJJJsBEDE8D)?D!	D)	
ED#ED)/D%0D)
ED'E!D)#E%D)'E)E	/D20
E	;E	=	ErpzMatrix API timeout (30s)rzMatrix send failed: )rrrrrrrrrr_standalone_payloadsrr"r?r)pconfigrnmessagerrrrrrrrrrrrrrs&f&$$$       @@@@rT_standalone_sendr*sGWb)//REM6ii-ZZSUW3X^^\^ghh&"geW$5~GYZ((***g
@
@08B#*#3#3HW4Er#RRFzz),,!M!+**9#+**MKLLM+S#B%&@AA+**B+***$604556sRG5EGG%G7G
GG
G(G5)+GE9GF22!E=E;
E=F21F24
GF.GG5F2

GF0GG5E63G55E66G59G;E==F+	F2
G#F&$G)G5*F+	+F2.G0G2G	8F;9
G	G	G
G5GG2
G-'G2(G5-G22G5c V^8dQhRRRR/#)rLrr}razlist[dict[str, Any]]rR)rSs"rTrUrURs#*>rVcRp\\4;_uu_4^RIpRRR4.p\P!V\
\4FpRRRV/pVer\V4wrVVPVRR.R7pRR	R
\\P!RRV4V4/p\/VCVC4\8:dVPV4VPV4K	V# +'giL;i)
zOne m.room.message content per chunk. The caller chunks on characters, and a chunk of
non-Latin text can still exceed the homeserver's byte cap, so re-chunk on UTF-8 bytes.Nrrfrrr}rrSrirhz(.*?)r)rrrr;rrrrYrhrrrrmrir)	rrpayloadsrr	tokenizedrr[rqs	&        rTrrRsC	+		
H$55g?`bklh6?#3E#: I<<	}h6O<PD!#;=MOb02H$OQZP\]I66I67;MMy) mO
	sCC.	cV^8dQhRR/#rrR)rSs"rTrUrUfs:-:-4:-rVcaa^RIHpHpHo^RIHoHpHpHpH	pH
p^RIHpV!R4V!RRRR4'dR#R.FpV!V4K
	R	VV3R
llp	V	!RR4V!R
4V	!RRRR7p
V
'dV	!RR4V!R4M"V	!RR4V	!RRRR7'd	V!R4V
'gV!R4'dV!RR4pV'dS!RR4V!R4^RI
HpV!R4V!R.RR7V!R 4V!R#4V!R$4S!R%4pV'd#S!R&VP!R'R(44V!R)4MV!R*4R/FpV!V4K
	S!R+4P#4pV'dS!R,V4R#V!R,4'dV!R-4R#R#R# \dp
T!R!T
24T!R"4Rp
?
LRp
?
ii;i)0zGInteractive credential setup (setup_fn); CLI helpers are lazy-imported.)
get_env_valueremove_env_valuesave_env_value)r
prompt_yes_noprint_header
print_info
print_success
print_warning)declines_reconfigureMatrixzReconfigure Matrix?rrNc$V^8dQhRRRRRR/#)rLr
r}questionrarR)rSs"rTrU'interactive_setup..__annotate__rs!#srVcj<S!V3/VBpV'd!S!YR8XdVPR4MT4V#)rr)r)r
rkwrrrs&&, rT_askinteractive_setup.._askrs6x&2&3>CJ,<,<,>??rVcV^8dQhRR/#rrR)rSs"rTrUrUsTrVc"6^RIHp^RIHp^RIHp^RIHpVP!R"/VBRRRRR	\R
\/BVBR\R\R
RR.RRR\R\RRR\R\ RRRRRVRRRVP"R VP$/BVP&BR!#)#ra)
PLATFORM_HINT)SEND_ENTRY_KWARGS)DASHBOARD_CARD)gateway_envrrrradapter_factorycheck_fnensure_deps_fnis_connectedrequired_envrrinstall_hintz!pip install 'mautrix[encryption]'setup_fnapply_yaml_config_fncron_deliver_env_varrstandalone_sender_fnrru🔐allow_update_commandT
platform_hintdisplay_tiermedium
env_overridesenv_enable_credentialsNrR)adapter_hintrsend_targetsrdashboard_cardrrfrregister_platformrrrrrr
rr
ENV_OVERRIDESENV_ENABLE_CREDENTIALSAUTHZ)rrrrrs&    rTregisterr.s+/.




%
7D
Ob

*	
9F	

*+@A

Qt
#

:L

cu

.
C]
ek
"
$

"//
 +AA
FQEVEV
rVrR>m_forbiddenm_missing_tokenm_unknown_token>
.bmprrr.svg.avif.heic.heif.jpegr>
.aac.amr.m4a.mkv.mov.mp3.mp4rr.wav.flacr.webm)u🔟)u🅰️u🅱️rrtr6)
)r5r6r)rrr)rrr)rrr)rrr)rrcsv)rrrB)rrrB)rrrB)rrr})rW
__future__rrrrr
contextlibrloggingrr*rr{r[rrrrrrdataclassesrrr[r	rhtml.parserr
pathlibrtypingrr
rr
agent.i18nragent.secret_scopergateway.platforms._sharedrrrrrrrrrrrrrrrrrr}rgateway.configr8r9r!r:r;r<r=r>r?r@rAgateway.platforms.eventrBrCrDgateway.platforms.helpersrE&plugins.platforms.matrix.voice_mentionrFrGrHrI	getLoggerrSrrr^rrrrrrrrrrrrrrr^rlrx_MatrixModelPickerPrompt_MatrixChoicePickerPromptrmrrrrrhermes_constantsrrrrOrrrrrr1rrrrrrrrrrrrrrrr5r:r@rDrgrMrUrYrhrmrvryrrrrrrrr	r
rr.rRrVrTrUs2#		

66('"++)
Oeee 49PP@ll			8	$ wUw
#J**%OQSQZQZ[40"$,F!G"(5$'(<,V(A$:A$H$RRR
F
F
F8KJ4
%7!$;!>%U

C(?zz"[\u')YZ')op"'&O;&O&O;&O!ORa!a"@Ck"kW
["i
c62$(3R
A\
]
C$:A

JK
530
,( .bM$'M$`H%64%6UY%6jo%6P(:-z8@EdO.10J006F%r(*l,k=,JKI-r(Iy-4PQM3R>8]