ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
calendarserver
/
push
/
Filename :
notifier.pyc
back
Copy
� �t�ac @ sJ 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 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 Z d d l m Z e � Z d e e e j � f d � � YZ d e f d � � YZ d e f d � � YZ d � Z! d e f d � � YZ" d S( s, Notification framework for Calendar Server i����( t fromTable( t Deletet Selectt Parameter( t JobItem( t WorkItemt WORK_PRIORITY_HIGHt WORK_WEIGHT_1( t Logger( t inlineCallbacks( t schema( t IStoreNotifierFactoryt IStoreNotifier( t implementsN( t PushPriorityt PushNotificationWorkc B s2 e Z e d � � Z e Z e Z e d � � Z RS( c C s | j j | j k S( N( t tablet PUSH_IDt pushID( t self( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt <lambda>, t c c se t | j j | j j | j j g d | j d | j j | j k �j | j � V} | j } | rt | � \ } } } t | | j f � } t d | j d | j j j t d t | � � � � j | j d | �Vt d t j d t j j t d t | � � � � j | j d | �Vn | j j } | d k rat j | � } | j | j | j d | �Vn d S( Nt Fromt Wheret workIDst jobIDst priority( R R t WORK_IDt JOB_IDt PUSH_PRIORITYR R t ont transactiont pushPriorityt zipt maxR t InR t lenR t jobIDt _pushDistributort NoneR t lookupByValuet enqueue( R t resultst maxPriorityR R t prioritiest pushDistributorR ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt doWork0 s( !! ' $ ( t __name__t __module__t propertyt groupR t default_priorityR t default_weightR R. ( ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyR * s t Notifierc B sc e Z d Z e � Z e e � d � Z d � Z d � Z e e j d � � Z d � Z d � Z RS( sY Provides a hook for sending change notifications to the L{NotifierFactory}. c C s | | _ | | _ t | _ d S( N( t _notifierFactoryt _storeObjectt Truet _notify( R t notifierFactoryt storeObject( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt __init__e s c C s. | j j d d | j d d �t | _ d S( Ns enableNotify: {id}t idt defaulti ( t logt debugt _idsR8 R9 ( R t arg( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt enableNotifyj s !c C s. | j j d d | j d d �t | _ d S( Ns disableNotify: {id}R= R> i ( R? R@ RA t FalseR9 ( R ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt disableNotifyn s !c c s� | j j � f } t | j d � r= | | j j � f 7} n x� | D]� \ } } | j r� | j j d d | j d | d | d | j �| j j | | | d | �VqD | j j d d | j d | d | �qD Wd S( sr Send the notification. For a home object we just push using the home id. For a home child we push both the owner home id and the owned home child id. @param txn: The transaction to create the work item with @type txn: L{CommonStoreTransaction} @param priority: the priority level @type priority: L{PushPriority} t parentNotifierIDsB Notifications are enabled: {obj} {prefix}/{id} priority={priority}t objt prefixR= R s/ Skipping notification for: %{obj} {prefix}/{id}N( R7 t notifierIDt hasattrRF R9 R? R@ t valueR6 t send( R t txnR t idsRH R= ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt notifyr s c C s | j | j | � S( N( t __class__R6 ( R R; ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt clone� s c C s t | j d � rW | j j � r? | j j � j � \ } } ql | j j � \ } } n | j j � \ } } | j j | | � S( s� The pushkey is the notifier id of the home collection for home and owned home child objects. For a shared home child, the push key is the notifier if of the owner's home child. t ownerHome( RJ R7 t ownedRR RI R6 t pushKeyForId( R RH R= ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt nodeName� s ( R/ R0 t __doc__R R? R R R< RC RE R R t highRO RQ RU ( ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyR5 \ s ! t NotifierFactoryc B sT e Z d Z e � Z e e � d d � Z e e j d � � Z d � Z d � Z RS( sv Notifier Factory Creates Notifier instances and forwards notifications from them to the work queue. c C sG d | _ | | _ | | _ | d k r: d d l m } n | | _ d S( Ni����( t reactor( R' t storet hostnamet coalesceSecondst twisted.internetRY ( R R[ R\ RY ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyR< � s c c sO | j t d | j | | � d t j j � t j d | j � d | j �Vd S( sT Enqueue a push notification work item on the provided transaction. R t notBeforet secondsR N( R) R RT t datetimet utcnowt timedeltaR\ RK ( R RH R= RM R ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyRL � s "c C s t | | � S( N( R5 ( R R; ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt newNotifier� s c C s d | | j | f } | d S( Ns /%s/%s/%s/i� ( R[ ( R RH R= t key( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyRT � s N( R/ R0 RV R R? R R R' R< R R RW RL Rc RT ( ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyRX � s c C s� y | \ } } Wn t k r$ d SX| j j j } | j r� i } | | d | d <| j sg | j r� d | j | j | j f } n d | j | j | j f } | | d <| j | d <| j | d <| Sd S( sN Returns the Apple push notification settings specific to the pushKey t Topict APSBundleIDs https://%s:%s/%ss http://%s:%s/%st SubscriptionURLt" SubscriptionRefreshIntervalSecondst APSEnvironmentN( t ValueErrorR' t Notificationst Servicest APNSt Enabledt EnableSSLt BehindTLSProxyt ServerHostNamet SSLPortRg t HTTPPortRh t Environment( RI t configt protocolt ignoredt applePushSettingst settingst url( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt getPubSubAPSConfiguration� s( t PushDistributorc B s, e Z d Z d � Z e e j d � � Z RS( sH Distributes notifications to the protocol-specific subservices c C s | | _ d S( st @param observers: the list of observers to distribute pushKeys to @type observers: C{list} N( t observers( R R} ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyR< � s c c s5 x. | j D]# } | j | | d d d | �Vq Wd S( sh Pass along enqueued pushKey to any observers @param transaction: a transaction to use, if needed @type transaction: L{CommonStoreTransaction} @param pushKey: the push key to distribute to the observers @type pushKey: C{str} @param priority: the priority level @type priority: L{PushPriority} t dataChangedTimestampR N( R} R) R' ( R R t pushKeyR t observer( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyR) � s ( R/ R0 RV R< R R RW R) ( ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyR| � s (# RV t twext.enterprise.dal.recordR t twext.enterprise.dal.syntaxR R R t twext.enterprise.jobs.jobitemR t twext.enterprise.jobs.workitemR R R t twext.python.logR t twisted.internet.deferR t! txdav.common.datastore.sql_tablesR t txdav.idavR R t zope.interface.declarationsR R` t calendarserver.push.ipushR R? t PUSH_NOTIFICATION_WORKR t objectR5 RX R{ R| ( ( ( s/ /opt/cpanel-ccs/calendarserver/push/notifier.pyt <module> s" "2J(