Server : Apache/2.4.52 (Ubuntu) System : Linux webserver 6.8.0-49-generic #49~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Nov 6 17:42:15 UTC 2 x86_64 User : www-data ( 33) PHP Version : 8.1.2-1ubuntu2.21 Disable Function : NONE Directory : /lib/python3/dist-packages/twisted/words/im/__pycache__/ |
o
�b�% � @ s� d Z ddlmZ ddlmZmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
mZ ddlmZmZmZ G d d
� d
e
j�Zeej�G d d � d e
j��ZG d
d� de je
j�Zedd�Zeej �G dd� de
j ��Z dS )z2
L{twisted.words} support for Instance Messenger.
� )� implementer)�defer�error)�log)�Failure)�pb)� basesupport�
interfaces)�AWAY�OFFLINE�ONLINEc @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�TwistedWordsPersonzHI a facade for a person you can talk to through a twisted.words service.c C s t j�| ||� t| _d S �N)r �AbstractPerson�__init__r �status)�self�name� wordsAccount� r �</usr/lib/python3/dist-packages/twisted/words/im/pbsupport.pyr �
zTwistedWordsPerson.__init__c C s | j tkp | j tkS r )r r r
�r r r r �isOnline � zTwistedWordsPerson.isOnlinec C s | j S r )r r r r r � getStatus s z TwistedWordsPerson.getStatusc C sF |r| j jj�| j||�}|�| jd| � |S | j jj�d| j|�S )zReturn a deferred...�* �
directMessage)�account�client� perspectiver r �
addErrback�metadataFailed�
callRemote�r �text�metadata�dr r r � sendMessage! s
�z TwistedWordsPerson.sendMessagec C s" t d|d|� | jjj�| j|�S )N�result:�text:)�printr r r r r �r �resultr% r r r r" , s z!TwistedWordsPerson.metadataFailedc C s || _ | j�� �| � d S r )r �chat�getContactsList�setContactStatus)r r r r r � setStatus0 s z TwistedWordsPerson.setStatusN)
�__name__�
__module__� __qualname__�__doc__r r r r( r" r1 r r r r r
s r
c @ sF e Zd Zdd� Zddd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dS )�TwistedWordsGroupc C s t j�| ||� d| _d S �Nr )r �
AbstractGroupr �joined)r r � wordsClientr r r r 7 r zTwistedWordsGroup.__init__Nc C sH |r| j jj�d| j||�}|�| jd| � |S | j jj�d| j|�S )zReturn a deferred.� groupMessager )r r r r# r r! r" r$ r r r �sendGroupMessage; s
�
�z"TwistedWordsGroup.sendGroupMessagec C s$ | j jj�d|| jjd�| j� d S )N�setGroupMetadata)�topic� topic_author�r r r r# r )r r% r r r �setTopicI s
�zTwistedWordsGroup.setTopicc C s$ t d|d|� | jjj�d| j|�S )Nr) r* r; )r+ r r r r# r r, r r r r" P s
�z TwistedWordsGroup.metadataFailedc C �
d| _ d S )N� �r9 r r r r �joiningV �
zTwistedWordsGroup.joiningc C rB r7 rD r r r r �leavingY rF zTwistedWordsGroup.leavingc C s | j jj�d| j�S �N�
leaveGroupr@ r r r r �leave\ r zTwistedWordsGroup.leaver )
r2 r3 r4 r r< rA r" rE rG rJ r r r r r6 5 s
r6 c @ s� e Zd ZdZd'dd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z d'dd�Z
dd� Z dd� Z dd� Z
d'dd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� ZdS )(�TwistedWordsClientz�In some cases, this acts as an Account, since it a source of text
messages (multiple Words instances may be on a single PB connection)
Nc C s: d� |j||�| _|| _td||� || _|| _|| _d S )Nz
{} ({}:{})zHELLO I AM A PB SERVICE)�format� accountNamer r+ r. r �_logonDeferred)r �acct� serviceName�perspectiveName�chatuirN r r r r e s �
zTwistedWordsClient.__init__c C � | j �|| �S r )r. � getPerson�r r r r r rT q � z TwistedWordsClient.getPersonc C rS r )r. �getGrouprU r r r rW t rV zTwistedWordsClient.getGroupc C s | j �| �|��S r )r. �getGroupConversationrW rU r r r rX w � z'TwistedWordsClient.getGroupConversationc C s | j �d|� d S )N�
addContact)r r# rU r r r rZ z rY z TwistedWordsClient.addContactc C � t d||� | �|��|� d S )Nzreceived group members:)r+ rX �setGroupMembers)r �names�groupr r r �remote_receiveGroupMembers} � z-TwistedWordsClient.remote_receiveGroupMembersc C s( t d||||� | �|��|||� d S )Nzreceived a group message)r+ rX �showGroupMessage)r �senderr^ �messager& r r r �remote_receiveGroupMessage� s z-TwistedWordsClient.remote_receiveGroupMessagec C r[ )Nz
member joined)r+ rX � memberJoined�r �memberr^ r r r �remote_memberJoined� r` z&TwistedWordsClient.remote_memberJoinedc C s t d� | �|��|� d S )Nz member left)r+ rX �
memberLeftrf r r r �remote_memberLeft� s z$TwistedWordsClient.remote_memberLeftc C s | j �|| ��|� d S r �r. rT r1 )r r r r r r �remote_notifyStatusChanged� s z-TwistedWordsClient.remote_notifyStatusChangedc C s" | j �| j �|| ���||� d S r )r. �getConversationrT � showMessage)r r rc r& r r r �remote_receiveDirectMessage� s �z.TwistedWordsClient.remote_receiveDirectMessagec C s& |D ]\}}| j �|| ��|� qd S r rk )r �clistr r r r r �remote_receiveContactList� s �z,TwistedWordsClient.remote_receiveContactListc C s. d|v r| � |��|d |�dd �� d S d S )Nr> r? )rX rA �get)r �dict_� groupNamer r r �remote_setGroupMetadata� s
��z*TwistedWordsClient.remote_setGroupMetadatac C �& | � |��� | j�d|��| j|�S )N� joinGroup)rW rE r r# � addCallback�_cbGroupJoinedrU r r r rw � � �z TwistedWordsClient.joinGroupc C rv rH )rW rG r r# rx � _cbGroupLeftrU r r r rI � rz z TwistedWordsClient.leaveGroupc C s0 | j �| �|��}|�dd� | j�d|� d S )N�sysz
you joined�getGroupMembers)r. rX rW ra r r# �r r- r � groupConvr r r ry � s z!TwistedWordsClient._cbGroupJoinedc C s. t d|� | j�| �|�d�}|�dd� d S )N�leftrC r| zyou left)r+ r. rX rW ra r~ r r r r{ � s
z TwistedWordsClient._cbGroupLeftc C s4 t d|� | jd ur| j�| � || _| j�� d S )NzConnected Words Client!)r+ rN �callbackr r. r/ )r r r r r � connected� s
z TwistedWordsClient.connectedr )r2 r3 r4 r5 r rT rW rX rZ r_ rd rh rj rl ro rq ru rw rI ry r{ r� r r r r rK ` s(
rK N)�
twisted.wordsztwisted.realityc @ sT e Zd ZdZeZeZ ddd�Zdd� Z dd� Z
d d
� Z d d � Z d
d� Z
dd� ZdS )� PBAccount�PBNc C sX t j�| ||||||� g | _|sdd|fg}|D ]\}} }
| j�t| | |
g� qdS )z_
@param username: The name of your PB Identity.
@type username: string
r� N)r �AbstractAccountr �services�append� pbFrontEnds) r rM � autoLogin�username�password�host�portr� � serviceTyperP rQ r r r r � s � ��zPBAccount.__init__c sN �j s"�js"d�_ ��� �}|��j� � �fdd�}|�|� |S t�d��)z
@returns: this breaks with L{interfaces.IAccount}
@returntype: DeferredList of L{interfaces.IClient}s
rC c s6 | D ]\}}|r� � |� ��|� qt�|� qd S r )�registerAccountClient� _cb_logOnr �err)�results�successr- �rR r r r � registerMany� s
�z%PBAccount.logOn.<locals>.registerManyzConnection in progress)�
_isConnecting� _isOnline� _startLogOnr! � _loginFailedrx r �ConnectionError)r rR r' r� r r� r �logOn� s
zPBAccount.logOnc C s d S r r r r r r �logOff� s zPBAccount.logOffc C s6 t ddd� t�| j| j�}|j| j| j|fd� |S )Nz
Connecting...� ��end�� callbackArgs)r+ r � getObjectAtr� r� � addCallbacks� _cbConnected� _ebConnected)r rR r' r r r r� � s zPBAccount._startLogOnc C s@ t d� t ddd� t�|| j| j�}|j| j| j|fd� |S )Nz
Connected!zIdentifying...r� r� r� )r+ r � authIdentityr� r� r� �_cbIdentr� )r �rootrR r' r r r r� � s
zPBAccount._cbConnectedc C s� |st d� | �ttd���S t d� g }| jD ]"\}}}t�� }|�|� || ||||�}|�d|||�� |j
� qt� |�S )Nzfalsely identified.z username or password incorrectz Identified!�attach) r+ r� r � Exceptionr� r �Deferredr� r# rx r� � DeferredList) r �identrR �dl� handlerClass�sname�pnamer' �handlerr r r r� s
�
�
zPBAccount._cbIdentc C s t d� |S )NzNot connected.)r+ )r r r r r r� s zPBAccount._ebConnectedr )r2 r3 r4 � gatewayTyper6 �
_groupFactoryr
�_personFactoryr r� r� r� r� r� r� r r r r r� � s
� r� ) r5 �zope.interfacer �twisted.internetr r �twisted.pythonr �twisted.python.failurer �twisted.spreadr �twisted.words.imr r �twisted.words.im.localsr
r r r r
�IGroupr8 r6 �
Referenceable�AbstractClientMixinrK r� �IAccountr� r� r r r r �<module> s !*
]