ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
common
/
datastore
/
Filename :
sql_external.pyc
back
Copy
� �t�ac @ s d 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 m Z m Z d d l m Z m Z d d l m Z d d l m Z m Z d d l m Z e � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ e e _ d S( s SQL data store. i����( t Logger( t inlineCallbackst returnValuet succeed( t PropertyStore( t CommonHomet CommonHomeChildt CommonObjectResource( t NotificationCollectiont NotificationObjectRecord( t _HOME_STATUS_EXTERNAL( t NonExistentExternalSharet ExternalShareFailed( t ChangeCategoryt CommonHomeExternalc B s e Z d Z e d � � Z d � Z d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z e d d � � Z e d � Z e d � � Z d � Z d � Z e d � � Z d � Z g e d � Z d � Z e j d � Z d � Z d � Z e d � � Z RS( s0 A CommonHome for a user not hosted on this system, but on another pod. This is needed to provide a "reference" to the external user so we can share with them. Actual operations to list child resources, etc are all stubbed out since no data for the user is actually hosted in this store. c C se i | d 6| d 6t d 6} g | j � D] } | j | � ^ q( } | | | � } | j j | _ | S( s� During migration we need to refer to the remote home as an external home but without have a local representation of it in the store. There will be a new local store home for the migrating user that will operate on local store objects. The synthetic home operates only on remote objects. @param diruid: directory UID of user @type diruid: L{str} @param resourceID: resource ID in the remote store @type resourceID: L{int} t _resourceIDt _ownerUIDt _status( R t homeAttributest gett _childClasst _externalClass( t clst transactiont diruidt resourceIDt attrMapt attrt homeDatat result( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt makeSyntheticExternalHome. s (c C s t t | � j | | � d S( N( t superR t __init__( t selfR R ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR D s c C sF x9 | j j j � D]% \ } } | j | | j | � � q Wt | � S( s� External share does not have metadata or properties so we skip those by by-passing the super method, but we do need to add notifiers. ( t _txnt _notifierFactoriest itemst addNotifiert newNotifierR ( R! t factory_typet factory( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt initFromStoreG s c c s- | j j � j j | � V} | j | � d S( s` Read the home metadata from remote home and save as attributes on this object. N( R" t storet conduitt send_home_metadatat deserialize( R! t mapping( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt readMetaDataR s c C s | j j � j j | | � S( N( R" R* R+ t send_home_set_status( R! t newStatus( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt setStatusZ s c C s t t | � j | � S( s� Set the status on the object in the local store not the remote one. @param newStatus: the new status to set @type newStatus: L{int} ( R R R2 ( R! R1 ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt setLocalStatus] s c C s t S( sG Is this an external home. @return: a string. ( t True( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt externalf s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( t AssertionError( R! t shareUID( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt objectWithShareUIDn s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! R7 ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt invitedObjectWithShareUIDt s c c sE | d k r t d � � n t t | � j | | � V} t | � d S( s8 No real children - only external ones. s! CommonHomeExternal: not supportedN( t NoneR6 R R t createChildWithNameR ( R! t namet bindUIDt child( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR; z s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! R< t useTrash( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt removeChildWithName� s c c sE | j d k r t d � � n t t | � j | j � d t �Vd S( s� Remove an external child. Check that it is invalid or unused before calling this because if there are valid references to it, removing will break things. s! CommonHomeExternal: not supportedR? N( t _bindUIDR: R6 R R R@ R< t False( R! R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt removeExternalChild� s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt syncToken� s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! t revisiont depth( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt resourceNamesSinceRevision� s c c sD t j | j � | j � d | j | j d | j �V} | | _ d S( sB No property store - stub to a NonePropertyStore. t notifyCallbackN( R t loadt uidR: R" R t notifyChangedt _propertyStore( R! t props( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt _loadPropertyStore� s c C s | j S( N( RL ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt properties� s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! RJ t ignore_childrent allowShared( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt objectResourcesWithUID� s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! t rid( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt objectResourceWithID� s c C s t d � S( sW Notifications are not handled for external homes - make this a no-op. N( R R: ( R! t category( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRK � s c C s t d � S( sM No changes recorded for external homes - make this a no-op. N( R R: ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt bumpModified� s c C s t d � � d S( s No children. s! CommonHomeExternal: not supportedN( R6 ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt removeUnacceptedShares� s c c s� | j j � j j | � V} t t g | j � D]Z \ } } | | j j j | d � | j j j | d � | j j j | d � f f ^ q/ � � d S( Ni i i ( R" R* R+ t send_home_shared_to_recordsR t dictR$ R t _bindRecordClassR- t _metadataRecordClass( R! t resultst kt v( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt sharedToBindRecords� s N( t __name__t __module__t __doc__t classmethodR R R) R R/ R2 R3 R5 R8 R9 R: R; R4 R@ RC RD RG RN RO RR RT R t defaultRK RV RW R_ ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR ' s0 t CommonHomeChildExternalc B s� e Z d Z e d � � Z e e d � � � Z e e d d d e e d � � � Z d � Z e d � � Z e d � � Z e d d � � Z e d � � Z e d d � � Z e d � � Z e d � � Z e d � � Z e d � � Z d � Z RS( s� A CommonHomeChild for a collection not hosted on this system, but on another pod. This will forward specific apis to the other pod using cross-pod requests. c C s | j j � j j | � S( s| Retrieve the names of the children that exist in the given home. @return: an iterable of C{str}s. ( R" R* R+ t send_homechild_listobjects( R t home( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt listObjects� s c c sa | j j � j j | � V} g } x. | D]& } | j | | � V} | j | � q) Wt | � d S( N( R" R* R+ t send_homechild_loadallobjectsR- t appendR ( R Rg t raw_resultsR\ R. R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt loadAllObjects� s c c s_ | j j � j j | | | | | | � V} | rQ | j | | � V} t | � n t d � d S( N( R" R* R+ t send_homechild_objectwithR- R R: ( R Rg R< R R= t acceptedt onlyInTrashR. R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt objectWith� s + c C s t S( sG Is this an external home. @return: a string. ( R4 ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR5 s c c s= t j d d | �| j � V} | j | � V| j � Vd S( s� An external request has returned and indicates the external share no longer exists. That means this shared resource is an "orphan" and needs to be remove (uninvited) to clean things up. s3 Non-existent share detected and removed for {share}t shareN( t logt errort ownerViewt removeSharet cleanExternalShare( R! Rt ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt fixNonExistentExternalShare s c c s3 | j � r# t t | � j � Vn t d � � d S( s� External shares are never removed directly - instead they must be "uninvited". However, the owner's external calendar can be removed. s& CommonHomeChildExternal: not supportedN( t ownedR Re t removeR6 ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRy s c C s t d � � d S( s The base class does an optimization to avoid removing/re-creating the actual object resource data. That might not always be possible with external shares if the shared resource is moved to a collection that is not shared or shared by someone else on a different (third) pod. The best bet here is to treat the move as a delete/create. s TODO: external resourceN( t NotImplementedError( R! R> t newparentt newname( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt moveObjectResource! s c c se y, | j j � j j | | t | � � V} Wn( t k rV | j � Vt d � � n Xt | � d S( s| Create a new child in this collection as part of a move operation. This needs to be split out because behavior differs for sub-classes and cross-pod operations. @param name: new name to use in new parent @type name: C{str} or C{None} for existing name @param component: data for new resource @type component: L{Component} s External share does not existN( R" R* R+ t send_homechild_moveheret strR Rw R R ( R! R< t componentR ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt moveObjectResourceHere, s , c c s\ y# | j j � j j | | � V} Wn( t k rM | j � Vt d � � n Xt | � d S( sw Remove the child as the result of a move operation. This needs to be split out because behavior differs for sub-classes and cross-pod operations. @param rid: the child resource-id to move @type rid: C{int} @param child: the child resource to move - might be C{None} for cross-pod @type child: L{CommonObjectResource} s External share does not existN( R" R* R+ t send_homechild_moveawayR Rw R R ( R! RS R> R ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt moveObjectResourceAway? s # c c sk | j d k r] y | j j � j j | � V} Wq] t k rY | j � Vt d � � q] Xn t | � d S( Ns External share does not exist( t _syncTokenRevisionR: R" R* R+ t send_homechild_synctokenrevisionR Rw R R ( R! RE ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt syncTokenRevisionR s c c s\ y# | j j � j j | | � V} Wn( t k rM | j � Vt d � � n Xt | � d S( Ns External share does not exist( R" R* R+ t) send_homechild_resourcenamessincerevisionR Rw R R ( R! RE t names( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRG \ s # c k se y, | j j � j j | | j � | � V} Wn( t k rV | j � Vt d � � n Xt | � d S( Ns External share does not exist( R" R* R+ t send_homechild_searcht serializeR Rw R R ( R! t filtert kwargsR\ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt searchf s , c c sa | j j � j j | � V} t t g | j � D]$ \ } } | | j j | � f ^ q/ � � d S( N( R" R* R+ t send_homechild_sharing_recordsR RY R$ RZ R- ( R! R\ R] R^ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt sharingBindRecordsp s c C s | j j � j j | | � S( N( R" R* R+ t& send_homechild_migrate_sharing_records( R! R= ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt migrateBindRecordsu s N( R` Ra Rb Rc Rh R Rl R: R4 RB Rp R5 Rw Ry R} R� R� R� RG R� R� R� ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRe � s( t CommonObjectResourceExternalc B s� e Z d Z e e d � � � Z e e d � � � Z e d � � Z e d � � Z e e d d d d � � � Z e d � � Z e d � � Z e e d d � � � Z e d � � Z e d � � Z d � Z RS( s� A CommonObjectResource for a resource not hosted on this system, but on another pod. This will forward specific apis to the other pod using cross-pod requests. c c sj | j j � j j | � V} g } | r\ x1 | D]& } | j | | � V} | j | � q/ Wn t | � d S( N( R" R* R+ t" send_objectresource_loadallobjectsR- Rj R ( R t parentt mapping_listR\ R. R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRl s c c sm | j j � j j | | � V} g } | r_ x1 | D]& } | j | | � V} | j | � q2 Wn t | � d S( N( R" R* R+ t+ send_objectresource_loadallobjectswithnamesR- Rj R ( R R� R� R� R\ R. R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt loadAllObjectsWithNames� s c C s | j j � j j | � S( N( R" R* R+ t send_objectresource_listobjects( R R� ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRh � s c C s | j j � j j | � S( N( R" R* R+ t send_objectresource_countobjects( R R� ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt countObjects� s c c sY | j j � j j | | | | � V} | rK | j | | � V} t | � n t d � d S( N( R" R* R+ t send_objectresource_objectwithR- R R: ( R R� R< RJ R R. R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRp � s % c C s | j j � j j | | � S( N( R" R* R+ t& send_objectresource_resourcenameforuid( R R� RJ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt resourceNameForUID� s c C s | j j � j j | | � S( N( R" R* R+ t& send_objectresource_resourceuidforname( R R� R< ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt resourceUIDForName� s c c sb | j j � j j | | t | � d | �V} | rT | j | | � V} t | � n t d � d S( Nt options( R" R* R+ t send_objectresource_createR R- R R: ( R R� R< R� R� R. R> ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt create� s . c k sE | j j � j j | t | � | � V| _ d | _ t | j � d S( N( R" R* R+ t send_objectresource_setcomponentR t _componentChangedR: t _cachedComponentR ( R! R� R� ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt setComponent� s + c c sT | j d k rC | j j � j j | � V} | j j | � | _ n t | j � d S( N( R� R: R" R* R+ t send_objectresource_componentt _componentClasst fromStringR ( R! t text( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR� � s c C s | j j � j j | � S( N( R" R* R+ t send_objectresource_remove( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyRy � s N( R` Ra Rb Rc R Rl R� Rh R� R: Rp R� R� R� R� R� Ry ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR� y s$ t NotificationCollectionExternalc B sJ e Z d Z e e d � � Z d � Z e d � � Z d � Z d � Z RS( s� A NotificationCollection for a resource not hosted on this system, but on another pod. This will forward specific apis to the other pod using cross-pod requests. c C s% t t | � j | | d t d | �S( Nt statusR� ( R R� t notificationsWithUIDR ( R t txnRJ R� ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR� � s c C s t | � S( sH NoOp for an external share as there are no properties. ( R ( R! ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR) � s c c s6 | j j � j j | � V} t t t j | � � d S( N( R" R* R+ t send_notification_all_recordsR t mapR R- ( R! R\ ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt notificationObjectRecords� s c C s | j j � j j | | � S( N( R" R* R+ t send_notification_set_status( R! R1 ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR2 � s c C s t t | � j | � S( s� Set the status on the object in the local store not the remote one. @param newStatus: the new status to set @type newStatus: L{int} ( R R� R2 ( R! R1 ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR3 � s ( R` Ra Rb Rc RB R� R) R R� R2 R3 ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyR� � s N( Rb t twext.python.logR t twisted.internet.deferR R R t txdav.base.propertystore.sqlR t txdav.common.datastore.sqlR R R t' txdav.common.datastore.sql_notificationR R t! txdav.common.datastore.sql_tablesR t txdav.common.icommondatastoreR R t txdav.idavR Rr R Re R� R� R ( ( ( s6 /opt/cpanel-ccs/txdav/common/datastore/sql_external.pyt <module> s ��V!