hk/dZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl m Z mZmZmZmZddlmZ ddlmZdZdZej4dZGd d ej8Zy#e$r ddlmZY:wxYw) z7 Handles making requests and formatting the responses. N)STANDARD_OUTPUT BOLD_OUTPUT ERROR_OUTPUT uses_settingsmsg)format)StringIOdc|s |jdStjjj |r|Stjjj |r |j|jSd|vs*tjjj|rfd|vr|jdd\}}tjjj|std|z|r7tjjj|std|zt|}n|d}}i}|jD]=}|j|k(s|r|j |k(s%|j||j <?t#|d k(rtd |zt#|dk(rt%|j'd Sd |z}t)|D]\}}|d |dz||||fzz }t|td |z#tdxYw#td|zxYw)a Resolves user input into a relay fingerprint. This accepts... * Fingerprints * Nicknames * IPv4 addresses, either with or without an ORPort * Empty input, which is resolved to ourselves if we're a relay :param str arg: input to be resolved to a relay fingerprint :param stem.control.Controller controller: tor control connection :returns: **str** for the relay fingerprint :raises: **ValueError** if we're unable to resolve the input to a relay fingerprintz,We aren't a relay, no information to providez0Unable to find a relay with the nickname of '%s':z'%s' isn't a valid IPv4 addressz'%s' isn't a valid portNrzNo relays found at %szAThere's multiple relays at %s, include a port to specify which. z %i. %s:%s, fingerprint: %s z1'%s' isn't a fingerprint, nickname, or IP address)get_info ValueErrorstemutil tor_toolsis_valid_fingerprintis_valid_nicknameget_network_statusr connectionis_valid_ipv4_addressrsplit is_valid_portintget_network_statusesaddressor_portlenlistvalues enumerate) arg controllerrportmatchesdescresponseirs c/var/www/betterdocs.net/sherlock_api/venv/lib/python3.12/site-packages/stem/interpreter/commands.py_get_fingerprintr+ s4" G   // yy//4 J yy,,S1Q  * *3 / ; ;; czTYY))??D czjja(mgt YY ! ! 7 7 @:WDEE  ,,::4@2T9:: Yd4tgG//13  t||t+"&"2"2'$,, 3  7|q .4 55 W  '.." #A &&VY\\h!'*c*!W4AwQXY`Qa7bbbc x  H3N OOSG E FF Q ICO PPsH'*H7' H47Ic#Ktjtjf}||ct_t_ d|\t_t_y#|\t_t_wxYwwN)sysstdoutstderr)r/r0originals r*redirectr2`sL ZZ #(!6#*cj& %CJ XCJ s8A3AA3A00A3cFeZdZdZdZdZdZdZdZdZ e d dZ y ) ControlInterpreterzw Handles issuing requests and providing nicely formed responses, with support for special irc style subcommands. cg_tjjttj |j d|_d_d_ jjfd}|j_ y)N)rz stem.controlr$eventsTFc|jjd|tjtkDrjj yy)Nr)_received_eventsinsertr MAX_EVENTSpop) event_messagehandle_event_realselfs r*handle_event_wrapperz9ControlInterpreter.__init__..handle_event_wrappersK & ""1m4 T " " #j 0 !!# 1) r8codeInteractiveConsole__init__rcontrol get_events _controller_run_python_commandsis_multiline_context _handle_event)r>r$r?r=s` @r*rCzControlInterpreter.__init__qsD$$Tll ,"D $D !&D ((66$&:D"r@ct|j}tttj|}|r|Dcgc]}|j |vs|}}|Scc}wr-)r r8mapstruppertype)r> event_typesr6es r*rEzControlInterpreter.get_eventssR $'' (Fs399k23K!;aQVV{%:;f; Mr#s r*do_helpzControlInterpreter.do_helps)    ) )$*:*:C @@r@c |jj}d|vr|jdd=tdgtSdj |j |Dcgc]}tt|gtc}Scc}w)a Performs the '/events' operation, dumping the events that we've received belonging to the given types. If no types are specified then this provides all buffered events. If the user runs '/events clear' then this clears the list of events we've received. CLEARNzcleared event backlog )rMsplitr8rrjoinrErL)r>r#rOrPs r* do_eventszControlInterpreter.do_eventssv))+##%K+    " + >o >> 99Q\@]^1fSV6o6^ __^s Bc  t||j}|jj |d}|jj|d}d}|jj|d}|std|zgt Stjjjd}|j|} |j|} | D]} | }| D]} | }g} | jt!j"|j$d | j|jj'd|j$z| rddj)| znd } |rt |j*}n|rt |j*}nd }|j,d |d td gt.|j$d|j0| zg}|r5|jtdgt.t |j2z|jtdgt.dj)|j4z|jtdgt.|z|r|j6rtj8j:j=|j6}dD]}|j?|d}dD]}|j?|d}|jtdgt.|zd|fd|fd|fd|fg}tdgt@}|D]X\}} | s |d |t|gt.|d gz }|t | jCDcgc]}t|gt@c}z }Zdj)|S#t$r#}tt |gt cYd}~Sd}~wwxYw#YxYw#Y{xYwcc}w)z Performs the '/info' operation, looking up a relay by fingerprint, IP address, or nickname and printing its descriptor and consensus entries in a pretty fashion. Nz+Unable to find consensus information for %s)timeoutrzip-to-country/%sz (%s)z, Unknownz ()z address: r z tor version: zflags: z exit policy: )z at z AT @)z dot z DOT .z contact: zServer Descriptor:zExtrainfo Descriptor:zMicrodescriptor:zRouter Status Entry:zP--------------------------------------------------------------------------------rW)"r+rFrrrLrrget_server_descriptorget_microdescriptorr descriptorremoteDescriptorDownloaderget_server_descriptorsget_extrainfo_descriptorsappendsocket gethostbyaddrrrrY exit_policynicknamerr tor_versionflagscontactr str_tools _to_unicodereplacer splitlines)r>r#r excns_desc server_descextrainfo_desc micro_desc downloaderserver_desc_queryextrainfo_desc_queryr'address_extrainfoaddress_extrainfo_labelexit_policy_labellinesrqaliasdescriptor_sectiondivlabellines r*do_infozControlInterpreter.do_infos-$S$*:*:;k11+tDG""88dKKN!!55k4HJ  AKO _R^ __ ''<?[)/:&w'   ,O ,C)U t  "c6%6+6R@@ SY=Q=Q=STT&00TTU 99U o - CH ,| ,,-@    ^Us;N $1N;7OO  N8N3-N83N8;OOc |s#|jrdnd}td|zgtS|jdk(rd|_n.|jdk(rd|_ntd|zgtS|jrd }nd }t|gtS) z] Performs the '/python' operation, toggling if we accept python commands or not. enableddisabledzPython support is currently %s.enableTdisableFzP'%s' is not recognized. Please run either '/python enable' or '/python disable'.zIPython support enabled, we'll now run non-interpreter commands as python.zBPython support disabled, we'll now pass along all commands to tor.)rGrrlowerr)r>r#statusr(s r* do_pythonzControlInterpreter.do_pythons  55y:f 5> Q QQ  "&d  !"'d fill |o{ ||   \hUh ( -_ --r@cL|jd}}d|vr|jdd\}}d}|jdr|j}|dk(rt j |dk(r|j |}n|dk(r|j|}n|dk(r|j|}n|d k(r|j|}nhtd |zgt}nS|j}|jd dd vrttd gt}n|dk(r/|jj|t j ||j!divxr|jdk7}|j"re|sct%}t'||5t(j*j-|||_ddd|j1j}nF t|jj|j3jgt4}|r|dz }|r t=||S#1swYxYw#tj6$r>} t9| tj rtt;| gt}Yd} ~ nd} ~ wwxYw)a Runs the given command. Requests starting with a '/' are special commands to the interpreter, and anything else is sent to the control port. :param stem.control.Controller controller: tor control connection :param str command: command to be processed :param bool print_response: prints the response to stdout if true :returns: **list** out output lines, each line being a list of (msg, format) tuples :raises: **stem.SocketClosed** if the control connection has been severed r^ r/z/quitz/eventsz/infoz/pythonz/helpz'%s' isn't a recognized command+)LOADCONFPOSTDESCRIPTORz"msg.multiline_unimplemented_noticeQUITz help.usager6NrW)striprX startswithrr SocketClosedrZrrrTrrrMrtrrFgetrGr r2rArBpushrHgetvalue raw_contentrControllerError isinstancerLprint) r>commandconfigprint_responsecmdr#outputis_tor_commandconsole_outputrvs r* run_commandzControlInterpreter.run_command-sJ4}}C cz3"hc3 F ~~c IIKc !! ) $ '>c" ) $ '>c"9GCSlS IIKc S" !? ?@AQLQ &= W%!! < <<XPXAX  $ $^#:.7 T(,(?(?(D(DT7(SD % T"**,224& 7D,,009EEGMMObRabF nf  f M' T T%% 7#t001c#h66f  7s%&I+AIIJ#%4JJ#N)F) __name__ __module__ __qualname____doc__rCrErTrZrrrrr@r*r4r4ks@ :@A`$`D..QQr@r4)rrA contextlibrkr.r stem.controlstem.descriptor.remotestem.interpreter.helpstem.util.connectionstem.util.str_toolsstem.util.tor_toolsstem.interpreterrrrrrstem.util.termr cStringIOr ImportErrorior:r+contextmanagerr2rBr4rr@r*rs  [[!  =P@ &&T00TcsA77 BB