File: //lib/python3/dist-packages/twisted/words/im/__pycache__/pbsupport.cpython-38.pyc
U
W[�% � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddl
m Z ddl m
Z
mZmZ dd lmZmZ dd
lmZ G d d � d ej�Zeej�G d
d� dej��ZG dd� de jej�Z e dd�Z eej �G dd� dej ��Z dS )z2
L{twisted.words} support for Instance Messenger.
� )�print_function)�defer)�error)�log)�Failure)�pb)�ONLINE�OFFLINE�AWAY)� basesupport�
interfaces)� implementerc @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�TwistedWordsPersonzMI 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�nameZ wordsAccount� r �</usr/lib/python3/dist-packages/twisted/words/im/pbsupport.pyr s zTwistedWordsPerson.__init__c C s | j tkp| j tkS r )r r r
�r r r r �isOnline s
�zTwistedWordsPerson.isOnlinec C s | j S r )r r r r r � getStatus" s z TwistedWordsPerson.getStatusc C sJ |r0| j jj�| j||�}|�| jd| � |S | j jj�d| j|�S dS )z Return a deferred...
�* �
directMessageN)�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 0 s z!TwistedWordsPerson.metadataFailedc C s || _ | j�� �| � d S r )r �chat�getContactsListZsetContactStatus)r r r r r � setStatus4 s z TwistedWordsPerson.setStatusN)
�__name__�
__module__� __qualname__�__doc__r r r r& r r. 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 Z wordsClientr r r r : s zTwistedWordsGroup.__init__Nc C sL |r2| j jj�d| j||�}|�| jd| � |S | j jj�d| j|�S dS )zReturn a deferred.
� groupMessager N)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 )NZsetGroupMetadata)�topic� topic_author�r r r r! r )r r# r r r �setTopicK s
�zTwistedWordsGroup.setTopicc C s$ t d|d|� | jjj�d| j|�S )Nr' r( r7 )r) r r r r! r r* r r r r Q s
�z TwistedWordsGroup.metadataFailedc C s
d| _ d S )N� �r6 r r r r �joiningV s zTwistedWordsGroup.joiningc C s
d| _ d S r4 r> r r r r �leavingY s zTwistedWordsGroup.leavingc C s | j jj�d| j�S �N�
leaveGroupr; r r r r �leave\ s �zTwistedWordsGroup.leave)N)
r/ r0 r1 r r8 r< r r? r@ rC r r r r r3 8 s
r3 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 ||f | _ || _td||� || _|| _|| _d S )Nz
%s (%s:%s)zHELLO I AM A PB SERVICE)� accountNamer r) r, r �_logonDeferred)r Zacct� serviceName�perspectiveName�chatuirF r r r r f s zTwistedWordsClient.__init__c C s | j �|| �S r )r, � getPerson�r r r r r rJ o s z TwistedWordsClient.getPersonc C s | j �|| �S r )r, �getGrouprK r r r rL r s zTwistedWordsClient.getGroupc C s | j �| �|��S r )r, �getGroupConversationrL rK r r r rM u s z'TwistedWordsClient.getGroupConversationc C s | j �d|� d S )N�
addContact)r r! rK r r r rN x s z TwistedWordsClient.addContactc C s t d||� | �|��|� d S )Nzreceived group members:)r) rM ZsetGroupMembers)r �names�groupr r r �remote_receiveGroupMembers{ s z-TwistedWordsClient.remote_receiveGroupMembersc C s( t d||||� | �|��|||� d S )Nzreceived a group message)r) rM �showGroupMessage)r ZsenderrP �messager$ r r r �remote_receiveGroupMessage s z-TwistedWordsClient.remote_receiveGroupMessagec C s t d||� | �|��|� d S )Nz
member joined)r) rM Z memberJoined�r �memberrP r r r �remote_memberJoined� s z&TwistedWordsClient.remote_memberJoinedc C s t d� | �|��|� d S )Nz member left)r) rM Z
memberLeftrU r r r �remote_memberLeft� s z$TwistedWordsClient.remote_memberLeftc C s | j �|| ��|� d S r �r, rJ r. )r r r r r r �remote_notifyStatusChanged� s z-TwistedWordsClient.remote_notifyStatusChangedc C s" | j �| j �|| ���||� d S r )r, ZgetConversationrJ Z showMessage)r r rS r$ r r r �remote_receiveDirectMessage� s z.TwistedWordsClient.remote_receiveDirectMessagec C s& |D ] \}}| j �|| ��|� qd S r rY )r Zclistr r r r r �remote_receiveContactList� s z,TwistedWordsClient.remote_receiveContactListc C s* d|kr&| � |��|d |�dd �� d S )Nr9 r: )rM r< �get)r Zdict_Z groupNamer r r �remote_setGroupMetadata� s z*TwistedWordsClient.remote_setGroupMetadatac C s& | � |��� | j�d|��| j|�S )N� joinGroup)rL r? r r! � addCallback�_cbGroupJoinedrK r r r r_ � s z TwistedWordsClient.joinGroupc C s& | � |��� | j�d|��| j|�S rA )rL r@ r r! r` � _cbGroupLeftrK r r r rB � s z TwistedWordsClient.leaveGroupc C s0 | j �| �|��}|�dd� | j�d|� d S )N�sysz
you joinedZgetGroupMembers)r, rM rL rR r r! �r r+ r Z groupConvr r r ra � s z!TwistedWordsClient._cbGroupJoinedc C s. t d|� | j�| �|�d�}|�dd� d S )N�leftr= rc zyou left)r) r, rM rL rR rd r r r rb � s
z TwistedWordsClient._cbGroupLeftc C s4 t d|� | jd k r | j�| � || _| j�� d S )NzConnected Words Client!)r) rF �callbackr r, r- )r r r r r � connected� s
z TwistedWordsClient.connected)N)N)N)r/ r0 r1 r2 r rJ rL rM rN rQ rT rW rX rZ r[ r\ r^ r_ rB ra rb rg r r r r rD b s( �
rD N)�
twisted.wordsztwisted.realityc @ sJ e Zd ZdZeZeZddd�Zdd� Z dd� Z
d d
� Z d d � Z d
d� Z
dS )� PBAccountZPBNc C sX t j�| ||||||� g | _|s.dd|fg}|D ] \}} }
| j�t| | |
g� q2dS )z_
@param username: The name of your PB Identity.
@type username: string
rh N)r �AbstractAccountr �services�append� pbFrontEnds) r rE Z autoLogin�username�password�host�portrk Z serviceTyperG rH r r r r � s � �zPBAccount.__init__c sR �j sD�jsDd�_ ��� �}|��j� � �fdd�}|�|� |S t�d��dS )z
@returns: this breaks with L{interfaces.IAccount}
@returntype: DeferredList of L{interfaces.IClient}s
r= c s6 | D ],\}}|r&� � |� ��|� qt�|� qd S r )ZregisterAccountClientZ _cb_logOnr �err)ZresultsZsuccessr+ �rI r r r � registerMany� s
z%PBAccount.logOn.<locals>.registerManyzConnection in progressN)Z
_isConnectingZ _isOnline� _startLogOnr Z _loginFailedr` r �ConnectionError)r rI r% rt r rs r �logOn� s
zPBAccount.logOnc C s6 t ddd� t�| j| j�}|j| j| j|fd� |S )Nz
Connecting...� ��end�Z callbackArgs)r) r Z getObjectAtrp rq � addCallbacks� _cbConnected� _ebConnected)r rI r% r r r ru � s �zPBAccount._startLogOnc C s@ t d� t ddd� t�|| j| j�}|j| j| j|fd� |S )Nz
Connected!zIdentifying...rx ry r{ )r) r Z authIdentityrn ro r| �_cbIdentr~ )r �rootrI r% r r r r} � s �zPBAccount._cbConnectedc C s� |s t d� | �ttd���S t d� g }| jD ]D\}}}t�� }|�|� || ||||�}|�d|||�� |j
� q0t� |�S )Nzfalsely identified.z username or password incorrectz Identified!Zattach) r) r~ r � Exceptionrk r ZDeferredrl r! r` rg Z DeferredList) r ZidentrI ZdlZ handlerClassZsnameZpnamer% Zhandlerr r r r � s
zPBAccount._cbIdentc C s t d� |S )NzNot connected.)r) )r r r r r r~ s zPBAccount._ebConnected)N)r/ r0 r1 Z gatewayTyper3 Z
_groupFactoryr Z_personFactoryr rw ru r} r r~ r r r r ri � s �
ri )!r2 Z
__future__r Ztwisted.internetr r Ztwisted.pythonr Ztwisted.python.failurer Ztwisted.spreadr Ztwisted.words.im.localsr r r
Ztwisted.words.imr r Zzope.interfacer
r r ZIGroupr5 r3 Z
ReferenceableZAbstractClientMixinrD rm ZIAccountrj ri r r r r �<module> s$ !)R�