U


W[��@stdZd
dl
mZmZ
d
dlZd
dlmZ
d
dlmZm	Z	m
Z

Gdd�de
j�ZGdd	�d	e
j
�Zd
d�Zdd
�ZdS)z]
Persistently cached objects for PB.

Maintainer: Glyph Lefkowitz

Future Plans: None known.
�)�absolute_import�divisionN)
�defer)�banana�jelly�flavorsc@s@eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dS)�Publishablez;An 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)zFSet the timestamp to current and (TODO) update all observers.
        N)�time�	timestamp�
rrrr
r	szPublishable.republishcCs
|�|
�
S)
�
(internal))
�getStateToPublishFor�r�perspectiverrr
�view_getStateToPublish!sz"Publishable.view_getStateToPublishcCs|��S)
zCImplement me to special-case your state for a perspective.
        )
�getStateToPublishrrrr
r%sz Publishable.getStateToPublishForc

Cstd
|j
�
�
dS)zKImplement 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|||jd�S)z?Get all necessary metadata to keep a clientside cache.
        �None)�remoter
r�servicer)ZperspectiveNameZ
getServiceZserviceNamerZ	ViewPointr
r)rrZobserverZpnameZsnamerrr
�getStateToCacheAndObserveFor/s







�z(Publishable.getStateToCacheAndObserveForN)
�__name__�
__module__�__qualname__�__doc__rr	rrrrrrrr
rs
rc@sJeZ
dZd
ZdZdZddd�
Zdd�Zdd	�Zd
d�Z	dd
�Z
dd�ZdS)�RemotePublishedz;The local representation of remote Publishable object.
    r
�pubcCsd
|j|j
t|j�
|
fS)Nz%s-%s-%s.%s)rr�strr
)rZextrrr
�getFileNameDs

�zRemotePublished.getFileNamec	Cs�|j�
|
�

g|_z&t|��d
��}|��}W5QRXWntk
rP


d}YnXt�t	�
|�
�
}|j|jk}|r�|�|j�

d|_
n|j�d�
�|j�

dS)N�rbr
�
r)�__dict__�update�_activationListeners�openr%�read�IOErrorrZunjellyr�decoder�_cbGotUpdate�_wasCleanWhenLoadedrZ
callRemote�addCallbacks)r�state�dataFile�dataZrecentZnewselfrrr
�setCopyableStateHs











z RemotePublished.setCopyableStatec
Cs,|j�
�}
|
d
=|
d=|
d=|
d=|
d=|
S)NZbrokerrZluidr*�isActivated)r(�copy)r�otherrrr
�__getstate__Ys





zRemotePublished.__getstate__c	Csh|j�
|
�

d
|_|jD]}||�

qg|_|��
t|��d��}|�t�	t
�
|�
�
�

W5QRXdS)Nr'�wb)r(r)r6r*�	activatedr+r%�writer�encoder)rZnewStateZlistenerr3rrr
r/ds








zRemotePublished._cbGotUpdatec


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

n|j
�|
�

d
S)zcExternally register for notification when this publishable has received all relevant data.
        N)r6r*�append)r�callbackrrr
�callWhenActivatedus

z!RemotePublished.callWhenActivatedN)
r#)rrr r!r6r0r%r5r9r/r;r@rrrr
r"?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)
    )
ZcallbackArgs)rZDeferredr1�	_pubReadyZerrback)�
d�d2rrr
�	whenReady}s




�rDcCs|�|
j
�

d
S)rN)r@r?)�resultrCrrr
rA�srA)r!Z
__future__rrrZtwisted.internetrZtwisted.spreadrrrZ	CacheablerZRemoteCacher"rDrArrrr
�<module>s
*>