+ D#j<a0t$^RIHt^RIt^RIt^RIt^RIt^RIH t ^RI H t H t ^RI HtRtR]R&R tR]R &R tR]R &R tR]R&]!0Rm4tR]R&] !RRR7!RR44tRRlt!RR] 4t!RR]P2] 4t.ROtR#)) annotationsN) dataclass)BaseHTTPRequestHandler HTTPServer)Finalzapi.anthropic.comz Final[str]ANTHROPIC_HOSTzgpt-CODEX_MODEL_PREFIXz anthropic.PICKER_MODEL_PREFIXg @z Final[float]UPSTREAM_TIMEOUT_SECSzFinal[frozenset[str]] HOP_BY_HOPT)frozenslotsc,]tRt^t$R]R&R]R&RtR#) RouteTargetboolcodexz str | NonemodelN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r_/home/user/overdeck-private-tests/subrouter-s5-systray-latest/modules/systray/claudex_router.pyrrs K rrc V^8dQhRRRR/#)robjectreturnrr)formats"r __annotate__r""s$$$;$rc \V\4'g \RR4#VP\4'dV\ \4RMTpVP\ 4'd \RV4#\RR4#)FNT) isinstancestrr startswithr lenr )rbares& r route_targetr)"sm eS ! !5$''050@0@AT0U0U5()+ ,[`D )**4&& ud ##rc]tRt^+t$RtR]R&RRltRRltRR ltR R lt R R lt RRlt RRlt RRlt RRltRRltRRltRRltRRltRtR#) _HandlerzHTTP/1.1 HybridRouterservercV^8dQhRR/#rr Noner)r!s"rr"_Handler.__annotate__/src (VPR4R#rN_forwardselfs&rdo_GET_Handler.do_GET/ crcV^8dQhRR/#r/r)r!s"rr"r12s4rc (VPR4R#r3r4r6s&r do_DELETE_Handler.do_DELETE2r:rcV^8dQhRR/#r/r)r!s"rr"r15s)))rc DVPVP44R#Nr5 _read_bodyr6s&rdo_POST_Handler.do_POST5 doo'(rcV^8dQhRR/#r/r)r!s"rr"r18s)))rc DVPVP44R#rArBr6s&rdo_PUT_Handler.do_PUT8rFrcV^8dQhRR/#r/r)r!s"rr"r1;s))$)rc DVPVP44R#rArBr6s&rdo_PATCH_Handler.do_PATCH;rFrc$V^8dQhRRRRRR/#)rr!r%argsrr r0r)r!s"rr"r1>s!#frc R#rAr)r7r!rPs&&*r log_message_Handler.log_message>rcV^8dQhRR/#)rr bytesr)r!s"rr"r1AsErc VPPR4pVfR#VPP\ V44# \ dR#i;i)content-lengthr)headersgetrfilereadint ValueError)r7lengths& rrC_Handler._read_bodyAsM!!"23 > ::??3v;/ /  s#A AAc V^8dQhRRRR/#)rbodyrVr r0r)r!s"rr"r1JsUtrc  6VPV4wrVPV4pTP TP TP YPY4R7TP4pTPT4TP4R# \d!pTPRRT 24Rp?R#Rp?ii;i \\PP3d pTPRRT 24Rp?LRp?ii;i TP4i;i)iz)claudex router: upstream connect failed: N)rbrYz)claudex router: upstream request failed: )_rewrite_for_codex_connectOSError_send_error_jsonrequestcommandpath_upstream_headers getresponse_relayhttpclient HTTPExceptionclose)r7rbr connectionexcresponses&& rr5_Handler._forwardJs--d3  u-J     diid9D>DDDc V^8dQhRRRR/#)rrbrVr ztuple[bytes, bool]r)r!s"rr"r1\s 9 9u 91C 9rc V'gVR3#\P!V4p\ T\ 4'gTR3#\ TPR44pTP'dTPfTR3#TPTR&\P!T4PR4R3# \\P3dTR3u#i;i)Frutf-8T) jsonloadsUnicodeDecodeErrorJSONDecodeErrorr$dictr)rZrrdumpsencode)r7rbpayloadtargets&& rrd_Handler._rewrite_for_codex\s;  jj&G'4((; gkk'23|||v||3; !<<zz'"))'2D88#D$8$89 ;  sB22CCc V^8dQhRRRR/#)rrrr http.client.HTTPConnectionr)r!s"rr"r1ks//d/'A/rc zV'dVPP4#VPP4#rA)r- connect_codexconnect_anthropic)r7rs&&rre_Handler._connectks+ ;;,,. .{{,,..rc$V^8dQhRRRRRR/#)rrbrVrrr zdict[str, str]r)r!s"rr"r1ps!  e D ^ rc lVPP4UUu/uF9wr4VP4\9gK VP4R9gK7W4bK; pppV'dRVPP 2M\ VR&RVR&V'd\\V44VR&V#uuppi)hostz 127.0.0.1:HostidentityzAccept-EncodingContent-Length)rrX) rYitemslowerr r- codex_portrr%r')r7rbrkeyvaluerYs&&& rrk_Handler._upstream_headersps#ll002 2 yy{*, 14D^1^ CJ2  DIJt{{'='=&>?n%/!" (+CIG$ % sB0B0B0c V^8dQhRRRR/#)rrtzhttp.client.HTTPResponser r0r)r!s"rr"r1|s))7)D)rc VPR4pVPVP4VP4FFwr4VP 4\ 9gVP 4R8XdK5VP W44KH VeVP RV4MVP RR4VP4VPR8XgVPR 9dR#VPR4pV'gMVfFVPP\V4R R 2P4V,R ,4MVPPV4VPP4KVf8VPPR 4VPP4R#R# \\ 3d RTnR#i;i) rXNrzTransfer-EncodingchunkedHEADTi xz s s0 )i0) getheader send_responsestatus getheadersrr send_header end_headersrir\wfilewriter'rflushBrokenPipeErrorConnectionResetErrorclose_connection)r7rtcontent_lengthrrchunks&& rrm_Handler._relay|sy!++,<= 8??+"--/JCyy{j(CIIK;K,K   S (0  %   -~ >   0) <  <<6 !X__ %B  ) d+!)JJ$$E 1~T%:%A%A%Ce%Kg%UVJJ$$U+   "%   .   "& !56 )$(D ! )s%F=?B:F==GGc$V^8dQhRRRRRR/#)rrr]messager%r r0r)r!s"rr"r1s! ) )s )S )T )rc  \P!RRRRRRV//4PR4pVPV4VP RR4VP R\ \ V444VP4VPPV4R # \\3d RTn R #i;i) typeerror api_errorrrxz Content-Typezapplication/jsonrTN) ryr~rrrr%r'rrrrrr)r7rrrs&&& rrg_Handler._send_error_jsons** Wg Y'P Q &/  )   v &   ^-? @   -s3wB?)rN)rrrrprotocol_versionrr8r=rDrIrMrRrCr5rdrerkrmrgrrrrr+r++sT! )))$ 9/ )< ) )rr+ca]tRt^tRtRtRV3Rllt]RRl4t]RRl4t R R lt R R lt R Rlt RRlt RRltRtV;t#)r,TFc V^8dQhRRRR/#)rrr]r r0r)r!s"rr"HybridRouter.__annotate__s553545rc J<\SV`R\4WnRVnR#) 127.0.0.1N)rr)super__init__r+r_thread)r7r __class__s&&rrHybridRouter.__init__s )84$04 rcV^8dQhRR/#)rr r]r)r!s"rr"rs++c+rc :\VP^,4#))r]server_addressr6s&rportHybridRouter.ports4&&q)**rcV^8dQhRR/#)rr r%r)r!s"rr"rs//#/rc RVP 2#)zhttp://127.0.0.1:)rr6s&rbase_urlHybridRouter.base_urls"499+..rcV^8dQhRR/#rr rr)r!s"rr"rs  9 rc b\PPRVP\R7#)rtimeout)rnroHTTPConnectionrr r6s&rrHybridRouter.connect_codexs*{{)) 2G*  rcV^8dQhRR/#rr)r!s"rr"rsZZ#=Zrc T\PP\\R7#)r)rnroHTTPSConnectionrr r6s&rrHybridRouter.connect_anthropics{{**>CX*YYrcV^8dQhRR/#r/r)r!s"rr"rstrc VPe \R4h\P!VPRR7VnVPP 4R#)Nzclaudex router already startedT)rdaemon)r RuntimeError threadingThread serve_foreverstartr6s&rrHybridRouter.startsB << #?@ @ ''t/A/A$O  rcV^8dQhRR/#r/r)r!s"rr"rsdrc VP4VPe$VPP^R7RVnVP4R#)Nr)shutdownrjoin server_closer6s&rstopHybridRouter.stops=  << # LL  a  (DL rc$V^8dQhRRRRRR/#)rrhrclient_addressr r0r)r!s"rr"rs!FFtrc R#rAr)r7rhrs&&&r handle_errorHybridRouter.handle_errorrTr)rr)rrrrdaemon_threadsallow_reuse_addressrpropertyrrrrrrrr __classcell__)rs@rr,r,s_N55 ++// Z rr,>tetrailerupgraderr keep-alivetransfer-encodingproxy-authenticateproxy-authorization)rr r,r rr))__conditional_annotations__ __future__r http.clientrnry socketserverr dataclassesr http.serverrrtypingrrrr r r frozensetr rr)r+ThreadingMixInr,__all__)rs@rrs"" !:0 0!'J'".Z.&+|+$- / % !  $d#$ $z)%z)z'<.. 'T r