h*Q<ddlmZmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z ddl mZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZe rddlmZe ed s e!ed d e ed s e!ed d e ed s e!ed dGdde"Z#y))print_functionunicode_literalsN)ANYWINPY2 TYPE_CHECKINGunicode)gencert)QrCode) E_ACCESS E_ADDR_IN_USEE_ADDR_NOT_AVAIL E_UNREACH HAVE_IPV6IP6ALL VF_CAREFULNetdev atomic_movemin_exsunpacktermsize)SvcHubAF_UNIXi IPPROTO_IPV6) IP_FREEBINDcZeZdZdZdZddZdZdZdZdZ dZ d Z d Z d Z d Zd Zy)TcpSrvzk tcplistener which forwards clients to Hub which then uses the least busy HttpSrv to handle it c ||_|j|_|j|_tjdd|_g|_g|_i|_d|_ d|_ d|_ d}i}|jjD]}|dk(rtjrddg}d}n dg}d}n|g}d}|D]}g||< |jjD]8}d} |D].} |j||||j!|| dz } 0:|j s!|jj*s t'd|r|jd ddt-ddddi} t.rt-dddd| d<|jjD cgc])} | | Dcgc]}|j1ddc}vs(| +}} }|r |j3|jj|_| j5|jj7Dcic]\}}|j1dd|c}}| s |D]} t-| ddd| | <ni|_t9}|jj7D]\}}|j;dsd}|jj7D]$\}}||k(s d |vs|j;dr#d}&|s|jj<st|j?|j1ddg}tA|j7D]+\}}tA|D]}|j!|d|-i}i}g}g}i}|jjBj1dD cgc]} | j;ds| dd}} d} tA| j7dD]\}}|j;dr||vrtA|jjD]}||jE|gvr)||jEdgvr||jEdgvrA|d|}||vr|j!|d} |jjFrn|jjHs|dk(rd} d |vrdj#|n|}!|j!| j#| |!||dtK|v}"|"r|n|}# |#|j!||jjBs |d vr|}$nd!j#||}$g}%d"|vr|"r|%j!d"|$fd"|vsd#|vr|%j!d#|$f|D]<}&|&j;d$s|$j;|&d ds*|%j!|&|$f>|%D]\}'}( d||'|(<|r|D]} |jd | |jjBr|jM|n tOd%d&|jjP|f|jjR|ffD]L\})}*|)s tU|)d'5}+|+jWd%jY|*j[d(dddN|jjs|jj\r|j_|||_ yy#|r:d |vr6d } |jd | j#||dt%d d}Y>| rYCxYw#t&$rb} |jj(s|jj*r*d } |jd | j#||| d d}nYd} ~ d} ~ wwxYwcc}wcc}} w#d} |jd | t%zd i|_YxYwcc}}wcc} w#|g|#|<YxYw#|(di||'<Y?xYw#1swYxYw))NxFr::0.0.0.0Tr:z0listen on IPv6 [{}] failed; trying IPv4 {}... {}tcpsrvzcould not listen on {}:{}: {})cz/could not listen on any of the given interfaces 127.0.0.1z local only::1/z'failed to discover server IP addresses externalfe80 $z&available @ {}://{}:{}/ ({})c |dS)Nr)xs E/jellyfin/media/venv/lib/python3.12/site-packages/copyparty/tcpsrv.pyz!TcpSrv.__init__..s !A$)keyz httphttps[{}])Pr7z{}:{}puballzip- )endwbutf-8)0hubargslogsocketsetdefaulttimeoutstoppingsrvboundnetdevsnetlistnsrvqrihas_ipv6p_listenappendformatr Exception ign_ebind ign_ebind_allrrsplitdetect_interfacesupdateitemsset startswithlladdsortedwintitleget http_only https_onlyr _set_wintitleprintwr_h_epswr_h_aonopenwritejoinencodeqrs_qr),selfrApadokipipsdualipaportsuccessful_bindstexepsr2k nonlocalsvll_okndjust_llip2nd2 listening_onportsqr1qr2msgs accessible_on title_tab title_varsdesczsprotohipis_extqrtephitsvartktvfnlsfs, r3__init__zTcpSrv.__init__/sHH 77   %     ))+++ BTz??+CD$+C Dd 3   #$ """ LLd3sGNN40,1, " + Zxx 7 7MN N  HHXr "  QLA  q"l;CJ $ W1qRU8VQa8V/VQW W  "#55diikkB JJt||7I7I7KLtq! Q*L M":A#Aq"j9CF:DLll((* ,FB==(G LL..0 $S9CNN64J#G $$)),, "((3-*+ ,  + :IBu  :##r4$89 : :  %)YY%7%7%=%=c%BXallSVFWaeX X :syy{?7 0HB}}V$5tyy{{+3 0r2.BFF4$44BFF9b$99 "D)]*!((,99&&YY))TS[#E+."9fmmB'" AHHUCt<=#wt}4#c%GNN4(yy))9$B D1BJ&6KK ,J&%:*=KK ,%/C~~e,s12w1G S"I./#0FB0,- " b)0_3 0 7 0r  &1% & 99     y ) $B YY   . YY   /  =FB"d^=qGGTYYr]227;<==  = 99<<499==hhsC(DG)m "#s $W $188CQ3RTU V&* ( 0 (! yy**dii.E.E;188Bb+AQG" (9WW ">1vx<3! L>Y>%#fCG00)+Q " ==s\%"+[ \% ^^9^>^*^_ _1_5_:_&0_5;\" \%\" \%!\" "\%% ^.A^  ^^)_ _#& _2 5_? c*|jd||y)Nr&)rC)rmmsgr(s r3nlogz TcpSrv.nlogs 3"r5cf dx}}d}d}d|vratj}|jd}|d}t|dkDrt |dd}t|dkDr t |d}n{d |vrN|dd} tjt |  }|jtjk(}|j}n)d|vrd }tj}nd }tj}|xs$tj|tj} tr|jj r/| j#tj$tj&d|r/| j#tjtj(d| j+d | j#tj,tj.dt1|jd dr/| j#tj2tj4d|r|j6j9| y |r| j;||fnts|jj<rFt>j@jC|rt?jD|| j;|nd|t?jFfz} t>j@jC| rt?jD| | j;| |dk7rt?jH| d||dk7rt?jJ| |tM|jN| |tP|r| jSdn|} || k7rtUtVd d|j6j9| y#d dl} | j |dj}YxYw#Y xYw#tTtjXf$r} | j[n#YnxYwd}|j\tVvr&dj_||}|s5dj_|}n#|j\t`vrdj_|}|s|sd}|jcd|d|s|jj<s|dz }te|d}~wwxYw)NFunix:r%rr'rfd:)filenoTfreebindz%s.%dr"z*port {} is busy on interface {}z!unix-socket {} is busyz&interface {} does not existzD NOTE: this crash may be due to a unix-socket bug; try --rm-sck r&z#; maybe this is a bug? try --rm-sck)3rDrrVlenintgrpgetgrnamgr_gidr IPPROTO_TCPfamilyAF_INET6AF_INET SOCK_STREAMrrB reuseaddr setsockopt SOL_SOCKET SO_REUSEADDR TCP_NODELAY settimeoutr IPV6_V6ONLYgetattrSOL_IPrrGrQbindrm_sckospathexistsunlinkgetpidchownchmodrrr getsocknameOSErrorr errorcloseerrnorRrrCrS)rmrprtuds_permuds_gidrHtcpipvudsrfdrGtfsportrwervs r3rPzTcpSrv._listens7 b=..C((3-CRB3x!|s1vq>3x!|:!#a&kG b[ABBMMR1E++!3!33C,,C BYC//CC..C=v}}S&*<*<=,, NN6,,f.A.A1 E  NN6--v/A/A1 E t  NN6..0B0BE J 499j% 0 NN6==&*<*,/COO%a(TEu}mA.33 HHOOC :!ll3q6299G4  D&    Axx=(FMMdTVWAHHLA--BII"MbAHHXq!,tyy//::A, / sDN(/O3E4O($OOR04PR+P B$R++R0c |jDcgc]}|jdd}}g}g}|jD]}|jtjk(r*d}t j dd|j}d}nd}|jdd\}}|tk(rd} |j|jj |jtjtj} | s(td j|j |j%||f|j%||j'} |r>d |vrdj|n|} dj| || t)j*} n%dj|| t)j*} |j#d | |jj,r t/| |j0j2j5d|||_||_t9||_|j=ycc}w#d} Y[xYw#|d k(rd|f|vr|j!YA|dk(rd |f|vr|j!Y_d } |j#d | j||dxYw)NrFz \.[0-9]+$r"rTr#rzfailed to listen on {}r$z ERROR: could not open listening socket, probably because one of the server ports ({}) is busy on one of the requested interfaces ({}); avoid this issue by specifying a different port (-p 3939) and/or a specific interface to listen on (-i 192.168.56.1) r&r%r9zlistening @ {}:{} f{} p{}zlistening @ {} f{} p{}zhttpsrv.listen)rGrrrDrresubrlistenrBnc getsockoptr SO_ACCEPTCONNrSrRrrCrQrrrqrdrAbrokersayrHrrK_distribute_netdevs)rmr2all_epsrHsrvsrGrrprtrorvfnorrs r3runz TcpSrv.runZsU04911==?2A&99882 7CzzV^^+VVL"coo.?@??,Ra0DV|  499<<((9(96;O;OPB#$<$C$CCOODU$VWW$ LL"d $ KK **,C+."9fmmB'"299#tS"))+V/66r3 L HHXs #yy{{c HHOO   0# 6e2 7h I    "u:&B ?d|u'<IIK:9d"3w">IIKX188D"#5q9s5I *%I.I>*IIIK<K&KcV|jjjd|j|jj t |j |j|j|jj|jjy)Nzhttpsrv.set_netdevs) rArrrIstart_zeroconfr rCrB restart_ftpd restart_tftpd)rms r3rzTcpSrv._distribute_netdevssg 14<<@ !$))T\\2   r5cd|_ |jD]}|j |jddy#YxYw)NTr&zok bye)rFrGrrC)rmrGs r3shutdownzTcpSrv.shutdownsD  xx    8$  s !>Ac||js/tj|jj|j |jj }|s^g}g}|jD]+\}}||jvs|jd|d|-|jjD]!\}}||vs |jd|d|#d}|jd|dj|dj|fzd||_|j|js.yy)Nz  added z = z removed znetwork change detected:%s%sr&r"r') rFtimesleeprBz_chkrWrMrYrIrQrCrir)rmrIr]remryr{rvs r3netmonz TcpSrv.netmons-- JJtyy ',,TYY[[9GCC  E1DLL(JJaCD E **, E1G#JJaCD E/A HHXqBGGCL"''#,#?? C"DL  $ $ &%--r5c ddlm}|Dcgc]}|jdr|}}|d}i}|D]}|jD]}dt |j vr|j dn |j }dj ||j} t| |jxsd|jd} | || < tj| j} | rE| | jk7r6d } |jd | j | j| d | | _t t!|j#} | |j$k(r|j&riS| |_d |vr>d |vr:|j#Dcic]\}}|j)dd|vs||!}}} t+|j-}|j#Dcgc]\}}|j|vs|}}}|Dcgc]}|j)dd}}|s t/ |D]e}|r |d d g|zvrd}|dvr|n|g}|D]Gt3fd|Ddsd|j4vs-|xj4d|zz c_Ig|Scc}w#Y^xYwcc}}wcc}}wcc}w#|j1}|r|gng}YxYw)Nr) get_adapters)rrTr%rz{}/{}r"z)netdev idx mismatch; ifaddr={} cpython={}r&r'r$r#r+z external)r$r#c3LK|]}|jdzs|yw)r+N)r[).0r2rps r3 z+TcpSrv.detect_interfaces..s DQ\\"s(-C1Ds$$r,, ) stolen.ifaddrrr[rqstrrprRnetwork_prefixrindex nice_namerDif_nametoindexnameidxrCr^rYrJrIrVlist _extdevs_nixrS _defroutenextr)rm listen_ipsrr2nicsrxnicniprssipr}rrvrJryr{ext_devsext_ipsrtliprrqrps @r3rWzTcpSrv.detect_interfacess/!+RA1<<@P3QaR RD! Cww #&#cff+#5cffQi366nnS#*<*<=CaCC //8Csbff}G188BFFC+@!D!$  fSYY[)* dll "t||I J &4z+A$'IIKQDAq1773<?j3P1a4QCQ )D--/0H%(YY[GTQAFFh4FqGGG0781qwws|A8G8k!  0Cc)T):W)DD%D $55'C5C 0DcDbI*CGLL8GLLD4K/L 0 0 cS RH8 )!B rdbGsSJJA&J J%+J%4,J6 J+7J+;J6J1J6J"+ J66Kc#Ktdd5}t||D]R}|jdjj }|ddk(s9t |dddzsL|d T dddy#1swYyxYww) Nz/proc/net/routerbr@r00000000r'rr)rgrdecodestriprVr)rmrlnrs r3rzTcpSrv._extdevs_nixs #T * a G IIg&,,.446Q47?s1Q4}q'8A$J    s) BAA<A<) A<3 B<BBcd}tjtjtj}dD]*} |j|df|j d}n|j|S#t tj f$r{}|jtvr"|jddj|n=|jtvr+|jddj|jYd}~d}~wwxYw)Nr")z 10.254.39.23z 172.31.39.23z 192.168.39.23z 239.254.39.23z 169.254.39.23rrr&zeaccess {} (trying next)zroute lookup failed; err {}) rDr SOCK_DGRAMconnectrrrrr rCrRrr)rmretsrprws r3rzTcpSrv._defroutes MM&..&*;*; <  WB W 2q'"mmoa( W&   V\\* W88x'HHX'A'H'H'LMXXY.HHX'D'K'KBHH'UV  Ws&A66D A1DD c |jdddi|d<|jd|d|d<i}|jD]\}}|Dcic] }d|vs|d }}t|}t|D]1}|j dd}||vs|j |d||<3|D cgc]} | j ds| } } t|dkDr| r| D]}|j||||<d } |}|jjj d D]} | j d r^tt|j| ddd dij} d j| dd} t| dkDr| dz } | dj| z } tdj| t j"d t j"j%ycc}wcc} w)Nr<z Local-Onlyrr;r%rz127.r'r"r.r/z(None)rz, ...z{} z ]0;{}\ )filer>)r`rYrZr^rVr]r[rpoprBr_rkeysrirRrdsysstderrflush)rmvsvs2ryrxrfilthaverpr2lotitlerOsepss r3rczTcpSrv._set_wintitlesFF5<"345 FF5"U),5 hhj FAs$'9b3b=BE9D9t9DSk !XXc]1%T>HHRL DH  ! ":Q\\&%9!:B:4y1}!BHHRL!CF   ##))#. %A||C F266!AB%(A#?#D#D#FGHIId2Ah't9q=LA U\\!_ $E % !((/cjjbI 7:;s G2G2+G7G7c|jDcic] \}}|dvs ||}}}|jDcic]\}}d|vs ||vs||}}}|jDcic]\}}||vs ||vs||}}}|j||j|d}t|t|z}|jj} |jj rJ| sH|rF|jj dz} td|xs|jD|| <| g|z}|D]}|j| s| dk(rnd}|s| }|syd|vrd|dn|} |jjrd} n3|jjrd } n|jjrd nd} |j||j|g} | rd nd }|| vs| sdnd j| d }dj| | ||jj}|j!d}t"rt%dt'|z|}|jj(|jj*|jj,}|jj.}t1j2|}|d k(r6 t5\}}t7|dz|}|j8|dzz|k\rdnd}|j;||}|jj<rdj||Sdsdfd}|dkDrt?j@d||}|jCdddz}rdnd}|dz}|j|}tDr|jCdd}||zScc}}wcc}}wcc}}w#d}YxYw)N)r)r*r%z.localc3 K|]}|yw)Nr1)rr{s r3rzTcpSrv._qr..Cs;!A;s .r"[]rr7r:z:{}rzhttp{}://{}{}/{}r@Brrz{} {}z[40;48;5;{0}m{1}[47;48;5;{2}mz{1}c `jdt|jdzS)Nr.r)rRrgroup)mbgfghalfcs r3ansifyzTcpSrv._qr..ansifyys'<<C#aggaj/$92> >r5u(█+)r=z zz [0;38;5;{0};47;48;5;{1}mz z {2}z` `)#rYrXrrBqrizmrrvaluesr[rarbrkr`rRqrlrjrrrqr_fgqr_bgqrpqrzr encode_binaryrminsizerenderno_ansirrreplacer)rmt1t2rzlit2ct2brprqr+rrr8rdportrttxtbtxtrnzoomqrctwthtszrLr*ccrvr'r(r)s @@@r3rlz TcpSrv._qr7sc&(hhjO72sB:N4Nr3wOO&(hhjP72sC2I"C-r3wPP%'XXZ S'"c2S=Rs]b#g S S # # 2hb!iimm 99<<99>>H,D;b'8'8':;;BtH&3,C B}}S!SCZB  B #r nr 99  E YY ! !E99==CbEr266"b>*"e^5rell586L ''sD$))--Hzz'" 4#d)+T2D YY__ YY__iimmyy}}""4( 19 !B"'2&HHsQw.#5q1ZZc " 99  ??3+ +7-E ? !8&"-B ZZj )H 402 ,8H . . HHRR   $'AQw_PP Sh s9 N-N- N3 N3N3, N99N9>N95N??ON)r)__name__ __module__ __qualname____doc__rrrPrrrrrWrrrcrlr1r5r3rr)sK )B#eN;#z!%'*4l2!FPr5r)$ __future__rrrrrDrrrrrrr certr stolen.qrcodegenr utilr r rrrrrrrrrrsvchubrhasattrsetattrobjectrr1r5r3rSs7 99$    vy! FIu%v~& FNB'v}% FM2&^ V^ r5