ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
dps
/
Filename :
client.pyc
back
Copy
� �t�ac @ s� d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z d d l Z d d l m Z d d l m Z d d l m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z m! Z! d d l" m# Z# d d l$ m% Z% d d l& m' Z' m( Z( m) Z) m* Z* m+ Z+ m, Z, m- Z- m. Z. m/ Z/ m0 Z0 m1 Z1 m2 Z2 m3 Z3 m4 Z4 m5 Z5 m6 Z6 m7 Z7 m8 Z8 m9 Z9 m: Z: m; Z; m< Z< m= Z= m> Z> d d l? m Z@ d d lA mB ZB mC ZC d d lD ZE d d l? ZE d d lF ZE d d lG ZE d d lH mI ZI e � ZJ eI e e% � d e eC f d � � Y� Z eI e# � d e eB f d � � Y� Z e d � � ZK d � ZL d � ZM eN d k r�eK � ZO eO jP eL eM � e jQ � n d S( i����N( t Logger( t DirectoryRecord( t DirectoryService( t Operand( t RecordTypet IDirectoryService( t ConstantsContainer( t reactor( t inlineCallbackst returnValuet succeed( t ConnectError( t ClientCreator( t amp( t Namest NamedConstant( t ICalendarStoreDirectoryRecord( t IStoreDirectoryService( t RecordWithShortNameCommandt RecordWithUIDCommandt RecordWithGUIDCommandt RecordsWithRecordTypeCommandt RecordsWithEmailAddressCommandt RecordsMatchingTokensCommandt RecordsMatchingFieldsCommandt MembersCommandt GroupsCommandt SetMembersCommandt VerifyPlaintextPasswordCommandt VerifyHTTPDigestCommandt WikiAccessForUIDCommandt ContinuationCommandt StatsCommandt ExternalDelegatesCommandt ExpandedMemberUIDsCommandt AddMembersCommandt RemoveMembersCommandt UpdateRecordsCommandt ExpandedMembersCommandt FlushCommandt SetAutoScheduleModeCommandt ContainsUIDsCommand( R ( t CalendarDirectoryRecordMixint CalendarDirectoryServiceMixin( t implementerR c B s e Z d Z e e j j j e j j j e j j j e j j j f � Z e e j j j e j j j e j j j f � Z d � Z d � Z d � Z e d � � Z e d � � Z d � Z e d � � Z d d � Z d d � Z d d � Z d d d � Z d d d � Z d d d d � Z e j d d d d � Z d � Z! d d � Z" e# d � Z$ d � Z% e d � � Z& e d � � Z' RS( s( Client side of directory proxy c C s2 | s d Si } x| j � D]\ } } y | j j | � } Wn t k rR q X| j j | � } | t t f k r� | | | <q | t j k r� t j | � | | <q t | t � r� | d k r� | j j | � | | <q!d | | <q t | t � r | d k r!| j j | � | | <q!q q Wt | | � S( sb Turn a dictionary of fields sent from the server into a directory record t recordTypeN( t Nonet iteritemst fieldNamet lookupByNamet ValueErrort valueTypet unicodet boolt uuidt UUIDt issubclassR R R- R ( t selft serializedFieldst fieldsR0 t valuet fieldR3 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _dictToRecord^ s* c C s t j | d � } | j | � S( s� Takes a dictionary with a "fields" key whose value is a pickled dictionary of a record's fields, and returns a record. R; ( t picklet loadsR> ( R9 t resultR: ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _processSingleRecord� s c C s} g } x. | d D]" } t j | � } | j | � q Wg } x9 | D]1 } | j | � } | d k rD | j | � qD qD W| S( s� Takes a dictionary with a "items" key whose value is an iterable of pickled dictionaries (of records' fields), and returns a list of records. t itemsN( R? R@ t appendR> R. ( R9 RA t serializedFieldsListR; t resultsR: t record( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _processMultipleRecords� s c c sz d d l m } | j j } t | d d � d k ri t j d � t t t j � j | � V} | | _ n t | j � d S( Ni����( t configt _connections Creating connection( t twistedcaldav.configRI t DirectoryProxyt SocketPatht getattrR. t logt debugR R R t AMPt connectUNIXRJ R ( R9 RI t patht connection( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _getConnection� s c k sg | j � V} y | j | | � V} Wn2 t k rX } t j d d | �d | _ � n Xt | � d S( s� Execute a remote AMP command, first making the connection to the peer. Any kwds are passed on to the AMP command. @param command: the AMP command to call @type command: L{twisted.protocols.amp.Command} s Failed AMP commandt errorN( RU t callRemotet ExceptionRO RV R. RJ R ( R9 t commandt kwdst ampProtoRF t e( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _sendCommand� s c C sq t j � | } d } d | k r+ d } n d | k rJ t | d � } n t j d d | d d | d | �d S( Ni R; i RC sB DPS call {command} duration={duration:.2f}ms, results={numResults}RY t durationg @�@t numResults( t timet lenRO RP ( R9 RY t startTimeRF R^ R_ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _logResultTiming� s c k s t j � } | j | | � V} | j d d � d k r] | j | | | � t | | � � n | g } xC | j d d � d k r� | j t d | d �V} | j | � qi Wi g d 6} x# | D] } | d j | d � q� W| j | | | � t | | � � d S( sR Execute a remote AMP command, first making the connection to the peer, then making the call, then running the results through the postProcess callback. Any kwds are passed on to the AMP command. @param command: the AMP command to call @type command: L{twisted.protocols.amp.Command} @param postProcess: a callable which takes the AMP response dictionary and performs any required massaging of the results, returning a L{Deferred} which fires with the post-processed results @type postProcess: callable t continuationRC N( R` R] t getR. Rc R R RD t extend( R9 RY t postProcessRZ Rb RF t multiRA ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _call� s c C s� t | t t f � r* | j j | � } n t | t � sK | j d � } n i | j j d � d 6| j d � d 6} | d k r� | | d <n | j t | j | � S( Ns utf-8R- t shortNamet timeoutSeconds( t isinstancet strR4 R- R1 t decodet namet encodeR. Ri R RB ( R9 R- Rj Rk RZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordWithShortName� s c C sf t | t � s! | j d � } n i | j d � d 6} | d k rP | | d <n | j t | j | � S( Ns utf-8t uidRk ( Rl R4 Rn Rp R. Ri R RB ( R9 Rr Rk RZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordWithUID s c C sB i t | � d 6} | d k r, | | d <n | j t | j | � S( Nt guidRk ( Rm R. Ri R RB ( R9 Rt Rk RZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordWithGUID s c C sa i | j j d � d 6} | d k r2 | | d <n | d k rK | | d <n | j t | j | � S( Ns utf-8R- t limitResultsRk ( Ro Rp R. Ri R RH ( R9 R- Rv Rk RZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordsWithRecordType& s c C s^ i | j d � d 6} | d k r/ | | d <n | d k rH | | d <n | j t | j | � S( Ns utf-8t emailAddressRv Rk ( Rp R. Ri R RH ( R9 Rx Rv Rk RZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordsWithEmailAddress6 s c C sx i g | D] } | j d � ^ q d 6| d 6} | d k rI | | d <n | d k rb | | d <n | j t | j | � S( Ns utf-8t tokenst contextRv Rk ( Rp R. Ri R RH ( R9 Rz R{ Rv Rk t tRZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordsMatchingTokensG s # c C s g } x~ | D]v \ } } } } t | t j � r@ t | � } n | j | j d � | j d � | j j d � | j j d � f � q W| d k r� | j j d � } n i | d 6| j j d � d 6| d 6} | d k r� | | d <n | d k r| | d <n | j t | j | � S( Ns utf-8R; t operandR- Rv Rk ( Rl R6 R7 R4 RD Rp Ro R. Ri R RH ( R9 R; R~ R- Rv Rk t newFieldsR0 t searchTermt matchFlagst matchTypeRZ ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordsMatchingFieldsY s. c C s | j t | j � S( N( Ri R! RH ( R9 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt" recordsWithDirectoryBasedDelegates~ s c C s t d � � d S( NsE This won't work until expressions are serializable to send across AMP( t NotImplementedError( R9 t expressiont recordTypes( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt recordsFromExpression� s c C sS | r t d � � n g | D] } | j j d � ^ q } | j t d | d t �S( Ns Cannot create records using DPSs utf-8t uidst create( R2 Rr Rp R] R% t False( R9 t recordsR� t rt recordUIDs( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt updateRecords� s %c C s( | j t d | j j d � d | j �S( NRr s utf-8t autoScheduleMode( R] R( Rr Rp Ro ( R9 RG R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt setAutoScheduleMode� s c c s> y | j t � Vt d � Wn t k r9 t d � n Xd S( N( R] R' R R. R ( R9 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt flush� s c c sM y+ | j t � V} t t j | d � � Wn t k rH t i � n Xd S( Nt stats( R] R R R? R@ R ( R9 RA ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR� � s N(( t __name__t __module__t __doc__R t twextt whot idirectoryR t txdavt delegatest wikiR- t FieldNamet augmentR0 R> RB RH R RU R] Rc Ri R. Rq Rs Ru Rw Ry R} R t ORR� R� R� R� R� R� R� R� ( ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR I s> # ) # R c B s} e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sO t | t � r! | j d � } n | j j t d � d | j j d � d | �S( Ns utf-8c S s | d S( Nt authenticated( ( t x( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt <lambda>� t Rr t password( Rl R4 Rp t serviceRi R Rr ( R9 R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt verifyPlaintextPassword� s c C s� | j j t d � d | j j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � d | j d � � S( Nc S s | d S( NR� ( ( R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR� � R� Rr s utf-8t usernamet realmt urit noncet cnoncet algorithmt nct qopt responset method( R� Ri R Rr Rp ( R9 R� R� R� R� R� R� R� R� R� R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt verifyHTTPDigest� s c C sf | j t j t j t j t j t j f k rX | j j t | j j d | j j d � �St g � Sd S( NRr s utf-8( R- R t groupt DelegatesRecordTypet readDelegateGroupt writeDelegateGroupt readDelegatorGroupt writeDelegatorGroupR� Ri R RH Rr Rp R ( R9 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt members� s c C s` | j t j t j t j t j f k rR | j j t | j j d | j j d � �St g � Sd S( sB Only allowed for delegates - not regular groups. Rr s utf-8N( R- R� R� R� R� R� R� Ri R& RH Rr Rp R ( R9 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt expandedMembers� s c C s+ | j j t | j j d | j j d � �S( NRr s utf-8( R� Ri R RH Rr Rp ( R9 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt groups� s c C s` t j d � g | D] } | j j d � ^ q } | j j t d � d | j j d � d | �S( Ns DPS Client addMemberss utf-8c S s | d S( Nt success( ( R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR� � R� Rr t memberUIDs( RO RP Rr Rp R� Ri R# ( R9 R� t mR� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt addMembers� s % c C s` t j d � g | D] } | j j d � ^ q } | j j t d � d | j j d � d | �S( Ns DPS Client removeMemberss utf-8c S s | d S( NR� ( ( R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR� R� Rr R� ( RO RP Rr Rp R� Ri R$ ( R9 R� R� R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt removeMembers s % c C s` t j d � g | D] } | j j d � ^ q } | j j t d � d | j j d � d | �S( Ns DPS Client setMemberss utf-8c S s | d S( NR� ( ( R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR� R� Rr R� ( RO RP Rr Rp R� Ri R ( R9 R� R� R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt setMembers s % c C s5 g } x( | d D] } | j | j d � � q W| S( NRC s utf-8( RD Rn ( R9 RF R� Rr ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _convertUIDs s c C sU t j d � | j t j k rG | j j t | j d | j j d � �St g � Sd S( Ns DPS Client expandedMemberUIDsRr s utf-8( RO RP R- R R� R� Ri R" R� Rr Rp R ( R9 ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt expandedMemberUIDs s c C sD t j d � | j j t d � d | j j d � d | j d � �S( s� Is the supplied UID an expanded member of this proxy group. @param uid: UID to test @type uid: L{str} @return: result @rtype: L{bool} s DPS Client containsUIDc S s | d S( NRA ( ( R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR� 4 R� Rr s utf-8t testUid( RO RP R� Ri R) Rr Rp ( R9 Rr ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt containsUID' s c C s) | d j d � } t j j j j | � S( Nt accesss utf-8( Rn R� R� R� t WikiAccessLevelR1 ( R9 RF R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt _convertAccess9 s c C sS t j d � | j j t | j d | j j d � d | rL | j j d � n d �S( Ns DPS Client accessForRecordt wikiUIDs utf-8Rr R� ( RO RP R� Ri R R� Rr Rp ( R9 RG ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt accessForRecord= s ( R� R� R� R� R� R� R� R� R� R� R� R� R� R� R� ( ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyR � s c c sa t d � } | j t j d � V} d j d | � GH| r] | j d � V} d j d | � GHn d S( Nt sagens short name: {r}R� t negass plain auth: {a}t a( R R. Rq R t usert formatR� ( t dsRG R� ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt makeEvenBetterRequestI s c C s d GHt j � d S( Nt yay( R t stop( RA ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt succeededf s c C s d j d | � GHt j � d S( Ns boo: {f}t f( R� R R� ( t failure( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt failedk s t __main__(R t cPickleR? R` R6 t twext.python.logR t twext.who.directoryR t BaseDirectoryRecordR t BaseDirectoryServicet twext.who.expressionR t twext.who.idirectoryR R R� t twext.who.utilR t twisted.internetR t twisted.internet.deferR R R t twisted.internet.errorR t twisted.internet.protocolR t twisted.protocolsR t twisted.python.constantsR R t& txdav.caldav.icalendardirectoryserviceR t txdav.common.idirectoryserviceR t txdav.dps.commandsR R R R R R R R R R R R R R R R! R" R# R$ R% R& R' R( R) t txdav.who.delegatesR� t txdav.who.directoryR* R+ t txdav.who.augmentR� t txdav.who.idirectoryt txdav.who.wikit zope.interfaceR, RO R� R� R� R� t dt addCallbackst run( ( ( s# /opt/cpanel-ccs/txdav/dps/client.pyt <module> sL � � e �