j^dZddlmZddlZddlZddlZddlmZddlmZm Z ddl m Z ddl m Z mZmZmZmZmZdd lmZmZmZmZmZmZdd lmZmZmZmZmZdd l m!Z!m"Z"dd l#m$Z$dd l%m&Z&m'Z'm(Z(ddl)m*Z*ddl+m,Z,m-Z-ddl.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?ddl@mAZAddlBmCZCddlDmEZEmFZFddlGmHZHddlImJZJmKZKmLZLddlMmNZNmOZOmPZPmQZQdZRejdZTejdZUeVhdZWeVhdZXeVhdZYGddeZe Z[Gd d!eZe Z\Gd"d#e]Z^ed$%Gd&d'Z_ed$%Gd(d)Z`Gd*d+eZaebZcd/d,ZdGd-d.Zey)0u Secure Gateway: der EINE Ausführungspfad des Aria-V3-Kerns. Telegram-Plugin (gate(), Permission-Intercept) -> Bridge -> Gateway.handle(): 1. Modus freigeschaltet? (config.allowed_modes; Default nur "shadow") 2. AUTHENTIFIZIERUNG: sender_id kommt NUR aus dem vom Transport gesetzten Feld (Plugin: ctx.from.id), nie aus dem Text oder selbstdeklarierten Feldern (unbekannte Felder werden abgelehnt). Abgleich mit der Allowlist; privat zusätzlich chat_id == sender_id. 3. Idempotenz je (chat_id, message_id), persistent. 4. Ein Befehlsparser; Modusbefehle nur für authentifizierte Besitzer. 5. Kontext bauen; Datenschutz- und Aufgabenklasse deterministisch. 6. Verfügbarkeit (Circuit-Breaker) und Budget (ohne Reservierung). 7. Eine Routinglogik (core.route); manuelle Wahl überstimmt nie. 8. Memory nur für Adapter mit accepts_memory, Ausschnitt für Ausschnitt gegen die Matrix geprüft; danach finale Klassifikation. 9. Shadow: nur protokollieren, nichts reservieren, nichts ausführen. 10. Ausführen: Outbound-Digest vom Adapter, Budget reservieren, HMAC- Clearance ausstellen, Entscheidung protokollieren (sonst keine Ausführung), adapter.execute(clearance, job) - der Adapter prüft selbst -, Budget abrechnen, Health verbuchen, Ergebnisprüfung, Ergebnis protokollieren. Es gibt keinen automatischen Wechsel auf ein anderes Backend nach einem Laufzeitfehler. Der einzige Fallback ist der optionale, vollständig geprüfte Fallback bei manueller Wahl (routing.manual_fallback = checked_fallback). ) annotationsN) dataclass)datetimetimezone)Enum)AnyCallableMappingOptionalProtocolSequence)AdapterInputError AdapterJob AdapterResultBackendAdapterExecutionPolicy ResultStatus)AuthorizationErrorClearanceIssuerClearanceKeyringClearanceVerifierKeyUnavailableError) BudgetLedgerestimate_tokens)ClaudeChannelAdapter)PrivacyAssessmentPrivacyClassifier classify_task) CodexAdapter) CommandKind parse_command)ConfigurationError GatewayConfig) AttachmentContextEnvelope MemorySnippet sha256_hex) BackendCHECKED_FALLBACK JobRequestMANUAL_CHOICE_NOT_PERMITTEDModePRIVACY_DENIED PrivacyTierRoutingDecisionroute) DecisionLog)HealthRegistry) JobLifecycle JobStatus) check_output)IsolatedRunner MockRunnerSubprocessRunner)IdempotencyStore ModeStore NonceStore StateErrorz ^\d{1,20}$z ^-?\d{1,20}$>groupchannelprivate supergroup> tstextchat_id chat_type sender_id transport message_id attachmentssender_username>kindmimenamesizesha256file_id local_pathc,eZdZdZdZdZdZdZdZdZ dZ y ) Handlingdropnot_interceptedreplyblockedfailedforward_to_claude_channelshadow_decisionerrorN) __name__ __module__ __qualname__DROPNOT_INTERCEPTEDREPLYBLOCKEDFAILEDFORWARD_TO_CLAUDE_CHANNELSHADOW_DECISIONERROR4/home/aria/aria-v3-dev/python/aria_router/gateway.pyrSrSHs+ D'O EG F ;'O ErhrSceZdZdZdZy) Principalowner group_memberN)r\r]r^OWNER GROUP_MEMBERrgrhrirkrkSs E!Lrhrkc eZdZdfd ZxZS) RequestErrorc2t||||_yN)super__init__code)selfrv __class__s riruzRequestError.__init__Ys  rh)rvstr)r\r]r^ru __classcell__)rxs@rirqrqXs rhrqT)frozenceZdZUdZded<ded<ded<ded<ded<d Zded <d Zd ed <d Zd ed<dZded<dZ e ddZ y )GatewayRequestzHEingang vom Transport. sender_id/chat_id/chat_type setzt NUR das Plugin.ryrFrDrEintrHrCtelegramrGN Optional[str]rJrBrgztuple[Attachment, ...]rIct|jtrtj |js t dt|j trtj |j s t d|jtvr t dt|jtus|jdkr t dt|jtrd|jvr t dt|jts t d|jd f|j d ffD]5\}}| t|trt#|d kDsd|vs,t |t|j$t&rt)d |j$Dr t d y)NINVALID_SENDER_IDINVALID_CHAT_IDINVALID_CHAT_TYPErINVALID_MESSAGE_ID INVALID_TEXTINVALID_TRANSPORTINVALID_USERNAME INVALID_TS@c3>K|]}t|t ywrs) isinstancer%).0as ri z/GatewayRequest.__post_init__..|s9r\]jJ>W:W9rsINVALID_ATTACHMENTS)rrFry_USER_IDmatchrqrD_CHAT_IDrE CHAT_TYPEStyperHr~rCrGrJrBlenrItupleany)rwvaluervs ri __post_init__zGatewayRequest.__post_init__lsf$..#.hnnT^^6T23 3$,,,HNN4<<4P01 1 >> +23 3   +t/B34 4$))S)Vtyy-@~. .$..#.23 3!113EFR^H_` )KE4 *UC*@CJQSOW]afWf"4(( )$**E2c9raeaqaq9r6r45 57srhct|ts tdt|tz }|r tddD]}||vstd|d}t|t s tdt |jd|kDr td|jd g}t|trt ||kDr td g}|D]} t| trt| tz sd | vr td  |jt| d | jd d | jd| jd| jd| jd| jd||d|d|d|d||d|jd|jdt| S#t$r} td | d} ~ wwxYw)NINVALID_REQUEST UNKNOWN_FIELD)rGrFrDrErHrC MISSING_FIELDrCrutf-8TEXT_TOO_LARGErIrrKrPrMrLrNrOrQ)rKrPrMrLrNrOrQrFrDrErHrGrJrB) rFrDrErHrCrGrJrBrI)rr rqsetBRIDGE_REQUEST_FIELDSryrencodegetlistBRIDGE_ATTACHMENT_FIELDSappendr% ValueErrorr) clsdatamax_text_bytesmax_attachmentsunknownrequiredrCraw_attachmentsrIitemexcs ri from_bridgezGatewayRequest.from_bridges$(01 1d)33 / /` 4Ht#"?33 4F|$$~. . t{{7# $~ 5/0 0((="5/40C4H?4Z45 5 # CDdG,D A ZZrhc eZdZejddddd ddZddZddZeddZeddZ ddZ dd Z dd Z dd Z d d Zd!d Zd"dZd#dZ d$dZe d%dZd&dZd'dZd(dZd)dZd*dZdZy)+GatewayN)clockmemory_provideradapter_factories forward_sink codex_runnerct|ts td||_||_|j }|j }t|j|j|j|_ t|jj|_t!|dz |_t%|j|j&|jj(||_t-|j|j&|j"|j|jj.||_t3|dz |j4|_t9|dz |_t3|dz |j4|_t9|d z |_tA|d z |jB| |_"tG|d z |jHjJ|jHjL| |_'tQ|d z |jRdz| |_*||_+|jY|xsi|||_-y)NzGatewayConfig required)public_marker_enabledextra_confidential_keywordsextra_internal_keywordsz nonces.json) ttl_secondsr)max_clock_skew_secondsrz dedupe.jsonz modes.jsonzshadow-dedupe.jsonzshadow-modes.jsonz budget.json)rz health.jsonzdecisions.jsonliQ).rr$r#config_clock state_dirrrrrr _classifierr clearancekey_file_keyringr<_noncesrmatrixr_issuerrr _verifierr:dedupe_ttl_seconds_deduper;_modes_shadow_dedupe _shadow_modesrbudget_budgetr3healthfailure_threshold open_seconds_healthr2decision_log_retention_days_log_memory_build_adapters _adapters) rwrrrrrrstaters riruzGateway.__init__s&-0$%=> >    ..,")"?"?(/(K(K$+$C$C  ))9)9)B)BC !%-"78 &t}}gnn393C3C3O3OW\^ *4=='..$,,X\XhXhBHBRBRBiBi168( (=v?X?XY  45 .u7K/KVMfMfg&u/B'BC#EM$96==PUV %em&;V]]=\=\&,mm&@&@O (9 96;];]`e;e&+- & --.?.E2|Uabrhc |dk(rt|j|S|jj}|}||jrddlm}||j|j|jt|j|jt|jt|jxsdt|jj |j"|j$ }n t'}t)|j||j*|j,t|j.|j0|jdk(|jS)Nclaude)sinkr)CagedCodexRunner) profileresource_limits auth_filecodex_auth_writable home_rootbus_envrprotect_startupwrite_allowlisttools)runnercommand_templateisolation_wrapperenvmax_output_bytesallow_sandbox_bypassrequire_output_file)rrrcodexreal_executionisolation.caged_runnerr workspace_rootr r ryr rrruser_busrtools_protect_startuptools_write_allowlistr8r rrrr)rwrMrrrrr s ri_default_adapterzGateway._default_adapters 8 '\J J !! >##D)((%--QVQfQf!%//2HaHa!%//2 08D!$++"7"78$)$?$?$)$?$?$DNN6ELbLb.3.E.E4PUPYPY?-2-C-C27--72J050D0D F Frhci}|jjD]}|js|j|jt }|3|t ur|j |j||}n||j}t|ts td|j|jk7r td|j|jur td|||j<|S)NINVALID_ADAPTERADAPTER_MISMATCHADAPTER_VERIFIER_MISMATCH) rbackendsenabledrrM_MISSINGr"rrrr#verifier)rw factoriesrradapterssettingsfactoryadapters rirzGateway._build_adapterss ,, .H##mmHMM8 ?rhc  |jjt|jd|d|ddy#t$rYywxYw)zIProtokolliert eine schon an der Bridge abgewiesene Anfrage (ohne Inhalt).decisionr[bridge)rBr>rrrv rejected_atN)rrCrr Exception)rwrvrs rilog_rejected_requestzGateway.log_rejected_requestDsI  IIOO4 #6W])0$xY Z   s9< AAc 2i}|jjD]}|jj|j}|j |j|j v|j|j|j|jj|jd||j<tt|jj|jj!|jj"j$|dS)N)r(r/rconsecutive_failures last_errorr)r allowed_modes key_availablecodex_real_executionr')rr'rrrMr(rrfailuresrNr usage_todayrsortedrOr availablerr)rwr'r-rs rirzGateway.statusLs ,, H\\'' 6F#++#==DNN: --(.$//,,228==A 'HX]] # )#DKK$=$=>!]]446$(KK$5$5$D$D   rhcN|jj}d}i}|j t|jdd5}t j |}dddtts td|jddk(r ti}}n|jdg}t|trtd|Dn t}|jd i}t|tr=|jD cic]"\} } t| tst| | $}} } |j | |j n||j z}|xs t|fS#1swYxYw#t tf$r}td|d}~wwxYwcc} } w) Nrr)encodingALLOWLIST_UNAVAILABLEdmPolicydisabled allowFromc32K|]}t|ywrs)ry)rxs rirz*Gateway._load_allowlist..rs5!s1v5sgroups)rauthtelegram_access_fileopenjsonloadOSErrorrr=rrr frozensetritemsryallowed_sender_ids) rwr`dmr_r9rrallow raw_groupskvs ri_load_allowlistzGateway._load_allowlistbsw{{'+  $ $ 0 C$33S7K-v99V,D-dD) !899xx #z1&["Fb19CE49PY5u55V_Va!XXh3 j$/4>4D4D4F^DAq*UVX\J]c!fai^F^  " " .,.J((BAXAXE1E>F!'F!1E;6E>>F FFc|jdk7ry|j\}}|jdk(r;|j|jk7ry|j|vryt j dfS|jdvr~|j|j}|y|jd xsg}t|tsy |r&|j|Dchc] }t|c}vry t jd fSy cc}w)Nr)NUNSUPPORTED_TRANSPORTr@)NCHAT_SENDER_MISMATCH)NSENDER_NOT_ALLOWED ALLOWLISTED)r>rA)NGROUP_NOT_CONFIGUREDr\)NGROUP_POLICY_INVALID)NSENDER_NOT_ALLOWED_IN_GROUP GROUP_POLICY)NUNSUPPORTED_CHAT_TYPE) rGrnrErDrFrkrnrrrryro)rwrallowedr_policy allow_fromr^s ri _authenticatezGateway._authenticatezs    *0..0    )'"3"333  /1??M1 1    7 7ZZ0F~3K06BJj$/3g// 7S1A7SS:))>9 9,8TsC;c gi}}|jjD]G}|jj|j}|j j |j}|jj|j|}|tjuxr|jdk7} |jxr|duxr|jdk7xr| } |j|du|j|| d||j<|jt|j|j|j | ||j"|j$|j&J||fS)Nrrb)r(r/rbudget_availableprincipal_restricted)rUbudget_allowed quality_scoremax_context_bytes task_quality)rr'rrrMrrrrUrkror(rrr) capabilitiestasksqualityrr) rw principaltokensr'statesr-r/r budget_ok restrictedrUs ri_backend_snapshotzGateway._backend_snapshotsHr& ,, Hnn((7G\\'' 6F ..x}}fEI"i&<&<<ZRZAZJ!)),gT.A,fmmW]F],!+^ $++t8KW]WdWd$-z%F8== ! OOG x44hnnPY(8H8H"*"<"<8K`K`   rhcp|j|}|j |js ddd|d<|St|jj ||}|j j |}gd} }|D]} t| ts td|jjtd| fjdd} |j jjj!|| s| dz } t|j"t%|| gz|j&} |j(#| j+|j(kDr| dz } |j-| t/|t/|| d|d<t|j"t%||j&S) Nr)offeredusedmemoryINVALID_MEMORY_SNIPPETr)rr)rrrejected)rraccepts_memoryrrrrrr' TypeErrorrclassifyr&partsrrpermitspromptrrIr size_bytesrr) rwrrenveloperecordr/snippetsr-rrsnippettier candidates ri_enrichzGateway._enrichs..) << w'='=+,a8F8 O 11'7CD;;&&w/Qh !Gg}5 899##,,_R -STZZ[\]^_`D;;&&--55gtDA 'twi?O9PRZRfRfgI))5):N:N:PS[SmSm:mA  KK  !(+8}c$iU]^xxd X=Q=QRRrhc |jj}djd|jDxsd}|jt k(r7|j}|j Dchc]%}|j|k(s|jD]}|'} }}d|d|dg} d| vrIdjtd||Dxsd } | jd |d |d |d | d d| vr| j|dd| vr| jd|d| ddhzr| j|dd| vr| jdd| vr| jd| jddj| S|jtk(r d|d |dSt|j Dchc]}|jD]}|c}}} ddj| xsd zd!zScc}}wcc}}w)"Nz, c3DK|]}|jdr|yw)z attachment.N) startswith)rrWs rirz#Gateway._explain..s\ ]@[!\s  z keine RegelzNicht gesendet: Modus /z ist gesetzt, aber z$ darf diesen Auftrag nicht bekommen.PRIVACY_NOT_PERMITTEDc34K|]}|jywrs)r)rts rirz#Gateway._explain..s*Qq177*QsnichtsuDatenschutz: Einstufung „u“ (z); u erhält nur: . UNAVAILABLEu ist derzeit nicht verfügbar.BUDGET_EXHAUSTEDuDas Tagesbudget für u ist erschöpft.CAPABILITY_MISSINGTASK_UNSUPPORTEDu" unterstützt diese Aufgabe nicht.CONTEXT_TOO_LARGEu,Der Kontext ist für dieses Modell zu groß.QUALITY_BELOW_MINIMUMuADie Qualitätsuntergrenze für diese Aufgabe wird nicht erreicht.uPDie manuelle Wahl hebt keine Prüfung auf. Mit /auto oder /claude erneut senden. uNicht gesendet: Einstufung „u#) ist für kein Modell freigegeben.u3Nicht gesendet: kein geeignetes Modell verfügbar (zkeine Backends).) rrjoinrule_idsrvr, candidatesrreasonsrTrr.) rG assessmentmode matrix_tiersrruleswantedcrWrlinesrys ri_explainzGateway._explains$$ \Z%8%8\\m`m ==7 7ZZF"*"5"5`Qf9LVWV_V_`QRq`q`G`.vh6I&QuvwE&'1))F*QLrr)rGrFrDrErH prompt_sha256 prompt_charsattachment_count)rrrr}updaterGrFrDrErHr(rCrrrI)rwrr5rs ri _base_recordzGateway._base_records"4;;=1JV]R]^ g~ . MM$..W=N=N[b[j[j$..g>P>P!+GLL,?,?,H!I #GLL 1s7K^K^G_    rhc 8|jj|d<|j|d<|j|d<t |j |d<|j r|j |d<ttj|z dzd|d< |jj||S#t$r`|r3ttjd |j |j" cYStd ii|j$d|j d zicYSwxYw) Nrrvrrr duration_msLOG_UNAVAILABLE)rrLOG_WRITE_FAILEDrg)rrrvrrrrroundtime monotonicrrCrJrrSrfrr__dict__)rwrresponsestartedmust_logs ri_respondzGateway._responds%..44z!v#??xx~~.w  $ $)1)B)BF% & %t~~'7''AT&I1 M} m IIOOF #   m&x~~7HQYQ`Q`.6oo??"l%k(9(9%k7HNNUjDj%kl l  msB00N>N  rhc rdnd}|jjvrttjd dfSt |t sttjd dfSd4fd }j|\}}|r |jnd|d|d <| |ttjd Sd |jd |j} | |d <r jn j} r jn j} | j!|j"d|jd|j| j%\} } | s'| |d<|ttjd| St'| }|t(j*u}t-|j.}|j0j|d<|j0t2j4ur"|ttj6d| S|j0t2j8t2j:fvrX|sV|j=t>j@|ttj@d| |jBjS|j0t2j8ur| jE|j|jF|jFj|d<|jFtHjJurdnd}|ttjLd| d|jFjd|dS|j0t2j:ur|jF|j.}}n9|r| jO|jntHjJ}|j.}|j|d<|jQsb|jRsV|j=t>j@|ttj@d| |jBjStU|jWdjjXjZkDrV|j=t>j@|ttj@d | |jBjSt]|d!|jR}j^ja|}tc|jjdjf}ti|jk}|jm|jnjtq|jr|jtDcgc]\}}||jd"c}}|jv|jxt{|j||jk|d#j||\}}||d$<t| |jv|jn|j|||jk%}t||jjjjjdjjjdjd&k('}|j|j|j|j|j|jDcgc]:}|j|jtq|j|jd(<c}d)|d*<|jr |j|j=t>j@|r<j|||jjjjnd}|ttj@|j| |jBj||jnj+S|j} |jtk(rd,nd!}! j|| ||}"j^ja|"}#|#jnj|d/<jjjj| |#jnsW|j=t>j@|ttj@d0| | |jBj.S| d1k(rtjntjL}$sKttj|j| | |!d2|$j|#jnj3d2fSj||||| | |"|#|!|| Scc}}wcc}w#t$rZ|j=t>j@|ttj@d-| | |jBj.cYSwxYw)5Nr5rMODE_NOT_ENABLEDrFrc6r|dfSj|dfS)NF)r)rr5rws ridonezGateway._decide..dones% 'H5P PT->->x-H5P Prh)rreasonauthenticationNOT_AUTHORIZEDztg--r: duplicate_ofDUPLICATE_MESSAGE)rcommandPLUGIN_OWNED_COMMANDMODE_COMMAND_NOT_ALLOWED)rr manual_modezautomatische Auswahlu=Datenschutz-, Budget- und Verfügbarkeitsregeln gelten weiterMODE_SETuModellmodus für diesen Chat: z (r)rr EMPTY_MESSAGErrrg)partr)r privacy_rules privacy_parts task_class task_ruler context_bytestoken_estimate backend_state)rchecked_fallback) min_qualitymanual_fallback)religiblerr)rvselected tie_breakmanual fallback_fromrrouting)rrrr)r*MEMORY_PROVIDER_ERRORrrr final_privacyPRIVACY_CHANGED_BY_ENRICHMENTrT)rrrrrr)rr)YrrOrrSrfrr}r|rr_rDrHrrrrclaimrGrr4rkrnr"rCrKr! PLUGIN_OWNEDr`SET_MODEONE_SHOT transitionr5rbrrrr-AUTOrarstriprIrrlimitsrr&rrrrdefault_task_classrrrrrrrrrulerTrrr+r1rrrrrvrrrrrrrrryr tiers_forr*rrJrrdre_execute)%rwrr5rr mode_namerr auth_reasonrdedupemodesclaimedoriginal lifecyclerlparsedhintrrrrtaskrrMrr'rjobrGrrVrrfinal_envelopefinalplanneds%` ` rirzGateway._decide sX!(Ih DKK55 5"8>>3ERYkZ\aa a'>2"8>>3DQX[Y[`` ` Q"&!3!3G!< ;DMSWcn#o   7GHI Iw'q););(<=!x!(d.A.A& D,>,>"LLG,=,=+>a?PPQRYRdRdQe)f)/@%-F> " 7JSYZ[ [ ( Y__,w||,"KK--y ;;+22 2(@(@BXaghi i ;;;//1E1EF Fu  !2!2 3(8(8:T]c/8/?/?/E/EGH H ;;+.. . IIgoov{{ 3$*KK$5$5F= !.4kkTYY.F*X  65STZT_T_TeTeSffhimhnnp3qst t ;;+.. ."(++v{{K8=%))GOO4499K\\F + 1 1}||~g&9&9  !2!2 3(8(8/RX/8/?/?/E/EGH H v}}W% &););)J)J J  !2!2 3(8(8:JSY/8/?/?/E/EGH H#62w/B/BC%%..x8 Xt{{':':'M'MN !4!4!67 !,,tJDWDW?XS]ScScdZT4tTZZ@d// SYZ^ZkZkSl%002f    11)VD&"(*//4CTCTVa'/':':'<>h (;(;(B(B%)[[%8%8%D%D)-)<)<)L)LPb)bdMMx/?/?hN`N`oo8N8N;C;N;NP67()yyajjUYZ[ZcZcUd'(yy2P y 8#3#3#;  !2!2 3]]8ZdkkFYFYF`F`FjFjk#' (8(8(--PV/8/?/?/E/ERW0:0E0EGH H"")1:J)J%PR Y!\\'7HfMN   )).9"'**"2"2{{""))11'5::F  !2!2 3(8(8:Ybh07 @P@P@V@VXY Y:AH9L855RZR`R`"(((--PW_dgmmUZZEUEU  }}Wfgy&'Sach"E85 5_eP Y  !2!2 3(8(8:QZ`07 @P@P@V@VXY Y Ysf .?f'fA g;:g;c |j} dk(r*t|jjjn t} t ||j |j|j|j|j| }|j|d<tjfd8fd } | j|}t#|j%}|j&j)|s|dS |j*j-j.||j |j}d |j<|d |d<j?t@jBjDjF|d< |jHjKi|dddj?t@jN | jQ||}|jDtTju}|j&j3| |jWDcic] \}}|dvs ||}}}d|d<|d<|jDjF|d<|jX|d<|jDtTjZur(|j\j_ta|jb|jjdjf}j?t@jhtk|jb|d<tm|jbjod|d <tq|jr|d!<t5tjtd"jDjF|jv| |jxzj.jF#}n%|jDtTjzurj?t@jhd}| j t|k(r| rd$| j~d%d&}t5tjd'jDjF||j| j.jF( }nj|jDtTjLur|j\j|jXxsd)}||d*<j?|jrt@jnt@jL| rd+d,|jXd-nd}t5tjL|jXxsd.jDjF|| j.jF#}nuj?t@jLt5tj|jXxsd/jDjF| j.jF0}ttj|z d1zd2|d3<|jjF|d<|j |d<|jD|d<tq|jx|d4< |jHjK|||d6<y7#t$r}||j cYd}~Sd}~wwxYw#t0$rP}|j&j3d t5tj6|j  d fcYd}~Sd}~wt8$r9}|j&j3d ||j cYd}~Sd}~wt:$r|j&j3d wxYw#t:$rs|j&j3d j?t@jLt5tj6djDjFd fcYSwxYw#t:$r!tStTjLd}Y'wxYwcc}}w#t:$r,t5d9ii|jd4|jxd5zi}YwxYw):Nr)timeout_secondsfinal_context_sha256rvrcjtjurjtjt ||jj jj dfS)N)rrrrT)rr5CREATEDrrbrrr)rvrrrrrs rirWz!Gateway._execute..blockedsf9#4#44$$Y%6%67"8T&'*3*:*:*@*@*//J_J_abfg grhr)rrrcontext_digestrFrDF)consumed)rrT)clearance_issued expires_atoutbound_sha256 authorizationrpendingCLEARANCE_ISSUED)rrvrrADAPTER_EXCEPTION) error_code)rBrrrGrFrDrErHoutcomer>radapter_status adapter_code) max_chars output_charsr output_sha256 redactions COMPLETED)rrrrrrz Hinweis: uJ war für diesen Auftrag nicht zulässig; nach vollständiger Prüfung an z weitergeleitet.FORWARD_ISSUED)rrrrrrrrhealth_countedz Auftrag an z fehlgeschlagen (z?). Es gibt keinen automatischen Wechsel auf ein anderes Modell.rcADAPTER_BLOCKED)rrrrrrrrrrr)NT)rvryrrSrg)JrrrrrrrFrDrHrJrBdigestrSrboutbound_digestrrvrrrreserverissuerrsettlerrfrrJr#rr5ROUTEDrrrrCrcRUNNINGr5rrrgr)SUCCESSrrAr6outputrmax_reply_charsr1rr(rrr0rarCrFORWARDr*rrdrrB timed_out TIMED_OUTrrrrr)rwrrrrrrrrrrlrGr/rzrrWr6rrrresultr!rlrmoutcome_recordcheckedrnoticecountedrVs ``` ` rir zGateway._execute}s@..)W^biWi1B1B1R1RS " 7+<+g41aQCf>f!Q$gg"+w$+y!+1==+>+>'()/):):~& ==L00 0 LL ' ' 0"6==DKK *.89M9Mg9V.WN? ++/0B0B+CN< (&x~~{6[b.7.>.>.D.DQXQ]Q]-2W]]-BJOOLaLacH]]l22 2  !4!4 5F}} 00U%h&<&<%=>==DIEUW&x'I'IK[dj/6y?O?O?U?Ubh/5~~UT^TcTcTiTikH]]l11 1ll11'6;L;L;RPRSG/6N+ ,  8H8H!4!4iN^N^ _X]#7)+>388FT[\^bb b! % LL    7388$ $  LL    7   H LL    7  !1!1 2"8>>3DV]d*3*:*:*@*@BCGH H H i"67L4G4GTghF ig^ q&p)oH,=,=)owYnHn)opH qs>Z?Z*"],_+9 ``!` Z' Z"Z'"Z'* ])3A[>8])> ]) .\>8])>+]),A9_('_(+&``1aa) rr$rzCallable[[], float]rzOptional[MemoryProvider]rrrzOptional[IsolatedRunner])rMryrr)r+rrr)rzMapping[str, BackendAdapter])rr2)rr}rr)rryrDryr?rrr)rvryrrrNoner)rztuple[frozenset[str], dict])rr}rztuple[Optional[Principal], str])rrkrr~rztuple[list[Backend], dict]) rr}rryrr&rrrr&) rGr0rrrr-rzCallable[[str], frozenset]rry)rrr5rrr) rrrrrfloatrrrr)rrr5rrr)rrrr)rrr5rrrrrH)r\r]r^rrur"rpropertyr,r2r9rrErKrrnr|rr staticmethodrrrr7rrr rgrhrirrsNRii=ABF"T c": c$? c3K cHF2*$$ 45  ,)0-, (SS!0S0w9w>Aww8 " Z r5hirhr)rrHrry)fr __future__rrcrer dataclassesrrrenumrtypingrr r r r r adapter_contractrrrrrrr%rrrrrrrrclaude_channelrrrrr codex_adapterr commandsr!r"rr#r$contextr%r&r'r(corer)r*r+r,r-r.r/r0r1r2r2rr3rr4r5 result_checkr6rr7r8r9rr:r;r<r=rcompilerrrfrrrryrSrkrrqr}rrobjectr)rrrgrhrirYsb4# !'GG20II'05KK&".&@@FF 2::m $ 2::o & D E !#%%hisD"T" :  $D D D N $   @hXh 8[SSrh