Name	Size	Mode	Actions
banana.cpython-310.pyc	9382	0644	editdlrm
flavors.cpython-310.pyc	23465	0644	editdlrm
interfaces.cpython-310.pyc	1162	0644	editdlrm
jelly.cpython-310.pyc	32110	0644	editdlrm
pb.cpython-310.pyc	48545	0644	editdlrm
publish.cpython-310.pyc	4909	0644	editdlrm
util.cpython-310.pyc	8081	0644	editdlrm
__init__.cpython-310.pyc	241	0644	editdlrm

o �
b,�@sddZd
dl
Z
d
dlmZ
d
dlmZmZmZ
Gdd�dej�Z Gdd�dej �Zd d �Zdd�Z dS) z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. �N)
�defer)�banana�flavors�jellyc@s@eZ
dZd
Zdd�Zdd�Zdd�Zdd �Zd d�Zdd �Z dS)�Publishablez6An 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__s

zPublishable.__init__c

Cst��|_
d
S)z=Set the timestamp to current and (TODO) update all observers.N)�time� timestamp�
r r r rr�zPublishable.republishcCs |�|
�
S)
� (internal))
�getStateToPublishFor�r �perspectiver r r�view_getStateToPublishs z"Publishable.view_getStateToPublishcCs|��S)
z:Implement me to special-case your state for a perspective.)
�getStateToPublishrr r rr#sz Publishable.getStateToPublishForc

Cstd
|j
�
�
)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)�NotImplementedError� __class__rr r rr'rzPublishable.getStateToPublishcCs:|
r|
j}|
�
�j}nd
}d
}t�|
|�|j|||jd�S)z6Get all necessary metadata to keep a clientside cache.�None)�remoterr�servicer)�perspectiveName� getService�serviceNamer� ViewPointrr)r r�observer�pname�snamer r r�getStateToCacheAndObserveFor+s






�z(Publishable.getStateToCacheAndObserveForN) �__name__� __module__�__qualname__�__doc__rrrrrr#r r r rrs
rc@sJeZ
dZd
ZdZdZddd�
Zdd�Zdd �Zd d�Z dd �Z dd�ZdS)�RemotePublishedz6The local representation of remote Publishable object.r
�pubcCsd
�|j
|jt|j�
|
�S)Nz{}-{}-{}.{})�formatrr�strr)r �extr r r�getFileNameCs




�zRemotePublished.getFileNamecCs�|j�
|
�

g|_zt|��d
��}|��}Wd�
n1s w



Y
Wnty1


d}Ynwt�t � |�
�
}|j|jk}|rM|�|j�

d|_ dS|j�d�
�|j�

dS)N�rbr
�
r)�__dict__�update�_activationListeners�openr-�read�OSErrorr�unjellyr�decoder�_cbGotUpdate�_wasCleanWhenLoadedr� callRemote�addCallbacks)r �state�dataFile�data�recent�newselfr r r�setCopyableStateKs 




��
�



z RemotePublished.setCopyableStatec
Cs,|j�
�}
|
d
=|
d=|
d=|
d=|
d=|
S)N�brokerr�luidr2�isActivated)r0�copy)r �otherr r r�__getstate__\s




zRemotePublished.__getstate__cCs~|j�
|
�

d
|_|jD]}||�

qg|_|��
t|��d��}|�t� t � |�
�
�

Wd�
dS1s8w



Y
dS)Nr/�wb)r0r1rDr2� activatedr3r-�writer�encoder)r �newState�listenerr=r r rr8gs






"�zRemotePublished._cbGotUpdatec


Csd
S)znImplement this method if you want to be notified when your publishable subclass is activated. Nr rr r rrIrszRemotePublished.activatedcCs"|jr |
|�

d
S|j
�|
�

d
S)zZExternally register for notification when this publishable has received all relevant data.N)rDr2�append)r �callbackr r r�callWhenActivatedws
z!RemotePublished.callWhenActivatedN)
r))r$r%r&r'rDr9r-rArGr8rIrPr r r rr(=s

r(c
Cs t�
�}
|jt|
j|
f
d
�
|
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)r�Deferredr;� _pubReady�errback)�
d�d2r r r� whenReadys 

rWcCs|�|
j
�

d
S)rN)rPrO)�resultrVr r rrS�srS)r'r �twisted.internetr�twisted.spreadrrr� Cacheabler�RemoteCacher(rWrSr r r r�
s 
)B