U  W[@stdZddlmZmZddlZddlmZddlmZm Z m Z Gddde j Z Gdd d e j Zd d Zd d ZdS)z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. )absolute_importdivisionN)defer)bananajellyflavorsc@s@eZdZdZddZddZddZdd Zd d Zd d Z dS) Publishablez;An object whose cached state persists across sessions. cCs|||_dS)N) republish publishedID)selfr r 8/usr/lib/python3/dist-packages/twisted/spread/publish.py__init__szPublishable.__init__cCst|_dS)zFSet the timestamp to current and (TODO) update all observers. N)time timestampr r r r r szPublishable.republishcCs ||S) (internal))getStateToPublishForr perspectiver r r view_getStateToPublish!sz"Publishable.view_getStateToPublishcCs|S)zCImplement me to special-case your state for a perspective. )getStateToPublishrr r r r%sz Publishable.getStateToPublishForcCstd|jdS)zKImplement me to return state to copy as part of the publish phase. z%s.getStateToPublishForN)NotImplementedError __class__rr r r r*szPublishable.getStateToPublishcCs:|r|j}|j}nd}d}t|||j|||jdS)z?Get all necessary metadata to keep a clientside cache. None)remoter rservicer)ZperspectiveNameZ getServiceZ serviceNamerZ ViewPointr r)r rZobserverZpnameZsnamer r r getStateToCacheAndObserveFor/s  z(Publishable.getStateToCacheAndObserveForN) __name__ __module__ __qualname____doc__rr rrrrr r r r rsrc@sJeZdZdZdZdZdddZddZdd Zd d Z d d Z ddZ dS)RemotePublishedz;The local representation of remote Publishable object. rpubcCsd|j|jt|j|fS)Nz %s-%s-%s.%s)rrstrr )r Zextr r r getFileNameDszRemotePublished.getFileNamec Cs|j|g|_z&t|d}|}W5QRXWntk rPd}YnXtt |}|j |j k}|r| |jd|_ n|jd|j dS)Nrbrr)__dict__update_activationListenersopenr%readIOErrorrZunjellyrdecoder _cbGotUpdate_wasCleanWhenLoadedrZ callRemote addCallbacks)r statedataFiledataZrecentZnewselfr r r setCopyableStateHs    z RemotePublished.setCopyableStatecCs,|j}|d=|d=|d=|d=|d=|S)NZbrokerrZluidr* isActivated)r(copy)r otherr r r __getstate__Ys zRemotePublished.__getstate__c Csh|j|d|_|jD] }||qg|_|t|d}|t t |W5QRXdS)Nr'wb) r(r)r6r* activatedr+r%writerencoder)r ZnewStateZlistenerr3r r r r/ds   zRemotePublished._cbGotUpdatecCsdS)znImplement this method if you want to be notified when your publishable subclass is activated. Nr rr r r r;pszRemotePublished.activatedcCs |jr||n |j|dS)zcExternally register for notification when this publishable has received all relevant data. N)r6r*append)r callbackr r r callWhenActivatedus z!RemotePublished.callWhenActivatedN)r#) rrr r!r6r0r%r5r9r/r;r@r r r r r"?s   r"cCs t}|jt|j|fd|S)aD Wrap a deferred returned from a pb method in another deferred that expects a RemotePublished as a result. This will allow you to wait until the result is really available. Idiomatic usage would look like:: publish.whenReady(serverObject.getMeAPublishable()).addCallback(lookAtThePublishable) )Z callbackArgs)rZDeferredr1 _pubReadyZerrback)dd2r r r whenReady}s  rDcCs||jdS)rN)r@r?)resultrCr r r rAsrA)r!Z __future__rrrZtwisted.internetrZtwisted.spreadrrrZ CacheablerZ RemoteCacher"rDrAr r r r s *>