o i,@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 \C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\twisted/spread/publish.py__init__s zPublishable.__init__cCst|_dS)z=Set the timestamp to current and (TODO) update all observers.N)time timestampr r r r rzPublishable.republishcCs ||Sz (internal)N)getStateToPublishForr perspectiver r r view_getStateToPublishs z"Publishable.view_getStateToPublishcCs|S)z:Implement me to special-case your state for a perspective.N)getStateToPublishrr r r r#sz Publishable.getStateToPublishForcCstd|j)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishForN)NotImplementedError __class__rr r r r'rzPublishable.getStateToPublishcCs:|r |j}|j}nd}d}t|||j|||jdS)z6Get all necessary metadata to keep a clientside cache.None)remoterrservicerN)ZperspectiveNameZ getServiceZ serviceNamerZ ViewPointrr)r rZobserverZpnameZsnamer r r getStateToCacheAndObserveFor+s  z(Publishable.getStateToCacheAndObserveForN) __name__ __module__ __qualname____doc__r rrrrrr r r r rs rc@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.getFileNamecCs|j|g|_zt|d }|}Wdn1s wYWn ty1d}Ynwtt |}|j |j k}|rM| |jd|_ dS|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__cCs~|j|d|_|jD]}||q g|_|t|d}|t t |WddS1s8wYdS)Nr(wb) r)r*r8r+ activatedr,r&writerencoder)r ZnewStatelistenerr4r r r r0gs   "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 ||dS|j|dS)zZExternally register for notification when this publishable has received all relevant data.N)r8r+append)r callbackr r r callWhenActivatedws z!RemotePublished.callWhenActivatedN)r") rrrr r8r1r&r7r;r0r=rCr 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 callbackArgsN)rZDeferredr2 _pubReadyZerrback)dd2r r r whenReadys rGcCs||jdSr)rCrB)resultrFr r r rDsrD)r r Ztwisted.internetrZtwisted.spreadrrrZ CacheablerZ RemoteCacher!rGrDr r r r s )B