\d,dZddlZddlmZddlmZmZmZGddejZ Gddej Z d Z d Z dS) z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. N)defer)bananaflavorsjellyc6eZdZdZdZdZdZdZdZdZ dS) Publishablez6An object whose cached state persists across sessions.c<|||_dS)N) republish publishedID)selfr s 6lib/python3.11/site-packages/twisted/spread/publish.py__init__zPublishable.__init__s  &c6tj|_dS)z=Set the timestamp to current and (TODO) update all observers.N)time timestampr s r r zPublishable.republishsrc,||S) (internal))getStateToPublishForr perspectives r view_getStateToPublishz"Publishable.view_getStateToPublishs((555rc*|S)z:Implement me to special-case your state for a perspective.)getStateToPublishrs r rz Publishable.getStateToPublishFor#s%%'''rc0td|jz)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)NotImplementedError __class__rs r rzPublishable.getStateToPublish's!";dn"LMMMrc|r!|j}|j}nd}d}tj|||j|||jdS)z6Get all necessary metadata to keep a clientside cache.None)remoter rservicer)perspectiveName getService serviceNamer ViewPointr r)r robserverpnamesnames r getStateToCacheAndObserveForz(Publishable.getStateToCacheAndObserveFor+sd  /E**,,8EEEE' T::+     rN) __name__ __module__ __qualname____doc__rr rrrr*rr rrsw@@'''%%%666(((NNN     rrc@eZdZdZdZdZd dZdZdZdZ dZ d Z d S) RemotePublishedz6The local representation of remote Publishable object.rpubcjd|j|jt|j|S)Nz {}-{}-{}.{})formatr"rstrr )r exts r getFileNamezRemotePublished.getFileNameCs6## L    ! !     rc&|j|g|_ t|d5}|}dddn #1swxYwYt jtj |}|j |j k}n#t$rd}YnwxYw|r#| |jd|_ dS|jd|j dS)Nrbrr)__dict__update_activationListenersopenr7readrunjellyrdecoderOSError _cbGotUpdate_wasCleanWhenLoadedr! callRemote addCallbacks)r statedataFiledatanewselfrecents r setCopyableStatez RemotePublished.setCopyableStateKsP U###$&! 9d&&(($// '8}} ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' mFM$$7$788G&$.8FF    FFF   X   g. / / /'(D $ $ $ K " "#6 7 7 D DTEV W W W W Ws5"B(A& B(&A**B(-A*.B(( B76B7cV|j}|d=|d=|d=|d=|d=|S)Nbrokerr!luidr= isActivated)r;copy)r others r __getstate__zRemotePublished.__getstate__\s@ ""$$ (O (O &M ( ) -  rc|j|d|_|jD] }||g|_|t |d5}|tj tj |ddddS#1swxYwYdS)Nr:wb) r;r<rPr= activatedr>r7writerencoder)r newStatelistenerrHs r rCzRemotePublished._cbGotUpdategs X&&&1  H HTNNNN$&!  $""$$d + + =x NN6=T):):;; < < < = = = = = = = = = = = = = = = = = =s4:B;;B?B?cdS)znImplement this method if you want to be notified when your publishable subclass is activated. Nr/rs r rVzRemotePublished.activatedrsrcb|jr ||dS|j|dS)zZExternally register for notification when this publishable has received all relevant data.N)rPr=append)r callbacks r callWhenActivatedz!RemotePublished.callWhenActivatedws;   7 HTNNNNN  % , ,X 6 6 6 6 6rN)r2) r+r,r-r.rPrDr7rLrSrCrVr_r/rr r1r1=s@@K    XXX"    = = =   77777rr1crtj}|t|j|f|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) ) callbackArgs)rDeferredrF _pubReadyerrback)dd2s r whenReadyrgs2   BNN9bjuN=== Irc:||jdS)rN)r_r^)resultrfs r rcrcs R[)))))r)r.rtwisted.internetrtwisted.spreadrrr Cacheabler RemoteCacher1rgrcr/rr rns  """"""1111111111& & & & & '#& & & R?7?7?7?7?7g)?7?7?7D   *****r