ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
twistedcaldav
/
Filename :
controlapi.pyc
back
Copy
� �t�ac @ s� d Z d g 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 d d l m Z d d l m Z 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! m" Z" 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. d d l/ m0 Z0 d d l1 m2 Z2 m3 Z3 m4 Z4 d d l1 m5 Z5 d d l6 m7 Z7 d d l8 Z8 d d l9 Z9 d d l: Z: d d l; Z; e � Z< d e e e f d � � YZ= d S( s Control API resource. This provides an HTTP API to allow an admin to trigger various "internal" actions on the server. The intent of this is to primarily support automated testing tools that may need to alter server behavior during tests via an HTTP-only API. t ControlAPIResourcei����( t recordForPrincipalID( t JobItem( t WORK_PRIORITY_HIGHt WORK_WEIGHT_1( t Logger( t reactor( t succeedt inlineCallbackst returnValue( t config( t DAVResourcet DAVResourceWithoutChildrenMixin( t ReadOnlyNoCopyResourceMixIn( t ScheduleOrganizerWorkt ScheduleOrganizerSendWorkt ScheduleReplyWorkt ScheduleRefreshWorkt ScheduleAutoReplyWork( t TestWork( t GroupCacherPollingWorkt GroupRefreshWorkt GroupAttendeeReconciliationWorkt GroupDelegateChangesWorkt GroupShareeReconciliationWork( t element( t responsecode( t http_PROPFIND( t NonePropertyStore( t allDataFromStream( t HTTPErrort JSONResponset StatusResponse( t Response( t MimeTypeNc B s e Z d Z d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e Z d � Z d d � Z d � 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 RS( sp Resource used to execute admin commands. Extends L{DAVResource} to provide service functionality. c C s2 t j | d | �| | _ | | _ | | _ d S( sA @param parent: the parent resource of this one. t principalCollectionsN( R t __init__t parentt _storet _directory( t selft roott directoryt storeR# ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyR$ K s c C s( t | d � s! t | � | _ n | j S( Nt _dead_properties( t hasattrR R, ( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt deadPropertiesV s c C s t d � S( N( R t None( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt etag[ s c C s d S( N( R/ ( R( t request( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt checkPreconditions^ s c C s t t j t j � � S( N( R t davxmlt ACLR t AdminACEs( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt defaultAccessControlLista s c C s t j d � S( Ns text/html; charset=utf-8( R" t fromString( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt contentTyped s c C s d S( N( R/ ( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt resourceTypeg s c C s t S( N( t False( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt isCollectionj s c C s t S( N( R: ( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt isCalendarCollectionm s c C s t S( N( R: ( R( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt isPseudoCalendarCollectionp s c C s8 d } t d i | � } | j j d t d d � � | S( Nsn <html> <head> <title>Control API Resource</title> </head> <body> <h1>Control API Resource.</h1> </body </html>i� s content-typet textt html( R! t headerst setHeaderR" ( R( R1 t outputt response( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt renders s c C s | j | � S( s4 GET just returns HTML description. ( RD ( R( R1 ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt http_GET� s c C s9 | d k r i } n | | d <| | d <t t j | � S( Nt statust description( R/ R R t OK( R( RF RG t result( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt _ok� s c C s* t t t j i | d 6| d 6� � � d S( NRF RG ( R R R t BAD_REQUEST( R( RF RG ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt _error� s c C s� g } xy t | d d � �D]b } y | j } Wn t k rH g } n X| j i | j j d 6| j d 6| j d 6| d 6� q W| S( Nt keyc S s | j S( N( t uid( t r( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt <lambda>� t t typet cnRN t sn( t sortedt shortNamest AttributeErrort appendt recordTypet namet displayNameRN ( R( t recordst resultst recordRV ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt _recordsToJSON� s c c s� | j | t j � f � V| j j d � } d j | j | j � d k r� | j j d d | �t t t j d j | � � � � n t | j � V} y t j | � } WnY t t f k r} | j j d d | d | �t t t j d j | | � � � � n Xy | d } Wn! t k r4| j d d � n Xd j | � } t | | � so| j d d j | � � n t | | � | � V} t | � d S( sA POST method with JSON body is used for control. s content-types {}/{}s application/jsons' MIME type {mime} not allowed in requestt mimes# MIME type {} not allowed in requests) Invalid JSON data in request: {ex} {body}t ext bodys# Invalid JSON data in request: {} {}t actiont errors' No 'action' member in root JSON object.s action_{}s! The action '{}' is not supported.N( t authorizeR3 t ReadR@ t getHeadert formatt mediaTypet mediaSubtypet logRd R R R RK R t streamt jsont loadst ValueErrort TypeErrort KeyErrorRL R- t getattrR ( R( R1 R8 Rb t jt eRc t methodRI ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt http_POST� s( $ ( c c s� y | d } Wn! t k r1 | j d d � n Xy t | j | � V} Wn t k rb d } n X| d k r� | j d d j | � � n | j � V} t | j d d i | d 6| j | � d 6� � d S( Nt groupRd s& No 'group' member in root JSON object.s' No group with id '{}' in the directory.t oks Group membershipt members( Rq RL R R' Ro R/ Rh Ry R RJ R_ ( R( Rs t grpIDR^ Ry ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_listgroupmembers� s c c s� y | d } Wn! t k r1 | j d d � n Xy | d } Wn! t k rc | j d d � n Xy t | j | � V} Wn t k r� d } n X| d k r� | j d d j | � � n | j � V} t g | D] } | j ^ q� � } t � } t � } t � } xi | D]a } t | j | � V} | d k rC| j | � q| j | k rb| j | � q| j | � qW| r�| j | � V| j j | g d t �Vn t | j d d i | d 6| j | � d 6| j | � d 6t | � d 6� � d S( NRw Rd s& No 'group' member in root JSON object.Ry s( No 'members' member in root JSON object.s' No group with id '{}' in the directory.t createRx s Added group memberst addedt existst invalid( Rq RL R R' Ro R/ Rh Ry t setRN t addt addMemberst servicet updateRecordsR: R RJ R_ RU ( R( Rs Rz t memberIDsR^ t existingMemberst membert existingMemberUIDsR� R R~ t memberIDt memberRecord( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_addgroupmembers� sD " c c s� y | d } Wn! t k r1 | j d d � n Xy | d } Wn! t k rc | j d d � n Xy t | j | � V} Wn t k r� d } n X| d k r� | j d d j | � � n | j � V} t g | D] } | j ^ q� � } t � } t � } t � } xi | D]a } t | j | � V} | d k rC| j | � q| j | k rb| j | � q| j | � qW| r�| j | � | j j | g d t �Vn t | j d d i | d 6| j | � d 6| j | � d 6t | � d 6� � d S( NRw Rd s& No 'group' member in root JSON object.Ry s( No 'members' member in root JSON object.s' No group with id '{}' in the directory.R| Rx s Removed group memberst removedt missingR ( Rq RL R R' Ro R/ Rh Ry R� RN R� t removeMembersR� R� R: R RJ R_ RU ( R( Rs Rz R� R^ R� R� R� t removeR R� R� R� ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_removegroupmembers sD " c c s� | j j d d � } t j t j � t j � t j | d d t �V} | j } | j � Vd | k r� | d r� t j | j j t d | � Vt j | j j t d t t t t f � Vn t | j d d � � d S( Nt labels' ControlAPIResource.action_refreshgroupsi t forcet waitg N@Rx s Group refresh scheduled( R& t newTransactiont ost killt getppidt signalt SIGUSR1R t reschedulet Truet jobIDt commitR t waitJobDoneR t waitWorkDoneR R R R R RJ ( R( Rs t txnt workR� ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_refreshgroups< s c c sF t j | j j t d t t t t t f � Vt | j d d � � d S( s@ Wait for all schedule queue items to complete. g ^@Rx s Scheduling doneN( R R� R& R� R R R R R R R RJ ( R( Rs ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_schedulingdoneL s c c s? y | d } Wn t k r' d } n Xy | d } Wn t k rO t } n Xy | d } Wn t k rw t } n Xy | d } Wn t k r� d } n Xy | d } Wn t k r� d } n Xt j � } xN t | � D]@ } t | t j � | d � } t j | j | | | | � Vq� Wt | j d d � � d S( s@ Wait for all schedule queue items to complete. t wheni t priorityt weightt delayt jobsi Rx s Test work scheduledN( Rq R R t timet ranget maxR t scheduleR& R RJ ( R( Rs R� R� R� R� R� t start_timet _t effective_when( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_testworkW s< c c s� d d l m } d d l m } | j j d d � } | | d � V| j � Vt j | j j t d | f � Vt | j d d � � d S( s@ Wait for all schedule queue items to complete. i����( t _triggerRevisionCleanup( t RevisionCleanupWorkR� s) ControlAPIResource.action_revisioncleanupi< g ^@Rx s RevisionCleanupWork doneN( t, txdav.common.datastore.work.revision_cleanupR� R� R& R� R� R R� R R RJ ( R( Rs R� R� R� ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt action_revisioncleanup s ( N( t __name__t __module__t __doc__R$ R. R0 R2 R6 R8 R9 R; R< R= RD R RE R/ RJ RL R_ R Rv R{ R� R� R� R� R� R� ( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyR D s2 $++ ((> R� t __all__t calendarserver.tools.utilR t twext.enterprise.jobs.jobitemR t twext.enterprise.jobs.workitemR R t twext.python.logR t twisted.internetR t twisted.internet.deferR R R t twistedcaldav.configR t twistedcaldav.extensionsR R t twistedcaldav.resourceR t& txdav.caldav.datastore.scheduling.workR R R R R t% txdav.common.datastore.work.load_workR t txdav.who.groupsR R R R R t txdav.xmlR R3 t txweb2R t txweb2.dav.method.propfindR t txweb2.dav.nonepropsR t txweb2.dav.utilR t txweb2.httpR R R R! t txweb2.http_headersR" Rm R� R� R� Rk R ( ( ( s+ /opt/cpanel-ccs/twistedcaldav/controlapi.pyt <module> s6 ((