| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/twisted/words/im/__pycache__/ |
Upload File : |
o
�b � @ s� d Z ddlmZ ddlmZ ddlmZmZ ddlm Z ddl
m Z ddl m
Z
ddlmZmZ G d d
� d
�ZG d d � d �ZG d
d� d�ZG dd� de j�ZdS )zyInstance Messenger base classes for protocol support.
You will find these useful if you're adding a new protocol to IM.
� )�Type)�error)�Protocol�connectionDone)�styles)�Failure��prefixedMethods)�OFFLINE� OfflineErrorc @ sP e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd efd d
�Z d efdd�Z
dS )�
AbstractGroupc C s || _ || _d S �N)�name�account)�selfr r � r �>/usr/lib/python3/dist-packages/twisted/words/im/basesupport.py�__init__ s
zAbstractGroup.__init__c C �
t | d�S )z�finds group commands
these commands are methods on me that start with imgroup_; they are
called with no arguments
�imgroup_r �r r r r �getGroupCommands �
z AbstractGroup.getGroupCommandsc C r )a( finds group commands
these commands are methods on me that start with imgroup_; they are
called with a user present within this room as an argument
you may want to override this in your group in order to filter for
appropriate commands on the given user
� imtarget_r )r �targetr r r �getTargetCommands# s
z AbstractGroup.getTargetCommandsc C � | j jst�| j j�| j� d S r
)r �clientr � joinGroupr r r r r �join. � zAbstractGroup.joinc C r r
)r r r �
leaveGroupr r r r r �leave3 r zAbstractGroup.leave�returnc C s d| j � d| j�d�S )N�<� �>)� __class__r r r r r �__repr__8 s zAbstractGroup.__repr__c C � | j � d| jj� �S �N�@�r r � accountNamer r r r �__str__; � zAbstractGroup.__str__N) �__name__�
__module__� __qualname__r r r r r" �strr( r. r r r r r s r c @ s@ e Zd Zdd� Zdd� Zdd� Zdefdd �Zdefd
d �Zd S )
�AbstractPersonc C s || _ || _t| _d S r
)r r r
�status)r r � baseAccountr r r r @ s
zAbstractPerson.__init__c C r )z�finds person commands
these commands are methods on me that start with imperson_; they are
called with no arguments
� imperson_r r r r r �getPersonCommandsE r z AbstractPerson.getPersonCommandsc C s dS )z#
Returns a string.
z--r r r r r � getIdleTimeM s zAbstractPerson.getIdleTimer# c C s d| j � d| j�d| j� d�S )Nr$ r% �/r& )r' r r5 r r r r r( S s zAbstractPerson.__repr__c C r) r* r, r r r r r. V r/ zAbstractPerson.__str__N) r0 r1 r2 r r8 r9 r3 r( r. r r r r r4 ? s r4 c @ sL e Zd ZU dZdZee ed< dd� Zdd� Z e
fde fd d
�Z d d � Z
dS )
�AbstractClientMixinz�Designed to be mixed in to a Protocol implementing class.
Inherit from me first.
@ivar _logonDeferred: Fired when I am done logging in.
N�
_protoBasec C s< | j jD ]
}t|t�r|| j _ nq || _|| _|| _d S r
)r' � __bases__�
issubclassr r< r �chat�_logonDeferred)r r �chatui�
logonDeferred�baser r r r d s
�
z AbstractClientMixin.__init__c C s | j �| � d S r
)r< �connectionMader r r r rD o s z"AbstractClientMixin.connectionMade�reasonc C s$ | j �| |� | �� | j�| |�S r
)r � _clientLost�unregisterAsAccountClientr< �connectionLost�r rE r r r rH r s z"AbstractClientMixin.connectionLostc C s | j �| � dS )z*Tell the chat UI that I have `signed off'.N)r? �unregisterAccountClientr r r r rG w s z-AbstractClientMixin.unregisterAsAccountClient)r0 r1 r2 �__doc__r< r r �__annotations__r rD r r rH rG r r r r r; Z s
r; c @ s� e Zd ZdZdZdZdZeZe Z
dZ dd� Z dd� Z
d d
� Zd d � Zd
d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdefd d �ZdS ) �AbstractAccounta Base class for Accounts.
I am the start of an implementation of L{IAccount<interfaces.IAccount>}, I
implement L{isOnline} and most of L{logOn}, though you'll need to implement
L{_startLogOn} in a subclass.
@cvar _groupFactory: A Callable that will return a L{IGroup} appropriate
for this account type.
@cvar _personFactory: A Callable that will return a L{IPerson} appropriate
for this account type.
@type _isConnecting: boolean
@ivar _isConnecting: Whether I am in the process of establishing a
connection to the server.
@type _isOnline: boolean
@ivar _isOnline: Whether I am currently on-line with the server.
@ivar accountName:
@ivar autoLogin:
@ivar username:
@ivar password:
@ivar host:
@ivar port:
r N� c C s4 || _ || _|| _|| _|| _|| _i | _i | _d S r
)r- � autoLogin�username�password�host�port�_groups�_persons)r r- rO rP rQ rR rS r r r r � s
zAbstractAccount.__init__c C s$ dD ]
}t | |�st| |i � qd S )N)rT rU )�hasattr�setattr)r �kr r r �upgrateToVersion2� s
��z!AbstractAccount.upgrateToVersion2c C s6 t j�| �}dD ]}z||= W q ty Y qw |S )N)r � _isOnline�
_isConnecting)r � Versioned� __getstate__�KeyError)r �staterX r r r r] � s
�z AbstractAccount.__getstate__c C s | j S r
)rZ r r r r �isOnline� s zAbstractAccount.isOnlinec C sN | j s"| js"d| _ | �|�}|�| j� |�|j� |�| j� |S t� d��)a= Log on to this account.
Takes care to not start a connection if a connection is
already in progress. You will need to implement
L{_startLogOn} for this to work, and it would be a good idea
to override L{_loginFailed} too.
@returntype: Deferred L{interfaces.IClient}
� zConnection in progress)
r[ rZ � _startLogOn� addCallback� _cb_logOn�registerAccountClient�
addErrback� _loginFailedr � ConnectError)r rA �dr r r �logOn� s
zAbstractAccount.logOnc C �. | j �|�}|du r| �|| �}|| j |< |S )zkGroup factory.
@param name: Name of the group on this account.
@type name: string
N)rT �get�
_groupFactory)r r �groupr r r �getGroup� �
zAbstractAccount.getGroupc C rk )zmPerson factory.
@param name: Name of the person on this account.
@type name: string
N)rU rl �_personFactory)r r �personr r r � getPerson� rp zAbstractAccount.getPersonc C s t � �)z{Start the sign on process.
Factored out of L{logOn}.
@returntype: Deferred L{interfaces.IClient}
)�NotImplementedError)r rA r r r rb � s zAbstractAccount._startLogOnc C s d| _ d| _|| _|S )Nr ra )r[ rZ r )r r r r r rd � � zAbstractAccount._cb_logOnc C s d| _ d| _|S )z�Errorback for L{logOn}.
@type reason: Failure
@returns: I{reason}, for further processing in the callback chain.
@returntype: Failure
r )r[ rZ rI r r r rg � s z AbstractAccount._loginFailedc C s d | _ d| _d| _|S )Nr )r r[ rZ )r r rE r r r rF ru zAbstractAccount._clientLostr# c C s d� | j| j| j| j| j�S )Nz<{}: {} ({}@{}:{})>)�formatr' r- rP rR rS r r r r r( s �zAbstractAccount.__repr__)r0 r1 r2 rK rZ r[ r r rm r4 rq �persistanceVersionr rY r] r` rj ro rs rb rd rg rF r3 r( r r r r rM | s( rM N)rK �typingr �twisted.internetr �twisted.internet.protocolr r �twisted.persistedr �twisted.python.failurer �twisted.python.reflectr �twisted.words.im.localsr
r r r4 r; r\ rM r r r r �<module> s )"