+Fc@s*dZddkZddkZddkZddkZddkZddkZddkZddkZddk Z ddk Z ddk Z ddk Te i Z e i Z dZdZdefdYZdefd YZd efd YZd efd YZdefdYZdedZdefdYZdefdYZdefdYZdefdYZdefdYZdefdYZde fdYZ!d e fd!YZ"d"e#fd#YZ$d$efd%YZ%d&Z&d'Z'd(Z(dS()s)networked spam-signature detection clientiN(t*s6$Id: client.py,v 1.48 2003/02/01 10:29:42 ftobin Exp $s /dev/randomtClientcBseZdddgZdZdZdZdZdZdZd Z d Z d Z d Z d Z dddZdZRS(tsockettoutputtaccountsii cCs6titit||_t|_|idS(N(tsignaltSIGALRMthandle_timeoutRtOutputRt build_socket(tselfR((s1/var/lib/python-support/python2.5/pyzor/client.pyt__init__s  cCs,t}|i|||i|iS(N(t PingRequesttsendt read_responset get_thread(R taddresstmsg((s1/var/lib/python-support/python2.5/pyzor/client.pytping#s cCs/t|}|i|||i|iS(N(t InfoRequestR RR(R tdigestRR((s1/var/lib/python-support/python2.5/pyzor/client.pytinfo(s cCs2t||}|i|||i|iS(N(t ReportRequestR RR(R RtspecRR((s1/var/lib/python-support/python2.5/pyzor/client.pytreport-scCs2t||}|i|||i|iS(N(tWhitelistRequestR RR(R RRRR((s1/var/lib/python-support/python2.5/pyzor/client.pyt whitelist2scCs/t|}|i|||i|iS(N(t CheckRequestR RR(R RRR((s1/var/lib/python-support/python2.5/pyzor/client.pytcheck7s cCstititi|_dS(N(RtAF_INETt SOCK_DGRAM(R ((s1/var/lib/python-support/python2.5/pyzor/client.pyR <scCso|i|i|}tti|i|ii|}|ii dt ||i i |d|dS(Ns sending: %si( tinit_for_sendingRtstrt MacEnvelopetwraptusernametkeystufftkeyRtdebugtreprRtsendto(R RRtaccountt mac_msg_str((s1/var/lib/python-support/python2.5/pyzor/client.pyR ?s    cCs|i|ii|ifS(N(t time_callRtrecvfromtmax_packet_size(R ((s1/var/lib/python-support/python2.5/pyzor/client.pytrecvIscCsP|djo h}nti|izt|||SWdtidXdS(Ni(tNoneRtalarmttimeouttapply(R tcalltvarargstkwargs((s1/var/lib/python-support/python2.5/pyzor/client.pyR+Ms  cCs|i\}}|iidt|tti|}|iy_|i}||joB|i ot d||fq|ii d||fnWn#t j o|ii dnX|S(Ns received: %ss.received unexpected thread id %d (expected %d)s)received error thread id %d (expected %d)sno thread id received( R.RR&R'tResponset cStringIOtStringIOtensure_completeRt in_ok_ranget ProtocolErrortwarntKeyError(R t expect_idtpacketRRt thread_id((s1/var/lib/python-support/python2.5/pyzor/client.pyRUs      (N(t__name__t __module__t __slots__R1R-R RRRRRR R R.R/R+R(((s1/var/lib/python-support/python2.5/pyzor/client.pyRs        t ServerListcBseZdZdZRS(s9http://pyzor.sourceforge.net/cgi-bin/inform-servers-0-3-xcCs\xU|D]M}|}|i}|o.|id o|itii|qqWdS(Nt#(tstript startswithtappendtpyzortAddresstfrom_str(R t serverfiletlinet orig_line((s1/var/lib/python-support/python2.5/pyzor/client.pytreadps  (RARBt inform_urlRO(((s1/var/lib/python-support/python2.5/pyzor/client.pyRDmstExecCallcBseZdddgZeddgZdZddZdZd Z d Z d Z d Z d Z dZdZdZdZeeZdZeeZhe d<e d<ed<ed<e d<e d<ed<ed<ddt |d d t_ ti i d ttid nt i|} | idhdd<tid<dd<ttid<} x-| iD]\} }| id| |qW| itii|d| idd} | iddt_tii|pti |n|d} tii|  p | djo=ti i d| i!ddt"| i!dd| n|i#| |_$t|i%| idd|_&|i'i(| p|in|i'| }|dj oby+t)|||fpti*dnWqnt+j o$ti i dti*dqnXndS(Niitdshomedir=tlogs-ds --homedirs--logR&s /pyzor.logtas pyzor[s]: RRRSt ServersFiletDiscoverServersURLRt AccountsFiletTimeouttconfigtdiscoversdownloading servers from %s stimeout from server (,R/tgetopttsystargvt GetoptErrortusagetlenRRRIt get_homedirtopentstderrtwriteR'tostgetpidtConfigt add_sectionRDRPR RR1titemstsetROtpathtjoint get_filenametgetinttexiststmkdirtgettdownloadt get_serversRSt get_accountsRRt dispatchesthas_keyR2texitt TimeoutError(R R&tspecified_homedirtoptionsRUtargstotvthomedirR[tdefaultstkt servers_fntcommandtdispatch((s1/var/lib/python-support/python2.5/pyzor/client.pytrunsn,      (      !   cCsQ|dj otiid|ntiidtidtiddS(Ns%s s usage: %s [-d] [--homedir dir] command [cmd_opts] command is one of: check, report, discover, ping, digest, predigest, genkey Data is read on standard input (stdin). ii(R/R^ReRfR_Ry(R ts((s1/var/lib/python-support/python2.5/pyzor/client.pyRas   cCsyti|ddWn+tij o|id|dnXt|ii}x$|iD]}|i||fqbW|iS(Nits)%s does not take any non-option argumentsi( R]R`Rat ClientRunnerRRRRSRtall_ok(R R}trunnertserver((s1/var/lib/python-support/python2.5/pyzor/client.pyRs c Csy&ti|dddg\}}Wn+tij o|id|dnXd}x+|D]#\}}|djo d}qaqaWt|ii}x`tti|i |D]F}|djoqnx)|i D]} |i | || f} qWqWt S(NiRtmboxs)%s does not take any non-option argumentsiRs--mbox(R]R`RatInfoClientRunnerRRRtget_input_handlerR^tstdint digest_specR/RSRtTrue( R R}R|targs2tdo_mboxR~RRRRtresponse((s1/var/lib/python-support/python2.5/pyzor/client.pyRs$&     c Cs y&ti|dddg\}}Wn+tij o|id|dnXd}x+|D]#\}}|djo d}qaqaWt|ii}x^tti|i |D]D}|djoqnx'|i D]} |i | || fqWqW|i o|i S(NiRRs)%s does not take any non-option argumentsiRs--mbox(R]R`RatCheckClientRunnerRRRRR^RRR/RSRt found_hitt whitelisted( R R}R|RRR~RRRR((s1/var/lib/python-support/python2.5/pyzor/client.pyRs$&    c Csy&ti|dddg\}}Wn+tij o|id|dnXd}x+|D]#\}}|djo d}qaqaWt}x]tti|i|D]C}|djoqn|i ||i|i i p t }qqW|S(NiRRs)%s does not take any non-option argumentsiRs--mbox( R]R`RaRRR^RRR/t send_digestRRRtFalse( R R}R|RRR~RRR((s1/var/lib/python-support/python2.5/pyzor/client.pyRs$&   cCsb|djodSnt|tt|}x*|iD]}|i||||fq8W|iS(s*digest can be none; if so, nothing is sentN(R/t typecheckt DataDigestRRSRR(R RRt client_methodRR((s1/var/lib/python-support/python2.5/pyzor/client.pyR/s    c Csy&ti|dddg\}}Wn+tij o|id|dnXd}x+|D]#\}}|djo d}qaqaWt}x]tti|i|D]C}|djoqn|i ||i|i i p t }qqW|S(NiRRs)%s does not take any non-option argumentsiRs--mbox( R]R`RaRRR^RRR/RRRRR( R R}R|RRR~RRR((s1/var/lib/python-support/python2.5/pyzor/client.pyR=s$&   c Csy&ti|dddg\}}Wn+tij o|id|dnXd}x+|D]#\}}|djo d}qaqaWxHtti|i|D].}|djoqntii d|qWt S( NiRRs)%s does not take any non-option argumentsiRs--mboxs%s ( R]R`RaRR^RRR/tstdoutRfR(R R}R|RRR~RR((s1/var/lib/python-support/python2.5/pyzor/client.pyRUs&   c s~yti|ddWn+tij oid|dnXdfd}tthtd<|tS(NiRs)%s does not take any non-option argumentsiRcs'x ttiiD]}qWdS(N(RR^RR(R(RR (s1/var/lib/python-support/python2.5/pyzor/client.pytloopqst DataDigester(R]R`Ratmodglobal_applytglobalstPrintingDataDigesterR(R R}R((R Rs1/var/lib/python-support/python2.5/pyzor/client.pytprint_digestedisc Cs4yti|ddWn+tij o|id|dnXddk}|idd}|idd}||jotiid dSn~tt}|i t i }~t i |}t i }|i |i|i |tiid tiid |i|iftS( NiRs)%s does not take any non-option argumentsiitpromptsEnter passphrase: sEnter passphrase again: sPasswords do not match. s salt,key: s%s,%s (R]R`RatgetpassR^ReRfRdtrandfileROtshat digest_sizetnewtupdateRRt hexdigestR( R R}Rtp1tp2tsaltfiletsaltt salt_digestt pass_digest((s1/var/lib/python-support/python2.5/pyzor/client.pytgenkeyzs,     cCsTt}|it|t|djo!tiidtidn|S(Nis8No servers available! Maybe try the 'discover' command i(RDRORdRbR^ReRfRy(RRS((s1/var/lib/python-support/python2.5/pyzor/client.pyRus  cCsQt}tii|o1x.tt|D]\}}|||s\sRcCsd|_d|_d|_||_|i|\}}t|djodSnti|_ t||i jo|i |n|i |||t |i i|_|idj pt|idj ptdS(Ni(R/RRRRtget_line_offsetsRbRRRtatomic_num_linest handle_atomict handle_piecedRRtAssertionError(R tfpRRtoffsets((s1/var/lib/python-support/python2.5/pyzor/client.pyR s    cCsFt|_y/|idx|D]}|i|q WWnnXdS(swe digest everythingiN(RRtseekt handle_line(R RRM((s1/var/lib/python-support/python2.5/pyzor/client.pyRs  c Cst|_x|D]\}}d|jo djnpt|t|t|d}|i|x9t|D]+}|i}|pPn|i|qyWqWdS(NiidgY@( RRRtintRbRtrangetreadlineR( R RRRt perc_offsettlengthtoffsettiRM((s1/var/lib/python-support/python2.5/pyzor/client.pyRs  %   c Cs|io|i}d}nd}ti}g}x|D]}|i|}|i|}|o|i|nd}|iot|}n/|o'|d7}t|}|i |n||7}q?W|ip |}n||fS(sreturn tuple of (fp2, line offsets) If we are not seekable, fp will be copied into a tempfile, and fp2 is hence re-usable. If we are not seekable, we also normalize the lines while copying them into the tempfile. is N( RttellR/ttempfilet TemporaryFilet normalizetshould_handle_lineRHRbRf( R Rt cur_offsettnewfpRRMtnormt should_handletmoved((s1/var/lib/python-support/python2.5/pyzor/client.pyRs.          cCs:|io|i|}n |i}|i|dS(N(RRtrstript_really_handle_buf(R RMtbuf((s1/var/lib/python-support/python2.5/pyzor/client.pyREs  cCs|ii|dS(N(RR(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyRPscCs*|idjo tdnt|iS(Nsdigest not calculated yet(RR/t RuntimeErrortbool(R ((s1/var/lib/python-support/python2.5/pyzor/client.pyt is_atomicSs cCs|iS(N(R(R ((s1/var/lib/python-support/python2.5/pyzor/client.pyt get_digestXscCs||i}|}|ii||}|ii||}|ii||}|ii||}|iid|}|S(NR(tunwanted_txt_replt email_ptrntsubturl_ptrnt longstr_ptrnt html_tag_ptrntws_ptrn(R Rtreplts2((s1/var/lib/python-support/python2.5/pyzor/client.pyR[s cCst|it|jS(N(Rtmin_line_lengthRb(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyRhs(RARBt__doc__RCRRtretcompileRt IGNORECASERRRRRRR RRRRRRRRt classmethodR(((s1/var/lib/python-support/python2.5/pyzor/client.pyRs.     2     RcBseZdZdZRS(s5extends DataDigester: prints out what we're digestingcCs.tiid|tt|i|dS(Ns%s (R^RRftsuperRR(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyRqs(RARBRR(((s1/var/lib/python-support/python2.5/pyzor/client.pyRnsRcCs|djo/tdtt|||ifSn:|djot||Sn|djot|SntddS(svReturn an object that can be iterated over to get all the digests from fp according to spec. mbox is a booleanRcSs |dj S(N(R/(tx((s1/var/lib/python-support/python2.5/pyzor/client.pyt|sRtdigestssunknown input styleN(tfilterRtrfc822BodyCleanerRtMailboxDigestertJustDigestsIteratort ValueError(RRtstyleR((s1/var/lib/python-support/python2.5/pyzor/client.pyRws     RcBs#eZdgZdZdZRS(RcCs ||_dS(N(R(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR scCs'ti}|p tn|iS(N(RRt StopIterationR(R tl((s1/var/lib/python-support/python2.5/pyzor/client.pytnexts  (RARBRCR R(((s1/var/lib/python-support/python2.5/pyzor/client.pyRs  RcBs,eZdddgZedZdZRS(RRRcCs7ddk}|i|t|_||_||_dS(Ni(tmailboxtPortableUnixMailboxRRRR(R RRRR((s1/var/lib/python-support/python2.5/pyzor/client.pyR s     cCsoy|ii}Wn#tj odGHdGHd}nX|djo tnt||id|iiS(Ns2Error: Please feed mailbox files in on stdin, i.e.s& pyzor digest --mbox < my_mbox_fileR( RRtIOErrorR/RRRRR(R tnext_msg((s1/var/lib/python-support/python2.5/pyzor/client.pyRs   (RARBRCRR R(((s1/var/lib/python-support/python2.5/pyzor/client.pyRs RcBs5eZddddgZdZdZdZRS(Rt multifiletcurfilettypec Csti|dd}|i|_d|_d|_|id o@|idjo0|idjo |i djo d|_n|idjo d|_n|idjo|i }|i |_|djo|d jo d }nd dk }t i |_yti|i |i|Wnd|ij o5}tiid |i|fti|_n"tj o}|i |_nXy|iidWqqXqZn|id joyZti|i dt|_|ii|id|ii|i|i|_WqZtttifj o|i |_d|_qZXn|idjp|id jo|idj ptnP|idjo(y|idWnnX||_n|idjptdS(NRitFromttexttplaint7bittbinaryRt8bitst8bitis%s: %s t multiparttboundary( t mimetoolstMessaget getmaintypeRR/RRRxtsubtypet getencodingRtbinasciiRRtdecodetErrorR^ReRft __class__R7R8RRt MultiFileRtpushtgetparamRt TypeErrortAttributeErrorR(R RRtencodingRte((s1/var/lib/python-support/python2.5/pyzor/client.pyR sZ  D             cCsd}yt|idjo|ii}n|idjo=| o5|iio%|i|i|_|i}nWntttifj onX|S(NRRR R(stexts multipartsbinary( RRRRRRRRR(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyRs(cCscy|i}Wn;tij o,}tiid|i|ftnX|p tn|S(Ns%s: %s (RRRR^ReRfRR(R RR((s1/var/lib/python-support/python2.5/pyzor/client.pyRs  (RARBRCR RR(((s1/var/lib/python-support/python2.5/pyzor/client.pyRs ? RcBs;eZddgZdZdZddZdZRS(troutineRcCs||_|idS(N(Rtsetup(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR s cCs t|_dS(N(RR(R ((s1/var/lib/python-support/python2.5/pyzor/client.pyRscCs|djo h}ndt|}d}y)t|i||}|i||WnKtttfj o6}ti i |d|i i |ft |_nXdS(Ns%s s%s: %s (R/R R2Rthandle_responset CommErrorR=RR^ReRfRRARR(R RR4R5tmessageRR((s1/var/lib/python-support/python2.5/pyzor/client.pyRs  cCsB|ip t|_ntii|t|iddS(s)mesaage is a string we've built up so fars N(tis_okRRR^RRfR t head_tuple(R RR((s1/var/lib/python-support/python2.5/pyzor/client.pyR$s   N(RARBRCR RR/RR(((s1/var/lib/python-support/python2.5/pyzor/client.pyR s     RcBs,eZddgZdZdZdZRS(RRicCs)t|_t|_tt|idS(N(RRRRRR(R ((s1/var/lib/python-support/python2.5/pyzor/client.pyR4s  cCs|dt|i7}|iot|d}|djod}t|_n+t|d}|djo t|_n|d||f7}tii |dnti i |dS(Ns%s sWL-CountitCounts%d %ds ( R R!R RRRRR^RRfRe(R RRtwl_counttcount((s1/var/lib/python-support/python2.5/pyzor/client.pyR9s     (RARBRCtwl_count_clearsRR(((s1/var/lib/python-support/python2.5/pyzor/client.pyR-s  RcBseZdZRS(cCs|dt|i7}|iot|d}|d|7}|djoxdD]}|i|owt||}|d jo d }nti|}|djo|d t|d 7}n|d ||f7}qYqYWntii |nti i |dS(Ns%s R"s Count: %d itEnteredtUpdateds WL-Entereds WL-UpdateditNevers WhiteList Count: %d sWL-Counts %s: %s (R&R's WL-Entereds WL-Updated( R R!R RRxttimetctimeR^RRfRe(R RRR$tftvaltstringed((s1/var/lib/python-support/python2.5/pyzor/client.pyRNs$      (RARBR(((s1/var/lib/python-support/python2.5/pyzor/client.pyRMstAccountcBsDeZdZdZdZeeZdZeeZRS(cCs|idS(N(tvalidate(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR oscCs't|itit|itdS(N(RR#RItUsernameR$tKeystuff(R ((s1/var/lib/python-support/python2.5/pyzor/client.pyR/rscCs|dS(Ni((R ((s1/var/lib/python-support/python2.5/pyzor/client.pyR#vscCs|dS(Ni((R ((s1/var/lib/python-support/python2.5/pyzor/client.pyR$zs(RARBR R/R#tpropertyR$(((s1/var/lib/python-support/python2.5/pyzor/client.pyR.ns      R1cBsteZdZdZdZdZeeZdZeeZdZ e e Z dZ e e Z RS(sVtuple of (salt, key). Each is a long. One or the other may be None, but not both.cCs|idS(N(R/(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR scCs}|ddjo tdnx8|D]0}t|tp |djp tdq%q%Wtd|p tdndS(Nisno key informations!Keystuff must be long's or None'scSs |dj S(N(R/(R((s1/var/lib/python-support/python2.5/pyzor/client.pyRsskeystuff can't be all None's(R/Rt isinstancetlongR(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR/s cCsE|id}t|djo tdn|t|i|S(Nt,is]invalid number of parts for keystuff; perhaps you forgot comma at beginning for salt divider?(tsplitRbRtmapt hex_to_long(R Rtparts((s1/var/lib/python-support/python2.5/pyzor/client.pyt from_hexstrs cCs"|djodSnt|dS(s)Allows the argument to be an empty stringRiN(R/R4(th((s1/var/lib/python-support/python2.5/pyzor/client.pyR8s cCs|dS(Ni((R ((s1/var/lib/python-support/python2.5/pyzor/client.pyRscCs|dS(Ni((R ((s1/var/lib/python-support/python2.5/pyzor/client.pyR%s( RARBRR R/R:RR8RRR2R%(((s1/var/lib/python-support/python2.5/pyzor/client.pyR1s         RcBs;eZdZeeiedfZdZ dZ RS(sVKey is pyzor.Address, value is Account When getting, defaults to anonymous_accountlcCs:t|tit|ttt|i||dS(N(RRIRJR.RRt __setitem__(R RR((s1/var/lib/python-support/python2.5/pyzor/client.pyR<s cCs;ytt|i|SWntj o|iSnXdS(N(RRt __getitem__R=tanonymous_account(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR=sN(Nl( RARBRR.RItanonymous_userR1R/R>R<R=(((s1/var/lib/python-support/python2.5/pyzor/client.pyRs   RYcBs8eZdZdddgZdZdZdZRS(spIteration gives a tuple of (Address, Account) Layout of file is: host : port ; username : keystuff RtlinenoRcCs%||_d|_ti|_dS(Ni(RR@RIRR(R R((s1/var/lib/python-support/python2.5/pyzor/client.pyR s  cCs|S(N((R ((s1/var/lib/python-support/python2.5/pyzor/client.pyt__iter__sc Cs9x2|ii}|id7_|p tn|i}| p|idoqn|id}td|}t|djo|i i d|iqnyNt i |dt |dftt|dti|d ffSWqtj o&}|i i d |i|fqXqdS( NiREt:cSs |iS((RF(R((s1/var/lib/python-support/python2.5/pyzor/client.pyRsis4account file: invalid line %d: wrong number of partsiiis!account file: invalid line %d: %s(RRR@RRFRGR6R7RbRR<RIRJRR.R0R1R:R(R RNRMtfieldsR((s1/var/lib/python-support/python2.5/pyzor/client.pyRs*      (RARBRRCR RAR(((s1/var/lib/python-support/python2.5/pyzor/client.pyRYs   cCstidS(N(RQR(((s1/var/lib/python-support/python2.5/pyzor/client.pyRscCs tdS(N(Rz(tsignumtframe((s1/var/lib/python-support/python2.5/pyzor/client.pyRscCs ddk}|i||dS(Ni(turllibt urlretrieve(turltoutfileRF((s1/var/lib/python-support/python2.5/pyzor/client.pyRts ()RRgtos.pathRR7R]RR RRRRIt __author__t __version__t __revision__RtobjectRtlistRDRQRRRRt BasicIteratorRRRRRRttupleR.R1tdictRRYRRRt(((s1/var/lib/python-support/python2.5/pyzor/client.pyssH              U D  ]! !,,