U Tg,@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 :/tmp/pip-unpacked-wheel-1_7di8ic/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 extr r r getFileNameCs zRemotePublished.getFileNamec Cs|j|g|_z&t|d}|}W5QRXWntk rPd}YnXtt |}|j |j k}|r| |jd|_ n|jd|j dS)Nrbrr)__dict__update_activationListenersopenr%readOSErrorrZunjellyrdecoder _cbGotUpdate_wasCleanWhenLoadedrZ callRemote addCallbacks)r statedataFiledataZrecentnewselfr 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__c Csh|j|d|_|jD] }||qg|_|t|d}|t t |W5QRXdS)Nr'wb) r(r)r7r* activatedr+r%writerencoder)r ZnewStateZlistenerr3r 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)r7r*append)r callbackr r r callWhenActivatedws z!RemotePublished.callWhenActivatedN)r!) rrrrr7r0r%r6r:r/r<rAr 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 whenReadys rEcCs||jdS)rN)rAr@)resultrDr r r rBsrB)rr Ztwisted.internetrZtwisted.spreadrrrZ CacheablerZ RemoteCacher rErBr r r r s  )B