File: //proc/thread-self/root/lib/python3/dist-packages/twisted/spread/__pycache__/publish.cpython-38.pyc
U
W[� � @ st d Z ddlmZmZ ddlZddlmZ ddlmZm Z m
Z
G dd� de
j �Z G dd � 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@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )� Publishablez;An object whose cached state persists across sessions.
c C s | � � || _d S )N)� republish� publishedID)�selfr
� r �8/usr/lib/python3/dist-packages/twisted/spread/publish.py�__init__ s zPublishable.__init__c C s t � � | _dS )zFSet the timestamp to current and (TODO) update all observers.
N)�time� timestamp�r r r r
r s zPublishable.republishc C s
| � |�S )�
(internal))�getStateToPublishFor�r � perspectiver r r
�view_getStateToPublish! s z"Publishable.view_getStateToPublishc C s | � � S )zCImplement me to special-case your state for a perspective.
)�getStateToPublishr r r r
r % s z Publishable.getStateToPublishForc C s t d| j ��dS )zKImplement me to return state to copy as part of the publish phase.
z%s.getStateToPublishForN)�NotImplementedError� __class__r r r r
r * s z Publishable.getStateToPublishc C s: |r|j }|�� j}nd}d}t�|| �| j||| jd�S )z?Get all necessary metadata to keep a clientside cache.
�None)�remoter
r �servicer )ZperspectiveNameZ
getServiceZ serviceNamer Z ViewPointr
r )r r ZobserverZpnameZsnamer r r
� getStateToCacheAndObserveFor/ s
�z(Publishable.getStateToCacheAndObserveForN)
�__name__�
__module__� __qualname__�__doc__r r r r r r r r r r
r s r c @ sJ e Zd ZdZdZdZddd�Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dS )�RemotePublishedz;The local representation of remote Publishable object.
r �pubc C s d| j | jt| j�|f S )Nz %s-%s-%s.%s)r r �strr
)r Zextr r r
� getFileNameD s �zRemotePublished.getFileNamec C s� | j �|� g | _z&t| �� d��}|�� }W 5 Q R X W n tk
rP d}Y n X t�t �
|��}|j | j k}|r�| � |j � d| _
n| j�d��| j � d S )N�rbr � r )�__dict__�update�_activationListeners�openr% �read�IOErrorr Zunjellyr �decoder � _cbGotUpdate�_wasCleanWhenLoadedr Z
callRemote� addCallbacks)r �state�dataFile�dataZrecentZnewselfr r r
�setCopyableStateH s
z RemotePublished.setCopyableStatec C s, | j �� }|d= |d= |d= |d= |d= |S )NZbrokerr Zluidr* � isActivated)r( �copy)r �otherr r r
� __getstate__Y s
z RemotePublished.__getstate__c C sh | j �|� d| _| jD ] }|| � qg | _| �� t| �� d�� }|�t� t
�
| ��� W 5 Q R X d S )Nr' �wb) r( r) r6 r* � activatedr+ r% �writer �encoder )r ZnewStateZlistenerr3 r r r
r/ d s
z RemotePublished._cbGotUpdatec C s dS )znImplement this method if you want to be notified when your
publishable subclass is activated.
Nr r r r r
r; p s zRemotePublished.activatedc C s | j r|| � n | j�|� dS )zcExternally register for notification when this publishable has received all relevant data.
N)r6 r* �append)r �callbackr r r
�callWhenActivatedu s
z!RemotePublished.callWhenActivatedN)r# ) r r r r! r6 r0 r% r5 r9 r/ r; r@ r r r r
r" ? s
r" c C s 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)r ZDeferredr1 � _pubReadyZerrback)�d�d2r r r
� whenReady} s
�rD c C s | � |j� dS )r N)r@ r? )�resultrC r r r
rA � s rA )r! Z
__future__r r r Ztwisted.internetr Ztwisted.spreadr r r Z Cacheabler Z RemoteCacher" rD rA r r r r
�<module> s *>