OwlCyberSecurity - MANAGER
Edit File: notifications.pyc
� �t�ac @ s d Z d d g Z d d l m Z d d l m Z d d l m Z d d l m Z m Z m Z m Z d d l m Z m Z d d l m Z m Z d d l m Z d d l Z d d l Z e � Z d e f d � � YZ d e e f d � � YZ d e f d � � YZ d e f d � � YZ d S( s( Implements notification functionality. t NotificationResourcet NotificationCollectionResourcei����( t Logger( t responsecode( t element( t succeedt inlineCallbackst returnValuet maybeDeferred( t ReadOnlyNoCopyResourceMixInt CalDAVResource( t AbstractSQLDatabaset db_prefix( t SyncTokenValidExceptionNc B sJ e Z d Z d � Z d � Z d � Z d � Z d � Z e d � � Z RS( s7 An xml resource in a Notification collection. c C s | | _ t j | � d S( N( t _parentR t __init__( t selft parent( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR 1 s c C s | j j � S( N( R t principalCollections( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR 5 s c C s t S( N( t False( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt isCollection8 s c C s t � d S( N( t NotImplementedError( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt resourceName; s c C s t j S( N( R t FORBIDDEN( R t request( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt http_PUT> s c c sS t t | � j | � V} | t j k rE | j j | | j � � Vn t | � d S( N( t superR t http_DELETER t NO_CONTENTR t removedNotifictionMessageR R ( R R t response( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR A s ( t __name__t __module__t __doc__R R R R R R R ( ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR , s c B sq e Z d � Z d � Z d � Z d e d � Z d � Z e d � � Z e d � � Z e d � � Z d � Z RS( c C s( t | d � s! t | � | _ n | j S( Nt _notificationsDB( t hasattrt NotificationsDatabaseR" ( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt notificationsDBL s c C s t S( N( t True( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR R s c C s t j j S( N( t davxmlt ResourceTypet notification( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt resourceTypeU s c C s t g � S( N( R ( R R t componentTypet returnLatestVersion( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt getNotifictionMessagesX s c C s t | j � j | � S( N( R R% t recordForUID( R R t uid( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt getNotifictionMessageByUID[ s c c s4 | j � j | � V} | r0 | j | | � Vn d S( N( R% R. t deleteNotification( R R R/ t record( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt deleteNotifictionMessageByUID^ s c c s> | j � j | � V} | r0 | j | | � Vn t d � d S( N( R% t recordForNameR1 R t None( R R t rnameR2 ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt deleteNotifictionMessageByNamef s c c s/ | j | | j � V| j � j | j � Vd S( N( t _deleteNotificationt nameR% t removeRecordForUIDR/ ( R R R2 ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR1 p s c C s t | j � j | � S( N( R R% t removeRecordForName( R R R6 ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR u s N( R R R% R R* R5 R& R- R0 R R3 R7 R1 R ( ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR J s t NotificationRecordc B s e Z d � Z RS( c C s= | | _ | | _ t | t � r' | n t j | � | _ d S( N( R/ R9 t isinstancet dictt jsont loadst notificationtype( R R/ R9 RA ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR { s ( R R R ( ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR< y s R$ c B s� e Z e � Z e d Z d Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � Z d � Z d � Z d � Z d � Z d � Z RS( t notificationst 1c C sy | | _ t j j | j j j t j � } t t | � j | t d t �| j j j | j � | j j j | j � d S( sp @param resource: the L{CalDAVResource} resource for the notifications collection.) t autocommitN( t resourcet ost patht joint fpR$ t db_basenameR R R& t _txnt postCommitt _db_closet postAbort( R RE t db_filename( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR � s ! c C sA | j d � } g | d k r$ | n d D] } | j | � ^ q( S( Ns select * from NOTIFICATIONS( ( t _db_executeR5 t _makeRecord( R t recordst row( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt allRecords� s c C s- | j d | � } | r) | j | d � Sd S( Ns* select * from NOTIFICATIONS where UID = :1i ( RP RQ R5 ( R R/ RS ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR. � s c C sQ | j d | j | j t j | j � � | j d | j | j d t � d � d S( Nsc insert or replace into NOTIFICATIONS (UID, NAME, TYPE) values (:1, :2, :3) st insert or replace into REVISIONS (NAME, REVISION, DELETED) values (:1, :2, :3) t fastt N( RP R/ R9 R? t dumpsRA t bumpRevisionR& ( R R2 ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt addOrUpdateRecord� s "c C s# | j | � } | j | j � d S( N( R. R; R9 ( R R/ R2 ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR: � s c C s6 | j d | � | j d | j d t � d | � d S( Ns) delete from NOTIFICATIONS where NAME = :1sf update REVISIONS SET REVISION = :1, DELETED = :2 where NAME = :3 RU t Y( RP RX R& ( R R6 ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR; � s c C s� g | j d | � D]! \ } } | j d � | f ^ q } | j d d � � g } g } xU | D]M \ } } | r� | d k r� | r� | j | � q� q� | j | � q` t � q` W| | f S( Ns7 select NAME, DELETED from REVISIONS where REVISION > :1s utf-8t keyc S s | d S( Ni ( ( t x( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt <lambda>� t RZ ( RP t encodet sortt appendR ( R t revisionR9 t deletedt resultst changedt wasdeleted( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt whatchanged� s : c C s | j d � S( Ns& select REVISION from REVISION_SEQUENCE( t _db_value_for_sql( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt lastRevision� s c C s$ | j d � | j � | j d � S( NsN update REVISION_SEQUENCE set REVISION = REVISION + 1 s@ select REVISION from REVISION_SEQUENCE ( RP t _db_commitRh ( R RU ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyRX � s c C s t j S( sE @return: the schema version assigned to this index. ( R$ t schema_version( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt _db_version� s c C s t j S( sF @return: the collection type assigned to this index. ( R$ t db_type( R ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt _db_type� s c C sR | j d � | j d � | j d � | j d � | j d � | j d � d S( sr Initialise the underlying database tables. @param q: a database cursor to use. s� create table NOTIFICATIONS ( UID text unique, NAME text unique, TYPE text ) sA create index UID on NOTIFICATIONS (UID) sp create table REVISION_SEQUENCE ( REVISION integer ) sM insert into REVISION_SEQUENCE (REVISION) values (0) s� create table REVISIONS ( NAME text unique, REVISION integer, DELETED text(1) ) sG create index REVISION on REVISIONS (REVISION) N( t execute( R t q( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt _db_init_data_tables� s c C s d S( sC Upgrade the data from an older version of the DB. N( ( R Rp t old_version( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt _db_upgrade_data_tables) s c C s8 t g | D]' } t | t � r+ t | � n | ^ q � S( N( R< R= t unicodet str( R RS t item( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyRQ 1 s ( R R R t logR RJ Rk Rm R RT R. RY R: R; Rg Ri R RX Rl Rn Rq Rs RQ ( ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyR$ � s$ < ( R! t __all__t twext.python.logR t txweb2R t txdav.xmlR R' t twisted.internet.deferR R R R t twistedcaldav.resourceR R t twistedcaldav.sqlR R t txdav.common.icommondatastoreR R? RF Rw R R t objectR< R$ ( ( ( s. /opt/cpanel-ccs/twistedcaldav/notifications.pyt <module> s " /