0x1949 Team - FAZEMRX - MANAGER
Edit File: publish.cpython-310.pyc
o �b, � @ sd d Z ddlZddlmZ ddlmZmZmZ G dd� dej�Z G dd� dej �Z d d � Z d d � Z dS ) z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. � N)�defer)�banana�flavors�jellyc @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� Publishablez6An 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 )z=Set the timestamp to current and (TODO) update all observers.N)�time� timestamp�r r r r r � zPublishable.republishc C s | � |�S )� (internal))�getStateToPublishFor�r � perspectiver r r �view_getStateToPublish s z"Publishable.view_getStateToPublishc C s | � � S )z:Implement me to special-case your state for a perspective.)�getStateToPublishr r r r r # s z Publishable.getStateToPublishForc C s t d| j ��)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)�NotImplementedError� __class__r r r r r ' r z Publishable.getStateToPublishc C s: |r |j }|�� j}nd}d}t�|| �| j||| jd�S )z6Get all necessary metadata to keep a clientside cache.�None)�remoter r �servicer )�perspectiveName� getService� serviceNamer � ViewPointr r )r r �observer�pname�snamer 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 )�RemotePublishedz6The local representation of remote Publishable object.r �pubc C s d� | j| jt| j�|�S )Nz {}-{}-{}.{})�formatr r �strr )r �extr r r � getFileNameC s �zRemotePublished.getFileNamec C s� | j �|� g | _z t| �� d�� }|�� }W d � n1 s w Y W n ty1 d}Y nw t�t � |��}|j | j k}|rM| � |j � d| _ d S | j�d��| j � d S )N�rbr � r )�__dict__�update�_activationListeners�openr- �read�OSErrorr �unjellyr �decoder � _cbGotUpdate�_wasCleanWhenLoadedr � callRemote� addCallbacks)r �state�dataFile�data�recent�newselfr r r �setCopyableStateK s �� � z RemotePublished.setCopyableStatec C s, | j �� }|d= |d= |d= |d= |d= |S )N�brokerr �luidr2 � isActivated)r0 �copy)r �otherr r r � __getstate__\ s z RemotePublished.__getstate__c C s~ | j �|� d| _| jD ]}|| � q g | _| �� t| �� d��}|�t� t � | ��� W d � d S 1 s8w Y d S )Nr/ �wb) r0 r1 rD r2 � activatedr3 r- �writer �encoder )r �newState�listenerr= r r r r8 g 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 rI r s zRemotePublished.activatedc C s" | j r || � dS | j�|� dS )zZExternally register for notification when this publishable has received all relevant data.N)rD r2 �append)r �callbackr r r �callWhenActivatedw s z!RemotePublished.callWhenActivatedN)r) ) r$ r% r& r' rD r9 r- rA rG r8 rI rP 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) )� callbackArgs)r �Deferredr; � _pubReady�errback)�d�d2r r r � whenReady s rW c C s | � |j� dS )r N)rP rO )�resultrV r r r rS � s rS )r' r �twisted.internetr �twisted.spreadr r r � Cacheabler � RemoteCacher( rW rS r r r r �<module> s )B