OwlCyberSecurity - MANAGER
Edit File: sql_sharing.pyc
� �t�ac @ s� d d l m Z d d l m Z d d l m Z m Z m Z m Z m 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 m Z m Z m Z m Z m Z m Z m Z m Z 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( e � Z) d e* f d � � YZ+ e d d d d d d d d d d g � Z, d e* f d � � YZ- d S( i����( t namedtuple( t DateTime( t Insertt Parametert Updatet Deletet Select( t classproperty( t Logger( t inlineCallbackst returnValuet succeed( t PropertyName( t _BIND_MODE_OWNt _BIND_MODE_DIRECTt _BIND_MODE_INDIRECTt _BIND_STATUS_ACCEPTEDt _BIND_STATUS_DECLINEDt _BIND_STATUS_INVITEDt _BIND_STATUS_INVALIDt _BIND_STATUS_DELETEDt _HOME_STATUS_EXTERNALt _HOME_STATUS_DISABLED( t ExternalShareFailedt HomeChildNameAlreadyExistsErrort AllRetriesFailed( t ChangeCategory( t element( t uuid4t SharingHomeMixInc B s� e Z d Z e d d � � Z e d � � Z e d d � � Z e d � � Z e d d � � Z e d � � Z e d � � Z RS( sE Common class for CommonHome to implement sharing operations c c s; | j | � V} | d k r- | j | � Vn t | � d S( s/ This share is being accepted. N( t anyObjectWithShareUIDt Nonet acceptShareR ( t selft shareUIDt summaryt shareeView( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR 5 s c c s> | j | � V} | d k r* | j � Vn t | d k � d S( s/ This share is being declined. N( R R t declineShareR ( R! R" R$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR% A s c c s� | j j | j | d t d t �V} | d k s> | j � rV t d j | � � � n | j | � V} | d k r� | j | | | � V} n | t k r� | j | j � d | �V} n" | j | j � | | d | �V} | j | � d S( s+ External invite received. t statust creates Invalid owner UID: {}t shareNameN( t _txnt homeWithUIDt _homeTypeR t TrueR t externalR t formatt childWithBindUIDt createCollectionForExternalShareR t directShareWithUsert uidt inviteUIDToSharet setInviteCopyProperties( R! t ownerUIDt ownerNameR" t bindModet bindUIDR# t copy_invite_propertiest supported_componentst ownerHomet ownerViewR$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt processExternalInviteP s c c s� | j j | j | d t �V} | d k s8 | j � rP t d j | � � � n | j | � V} | d k r� t d j | � � � n | j | j � � V| j � Vd S( s+ External invite received. R& s Invalid owner UID: {}s Invalid share ID: {}N( R) R* R+ R R R- R R. R/ t uninviteUIDFromShareR2 t cleanExternalShare( R! R5 R8 R" R; R< ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt processExternalUninviteq s c c s� | j j | j | d t �V} | d k s8 | j � rP t d j | � � � n | j | � V} | d k r� t d j | � � � n | t k r� | j | | � Vn7 | t k r� | j � r� | j � Vq� | j | � Vn d S( s+ External invite received. R& s Invalid sharee UID: {}s Invalid share UID: {}N( R) R* R+ R R R- R R. R R R R t directt deleteShareR% ( R! R5 t shareeUIDR" t bindStatusR# t shareeHomeR$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt processExternalReply� s c c s� y | j | d | �V} Wn� t k r� | j | � V} | j � V} t | � d k rl t j d � � n t j d � | j | � V| j | d | �V} n X| d k r� t | d � r� | j | � Vn t | � d S( s� Create the L{CommonHomeChild} object that used as a "stub" to represent the external object on the other pod for the sharer. @param name: name of the collection @type name: L{str} @param bindUID: id on other pod @type bindUID: L{str} @param supported_components: optional set of support components @type supported_components: L{str} R8 i sX External invite collection name is present with a different bindUID and still has sharessS External invite collection name is present with a different bindUID - trying to fixt setSupportedComponentsN( t createChildWithNameR t childWithNamet sharingInvitest lent logt errort removeExternalChildR t hasattrRG R ( R! t nameR8 R: R< t oldOwnerViewt invites( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR0 � s& c # s� | j j j | j t | j j | j j � | j � k j | j j j t k � � V} t g | D]! } t | | j j � | f ^ q_ � } | s� t i � n | j j j | j t | j j | j j � j | j � � j | j j j t k � � V} x4 | D], } | j s� | j d t t � � � Vq� q� Wt g | D]! } t | | j j � | f ^ q5� } | j j j | j | j j j j | j � � � V} t g | D] } | j | f ^ q�� } t g | j � D]0 } t | | j j � t | | j j � f ^ q�� � | j j j | j | j j j j � j � � � V} t � f d � | D� � } t t g | D]+ } | | | | | | | | f f ^ qa� � d S( s~ Return an L{dict} that maps home/directory uid to a sharing bind record for collections shared to this user. R8 c 3 s% | ] } � | j | j f Vq d S( N( t resourceIDR5 ( t .0t home( t homeIDs( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pys <genexpr> s N( t _childClasst _bindRecordClasst queryR) t getattrt _bindHomeIDAttributeNamet idt AndR7 R t dictt _bindResourceIDAttributeNameR t Int keysR8 t updatet strR t _metadataRecordClassRS t valuest _homeRecordClass( R! t recordst recordt ownerRecordst ownerRecordt metadataRecordst homest homeMapt calendarID( ( RV s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt sharedToBindRecords� s4 ' 4 * !4 "(C " N( t __name__t __module__t __doc__R R R R% R= R@ RF R0 Ro ( ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR 0 s 1t SharingInvitationR2 R5 t ownerHomeIDRC t shareeHomeIDt shareeHomeStatust modeR& R# t SharingMixInc B s� e Z d Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e dH dH d � � Z e dH dH d � � Z e d � � Z e dH d � � Z e d � � Z e d � � Z e d � � Z e d � � Z dH d � Z e e j d � � Z e d � � Z e dH d � � Z e dH d � � Z e d � � Z e d � � Z! e d � � Z" e dH d � � Z# e d � � Z$ e d � � Z% e dH dH dH d � � Z& e dH dH dH d � � Z' e dH dH d � � Z( e dH dH dH d! � � Z) d" � Z* e d# � � Z+ e d$ � � Z, e d% � � Z- e d& � � Z. e d' � � Z/ d( � Z0 e d) � � Z1 e d* � � Z2 d+ � Z3 e d, � � Z4 d- � Z5 d. � Z6 d/ � Z7 d0 � Z8 e d1 � � Z9 d2 � Z: d3 � Z; d4 � Z< d5 � Z= d6 � Z> d7 � Z? d8 � Z@ d9 � ZA d: � ZB d; � ZC d< � ZD d= � ZE d> � ZF e d? � � ZG e d@ � � ZH e dA � � ZI e dB � � ZJ dC ZK e dD � � ZL e dE � � ZM e dF � � ZN e dG � � ZO RS(I s@ Common class for CommonHomeChild and AddressBookObject c K s� | j } t i t d � | j 6t d � | j 6t d � | j 6t d � | j 6t d � | j 6t d � | j 6t d � | j 6� S( sf DAL statement to create a bind entry that connects a collection to its home. t homeIDRS RP Rw RD R8 t message( t _bindSchemaR R t HOME_RESOURCE_IDt RESOURCE_IDt RESOURCE_NAMEt BIND_MODEt BIND_STATUSt BIND_UIDt MESSAGE( t clst kwt bind( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _bindInsertQuery s c C s@ | j } t | d | j t d � k j | j t d � k � �S( Nt WhereRS Ry ( R{ R R} R R] R| ( R� t columnMapR� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _updateBindColumnsQuery* s c C sC | j } t d | d | j t d � k j | j t d � k � � S( Nt FromR� RS Ry ( R{ R R} R R] R| ( R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt! _deleteBindForResourceIDAndHomeID3 s c C s5 | j } | j � | j � } t | d | d | �S( NR� R� ( R{ t bindColumnst additionalBindColumnsR ( R� t conditionR� t columns( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _bindFor< s c C ss | j } | j } t | j | j | j | j | j | j | j | j g d | j | d | j | j k �d | �S( NR� t onR� ( t _homeSchemaR{ R t OWNER_UIDR| t STATUSR} R~ R R� R� t join( R� R� RU R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _bindInviteForF s !c C s7 | j } | j | j t d � k j | j t k � � S( NRS ( R{ R� R} R R] R R ( R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt" _sharedInvitationBindForResourceIDY s c C s7 | j } | j | j t d � k j | j t k � � S( NRy ( R{ R� R| R R] R� R ( R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _acceptedBindForHomeIDa s c C s= | j } | j | j t d � k j | j t d � k � � S( sp DAL query that looks up home bind rows by home child resource ID and home resource ID. RS Ry ( R{ R� R} R R] R| ( R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _bindForResourceIDAndHomeIDg s c C s= | j } | j | j t d � k j | j t d � k � � S( sp DAL query that looks up home bind rows by home child resource ID and home resource ID. R8 Ry ( R{ R� R� R R] R| ( R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _bindForBindUIDAndHomeIDq s c C s= | j } | j | j t d � k j | j t d � k � � S( so DAL query that looks up any bind rows by home child resource ID and home resource ID. RP Ry ( R{ R� R~ R R] R| ( R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _bindForNameAndHomeID{ s c c s� | j | � V} | d k rc | j � t t f k r: t n d } | j | d | d | d | �Vn% | j d | d | d | d | � V} | j � j � r� | j | � Vn | j | � Vt | � d S( s� Invite a user to share this collection - either create the share if it does not exist, or update the existing share with new values. Make sure a notification is sent as well. @param shareeUID: UID of the sharee @type shareeUID: C{str} @param mode: access mode @type mode: C{int} @param summary: share message @type summary: C{str} Rw R& R# RC R( N( R$ R t shareStatusR R R t updateSharet createSharet viewerHomeR- t _sendExternalInvitet _sendInviteNotificationR ( R! RC Rw R# R( R$ R& ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR3 � s $#%c c s� | j | � V} | d k rr | j d | d t d | � V} | j d | � V| j � j � rr | j | � Vqr n t | � d S( s� Create a direct share with the specified user. Note it is currently up to the app layer to enforce access control - this is not ideal as we really should have control of that in the store. Once we do, this api will need to verify that access is allowed for a direct share. NB no invitations are used with direct sharing. @param shareeUID: UID of the sharee @type shareeUID: C{str} RC Rw R( t displaynameN( R$ R R� R t newShareR� R- R� R ( R! RC R( t displayNameR$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR1 � s c c s� | j | � V} | d k r� | j � j � rr y | j | � VWq� t k rn } t j d d | d | �q� Xn_ | j � r� | j � j � t k r� | j � t k r� | j | � Vq� | j | d t �Vn | j | � Vn d S( s� Remove a user from a share. Make sure a notification is sent as well. @param shareeUID: UID of the sharee @type shareeUID: C{str} s0 Could not send sharing uninvite '{userid}': {ex}t useridt ext notificationStateN( R$ R R� R- t _sendExternalUninvitet ExceptionRL RM RA R; R& R R� R t _removeInviteNotificationR� R t removeShare( R! RC R$ t e( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR> � s %c c s� | j � r� | j � t k r� | j � r? | j t | � Vn | j � V} | j | d t �V| j d | � V| j � s� | j | | � Vq� n d S( s/ This share is being accepted. R& R� N( RA R� R R- t _replyExternalInviteR< R� R� t _sendReplyNotification( R! R# R< ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR � s c c s� | j � r} | j � t k r} | j � r< | j t � Vn | j � V} | j | d t �V| j � s} | j | � Vq} n d S( s/ This share is being declined. R& N( RA R� R R- R� R< R� R� ( R! R< ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR% � s c c sV | j � V} | j � rG | j | � V| j � rR | j t � VqR n | j � Vd S( sm This share is being deleted (by the sharee) - either decline or remove (for direct shares). N( R< RA R� R- R� R R% ( R! R< ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyRB � s c c s; | j t � Vx& | j � VD] } | j | j � Vq Wd S( sl This share is being deleted (by the owner) - either decline or remove (for direct shares). N( t setSharedt FalseRJ R> RC ( R! t invitation( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt ownerDeleteShare s c c s7 | j � V} t | � d k r3 | j j | � Vn d S( s� Called when an external share is removed. This method will remove the reference to the external shared calendar when there are no more sharees on this pod. i N( RJ RK t _homeRN ( R! RR ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR? s c C s t d � S( sz Override in derived classes to do any specific operations needed when a share is first accepted. N( R R ( R! R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� & s c c s� | j � s | j � V} n | } t � } x7 | j � VD]( } | j t k r9 | j | j � q9 q9 W| r� | j � d k r� | j j � j j | j | j � j | j � j � | j � | | � Vn d S( s� Send a cross-pod message to all external shares to ensure change notifications are sent to external sharees' clients subscribed to notifications on the other pods. N( t ownedR< t setRJ Rv R t addRC R8 R R) t storet conduitt send_sharenotificationR; R+ R2 ( R! t categoryR< t externalUIDsR� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt notifyExternalShare- s c c s@ | j � V} t d � | � } | j d d � � t | � d S( sJ Get list of all invitations (non-direct) to this object. c S s | j t k S( N( Rw R ( t x( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt <lambda>U t t keyc S s | j S( N( RC ( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� V R� N( RJ t filtert sortR ( R! t invitations( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt allInvitationsM s c c se | j � } | t k rE t | j � j t j t j � | � � } n i d d 6| j � d 6} i d d 6| j � d 6t j � j � d 6| j � j � d 6| j � j � d 6| j � d 6| d k r� | j � n | d 6| j � Vd 6| j � d 6| d 6} t | d � r"| j � | d <n | j j | j � j � d t �V} | j | j � | | � Vd S( s1 Called on the owner's resource. s invite-notifications notification-types shared-typet dtstampt ownert shareeR2 R& t accessR6 R# t getSupportedComponentss supported-componentsR' N( t shareMessageR Rc t propertiest getR t fromElementR t DisplayNamet sharedResourceTypeR t getNowUTCt getTextR; R2 R� R" R R� t effectiveShareModeR( RO R� R) t notificationsWithUIDR, t writeNotificationObject( R! R$ R� R� t notificationtypet notificationdatat notifications( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� Y s* - %c c s� d | j � f } i d d 6| j � d 6} i d d 6| j � d 6t j � j � d 6| j � j � d 6| j � j � d 6| j � d 6| j � d 6| j � d 6| d 6} | j j | j � j � d t �V} | j | | | � Vd S( sa Create a reply notification based on the current state of this shared resource. s %s-replys invite-replys notification-types shared-typeR� R� R� R& R6 s in-reply-toR# R' N( R" R� R R� R� R; R2 R� R� R( R) R� R, R� ( R! R< R# t notificationUIDR� R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� z s %c c s7 | j j | j � j � � V} | j | j � � Vd S( s1 Called on the owner's resource. N( R) R� R� R2 t removeNotificationObjectWithUIDR" ( R! R$ R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c c s | j sf t t � � | _ | j i | j | j j 6� j | j d | j � d | j � j � �Vn | j j � j j | j | j � j | j � j � | j � | j � j � | j � | j � | j � | j � | j � d t | d � r� | j � n d � Vd S( NRS Ry R: R� ( t _bindUIDRc R R� R{ R� R� R) R\ R; R� R� t send_shareinviteR+ R2 R( R� R" t shareModeR8 R� t getInviteCopyPropertiesRO R� R ( R! R$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s" # c c s] | j j � j j | j | j � j | j � j � | j � | j � j � | j � � Vd S( N( R) R� R� t send_shareuninviteR; R+ R2 R8 R� R" ( R! R$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c c s� yZ | j j � j j | j | j � j | j � j � | j � j � | j � | | � VWn( t k r� | j � Vt d � � n Xd S( Ns External share does not exist( R) R� R� t send_sharereplyR� R+ R; R2 R" R t fixNonExistentExternalShare( R! R& R# ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c c s* | j � j | j � � V} t | � d S( s� Return the owner resource counterpart of this shared resource. Note we have to play a trick with the property store to coerce it to match the per-user properties for the owner. N( R; t childWithIDR\ R ( R! R< ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR< � s c c sz | j j � | k r" t d � n | j j | j j | d | �V} | d k rf | j | j � � Vn d } t | � d S( s� Return the shared resource counterpart of this owned resource for the specified sharee. Note we have to play a trick with the property store to coerce it to match the per-user properties for the sharee. t authzUIDN( R� R2 R R R) R* R+ t allChildWithIDR\ ( R! RC RE R$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR$ � s "(c c sF | j j | j j | d t �V} t | j | | | | | � V� d S( s� Share this (owned) L{CommonHomeChild} with another principal. @param shareeUID: The UID of the sharee. @type: L{str} @param mode: The sharing mode; L{_BIND_MODE_READ} or L{_BIND_MODE_WRITE} or L{_BIND_MODE_DIRECT} @type mode: L{str} @param status: The sharing status; L{_BIND_STATUS_INVITED} or L{_BIND_STATUS_ACCEPTED} @type: L{str} @param summary: The proposed message to go along with the share, which will be used as the default display name. @type: L{str} @return: the name of the shared calendar in the new calendar home. @rtype: L{str} R' N( R) R* R� R+ R, R t shareWith( R! RC Rw R& R# R( RE ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt shareWithUID� s "c # s � d k r t � n t � � � � � � f d � � } y � j j | � V} WnM t k r� � j � j � V} � j | d � d � d � �V| j } n6 X� t k r� � j | � V} | j � V| j � Vn � j t � V� j � V� j � Vt | � d S( s� Share this (owned) L{CommonHomeChild} with another home. @param shareeHome: The home of the sharee. @type: L{CommonHome} @param mode: The sharing mode; L{_BIND_MODE_READ} or L{_BIND_MODE_WRITE} or L{_BIND_MODE_DIRECT} @type: L{str} @param status: The sharing status; L{_BIND_STATUS_INVITED} or L{_BIND_STATUS_ACCEPTED} @type: L{str} @param summary: The proposed message to go along with the share, which will be used as the default display name. @type: L{str} @param shareName: The proposed name of the new share. @type: L{str} @return: the name of the shared calendar in the new calendar home. @rtype: L{str} c 3 sm � d k r � n � j � } � j j | d � j d � j d | d � d � d d d � �Vt | � d S( NRy RS RP Rw RD R8 Rz ( R t newShareNameR� R� t _resourceIDR ( t subtt newName( Rw R! R( RE R& R# ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt doInsert9 s Rw R& R# N( R R R R) t subtransactionR R� R� R� t _nameR t _initSyncTokent _initBindRevisionR� R, t notifyPropertyChangedt notifyChangedR ( R! RE Rw R& R# R( R� t bindNamet childR$ ( ( Rw R! R( RE R& R# s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� s& $ c c s{ | j j | j � j | d t �V} | j | d | d | t k rI t n t d | d | �V| j | � V} t | � d S( s� Create a new shared resource. If the mode is direct, the share is created in accepted state, otherwise the share is created in invited state. R' Rw R& R# R( N( R) R* R; R+ R, R� R R R R$ R ( R! RC Rw R# R( RE R$ ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� ` s %c c s� | j } i } | d k r: | | j k r: | | | j <n | d k re | | j k re | | | j <n | d k r� | | j k r� | | | j <n | r�| j | k r� | j � V} n | j | � j | j d | j d | j j �V| j | k r| | j | _ n | j | k r6| | j | _ | j | � Vn | j | k rX| | j | _ n | j � V| j � V| j � j � Vn d S( s Update share mode, status, and message for a home child shared with this (owned) L{CommonHomeChild}. @param shareeView: The sharee home child that shares this. @type shareeView: L{CommonHomeChild} @param mode: The sharing mode; L{_BIND_MODE_READ} or L{_BIND_MODE_WRITE} or None to not update @type mode: L{str} @param status: The sharing status; L{_BIND_STATUS_INVITED} or L{_BIND_STATUS_ACCEPTED} or L{_BIND_STATUS_DECLINED} or L{_BIND_STATUS_INVALID} or None to not update @type status: L{str} @param summary: The proposed message to go along with the share, which will be used as the default display name, or None to not update @type summary: L{str} RS Ry N( R{ R t _bindModeR t _bindStatusR� t _bindMessageR� t _previousAcceptCountR� R� R) R� R� t _changedStatust invalidateQueryCacheR� R� R� ( R! R$ Rw R& R# R� R� t previouslyAcceptedCount( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� r s0 c C s t d � S( Ni ( R ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c c s� | j j | j � � } | j t k rt | j � V| j � V| | j j | | j � <| | j j | | j � <ni | j t t f k r� | j d t � V| j j | j | j � d � | j j | j | j � d � n d S( Nt sharedRemoval( R� t _childrenKeyt isInTrashR� R R� R� t _childrenRP R\ R R t _deletedSyncTokenR, t popR ( R! R� R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c c s� | j j | j � � } | j � } | j d t � V| j | j | j d � | j | j | j d � | j � V| j � V| j j | j d | j d | j �V| j � Vd S( s/ Remove the shared version of this (owned) L{CommonHomeChild} from the referenced L{CommonHome}. @see: L{CommonHomeChild.shareWith} @param shareeView: The shared resource being removed. @return: a L{Deferred} which will fire with the previous shareUID R� RS Ry N( R� R� R� R� R� R, R� R� R� R R� R� R� R� R� R) R� ( R! R$ R� RE ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c c sm | j � rN | j � V} xM | D]' } | j | j � V} | j | � Vq Wn | j � V} | j | � Vd S( sW Unshares a collection, regardless of which "direction" it was shared. N( R� RJ R$ RC R� R< ( R! RR t inviteR$ R< ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt unshare� s c c s� | j � s t g � n | j j | j d | j d | j j �V} g } xo | D]g \ } } } } } } } } t | | j � j � | j � j � | | | | | | � } | j | � qQ Wt | � d S( s� Retrieve the list of all L{SharingInvitation}'s for this L{CommonHomeChild}, irrespective of mode. @return: L{SharingInvitation} objects @rtype: a L{Deferred} which fires with a L{list} of L{SharingInvitation}s. RS Ry N( R� R R� R� R) R� R� Rs R; RP R\ t append( R! t invitedRowst resultt homeUIDt homeRIDt homeStatust _ignore_resourceIDt resourceNameR7 RD t bindMessageR ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyRJ � s$ "% c c s� | j � s t i � n | j j | j i | j � | j 6� V} g | D] } t | | j � ^ qI } | j j | j | j j j | � � V} t d � | D� � } t t g | D]1 } | j t k r� | t | | j � | f ^ q� � � d S( sZ Return an L{dict} that maps home/directory uid to a sharing bind record. c s s! | ] } | j | j f Vq d S( N( RS R5 ( RT RU ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pys <genexpr># s N( R� R RX t querysimpleR) R\ R_ RZ R[ Rf RY RS R` R^ R7 R ( R! Rg Rh RV Rl Rm ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt sharingBindRecords s % c C s' | j � r | j | � S| j � Sd S( s� The user that owns this collection is being migrated to another pod. We need to switch over the sharing details to point to the new external user. N( R� t migrateSharedByRecordst migrateSharedToRecords( R! R8 ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt migrateBindRecords' s c c s3 | j � V} | j | � V} | d k rc | j | j � | t | d � rV | j � n d � V} n t } | j j | j i | j � | j 6� V} x� | D]~ } | j t k r� q� n | j j | j t | | j � � V} | j � r t } | j i | j � | j 6� Vq� | j � Vq� W| s/| j � Vn d S( sx The user that owns this collection is being migrated to another pod. We need to switch over the sharing details to point to the new external user. For sharees hosted on this pod, we update their bind record to point to a new external home/calendar for the sharer. For sharees hosted on other pods, we simply remove their bind entries. R� N( t externalHomeR/ R R0 RP RO R� R� RX R R) R\ R_ R7 R t homeWithResourceIDR+ RZ R[ t normalR, Rb t deletet remove( R! R8 RU t calendart remainingRg Rh RE ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR 1 s( () % c c s� | j j | j i | j � j � | j 6| j � | j 6� V} t | � d k r� | j � j � r� | j � V} | d j i | j � | j 6� Vq� | d j � V| j � V} | j � V} t | � d k r� | j � Vq� n t d � � d S( s� The user that owns this collection is being migrated to another pod. We need to switch over the sharing details to point to the new external user. i i s- We must have a bind record for this calendar.N( RX R R) R� R\ R[ R_ RK R; R R Rb R R< RJ R t AssertionError( R! Rg RU R RR ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR Z s c C s4 | j � } | j j | j | j � d t d t �S( s Create and return an L{CommonHome} for the user being migrated. Note that when called, the user directory record may still indicate that they are hosted on this pod, so we have to forcibly create a home for the external user. R& R' ( R� R) R* R+ R2 R R, ( R! t currentHome( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR � s c c sz | j � V| j | _ | j } | j i t d � | j 6� j | j d | j d | j d | j � j �V| j � Vd S( Nt revisionRS Ry ( t syncTokent _syncTokenRevisiont _bindRevisionR{ R� R t BIND_REVISIONR� R) R� R� R� ( R! R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c C s d S( s� The sharing resource type. Needs to be overridden by each type of resource that can be shared. @return: an identifier for the type of the share. @rtype: C{str} R� ( ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c C s t t � � S( sQ Name used when creating a new share. By default this is a UUID. ( Rc R ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c C s | j t k S( s* @see: L{ICalendar.owned} ( R� R ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c C s | j � o | j d k S( s� For an owned collection indicate whether it is shared. @return: C{True} if shared, C{False} otherwise @rtype: C{bool} t shared( R� R� ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt isSharedByOwner� s c c s� | j � s t d � � | r$ d n d } | j | k rF t d � n | | _ | j } t i | j | j 6d | j t d � k j | j t d � k � �j | j d | j d | j � j �V| j � V| j � Vd S( s� Set an owned collection to shared or unshared state. Technically this is not useful as "shared" really means it has invitees, but the current sharing spec supports a notion of a shared collection that has not yet had invitees added. For the time being we will support that option by using a new MESSAGE value to indicate an owned collection that is "shared". @param shared: whether or not the owned collection is "shared" @type shared: C{bool} s/ Cannot change share mode on a shared collectionR R� RS Ry N( R� R R R� R R{ R R� R} R R] R| R� R) R� R� R� R� ( R! R t newMessageR� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s # c C s | j t k S( sg Is this a "direct" share? @return: a boolean indicating whether it's direct. ( R� R ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyRA � s c C s | j t k S( sl Is this an "indirect" share? @return: a boolean indicating whether it's indirect. ( R� R ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt indirect� s c C s | j � S( s- @see: L{ICalendar.shareUID} ( RP ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR" � s c C s | j S( s. @see: L{ICalendar.shareMode} ( R� ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c C s | S( sH Get the effective share mode without a calendar object ( ( R! R7 t viewerUIDt txn( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _effectiveShareMode� s c C s | j S( s. @see: L{ICalendar.shareMode} ( R� ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s c C s? | j � } | j � d k r; | j � j � d | } n | S( s� This is a path like name for the resource within the home being shared. For object resource shares this will be a combination of the L{CommonHomeChild} name and the L{CommonObjecrResource} name. Otherwise it is just the L{CommonHomeChild} name. This is needed to expose a value to the app-layer such that it can construct a URI for the actual WebDAV resource being shared. t groupt /( RP R� t parentCollection( R! RP ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR( s c C s | j S( s0 @see: L{ICalendar.shareStatus} ( R� ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� s c C s | j S( s, @see: L{ICalendar.bindUID} ( R� ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR8 s c C s | j t k S( s0 @see: L{ICalendar.shareStatus} ( R� R ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt accepted s c C s | j S( s1 @see: L{ICalendar.shareMessage} ( R� ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� s c C s i S( s Get a dictionary of property name/values (as strings) for properties that are shadowable and need to be copied to a sharee's collection when an external (cross-pod) share is created. Sub-classes should override to expose the properties they care about. ( ( R! ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� $ s c C s d S( s� Copy a set of shadowable properties (as name/value strings) onto this shared resource when a cross-pod invite is processed. Sub-classes should override to expose the properties they care about. N( ( R! t props( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR4 , s c C s | j j | j j f S( s� Return a list of column name for retrieval of metadata. This allows different child classes to have their own type specific data, but still make use of the common base logic. ( t _homeChildMetaDataSchemat CREATEDt MODIFIED( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt metadataColumns4 s c C s d S( s� Return a list of attribute names for retrieval of metadata. This allows different child classes to have their own type specific data, but still make use of the common base logic. t _createdt _modified( R. R/ ( ( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt metadataAttributesC s c C sL | j j | j j | j j | j j | j j | j j | j j | j j f S( s� Return a list of column names for retrieval during creation. This allows different child classes to have their own type specific data, but still make use of the common base logic. ( R{ R| R} R~ R R� R R� R� ( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� R s c C s d S( s� Return a list of column names for retrieval during creation. This allows different child classes to have their own type specific data, but still make use of the common base logic. t _homeResourceIDR� R� R� R� R R� R� ( R1 R� R� R� R� R R� R� ( ( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt bindAttributese s i c C s d S( s� Return a list of column names for retrieval during creation. This allows different child classes to have their own type specific data, but still make use of the common base logic. ( ( ( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� z s c C s d S( s� Return a list of attribute names for retrieval of during creation. This allows different child classes to have their own type specific data, but still make use of the common base logic. ( ( ( R� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt additionalBindAttributes� s c C s� | j } | j } | j } | j � | j � | j � } t | d | j | | j | j k d � j | | j | j k d � d | j t d � k j | j t k � �S( NR� s left outerR� Ry ( R{ t _homeChildSchemaR* R� R� R- R R� R} R| R R] R� R ( R� R� R� t childMetaDataR� ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt _childrenAndMetadataForHomeID� s c c s� | j j } | d k r� | j | j | j | j � � V| j | j | j | j j | j � � V| j | j | j | j j | j � � V| j | j | j | j j | j � � Vn d S( N( R) t _queryCacherR t invalidateAfterCommitt keyForHomeChildMetaDataR� t keyForObjectWithNameR� R� t keyForObjectWithResourceIDt keyForObjectWithBindUIDR� ( R! t queryCacher( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyR� � s ))N(P Rp Rq Rr R R� t classmethodR� R� R� R� R� R� R� R� R� R R R3 R1 R> R R% RB R� R? R� R t defaultR� R� R� R� R� R� R� R� R< R$ R� R� R� R� R� R� R� R RJ R R R R R R� R� R� R� R R� RA R! R" R� R$ R� R( R� R8 R( R� R� R4 R- R0 R� R2 t bindColumnCountR� R3 R6 R� ( ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyRx s� " D> ! )) N(. t collectionsR t pycalendar.datetimeR t twext.enterprise.dal.syntaxR R R R R t twext.python.clspropR t twext.python.logR t twisted.internet.deferR R R t txdav.base.propertystore.baseR t! txdav.common.datastore.sql_tablesR R R R R R R R R R t txdav.common.icommondatastoreR R R t txdav.idavR t txdav.xmlR t uuidR RL t objectR Rs Rx ( ( ( s5 /opt/cpanel-ccs/txdav/common/datastore/sql_sharing.pyt <module> s" ( F �$