m Dc@sdZdkZdkZdkZdkZdkZdkZdkZdddddddd d d d d g ZdfdYZ dfdYZ e dddddddddddddddd d!d"d#d$d%d&gZ e i d'jpt e id(jpt e d)d*d+d,d-d.d/d0d1d2d3d4g Zeid5jpt eid6jpt e dd7d8d9d:d;gZe dd<d=d>d:d;d?d@dAgZe dd7dBd:d;gZe dCd)dDdEdFdGdHdIdJdKZhddL<d)dM<dEdN<dOdP<dQdR<d6dS<dTdU<dVdW<d'dX<dYdZ<dGd[<d5d\<dId]       cCsd}|id}|ptintid|\}}|oYxV|t |jo>|i|t |}|ptin||7}qNWn|||fS(s,Read a single packet from the socket s. R]is!HHN( R_tstrecvtheadertTorCtlt TorCtlClosedRSRTRURVRPtmore(RmR_RVRURoRr((Rt_receive_singleton_msgscCs(t|\}}}|tijo|||fSn|djotdnti d|d \}}|dg}t |d}xt|\}}}|tijotdn||7}|i|||jo||di|fSq||jotdqqWd S( s@Read a single message (possibly multi-packet) from the socket s.is FRAGMENTHEADER message too shorts!HLiisMissing FRAGMENT messageR]sFRAGMENT message too long!N(RsRmRUR^R_RR.RRSRTRaRbtdataRPRdR/RhRj(RmR_RaRbRUR^RdRt((Rt_receive_messages(      R]cCst|}|djo'tid||}d||fSntiddti||}||dd g}|dd}xu|omt|djo d}n t|}tidti |}|i ||i || ||}qWdi|S( s^Given a message type and optional message body, generate a set of packets to send. is!HHs%s%ss!HHHLiiR]N(RPR_RURStpackRVt reqheaderRR.t fragheadertmsgstflR/RhRj(RVR_RwRxRURzRy((Rt pack_messages&      t s cCs]g}xP|i|D]?}|pqn|i|d\}}|i||fqW|S(saHelper: parse a key/value list of the form [key sep value term]* . Return a list of (k,v).iN( tresR_tsplitttermtlinetsepRRRh(R_RRR}RRR((Rt_parseKVscCs%|ddjo |d Sn|SdS(s%Strip trailing NUL characters from s.itN(Rm(Rm((Rt _unterminate s cBstZdZdZdZdZdZdeifdZ ddZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZdZdfdZfdZdZRS(s8A Connection represents a connection to the Tor process.cCstii|||_dS(scCreate a Connection to communicate with the Tor process over the socket 'sock'. N(Rpt_ConnectionBaseRR tsockt_s(R R((RRscCs||_|i|_dS(sJCause future events from the Tor process to be sent to 'handler'. N(thandlerR t_handlerthandle0t _handleFn(R R((Rtset_event_handlers cCs)|\}}|iit||dS(sIHelper: Deliver a command of type 'type' and body 'body' to Tor. N(RVR_R RtsendallR{(R t.2RVR_((Rt_doSends cCs1t|i\}}}|tij||ffS(N(RuR RRUR^R_RR%(R R_R^RU((Rt _read_reply$sR]cCs|i|i||f\}}||jo||fSn|tijoet|djot dnt i d|d \}t |ti|d|dfnt d|dS(sHelper: Send a command of type 'tp' and body 'msg' to Tor, and wait for a command in response. If the response type is in expectedTypes, return a (tp,body) tuple. If it is an error, raise ErrorReply. Otherwise, raise ProtocolError. is(Truncated error message)s!Hs[unrecognized]sUnexpectd message type 0x%04xN(R tsendImplRR^RQt expectedTypesRRRPRRSRTterrCodeR Rtget(R R^RQRR((Rt _sendAndRecv(s! )cCs|iti|dS(sSend an authenticating secret to Tor. You'll need to call this method before other commands. You need to use a password if Tor expects one. N(R RRR&tsecret(R R((Rt authenticate<scCspt|tp2dig}|D]}|d|q!~}n|iti |ti g\}}t |S(sGet the value of the configuration option named 'name'. To retrieve multiple values, pass a list for 'name' instead of a string. Returns a list of (key,value) pairs. R]s%s N(t isinstanceRtstrRjt_[1]RmR RRR"R#R^R_R(R RR_R^RRm((Rt get_optionCs 2$cCs|i||gdS(sYSet the value of the configuration option 'key' to the value 'value'. N(R t set_optionstkeytvalue(R RR((Rt set_optionMscCsGdig}|D]\}}|dq~}|iti |dS(sYGiven a list of (key,value) pairs, set them as configuration options. R]s%s %s N( RjRtkvlistRRRQR RRR!(R RRRRQR((RRSs0cCsAdig}|D] }|dq~}|iti|dS(NR]s%s ( RjRtkeylistRRQR RRR!(R RRRQR((Rt reset_optionsZs*c Cst|tp2dig}|D]}|d|q!~}n|iti |ti g\}}|i d}h}x:tdt|ddD]}||d|||value mappings. R]s%s RiiiN(RRRRjRRmR RRR)R*R^R_R~tkvstdtxrangeRPti( R RR_RR^RRmRR((Rtget_info^s2$c Csg}xN|D]F}t|tio |itt|i q |i|q W|i t i dig}|D]}|tid|qt~dS(sChange the list of events that the event handler is interested in to those in 'events', which is a list of EVENT_TYPE members or their corresponding strings. R]s!HN(tevsteventstevRttypest StringTypeRhtgetattrRtupperR RRR$RjRteventRSRv(R RRRRR((Rt set_eventsms  cCs|itidS(s1Flush all configuration changes to disk. N(R RRR'(R ((Rt save_conf{scCsy|i}Wntj onXhdd<dd<dd<dd<dd<d d<d d <d d <d d<dd