ó [³XMc@s÷dZddlmZddlmZmZddlmZddlmZd„Z d„Z d„Z d „Z d dd „ƒYZ d ejfd „ƒYZdefd„ƒYZdefd„ƒYZdejfd„ƒYZd„Zd„ZdS(sE Dict client protocol implementation. @author: Pavel Pergamenshchik iÿÿÿÿ(tbasic(tdefertprotocol(tlog(tStringIOcCsL|dkrd S|ddkr)d}nd}d}t|ƒ}|dkr]|jdƒnxè|jdƒ}|dkr§|dkr;|jdƒ||jƒfSn”|dkrÛ|jdƒ}|dkr;d|fSn`|dkr|dkr||jƒfSd|fSn+|dkr;|dkr;||jƒfSn||7}q`dS( sQChew one dqstring or atom from beginning of line and return (param, remaningline)tit"iis\t N(NR(tNoneRtread(tlinetmodetrestiota((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt parseParams6               cCstd„|ƒS(sMunch a string into an 'atom'cSs&|tttdƒdddgƒkS(Ni!i"i'i\(tmaptchrtrange(tx((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt3s(tfilter(R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytmakeAtom0scCsrtdƒdddg}g}x=|D]5}t|ƒ|krN|jdƒn|j|ƒq&Wdj|ƒ}|S(Ni!i"i'i\s\R(Rtordtappendtjoin(tst mustquotetresulttc((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytmakeWord5s cCs\t|ƒdkr"|dkr"dSt|ƒdkrT|dd!dkrT|d}n|SdS(Nit.iis..(tlenR(R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt parseText?s % t DefinitioncBseZdZd„ZRS(sA word definitioncCs(||_||_||_||_dS(N(tnametdbtdbdescttext(tselfR#R$R%R&((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt__init__Is   (t__name__t __module__t__doc__R((((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR"Gst DictClientcBs@eZdZd ZdZd Zd Zd Zd Z d„Z d„Z d„Z d„Z d„Zd„Zd„Zd „Zd „Zd „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z!d„Z"d„Z#d„Z$d„Z%d„Z&d„Z'RS(!sdict (RFC2229) clienticCsd|_d|_dS(N(RtdataR(R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR(Ys cCsd|_d|_dS(Ntconntcommand(tstateR (R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytconnectionMade]s cCs?t|ƒ|jdkr(tdƒ‚ntjj||ƒdS(s3Throw up if the line is longer than 1022 charactersis(DictClient tried to send a too long lineN(R t MAX_LENGTHt ValueErrorRt LineReceivertsendLine(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR5ascCsËy|jdƒ}Wntk r'dSX|jdkr@d}n[t|ƒdkrtjd|ƒ|jdƒ|jjƒdSt |d ƒ}|d}t |d||j f|j ƒ}||ƒdS(NsUTF-8R&is-DictClient got invalid line from server -- %ssInvalid line from serverisdictCode_%s_%s( tdecodet UnicodeErrorR R Rtmsgt protocolErrort transporttLoseConnectiontinttgetattrR0tdictCode_default(R'R tcodetmethod((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt lineReceivedgs     "cCs/tjd|ƒ|jdƒ|jjƒdS(sUnkown messages3DictClient got unexpected message from server -- %ssUnexpected server messageN(RR8R9R:tloseConnection(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR>ys cCsdS(s*We are about to get kicked off, do nothingN((R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_221_readyscCsd|_|jƒdS(sGreeting messagetreadyN(R0t dictConnected(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_220_connƒs cCs|jdƒ|jjƒdS(Ns Access denied(R9R:RB(R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_530_connˆs cCs|jdƒ|jjƒdS(NsServer temporarily unavailable(R9R:RB(R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_420_connŒs cCs|jdƒ|jjƒdS(Ns(Server shutting down at operator request(R9R:RB(R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_421_conns cCsr|jdkstd‚d|_d|_d|_dt|jdƒƒt|jdƒƒf}|j|ƒdS(sSend a dict DEFINE commandRDs4DictClient.sendDefine called when not in ready statetdefines DEFINE %s %ssUTF-8N( R0tAssertionErrorRRR-RtencodeRR5(R'tdatabasetwordR/((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt sendDefine”s    .cCsr|jdkstd‚d|_d|_d|_dt|ƒt|ƒt|ƒf}|j|jdƒƒdS(sSend a dict MATCH commandRDs3DictClient.sendMatch called when not in ready statetmatchsMATCH %s %s %ssUTF-8N(R0RKRRR-RR5RL(R'RMtstrategyRNR/((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt sendMatchs    %cCsd|_|jdƒdS(sInvalid databaseRDN(R t defineFailed(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_550_define¦s cCsd|_|jdƒdS(sInvalid databaseRDN(R t matchFailed(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_550_match«s cCsd|_|jdƒdS(sInvalid strategyRDN(R RU(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_551_match°s cCsd|_|jdƒdS(sNo matchRDN(R RS(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_552_defineµs cCsd|_|jdƒdS(sNo matchRDN(R RU(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_552_matchºs cCs g|_dS(sn definitions retrievedN(R(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_150_define¿scCsšd|_t|ƒ\}}t|ƒ\}}t|ƒ\}}|oN|oN|sn|jdƒ|jjƒn(|jjt|||gƒƒg|_dS(sDefinition text followsR&sInvalid server responseN( R RR9R:RBRRR"R-(R'R RNR$R%((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_151_defineÃs  cCsd|_g|_g|_dS(sn matches found, text followsR&N(R RR-(R'R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_152_matchÐs  cCsTt|ƒ}|dkr@d|_|j|jd_d|_n|jj|ƒdS(s"A line of definition text receivedR/iÿÿÿÿN(R!RR R-RR&R(R'R R ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_text_defineÖs     cCs_d„}t|ƒ}|dkrKd|_t||jƒ|_d|_n|jj|ƒdS(sOne line of match text receivedcSs.t|ƒ\}}t|ƒ\}}||fS(N(R(Rtp1tttp2((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytlâsR/N(R!RR RR-RR(R'R RaR ((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_text_matchàs     cCs,|j}d|_d|_|j|ƒdS(tokRDN(RRR0t defineDone(R'R R_((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_250_defineîs   cCs,|j}d|_d|_|j|ƒdS(RcRDN(RRR0t matchDone(R'R R_((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytdictCode_250_matchõs   cCsdS(s5override to catch unexpected dict protocol conditionsN((R'treason((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR9üscCsdS(sCoverride to be notified when the server is ready to accept commandsN((R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyREscCsdS(s8override to catch reasonable failure responses to DEFINEN((R'Rh((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRSscCsdS(s"override to catch succesful DEFINEN((R'R((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRdscCsdS(s6override to catch resonable failure responses to MATCHN((R'Rh((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRU scCsdS(s!override to catch succesful MATCHN((R'R((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRfsN((R)R*R+RR-R2R0R RtfactoryR(R1R5RAR>RCRFRGRHRIRORRRTRVRWRXRYRZR[R\R]RbReRgR9RERSRdRURf(((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR,OsJ                         tInvalidResponsecBseZRS((R)R*(((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRjst DictLookupcBsDeZdZd„Zd„Zd„Zd„Zd„Zd„ZRS(sNUtility class for a single dict transaction. To be used with DictLookupFactorycCs9|jjs5|jjjt|ƒƒ|jjƒndS(N(RitdonetdterrbackRjt clientDone(R'Rh((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR9s cCsZ|jjdkr+t|j|jjƒn+|jjdkrVt|j|jjƒndS(NRJRP(Rit queryTypetapplyROtparamRR(R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRE!scCs1|jjjgƒ|jjƒ|jjƒdS(N(RiRmtcallbackRoR:RB(R'Rh((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRS's cCs1|jjj|ƒ|jjƒ|jjƒdS(N(RiRmRsRoR:RB(R'R((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRd,s cCs1|jjjgƒ|jjƒ|jjƒdS(N(RiRmRsRoR:RB(R'Rh((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRU1s cCs1|jjj|ƒ|jjƒ|jjƒdS(N(RiRmRsRoR:RB(R'R((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRf6s ( R)R*R+R9RERSRdRURf(((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRks     tDictLookupFactorycBsGeZdZeZdZd„Zd„Zd„Z d„Z d„Z RS(s-Utility factory for a single dict transactioncCs(||_||_||_d|_dS(Ni(RpRrRmRl(R'RpRrRm((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyR(As   cCsd|_|`dS(sCalled by client when done.iN(RlRm(R'((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRoGs cCs|jj|ƒdS(N(RmRn(R't connectorterror((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytclientConnectionFailedLscCs |js|jj|ƒndS(N(RlRmRn(R'RuRv((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pytclientConnectionLostOs cCs|jƒ}||_|S(N(RRi(R'taddrtp((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt buildProtocolSs  N( R)R*R+RkRRRlR(RoRwRxR{(((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRt<s    cCsKtjƒ}td||f|ƒ}ddlm}|j|||ƒ|S(s"Look up a word using a dict serverRJiÿÿÿÿ(treactor(RtDeferredRtttwisted.internetR|t connectTCP(thosttportRMRNRmRiR|((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRJYs  cCsNtjƒ}td|||f|ƒ}ddlm}|j|||ƒ|S(s Match a word using a dict serverRPiÿÿÿÿ(R|(RR}RtR~R|R(R€RRMRQRNRmRiR|((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyRPbs  N((R+ttwisted.protocolsRR~RRttwisted.pythonRRRRRR!R"R4R,t ExceptionRjRkt ClientFactoryRtRJRP(((s:/usr/lib/python2.7/dist-packages/twisted/protocols/dict.pyt s  Æ#