ó G¥êRc@sÅddlmZmZmZddlmZddlmZmZddl Z ddl Z de fd„ƒYZ d„Z d efd „ƒYZd efd „ƒYZed efd„ƒYƒZdS(i(tUSPBlockt RPCClientt ProtocolError(t constantsiÿÿÿÿ(ttotal_orderingtwrapsNt DiscussErrorcBseZdZd„ZRS(sLAn error returned from Discuss server itself which has a Discuss error code.cCsN||_|tjkr6tj|dtj|ƒntj|d|ƒdS(NsDiscuss error: %ssUnknown discuss error (code %i)(tcodeRterrorst Exceptiont__init__(tselfR((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR s (t__name__t __module__t__doc__R (((s2/usr/lib/python2.7/dist-packages/discuss/client.pyRscstˆƒ‡fd†ƒ}|S(NcsIyˆ|||ŽSWn.tjk rD|jjƒˆ|||ŽSXdS(N(tsocketttimeouttrpctconnect(R targstkwargs(tf(s2/usr/lib/python2.7/dist-packages/discuss/client.pyt autoreconnects  (R(RR((Rs2/usr/lib/python2.7/dist-packages/discuss/client.pytautoreconnectsstClientcBsGeZdZdedd„Zed„ƒZed„ƒZd„Z RS(sDiscuss client.i4cCsFt||||ƒ|_|rB|jƒjdƒrBtdƒ‚ndS(Ns???@sAuthentication to server failed(RRtwho_am_it startswithR(R tservertporttauthR((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR .scCs+ttjƒ}|jj|ƒ}|jƒS(s(Ask server for the server version number(RRtGET_SERVER_VERSIONRtrequesttread_long_integer(R Rtreply((s2/usr/lib/python2.7/dist-packages/discuss/client.pytget_server_version3scCs+ttjƒ}|jj|ƒ}|jƒS(skAsk server for the Kerberos principal with which discuss identified the client after the handshake.(RRtWHO_AM_IRRt read_string(R RR!((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR;scCs|jjjƒdS(sDisconnect from the server.N(RRtclose(R ((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR%DsN( R R RtTruetNoneR RR"RR%(((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR+s  tMeetingcBsÎeZdZd„Zeed„ƒZed„ƒZed„ƒZed„ƒZ ed„ƒZ edddd „ƒZ edd d „ƒZ ed „ƒZed „ƒZed„ƒZed„ƒZRS(sDiscuss meeting.cCsV||_|j|_||_|jdƒd|_|jj|f|_t|_dS(Nt/iÿÿÿÿ( tclientRtnametsplitt short_nameRtidtFalset info_loaded(R R*R+((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR Ls    cCsE|jr| rdSttjƒ}|j|jƒ|jj|ƒ}|jƒ|_ |j ƒ|_ |j ƒ|_ |j ƒ|_ |jƒ|_|jƒ|_|jƒ|_|jƒ|_tjj|jƒƒ|_tjj|jƒƒ|_|jƒ|_|j ƒ|_|jƒ}|dkr8t|ƒ‚nt|_dS(s'Load all the properties into the class.Ni(R0RRt GET_MTG_INFOt put_stringR+RRR tversionR$tlocationt long_nametchairmantfirsttlasttlowestthighesttdatetimet fromtimestampt date_createdt date_modifiedt read_booleantpublict access_modesRR&(R tforceRR!tresult((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt load_infoTs*  cCs‚ttjƒ}|j|jƒ|jdƒ|j|ƒ|jj|ƒ}|jƒ}|j ƒ}|dkr~t |ƒ‚n|S(s¿Check whether the meeting has updated since last time we looked at it. Returns true if given last < real last, false if they are equal and error if given is greater than real.i( RRt UPDATED_MTGR2R+tput_long_integerRRR?R R(R R8RR!tupdatedRC((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt check_updateqs     cCsRttjƒ}|j|jƒ|j|ƒ|jtj7_|jj |ƒdS(s5Send request for the tranasction into the connection.N( RRt GET_TRN_INFO3R2R+RFt block_typet PROC_BASERtsend(R tnumberR((s2/usr/lib/python2.7/dist-packages/discuss/client.pytrequest_transaction„s  cCsQ|jjƒ}|jƒ}|jƒ}t||ƒ}||_||_|jƒ|_|jƒ|_|jƒ|_|jƒ|_ |jƒ|_ |jƒ|_ |jƒ|_ t j j|jƒƒ|_|jƒ|_|jƒ|_|jƒ|_|jƒ|_|jƒ|_|jƒ|_|jƒ}|dkrMt|ƒ‚n|S(s)Read the transaction from the connection.i(RtreceiveR t TransactionR3tcurrenttprevtnexttpreftnreftfreftlreft chain_indexR;R<t date_enteredt num_linest num_charsR$tsubjecttauthortflagst signatureR(R R!R3RMttrnRC((s2/usr/lib/python2.7/dist-packages/discuss/client.pytreceive_transactions0      cCs|j|ƒ|jƒS(s?Retrieve the informataion about a transaction using the number.(RNRa(R RM((s2/usr/lib/python2.7/dist-packages/discuss/client.pytget_transaction°s iiÿÿÿÿc Cs$|dkr"|jƒ|j}n||d}|}d}|}g}xÕ|dkr|||kr—|dkr—|j|ƒ|d7}|d8}qKyJ|jƒ} |j| ƒ|rà|d| jd||dd|ƒnWn.tk r} | jtj kr| ‚qnX|d8}qKW|S(srReturn an iterator over the given range of transaction. Without arguments, iterates over all transactions.iÿÿÿÿiiôitcurttotaltleft( RDR8RNRatappendRMRRRt DELETED_TRN( R tstarttendtfeedbackt to_requesttto_readt buffer_sizeRcRCR`terr((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt transactions¸s.        + ic Cs ttj|rtjntjƒ}|j|jƒ|jt|ƒƒ|j|ƒ|rk|j|ƒn|j|ƒttj ƒ}||_ |j j |ƒ|j j |ƒ|j j ƒ}|jtjkràtdƒ‚n|jƒ}|jƒ} | dkrt| ƒ‚n|j|ƒS(s!Add a transaction to the meeting.sTransport-level errori(RRRKtADD_TRN2tADD_TRNR2R+RFtlent TFILE_BLKtbufferRRLRORJt REPLY_TYPERR RRb( R ttextR\R_treply_toRttfileR!tnew_idRC((s2/usr/lib/python2.7/dist-packages/discuss/client.pytpostÛs&%      c Cs°ttjƒ}|j|jƒ|jj|ƒ}|jƒ}|dkrXt|ƒ‚n|jƒ}g}x?t |ƒD]1}|j ƒ}|j ƒ}|j ||fƒqwW|S(s]Retrieve the access list of the meeting. Returns the list of principal-access tuples.i( RRtGET_ACLR2R+RRR RtrangeR$Rf( R RR!RCtlengthtacltitmodest principal((s2/usr/lib/python2.7/dist-packages/discuss/client.pytget_aclús     cCsuttjƒ}|j|jƒ|j|ƒ|jj|ƒ}|jƒ}|jƒ}|dkrqt |ƒ‚n|S(s7Retrieve the access mode of a given Kerberos principal.i( RRt GET_ACCESSR2R+RRR$R R(R RRR!R€RC((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt get_accesss    cCsvttjƒ}|j|jƒ|j|ƒ|j|ƒ|jj|ƒ}|jƒ}|dkrrt|ƒ‚ndS(s/Changes the access mode of the given principal.iN( RRt SET_ACCESSR2R+RRR R(R RR€RR!RC((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt set_access!s    cCsittjƒ}|j|jƒ|j|ƒ|jj|ƒ}|jƒ}|dkret |ƒ‚ndS(s'Undelete the transaction by its number.iN( RRt RETRIEVE_TRNR2R+RFRRR R(R t trn_numberRR!RC((s2/usr/lib/python2.7/dist-packages/discuss/client.pytundelete_transaction/s   N(R R RR RR/RDRHRNRaRbR'RoRzR‚R„R†R‰(((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR(Is   !"RPcBsGeZdZd„Zed„ƒZed„ƒZd„Zd„ZRS(s?Discuss transaction. Returned by methods of the meeting object.cCs"||_||_|j|_dS(N(tmeetingRMR(R RŠRM((s2/usr/lib/python2.7/dist-packages/discuss/client.pyR @s  cCsÕttjtjƒ}|j|jjƒ|j|jƒ|jdƒ|j j |ƒ|j j ƒ}|j j ƒ}|j tj ks˜|j tjkr§tdƒ‚n|jƒ}|dkrÎt|ƒ‚n|jS(s%Retrieve the text of the transaction.is7Bad server response when retriving transaction contents(RRRKtGET_TRNR2RŠR+RFRMRRLRORJRsRuRR RRt(R RRxR!RC((s2/usr/lib/python2.7/dist-packages/discuss/client.pytget_textEs $  cCsottjƒ}|j|jjƒ|j|jƒ|jj |ƒ}|j ƒ}|dkrkt |ƒ‚ndS(sDelete the transaction.iN( RRt DELETE_TRNR2RŠR+RFRMRRR R(R RR!RC((s2/usr/lib/python2.7/dist-packages/discuss/client.pytdeleteYs  cCs|j|jkS(N(RM(R tother((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt__le__fscCs?t|tƒr7|j|jko6|jj|jjkStSdS(N(t isinstanceRPRMRŠR+R/(R R((s2/usr/lib/python2.7/dist-packages/discuss/client.pyt__eq__is(( R R RR RRŒRŽRR’(((s2/usr/lib/python2.7/dist-packages/discuss/client.pyRP<s   (RRRRtRt functoolsRRR;RR RRtobjectRR(RP(((s2/usr/lib/python2.7/dist-packages/discuss/client.pyts   ó