a )(b,@sddZddlZddlmZddlmZmZmZGdddejZ Gdddej Z d d Z d d Z dS) z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. N)defer)bananaflavorsjellyc@s@eZdZdZddZddZddZdd Zd d Zd d Z dS) Publishablez6An object whose cached state persists across sessions.cCs|||_dS)N) republish publishedID)selfrr 5lib/python3.9/site-packages/twisted/spread/publish.py__init__szPublishable.__init__cCst|_dS)z=Set the timestamp to current and (TODO) update all observers.N)time timestampr r r r rszPublishable.republishcCs ||S) (internal))getStateToPublishForr perspectiver r r view_getStateToPublishsz"Publishable.view_getStateToPublishcCs|S)z:Implement me to special-case your state for a perspective.)getStateToPublishrr r r r#sz Publishable.getStateToPublishForcCstd|jdS)zBImplement 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)z6Get all necessary metadata to keep a clientside cache.None)remoterrservicer)ZperspectiveNameZ getServiceZ serviceNamerZ ViewPointrr)r rZobserverZpnameZsnamer r r getStateToCacheAndObserveFor+s  z(Publishable.getStateToCacheAndObserveForN) __name__ __module__ __qualname____doc__r rrrrrr r r r rsrc@sJeZdZdZdZdZdddZddZdd Zd d Z d d Z ddZ dS)RemotePublishedz6The local representation of remote Publishable object.rpubcCsd|j|jt|j|S)Nz {}-{}-{}.{})formatrrstrr)r Zextr r r getFileNameCs zRemotePublished.getFileNamecCs|j|g|_z:t|d}|}Wdn1s@0YWntybd}Yn0tt |}|j |j k}|r| |jd|_ n|jd|j dS)Nrbrr)__dict__update_activationListenersopenr$readOSErrorrZunjellyrdecoder _cbGotUpdate_wasCleanWhenLoadedrZ callRemote addCallbacks)r statedataFiledataZrecentZnewselfr r r setCopyableStateKs *    z RemotePublished.setCopyableStatecCs,|j}|d=|d=|d=|d=|d=|S)NZbrokerrZluidr) isActivated)r'copy)r otherr r r __getstate__\s zRemotePublished.__getstate__cCs||j|d|_|jD] }||qg|_|t|d&}|t t |Wdn1sn0YdS)Nr&wb) r'r(r5r) activatedr*r$writerencoder)r ZnewStateZlistenerr2r r r r.gs   zRemotePublished._cbGotUpdatecCsdS)znImplement this method if you want to be notified when your publishable subclass is activated. Nr rr r r r:rszRemotePublished.activatedcCs |jr||n |j|dS)zZExternally register for notification when this publishable has received all relevant data.N)r5r)append)r callbackr r r callWhenActivatedws z!RemotePublished.callWhenActivatedN)r!) rrrrr5r/r$r4r8r.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)rZDeferredr0 _pubReadyZerrback)dd2r r r whenReadys rCcCs||jdS)rN)r?r>)resultrBr r r r@sr@)rr Ztwisted.internetrZtwisted.spreadrrrZ CacheablerZ RemoteCacher rCr@r r r r s  )B