ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
common
/
datastore
/
podding
/
Filename :
util.pyc
back
Copy
� �t�ac @ sr d d l m Z m Z d d l m Z d d l m Z m Z d d l m Z m Z m Z d e f d � � YZ d S( i����( t inlineCallbackst returnValue( t FailedCrossPodRequestError( t NotificationCollectiont NotificationObject( t NonExistentExternalSharet ECALENDARTYPEt EADDRESSBOOKTYPEt UtilityConduitMixinc B s� e Z d Z e d � � Z e d � � Z e e d d d d � � Z e d d � � Z e e d d d � � Z e d � � Z e d � � Z e d � � Z e d � � Z RS( s@ Defines utility methods for cross-pod API and mix-ins. c c sK d d l m } m } m } i | d 6} | j } d } d } d } d } d } t | | � r� | j � } | j � } | j � } | } n� t | | � r� | j � } | j � } | } | | d <n\ t | | � r� | } | } | j } | | d <n+ t | t � r"| } | j } | | d <n | r�| j | d <| j � | d <t | d t � rdt | d <n | r�| j � r�| j � | d <q�| j � | d <n | r�| j � | d <n | j j � j | j � � V} nW | r.| j � | d <t | d t � r t | d <n | j j � j | j � � V} n t | | | j � f � d S( s� Create the JSON data needed to identify the remote resource by type and ids, along with any parent resources. @param action: the conduit action name @type action: L{str} @param storeObject: the store object that is being operated on @type storeObject: L{object} @param classMethod: indicates whether the method being called is a classmethod @type classMethod: L{bool} @return: the transaction in use, the JSON dict to send in the request, the server where the request should be sent @rtype: L{tuple} of (L{CommonStoreTransaction}, L{dict}, L{str}) i����( t CommonObjectResourcet CommonHomeChildt CommonHomet actiont classMethodt homeTypet homeUIDt _migratingHomet allowDisabledHomet homeChildIDt homeChildSharedIDt objectResourceIDt notificationUIDN( t txdav.common.datastore.sqlR R R t _txnt Nonet isinstancet ownerHomet viewerHomet parentCollectionR t _homeTypet uidt getattrt Falset Truet ownedt idt namet storet directoryServicet recordWithUIDR t server( t selfR t storeObjectR R R R t resultt txnt owner_homet viewer_homet home_childt object_resourcet notificationt recipient( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _getRequestForStoreObject# s\ " "c c s{ | } d } d | k r$ t | _ n d | k r� | j | d | d � V} | d k rf t d � � n t | _ | } | j d t � r� | j } q� n d | k r� | j | d � V} | d k r� t d � � n | } | j d t � rZ| j } qZnb d | k rZ| j | d � V} | d k r3t d � � n | } | j d t � rZ| j } qZn d | k r�| j | d � V} | d k r�t d � � n | } n d | k rg| j | d � V} | d k r:t | _ xd t t f D]G } | j | | d � V} | d k r�| j | d d t �V} Pq�q�Wt d � � n t | _ | } | j d t � rgt } qgn t | | f � d S( sU Resolve the supplied JSON data to get a store object to operate on. R R R s Invalid owner UID specifiedR R s Invalid home child specifiedR R s! Invalid object resource specifiedR t creates" Invalid notification UID specifiedN( R R! t _allowDisabledt homeWithUIDR R t _internalRequestt gett _childClasst childWithIDt _objectResourceClasst childWithNameR t objectResourceWithIDt notificationsWithUIDR R R R ( R) R, t requestt returnObjectt classObjectt homet homeChildt objectResourceR1 t storeType( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _getStoreObjectForRequestn s\ c c s� | j | | | � V\ } } } | d k r8 | | d <n | d k rQ | | d <n | j | | | � V} t | d k r� | | � n | � d S( s� A simple send operation that returns a value. @param actionName: name of the action. @type actionName: C{str} @param shareeView: sharee resource being operated on. @type shareeView: L{CommonHomeChildExternal} @param objectResource: the resource being operated on, or C{None} for classmethod. @type objectResource: L{CommonObjectResourceExternal} @param transform: a function used to convert the JSON response into return values. @type transform: C{callable} @param args: list of optional arguments. @type args: C{list} @param kwargs: optional keyword arguments. @type kwargs: C{dict} t argumentst keywordsN( R3 R t sendRequestToServerR ( R) t actionNameR* R t transformt argst kwargsR, R? R( t response( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _simple_object_send� s c c s� | j | | � V\ } } | d k r\ t | | � | | j d d � | j d i � � V} n1 t | | � | j d d � | j d i � � V} t | d k r� | | � n | � d S( s? A simple recv operation that returns a value. We also look for an optional set of arguments/keywords and include those only if present. @param actionName: name of the action. @type actionName: C{str} @param request: request arguments @type request: C{dict} @param method: name of the method to execute on the shared resource to get the result. @type method: C{str} @param transform: method to call on returned JSON value to convert it to something useful. @type transform: C{callable} RG RH N( ( ( RF R R R8 R ( R) R, RJ R? t methodRK R* RA t value( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _simple_object_recv� s 71c sT t | d j � � � � � f d � � t | d j � � � � � f d � � d S( Ns send_{}c s( | j � | d � d � d | d | �S( NR RK RL RM ( RO ( R) R* RL RM ( R R t transform_send_result( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt <lambda>� s s recv_{}c s | j | � | � d � �S( NRK ( RR ( R) R, t message( R RP t transform_recv_result( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyRT � s ( t setattrt format( t bindclsR RP R RV RS ( ( R R RP RV RS s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _make_simple_action� s c C s | d k r | j � Sd S( sP Convert the value to the external (JSON-based) representation. N( R t serialize( RQ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _to_serialize� s c C s g | D] } | j � ^ q S( sP Convert the value to the external (JSON-based) representation. ( R[ ( RQ t v( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _to_serialize_list s c C s t | � S( N( t str( RQ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _to_string s c C s t | � S( N( t tuple( RQ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt _to_tuple s N( t __name__t __module__t __doc__R R3 RF R R RO RR t staticmethodRZ R\ R^ R` Rb ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyR s KEN( t twisted.internet.deferR R t# txdav.common.datastore.podding.baseR t' txdav.common.datastore.sql_notificationR R t txdav.common.icommondatastoreR R R t objectR ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/podding/util.pyt <module> s