+ jHjLv Rt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t H t ^RIHt^RIHt]P$!]4t!RR4tRR ltR R lt]P0tR R ltRRlt]P8!R]P:4R3]P8!R]P:4R3]P8!R]P:4R3]P8!R]P:4R3]P8!R4R3]P8!R4R3]P8!R]P<4R33t]P8!R4t ]P8!R]PB4t"]P8!R4t#RRlt$RR/R R!llt%!R"R#4t&R$R%lt'R&R'lt(]P8!R(4t)R)R*lt*R+R,lt+R-R.lt,R/R0lt-R1RR2RR3RR4R/R5R6llt.R7R8lt/R9R:lt0R;R<lt1R=R>lt2R?R@lt3]P8!RA4t4RBt5RZRClt6RDRElt7RFRGlt8RHRIlt9RJRKlt:R[RLRMllt;R\RNltRTt?R]t@RUtARVRWltBRXRYltCR#)^uShared helpers for gateway platform adapters: message dedup, markdown stripping, thread participation tracking, GFM table → bullets, mention-pattern compilation, and fence-aware markdown chunking.NPath)AnyMutableMappingOptional) MessageEvent)atomic_json_writeca]tRt^toRtRV3RlRlltV3RlRltV3RlRltV3RlR ltR t V3R lR lt R t Vt R#)MessageDeduplicatorzRTTL-based message deduplication cache (``if dedup.is_duplicate(msg_id): return``).c&<V^8dQhRS[RS[/#)max_size ttl_seconds)intfloat)format __classdict__s">/home/ubuntu/.hermes/hermes-agent/gateway/platforms/helpers.py __annotate__ MessageDeduplicator.__annotate__s   % c,/VnWnW nR#N)_seen _max_size_ttl)selfr rs&&&r__init__MessageDeduplicator.__init__s') ! rc&<V^8dQhRS[RS[/#r msg_idreturnstrbool)rrs"rrrs34rc V'gR#\P!4pWP9d8W PV,, VP8dR#VPVW PV&\VP4VP8dW P, pVPP 4UUu/uFwrEWS8gK WEbK uppVn\VP4VP8dC\ \VPP 4RR7VP)R4VnR#uuppi)z?Return True if *msg_id* was already seen within the TTL window.FTcV^,#))items&r2MessageDeduplicator.is_duplicate..+s dSTgr)keyN)timerrlenritemsdictsorted)rr!nowcutoffkvs&& r is_duplicate MessageDeduplicator.is_duplicatesiik ZZ ZZ''$))3 6" 6 tzz?T^^ +99_F+/::+;+;+=L+=41$!$+=LDJ4::/!&)9)9);AU"VX\XfXfWfWg"hi  Ms  EEc&<V^8dQhRS[RS[/#r r#)rrs"rrr.sstrc V'dVPPV4MRpVfR#\P!4V, VP8dR#VPVR#)zBReturn whether *msg_id* is live in the cache without inserting it.NFT)rgetr.r)rr!seen_ats&& rcontainsMessageDeduplicator.contains.sI,2$**..( ? 99; 499 , JJv rc$<V^8dQhRS[RR/#)r r!r"Nr$)rrs"rrr8s%%c%d%rc >VPPVR4R#)z replacement) and after disposing a failed reconnect candidate (candidate -> retained predecessor): a candidate that fails connect can hold acked updates and salvage pending batches in disconnect(), which must not die with it.adopt_held_inboundN)r]callable)rdreadopts&& rhand_over_held_inboundrjSs0 F0$ 7E huoo f .rcRV^8dQhR\\P,RR/#)r taskr"N)rasyncioTask)rs"rrrds#  HW\\2 t rcP"VeVP4'dR#VP4V\P!4JdG\P !\P \4;_uu_4VGRjxL RRR4R#R#L +'giR#;i5i)zCancel *task* and wait for it to unwind. ``None``/finished tasks are no-ops; awaiting the current task would deadlock, so a self-cancel only requests cancellation. Exceptions the task dies with are swallowed: at teardown nobody is left to handle them.N)donecancelrm current_task contextlibsuppressCancelledError Exception)rls&r cancel_taskrwdsp |tyy{{KKM 7''))  !7!7 C CJJD C* D C Cs5B&AB&9B?BB B&B B#  B&c nV^8dQhR\\\3,R\R\R\RR/#)r storer-valuecapr"N)rr$rr)rs"rrrps9%%~c3h/%c%#%C%TX%rcVPVR4W V&\V4V8dV\\V44K'R#)zInsert into an insertion-ordered mapping with a hard size bound, evicting the oldest keys. A re-put moves the key to the newest position so live entries outlast stale ones.N)rBr/nextiter)ryr-rzr{s&&&&r bounded_putrps; IIc4#J e*s  $tE{# $ rz \*\*(.+?)\*\*\1z \*(.+?)\*z \b__(?![\s_])(.+?)(? ``label\nurl``. The bare URL is the only thing a platform with its own data detection (iMessage) can turn back into a tap target, so dropping it makes the link unreachable rather than merely unformatted. Non-http targets (``mailto:``, relative paths) are not auto-linked, so they keep the label-only behaviour.  )groupstrip_HTTP_TARGET_REr)rlabelres& r_keep_link_targetrsfKKN((*EKKN,@,@,B6   ( ({{1~_6>UG2fX*>>rkeep_link_targetsFc<V^8dQhR\R\R\/#)r textrr"r#)rs"rrrs! 9 9 9D 9S 9rc\Fwr#VPW04pK \PV'd\MRV4p\PRV4P 4#)zStrip markdown formatting for plain-text platforms (SMS, iMessage, etc.). ``keep_link_targets`` rewrites ``[label](https://url)`` as ``label\nurl`` instead of discarding the URL; pass it on platforms that auto-link bare URLs. r ) _STRIP_RULESsub _MD_LINK_REr_NEWLINE_SQUEEZE_REr)rrpatternrepls&$ rstrip_markdownrsP & {{4&& ??0A,ud SD  " "64 0 6 6 88rca]tRt^toRtRtRV3RlRlltV3RlRltV3RlRltV3R lR lt V3R lR lt V3R lRlt V3RlRlt V3RlRlt V3RlRltRtVtR#)ThreadParticipationTrackerzPersistent set of threads the bot has participated in (``_threads.json``); ``thread_id in tracker`` checks membership, ``tracker.mark(thread_id)`` persists.c&<V^8dQhRS[RS[/#)r platform_name max_tracked)r$r)rrs"rr'ThreadParticipationTracker.__annotate__sUUcUUrcWnW n\P!4Vn\P!4Vn\ PRVP444Vn R#)c38"TFp\V4xK R#5irr@).0ts& r 6ThreadParticipationTracker.__init__..s6T|!s1vv|sN) _platform _max_tracked threadingLock_lock_io_lockr1fromkeys_load_threads)rrrs&&&rr#ThreadParticipationTracker.__init__sG&'^^% !( )-6Ttzz|6T)T rc <V^8dQhRS[/#r r"r)rrs"rrrsDDTDrcD^RIHpV!4VP R2, #))get_hermes_homez _threads.json)hermes_constantsrr)rrs& r _state_path&ThreadParticipationTracker._state_paths4 dnn%5]#CCCrc0<V^8dQhRS[S[,/#rlistr$)rrs"rrrsXXtCyXrc\P!VP4PRR74p\ T\ 4'dTUu.uFp\T4NK up#.# \d.u#i;iuupi)z utf-8-sig)encoding)jsonloadsr read_textrvr^rr$)rdata thread_ids& rr ThreadParticipationTracker._loadsr ::d..0::K:PQD:DD$9O9O59I5WUWW I 5s4A)A<) A98A9c<V^8dQhRR/#r r"Nr))rrs"rrrsLLtLrc VP;_uu_4VP;_uu_4\VP4p\ V4VP 8d*WP )Rp\ PV4VnRRR4\VP4XRR7RRR4R# +'giL6;i +'giR#;i)N)indent) rrrrr/rr1rrr)r thread_lists& r_save ThreadParticipationTracker._saves ]]]"4==1 {#d&7&77"-/@/@.@.A"BK$(MM+$>DM  d..0+d K ]]]s#CAB1 $C1 C <C C c&<V^8dQhRS[RS[/#r rr"r#)rrs"rrrs  3 4 rc VP;_uu_4WP9d RRR4R#RVPV&RRR4R# +'giR#;i)aRecord *thread_id* in memory; ``True`` when a persist is still owed. The in-memory half stays synchronous even for :meth:`mark_async` so that a ``thread_id in tracker`` check immediately after marking is correct -- the mention-gating logic in the adapters depends on that. NFTrrrrs&&r _remember$ThreadParticipationTracker._remembers@ZZZMM)Z(,DMM) $ ZZZsA A  A c$<V^8dQhRS[RR/#r rr"Nr@)rrs"rrrscdrc XVPV4'dVP4R#R#)zMark *thread_id* as participated and persist. Blocking: ends in ``atomic_json_write`` -> ``os.replace``. Coroutines must use :meth:`mark_async` instead. N)rrrs&&rmarkThreadParticipationTracker.marks! >>) $ $ JJL %rc$<V^8dQhRS[RR/#rr@)rrs"rrrs ) )# )$ )rc ~"VPV4'd \VP4GRjxL R#R#L5i)aOff-loop form of :meth:`mark`. ``_save`` ends in ``atomic_json_write`` -> ``os.replace``, whose duration is unbounded under filesystem pressure. Every caller of this tracker sits on an inbound-message coroutine in the Discord and Matrix adapters, so the rename must not be paid inline on the event loop -- it stalls every other adapter's polling and every in-flight turn for as long as it runs. N)r _to_threadrrs&&r mark_async%ThreadParticipationTracker.mark_asyncs0 >>) $ $TZZ( ( ( % (s 0=; =c&<V^8dQhRS[RS[/#rr#)rrs"rrrs..c.d.rcVP;_uu_4WP9uuRRR4# +'giR#;irrrs&&r __contains__'ThreadParticipationTracker.__contains__s! ZZZ -ZZZs. ? c<V^8dQhRR/#rr))rrs"rrrs""t"rcVP;_uu_4VPP4RRR4R# +'giR#;ir)rrrFrGs&rrF ThreadParticipationTracker.clears' ZZZ MM   !ZZZs : A )rrrrrN)r)rOrPrQrRrS _MAX_TRACKEDrrrrrrrrrFrTrUrVs@rrrstYLUU$DDXXLL   ) )..""rrc0V^8dQhR\R\/#r chunksr")rr)rs"rrrsdrch"^RIHpV!RRR7p\V4FwrEV!V4GRjxL pVP'dK)V'd[\ VP \ 4'd\ VP 4M/pVPRV\V4R7WcnV# V#L5i)acSend ``chunks`` in order through ``send_one(chunk) -> SendResult``, stopping at the first failure. A failure after earlier chunks landed carries the ``partial_overflow`` contract that ``BasePlatformAdapter._is_partial_delivery`` reads, so no caller (send retry, plain-text fallback, cron standalone fallback) re-sends the head the recipient already has. ) SendResultFznothing to send)successerrorNT)partial_overflowdelivered_chunks total_chunks) gateway.platforms.baser enumeraterr^ raw_responser1rLr/)rsend_onerresult deliveredchunkraws&& r send_chunksrs2 -> ?F%f- &~~~3=f>Q>QSW3X3Xd6../^` D9[^_e[f g&)#  M. M's,B2B0B2B2A"B2c0V^8dQhR\R\/#)r phoner"r@)rs"rrrs++++rcV'gR#\V4^8:d-\V4^8dVR,R,VRR,#R#VR,R,VRR,#)zFRedact a phone number for logging, preserving country code and last 4.z:Nr Nz****N:NN)r/)rs&r redact_phonersV  5zQ25e*q.uRy6!E"#J.LfL 9v bc **rz0^\s*\|?\s*:?-+:?\s*(?:\|\s*:?-+:?\s*){1,}\|?\s*$c0V^8dQhR\R\/#r liner"r#)rs"rrr sstrc(RVP49#)z:Return True if *line* could plausibly be a table data row.|)r)rs&r is_table_rowr s $**, rcFV^8dQhR\R\\,/#rr$r)rs"rrr%s!!3!49!rc^RIHpV!V4#)zOSplit a GFM table row into stripped cells (delegates to agent.markdown_tables).)split_table_row)agent.markdown_tablesr)rrs& rsplit_markdown_table_rowr%s5 4  rcFV^8dQhR\\,R\/#)r table_blockr"r)rs"rrr+s((T#Y(3(rc  \V4^8d\V^,4M.p\V4^8dRPV4#\\V^,44\V4^,8Hp.p\VR,^R7FwrE\V4pV'd0V'dV^,'d V^,MRV 2pVR,pM\ RV4RV 24pTpVR.\V4,,R\V4p\ W4U U u.uFwrV'g W8wgKR V R V 2NK p p p VP RPR V R 2.V O44K R PV4#uup p i) zRender a GFM table as bold-heading + bullet groups (same alignment logic as Telegram's renderer: without a row-label column the full row is data and the heading bullet is skipped).r:r NN)startzRow r(NNc38"TFq'gK VxK R#5irr))rcells& rr&_render_table_block..9s;UTdDDUs  rNu• z: z**r)r/rjoinrr}zipappend) r headershas_row_label_colrendered_groupsindexrowcellsheading data_cellsheaderrzbulletss & r_render_table_blockr+sd;>k:Ja:O&{1~6UWG 7|ayy%%4[^DEWXYIYY!#O Bq9 (- "'E!HHeAhD.GrJ;U;tE7^LGJ B4#g,#66#g,G ADWAY=AY '5+;,T&E7+AY=tyyBwir*:)EW)EFG: ;; ''=s E?4 E?c0V^8dQhR\R\/#r rr"r@)rs"rrrBs33rcRV9gRV9dV#VPR4p.pRp^pV\V48dW,pVP4PR4pW6,pV'gV'gRV9dV^,\V48d\P W^,,4'd\V^,pV\V48d#\ W,4'd V^, pK2VP\WV44TpKVPV4V^, pEK RPV4#)zURewrite GFM pipe tables into bold-heading + bullet groups; fenced code is left alone.r-rF```) splitr/lstrip startswithTABLE_SEPARATOR_RErrrrr)rlinesoutin_fenceir is_fence_linejs& rconvert_table_to_bulletsr.Bs $#T/ JJt ECH A c%j.x 007 !Msd{q1us5z?Q&,,Uq5\::AAc%j.\%(%;%;Q JJ*51:6 7A JJt  FA 99S>rplatform_label display_labeldefaultslogger_c V^8dQhR\R\R,R\R,R\\,R,R\PR,R\\P ,/#)r log_prefixr/Nr0r1r2r")r$rloggingLoggerrPattern)rs"rrr[sf2B2B2BcDj2B,/$J2BIMcUYIY2B&-nnt&;2BGKBJJGW2Brc FaaT;'g\oVV3RlpVeT;'gTpVf.#\V\4'dV.MTp\V\4'g*SP RSV\ V4P 4.#T!VU u.uF5p \V \4'gKV P4'gK3V NK7 up RV4p V 'dSPRS\V 4V4V #Vf\T;'g.4pM\V\4'dVP4p V 'd\P!V 4M.p \V \4'dT MEV P4U Uu.uF)qPR4FqP4NK K+ upp pM\V\4'dTMV.pRV4Uu.uFq'gK VNK ppV!VR4#uup i \dRp Li;iuupp iuupi) aCompile regex wake-word/mention patterns from config or env values. * **Config-style** (dingtalk, telegram): pass ``platform_label``. ``raw`` must be a list or string (else warn + ``[]``); non-string entries skipped; info log on load. * **Wakeword-style** (photon, bluebubbles): pass ``defaults``. ``raw`` may be None (defaults), a string (JSON list or comma/newline separated), a list, or a scalar. ``log_prefix`` is interpolated into every log line so per-adapter output stays byte-identical to the historical inline implementations. c<.pVF8pVP\P!V\P44K: V# \Pd%pSP !TS.TOTNTN5!Rp?KrRp?ii;ir)rrcompile IGNORECASErwarning)patternswarn_fmt warn_argscompiledrexclogr4s&&* r_compile*compile_mention_patterns.._compileisr%'G L 7BMM BC 88 L HjK9KgKsKK Ls4AA=A88A=Nz9[%s] %s mention_patterns must be a list or string; got %sz&[%s] Invalid %s mention pattern %r: %sz$[%s] Loaded %d %s mention pattern(s),c3T"TFp\V4P4xK R#5ir)r$r)rps& rr+compile_mention_patterns..s:AQs&(z#[%s] Invalid mention pattern %r: %s)loggerr^r$rr<typerOrinfor/rrrv splitlinesr$)rr4r/r0r1r2rCdisplayr=rGr@rloadedrpartrtextsrBs&d$$$$ @rcompile_mention_patternsrQ[s   VC!11> ;I&sC00C5c(D)) KKS"NDN4K4K MIU1Jq#4FQ1779QQUDgO  HH;ZXX_ ` {B' C  yy{ )-TZZ%2F(556%)__%6.sC2B$u%%2Bsr)sumr$rs&rtext_has_unclosed_fencerXs& C$**T2BC Ca G1 LLrc0V^8dQhR\R\/#r r#)rs"rrrs773747rc`\VP4PR4R,4#)z=True when the last non-empty line starts and ends with ``|``.r) _is_pipe_rowrstripr$rWs&rtext_ends_with_table_rowr^s#  ++D1"5 66rc0V^8dQhR\R\/#r r#)rs"rrrs++++rc@VP4PR4#)z >(9(9#(>>rc0V^8dQhR\R\/#r r#)rs"rrrs----rcD\VPR4^,4#)z?True when an atomic block is a table (first line is ``|...|``).r)r\r$rWs&r is_table_atomrhs  4(+ ,,ru[。！？.!?]\nc8V\JdV#^RIHpV!WV4#)zCode-point count of the longest prefix of *text* within *budget* ``len_fn`` units (callers guarantee ``len_fn(text) > budget``, so plain ``len`` needs no search).)_custom_unit_to_cp)r/rrj)rbudgetlen_fnrjs&&& r _cp_budgetrms } 9 dF 33rcT;'g\pV!V4V8:dVR3#VR\WV4pVPR4p\P V4Uu.uFqfP 4NK ppV^8d V^,MV'd VR,M^pV'g-VPR4pV^8d V^,M \V4pVRVWR3#uupi)u=Split at the nearest paragraph boundary within *max_chars*; return (head, tail). Priority: blank line → newline after sentence-ending punctuation (CJK/ASCII) → last newline → forced split at the window boundary. ``head + tail == text`` always holds. *len_fn* measures in custom units (e.g. UTF-16 code units). rNrrr[)r/rmrfind_SENTENCE_END_NEWLINE_REfinditerend) r max_charsrl_lenwindowposm sentence_endscuts &&& rsplit_at_paragraph_boundaryrzs ==SD DzYRx 4:dt4 5F ,,v C&>&G&G&OP&OUUW&OMP1W#' =#41C ll4 qcAgc&k :tDz !! QsCcFV^8dQhR\R\\,/#r r)rs"rrrs  s tCy rcaa.o.oRpRVV3RllpVPR4FpV'd6SPV4VPR4'd RpV!4K>K@VPR4'dV!4RpSPV4KsVP4R8Xd V!4KS'd(\ SR,4\ V48wdV!4SPV4K V!4S#) zSplit markdown into indivisible atoms: fenced code blocks, tables (consecutive ``|...|`` lines) and paragraphs. Blank lines belong to no atom.FcV^8dQhRR/#rr))rs"rr*split_markdown_atoms..__annotate__s""D"rc<S'dKRPS4pVP4'dSPV4SP4R#R#)rN)rrrrF)atomatoms current_liness r_flush_current,split_markdown_atoms.._flush_currents< 99]+Dzz|| T"    ! rrr#Trr[)r$rr&rr\)rr*rrrrs& @@rsplit_markdown_atomsrsE!MH"" 4     &u%%  &__U # #  H   & ZZ\R   mB.?!@LQUDV!V   &!!" Lrc<V^8dQhR\R\R\/#)r prev_chunk next_chunkr"r@)rs"rrrs!cssrc*VP4pVP4pVPR4'gVPR4'dR#\ V4'd2V'd*\ VP R4^,4'dR#R#)zV``'\n'`` when the boundary sits at a code fence or a continued table, else ``'\n\n'``.r#rr)r]r%rdr&r^r\r$)rr prev_trimmed next_trimmeds&& rinfer_block_separatorrsq$$&L$$&LU##|'>'>u'E'E ++ lN`N`aeNfghNiAjAj rc\V^8dQhR\\,R\\,/#rr)rs"rrrs"  49 c rcD.p^pV\V48dW,p\V4'dWV^,\V48d@V\W0V^,,4,W^,,,pV^, pKgVPV4V^, pKV#)zRejoin chunks truncated mid-fence: while chunk *i* has an unclosed fence and a successor exists, merge the successor in via :func:`infer_block_separator`.)r/rXrr)rrr+ras& rmerge_streaming_fencesrsF A c&k/)%g..1q53v;3F 5ga!e} MMPV[\W\P]]G FA g Q Mrc\V^8dQhR\\,R\\,/#rr)rs"rrr s"  c tCy rc\V4^8:dV#.pRpVFYpVe RV RV 2MTp\Y2RJT;'gR4wrVV'dTMRpTPV'd VR,MT4K[ V#)zClose orphaned ``` fences at each chunk boundary and reopen (with the original language tag) on the next, so every chunk is fence-balanced alone.Nr#rrz ```)r/fence_state_afterr)rr) carry_langrbodyin_codelangs& rbalance_fences_across_chunksr s 6{a CJ.8.DZL5'*%)%41GIYIYWYZ $T$  W4'>$7  Jrc jV^8dQhR\R\R\R\\\3,/#)r rrrr")r$r%tuple)rs"rrrs4C$c5QUWZQZK[rcVPR4FdpVP4pVPR4'gK,VR,P4pV'dRMRV'd V^,MR3wrKf W3#)zSWalk ``text`` line by line toggling on ``` lines; return the final (in_code, lang).rr#:NNrTFr)r$rr&)rrrrretags&&& rrrsh 4 ::<   u % %2,$$&C+2Ks1vRT8UMGT ! =rclT;'g\p.pRpVFpV'gTMV V V 2p V!V 4V8:dT pK&V'dVPV4RpV!V4V8:dTpKRVeVPV!V44KoVPV4K V'dVPV4V#)zGreedily pack *blocks* (joined with *sep*) into chunks of at most *max_length*; an oversized block goes through *overflow(block)* (-> list of chunks) if given, else as-is.r)r/rextend) blocks max_lengthrlsepoverflowrtpackedrablock candidates &&&&& rgreedy_pack_blocksr$s ==SDFG!(E #ug.F  ?j (G   MM' "G ;* $G  ! MM(5/ * MM%  g Mrprefer_paragraphsTbalance_fencescV'g.#V'd\WV4pM\YT;'g\4pV'd \V4#T#)a)Split markdown into chunks of at most *limit*, respecting fences. ``prefer_paragraphs=True`` (yuanbao-derived): atoms (fences, tables, paragraphs) are greedily merged, oversized non-atomic chunks split at paragraph boundaries, small neighbours re-merged; a single atom larger than *limit* is emitted oversize, not broken. ``prefer_paragraphs=False`` (stream_consumer-derived): newline-preferred hard splitting with headroom reserved for fence markers. ``balance_fences=True`` closes/reopens fences at chunk boundaries so each chunk renders standalone. )_chunk_markdown_paragraphs_chunk_newline_preferredr/r)rlimitrlrrrs&&&$$ rsplit_text_fence_awarer=s@  +D@)$v}}E3A ' /MvMrcT;'g\pV!V4V8:dV.#.p\4p.p^p\V4FpV!V4p V'd^M^p Wz,V ,V8d.V'd&VPRP V44.^^rpV'gVW8dP\ V4'g\ V4'd.VP\V44VPV4KVPV4WzV ,, pK V'd!VPRP V44.p \V4FwrV!V 4V8:gW9g\V 4'dV PV 4K<T pV!V4V8d=\WVR7wrV'g VRVWRrV'gK6V PV4KIV'gKV PV4K V R,pV R,F?p VR,R,V ,pV!V4V8:dVVR&K.VPV 4KA VUu.uFpV'gK VNK up#uupi)zCYuanbao-derived paragraph/atom chunking pipeline (see module docs).r)rlN:Nr(Nr r[) r/setrrrrarhaddrrXrz)rrsrlrtrindivisible_set current_parts current_lenratom_lensep_lenridxr remainingheadmergedcombinedcs&&& rrrQs ==SD DzYv F #O!MK$T*:$!!  8 +i 7M MM&++m4 524aM("6"4((M$,?,?   F , MM$  T")) + fkk-01F'  ;) #s'=AXY^A_A_ MM%  9o )9)W]^OD"+JY"7:9Nit d# 9 MM) $(r F":&. >Y &!F2J MM%   #v!AAv ## #s I!I!cpV!V4V8:dV.#RV9d\V^, V^,^4MTp.pTpV!V4V8dX\WSV4pVPR^V4pWv^,8dTpVPVRV4WWRP R4pKdV'dVPV4V#)zCStream-consumer-derived newline-preferred splitting (no balancing).r#rN)maxrmrorr%)rrrl split_limitrrrksplit_ats&&& rrrs d|uv 49TM#ebj%1*a0uKFI  k )IF;??4F3 k !H i *+i(//5  i Mr ___hidden___c$V^8dQhR\/#r)r%)rs"rrrsMMdMrcVPPp\V\4'dV\ ,'dR#\ VRR4\8H# \dRpLNi;i)uTrue when a discord.py channel object is an obfuscated placeholder. Skip these wherever guild channels are enumerated (channel directory, message backfill): history reads and sends always fail with a permission error. Flag first; the sentinel name is the fallback for discord.py builds that don't expose the flag (a visible channel literally named ``___hidden___`` is then also skipped — deliberate bias toward hiding). #90154 NTr_)flagsrzAttributeErrorr^rDISCORD_CHANNEL_OBFUSCATED_FLAGr]DISCORD_OBFUSCATED_CHANNEL_NAME)channel flag_values& ris_discord_channel_obfuscatedrs^]](( *c""z4S'S'S 7FD )-L LL  sA A'&A'c0V^8dQhR\R\/#)r kwargsr"rZ)rs"rrrsFF3F3Frc <^RIHp^RIHp^RIHp\ VPRR4;'g/4pV.VPRR 4OVR&VPRR4VPR R 4R V9d V!4VR &MVR ,fVR V!R RV/VB#) a``httpx.AsyncClient`` for a platform adapter: connect-time SSRF validation (``tools.url_safety.create_ssrf_safe_async_client``), every redirect hop re-checked (``gateway.platforms.base.ssrf_redirect_guard``, run before any caller ``response`` hooks) and the shared keepalive pool limits (``platform_httpx_limits()``; pass ``limits=None`` for httpx's defaults). Defaults ``timeout=30.0`` and ``follow_redirects=True``; other kwargs go to httpx.)platform_httpx_limits)ssrf_redirect_guard)create_ssrf_safe_async_client event_hooksNresponsetimeoutg>@follow_redirectsTlimitsr)) %gateway.platforms._http_client_limitsrrrtools.url_safetyrr1rBr; setdefault)rrrrhookss, rplatform_http_clientrs L:> M4066B 7E,IuyyR/HIE* i& ($/v02x   ! 8  ( EU Ef EErrr)NrNi)DrSrmrsrr5rrr.pathlibrtypingrrrgateway.platforms.eventrutilsr getLoggerrOrIr rbrj to_threadrrwrr:DOTALL MULTILINErrr;rrrrrrrr'rrrr.rQrXr^rar\rhrprmrzrrrrrrrrrrrrrr)rrrsN3   000#   8 $.h.hb %    %ZZ ")),e4ZZ bii(%0ZZ3RYY?GZZ1299=uEZZ()2.ZZ U#ZZ r||,b1 jj45 **\2==9jj+ ? 95 9U"U"p(+ZZ ST ! (.22BSW2B9=2B\`2B>B2BtM 7 + ? - ::&9:4"( F  2N$N*/N(0$f0#*"0M$Fr