File: //proc/self/root/lib/python3/dist-packages/twisted/words/__pycache__/service.cpython-38.pyc
U
W[ � � @ s d Z ddlmZmZ ddlmZ ddlmZ ddlmZm Z m
Z ddl m
Z
mZ ddlmZmZmZ ddlmZmZ dd lmZ dd
lmZ dd lmZm Z dd l m Z eej �G d
d� de ��Z!eej"�G dd� de ��Z#dZ$eej%�G dd� de j&��Z'G dd� dej(�Z)G dd� dej*�Z+eej%�G dd� dej,��Z-e�.e+e-� G dd� dej*�Z/eej �G d d � d ej,��Z0e�.e/e0� G d d � d ej*�Z1eej%�G d d!� d!ej*��Z2ee2ej"ej3� G d"d#� d#ej,�Z4e�.e2e4� eej5ej6�G d$d%� d%e ��Z7G d&d'� d'e7�Z8ddd%d'gZ9d(S ))a
A module that needs a better name.
Implements new cred things for words.
How does this thing work?
- Network connection on some port expecting to speak some protocol
- Protocol-specific authentication, resulting in some kind of credentials object
- twisted.cred.portal login using those credentials for the interface
IUser and with something implementing IChatClient as the mind
- successful login results in an IUser avatar the protocol can call
methods on, and state added to the realm such that the mind will have
methods called on it as is necessary
- protocol specific actions lead to calls onto the avatar; remote events
lead to calls onto the mind
- protocol specific hangup, realm is notified, user is removed from active
play, the end.
� )�time�ctime)� implementer)� copyright)�portal� credentials�error)�defer�protocol)�log�failure�reflect)�
itervalues�unicode)�registerAdapter)�pb)�iwords�ewords)�ircc @ sV e Zd Zdd� Zdd� Zdd� Zdd� Zdd
d �Zd d
� Zdd� Z dd� Z
dd� Z d S )�Groupc C s || _ i | _ddd�| _d S )N� )�topic� topic_author)�name�users�meta��selfr � r �7/usr/lib/python3/dist-packages/twisted/words/service.py�__init__/ s
�zGroup.__init__c C s t �t||��S �N)r �Failure� Exception)r �err�pr r r � _ebUserCall8 s zGroup._ebUserCallc C s0 |D ]&\}}|s|j \}}| �||�� � qd S r! )�value�remove�getErrorMessage)r �resultsZsuccess�result�userr$ r r r � _cbUserCall< s
zGroup._cbUserCallc C s� t j�|�std|f ��|j| jkr�g }|| j|j< t| j�D ]6}||k r@t�|j | |�}|j
| j |d� |� |� q@t�
|��| j� t�d �S )Nz%r is not a chat client�r% )r � IChatClient�
providedBy�AssertionErrorr r r r �
maybeDeferred�
userJoined�
addErrbackr& �append� DeferredList� addCallbackr- �succeed)r r, Z additionsr% �dr r r �addC s z Group.addNc C s� z| j |j= W n tk
r" Y n\X g }t| j �D ]8}||k r2t�|j| ||�}|j| j|d� |� |� q2t�
|�� | j � t�
d �S �Nr. )r r �KeyErrorr r r2 �userLeftr4 r& r5 r6 r7 r- r8 )r r, �reasonZremovalsr% r9 r r r r( Q s z Group.removec C s t �t| j��S r! )r r8 �lenr �r r r r �sizea s z
Group.sizec C sp || ks t �g }t| j�D ]8}||k rt�|j|| |�}|j| j|d� |�|� qt� |��
| j � t� d �S r; )
r1 r r r r2 �receiver4 r& r5 r6 r7 r- r8 )r �sender� recipient�messageZreceivesr% r9 r r r rB e s z
Group.receivec C s` || _ g }t| j�D ].}t�|j| |�}|j| j|d� |�|� qt� |��
| j � t� d �S r; )
r r r r r2 �groupMetaUpdater4 r& r5 r6 r7 r- r8 )r r Zsetsr% r9 r r r � setMetadataq s zGroup.setMetadatac C s t | j�� �S r! )�iterr �valuesr@ r r r � iterusers| s zGroup.iterusers)N) �__name__�
__module__� __qualname__r r& r- r: r( rA rB rG rJ r r r r r - s
r c @ sN e Zd ZdZdZdd� Zdd� Zdd� Zddd �Zd
d � Z d d
� Z
dd� Z dS )�UserNc C s || _ g | _t� | _d S r! )r �groupsr � lastMessager r r r r � s z
User.__init__c C s || _ || _t� | _d S r! )�realm�mindr �signOn)r rQ rR r r r �loggedIn� s z
User.loggedInc s � �fdd�}� � �j��|�S )Nc s �j �� � | S r! )rO r5 �r+ ��groupr r r �cbJoin� s zUser.join.<locals>.cbJoin)r: rR r7 )r rW rX r rV r �join� s z User.joinc s" � �fdd�}� � �j|��|�S )Nc s �j �� � | S r! )rO r( rU rV r r �cbLeave� s zUser.leave.<locals>.cbLeave)r( rR r7 )r rW r> rZ r rV r �leave� s z
User.leavec C s t � | _|�| j||�S r! )r rP rB rR )r rD rE r r r �send� s z User.sendc C s
t | j�S r! )rH rO r@ r r r �
itergroups� s zUser.itergroupsc C s" | j d d � D ]}| �|� qd S r! )rO r[ )r �gr r r �logout� s z User.logout)N) rK rL rM rQ rR r rT rY r[ r\ r] r_ r r r r rN � s
rN zNickServ!NickServ@servicesc @ s� e Zd ZdZdZdZdZdZdZdd� Z dd� Z
dd � Z d
d � Z dPd d
�Z
dd� Zdd� ZdZdZdd� Zdd� Zdd� Zdd� Zdd� Zejd fejd fejd fejd fgZ ej d fej d!fgZ d"d#� Z d$d%� Z!d&d'� Z"d(d)� Z#dQd*d+�Z$dRd,d-�Z%d.d/� Z&d0d1� Z'd2d3� Z(d4d5� Z)d6d7� Z*d8d9� Z+d:d;� Z,d<d=� Z-d>d?� Z.d@dA� Z/dBdC� Z0dDdE� Z1dFdG� Z2dHdI� Z3dJdK� Z4dLdM� Z5dNdO� Z6dS )S�IRCUserzM
Protocol instance representing an IRC user connected to the server.
N�utf-8c C s | j | _| jj| _| jj| _d S r! )�irc_NICKSERV_PRIVMSG� irc_PRIVMSG�factoryrQ r �hostnamer@ r r r �connectionMade� s
zIRCUser.connectionMadec C s | j d k r| � � d | _d S r! )r_ �avatar�r r> r r r �connectionLost� s
zIRCUser.connectionLostc O s� d|kr| j |d< d|kr,| j�| j�|d< | ||d gt|� }g }|D ]"}t|t�rb|�d�}|�|� qJt j
j ||� d S )N�prefix�tora ) re r �encode�encoding�list�
isinstance�bytes�decoder5 r �IRC� sendMessage)r ZcommandZparameter_list�kwZarglistZarglistUnicode�argr r r rs � s
zIRCUser.sendMessagec C s& | � d|j|j| jf d|j � d S )N�%s!%s@%s�#)rY r re �r rW r, r r r r3 � s �zIRCUser.userJoinedc C s, | � d|j|j| jf d|j |p$d� d S )Nrv rw Zleaving)�partr re �r rW r, r> r r r r= � s
�zIRCUser.userLeftc C sZ t j�|�rd|j }n|j}|�dd�}|�� D ]"}| �d|j|j| jf ||� q2d S )Nrw �textz <an unrepresentable message>rv )r �IGroupr0 r �get�
splitlines�privmsgre )r rC rD rE Z
recipientNamer{ �Lr r r rB � s �zIRCUser.receivec C sD d|kr@|d }|� dd�}| �| jd|j |d||| jf � d S )Nr r r rw rv )r} r r re )r rW r r �authorr r r rF s �zIRCUser.groupMetaUpdatec C s |d | _ dS )z�
Password message -- Register a password.
Parameters: <password>
[REQUIRED]
Note that IRC requires the client send this *before* NICK
and USER.
���N)�password�r rj �paramsr r r �irc_PASS s zIRCUser.irc_PASSc C s� |d }zt |t�r |�| j�}W n2 tk
rT | �tt|�d� | j� � Y dS X || _
|| _ | j D ] \}}| �
||| jj � qh| jdkr�| �t|d� n| j}d| _| �||� dS )zh
Nick message -- Set your nickname.
Parameters: <nickname>
[REQUIRED]
r z;Your nickname cannot be decoded. Please use ASCII or UTF-8.Nz Password?)ro rp rq rm �UnicodeDecodeErrorr �NICKSERV�repr� transport�loseConnection�nicknamer �
_motdMessagesrs rd � _serverInfor� �logInAs)r rj r� r� �coder{ r� r r r �irc_NICK s2
�
�zIRCUser.irc_NICKc C s |d | _ dS )zk
User message -- Set your realname.
Parameters: <user> <mode> <unused> <realname>
r� N)Zrealnamer� r r r �irc_USERC s zIRCUser.irc_USERc C s` |d }|d }| j dkr&| j�� n6|�� dkrD| �t| j d� n| j }d| _ | �||� dS )�^
Send a (private) message.
Parameters: <msgtarget> <text to be sent>
r r� NZnickservz1Denied. Please send me (NickServ) your password.)r� r� r� �lowerr r� r� )r rj r� �targetr� r� r r r rb O s
�z IRCUser.irc_NICKSERV_PRIVMSGc C s6 | j j�t�||�| tj�}|j| j| j |fd� d S )N)Z errbackArgs)
rd r Zloginr ZUsernamePasswordr �IUser� addCallbacks�_cbLogin�_ebLogin)r r� r� r9 r r r r� f s
�zIRCUser.logInAsz:connected to Twisted IRCzA:Your host is %(serviceName)s, running version %(serviceVersion)sz,:This server was created on %(creationDate)sz&%(serviceName)s %(serviceVersion)s w nz(:- %(serviceName)s Message of the Day - z:End of /MOTD command.c C sZ |\}}}|t jks"td|f ��| `|| _|| _| jD ] \}}| �||| jj � q8d S )NzRealm is buggy, got %r)
r r� r1 rc rg r_ �_welcomeMessagesrs rd r� )r r+ �ifacerg r_ r� r{ r r r r� � s
zIRCUser._cbLoginc C sh |� tj�r | �t|d� n>|� tj�r8| �t|d� n"t�d� t� |� | �t|d� | j
� � d S )Nz*Already logged in. No pod people allowed!zLogin failed. Goodbye.z Unhandled error during login:z"Server error during login. Sorry.) Zcheckr �AlreadyLoggedInr r� �ecredZUnauthorizedLoginr �msgr$ r� r� )r r$ r� r r r r� � s( � �
�zIRCUser._ebLoginc C s | j dk r| �d| j� dS )zK
Ping message
Parameters: <server1> [ <server2> ]
NZPONG)rQ rs re r� r r r �irc_PING� s
zIRCUser.irc_PINGc C s | j �� dS )z>
Quit
Parameters: [ <Quit Message> ]
N)r� r� r� r r r �irc_QUIT� s zIRCUser.irc_QUITc G s. |r| � tjd� n| �| jd|j d� d S )N�:Unknown MODE flag.rw �+)rs r �ERR_UNKNOWNMODEZ channelModer )r rW �modes�argsr r r � _channelMode� s �zIRCUser._channelModec C s@ |r| � tjd� n(|| jkr.| � tjd� n| � tjd� d S )Nr� r� z(:You can't look at someone else's modes.)rs r r� rg Z RPL_UMODEISZERR_USERSDONTMATCH)r r, r� r r r � _userMode� s �
��zIRCUser._userModec s� z"� d }t |t�r |��j�}W n* tk
rL ��tj� d d� Y dS X |�d�r�� �fdd�}�j �
|dd� �}|j �j |t
� dd� �d� n6�fd d
�}�j �|�}|j �j|t
� dd� �d� dS ) z�
User mode message
Parameters: <nickname>
*( ( "+" / "-" ) *( "i" / "w" / "o" / "O" / "r" ) )
r z2:No such nickname (could not decode your unicode!)Nrw c s$ | � tj� ��tj� d d� d S )Nr � :That channel doesn't exist.��trapr � NoSuchGrouprs r �ERR_NOSUCHCHANNEL�r$ �r� r r r �ebGroup� s �z!IRCUser.irc_MODE.<locals>.ebGroup� )Z callbackArgsc s � � tjd� d S )Nz:No such nickname.�rs r �ERR_NOSUCHNICKr� r@ r r �ebUser� s �z IRCUser.irc_MODE.<locals>.ebUser)ro rp rq rm r� rs r r� �
startswithrQ � lookupGroupr� r� �tuple�
lookupUserr� )r rj r� �
channelOrUserr� r9 r� r r� r �irc_MODE� s4
�
� �zIRCUser.irc_MODEc C s dS )zl
Userhost message
Parameters: <nickname> *( SPACE <nickname> )
[Optional]
Nr r� r r r � irc_USERHOST� s zIRCUser.irc_USERHOSTc s� z"|d �t �t�r ���j��W n* tk
rL ��tj|d d� Y dS X |d � ��d�rv�j �
�dd� �}n�j � ��� dd� �}� �fd d
�}��fd d �}|�
||� dS )
r� r z6:No such nick/channel (could not decode your unicode!)Nr� rw r� c S s | j S r! )rR �r, r r r �<lambda> � z%IRCUser.irc_PRIVMSG.<locals>.<lambda>c s | d k r�j �| d� i�S d S )Nr{ )rg r\ )Ztarg)� messageTextr r r �cbTarget s z%IRCUser.irc_PRIVMSG.<locals>.cbTargetc s � � tj�d� d S )Nz:No such nick/channel.r� r� )r �
targetNamer r �ebTarget$ s
�z%IRCUser.irc_PRIVMSG.<locals>.ebTarget)ro rp rq rm r� rs r r� r� rQ r� r� r7 r� )r rj r� r� r� r� r )r� r r� r rc
s$
�
zIRCUser.irc_PRIVMSGc s� z"|d � t � t�r � ��j�� W n* tk
rL ��tj|d d� Y dS X � �d�rd� dd� � �fdd�}� �fdd �}�j �
� �� ||� dS )
zm
Join message
Parameters: ( <channel> *( "," <channel> ) [ <key> *( "," <key> ) ] )
r �1:No such channel (could not decode your unicode!)Nrw r� c s � �fdd�}�j �� ��|�S )Nc s> �� � �� ���jd� j dd� � �� D �� ��� � d S )Nrw c S s g | ]
}|j �qS r �r ��.0r, r r r �
<listcomp>E s zEIRCUser.irc_JOIN.<locals>.cbGroup.<locals>.cbJoin.<locals>.<listcomp>)r3 �namesr rJ �
_sendTopic)ZignrV r r rX @ s �z1IRCUser.irc_JOIN.<locals>.cbGroup.<locals>.cbJoin�rg rY r7 )rW rX r@ �rW r �cbGroup? s z!IRCUser.irc_JOIN.<locals>.cbGroupc s �� tjd� d� d S )Nrw z:No such channel.)rs r r� r� �� groupNamer r r r� I s
�z!IRCUser.irc_JOIN.<locals>.ebGroup) ro rp rq rm r� rs r r� r� rQ �getGroupr� �r rj r� r� r� r r� r �irc_JOIN, s
�
zIRCUser.irc_JOINc s� z*|d � t |d t�r(|d ��j�� W n* tk
rT ��tj|d d� Y dS X � �d�rl� dd� � t |�dkr�|d �t �t�r���d��nd���fdd�}� �fd d
�}�j
� � �� ||� dS ) zc
Part message
Parameters: <channel> *( "," <channel> ) [ <Part Message> ]
r z :Could not decode your unicode!Nrw r� ra c s$ � ��fdd�}�j �� ���|�S )Nc s �� � ��� d S r! )r= rU )rW r> r r r rZ l s z2IRCUser.irc_PART.<locals>.cbGroup.<locals>.cbLeave)rg r[ r7 )rW rZ )r> r r� r r� k s z!IRCUser.irc_PART.<locals>.cbGroupc s, | � tj� ��tjd� d| �� � d S )Nrw �:)r� r r� rs r �ERR_NOTONCHANNELr) r� r� r r r� p s
�z!IRCUser.irc_PART.<locals>.ebGroup)
ro rp rq rm r� rs r r� r� r? rQ r� r� r� r )r� r> r r �irc_PARTQ s* �
zIRCUser.irc_PARTc s� z"|d � t � t�r � ��j�� W n* tk
rL ��tj|d d� Y dS X � �d�rd� dd� � �fdd�}� �fdd �}�j �
� �� ||� dS )
zb
Names message
Parameters: [ <channel> *( "," <channel> ) [ <target> ] ]
r� r� Nrw r� c s( � � � jd| j dd� | �� D �� d S )Nrw c S s g | ]
}|j �qS r r� r� r r r r� � s z6IRCUser.irc_NAMES.<locals>.cbGroup.<locals>.<listcomp>)r� r rJ r� r@ r r r� � s
�z"IRCUser.irc_NAMES.<locals>.cbGroupc s$ | � tj� ���jd� g � d S )Nrw )r� r r� r� r r� ��channelr r r r� � s �z"IRCUser.irc_NAMES.<locals>.ebGroup) ro rp rq rm r� rs r r� r� rQ r� r� r� r r� r � irc_NAMESz s
�
zIRCUser.irc_NAMESc C s� z&|d }t |d t�r$|�| j�}W n$ tk
rJ | �tjd� Y dS X |�d�rb|dd� }t |�dkr�| �
||d � n
| � |� dS )zJ
Topic message
Parameters: <channel> [ <topic> ]
r z<:That channel doesn't exist (could not decode your unicode!)Nrw r� ) ro rp rq rm r� rs r r� r� r? � _setTopic� _getTopic)r rj r� r� r r r � irc_TOPIC� s �
zIRCUser.irc_TOPICc C s` |j �d�}|r\|j �d�p d}|j �dd�}| �| jd|j |� | �| jd|j ||� dS )zP
Send the topic of the given group to this user, if it has one.
r r z<noone>�
topic_dater rw N)r r} r r Z topicAuthor)r rW r r� �dater r r r� � s zIRCUser._sendTopicc s( � �fdd�}�j �� ���j|� d S )Nc s" | � tj� ��tjd� d� d S �N�=r� r� r� r� r r r� � s �z"IRCUser._getTopic.<locals>.ebGroup)rQ r� r� r� )r r� r� r r� r r� � s zIRCUser._getTopicc s4 ��fdd�}� �fdd�}�j �� ��||� d S )Nc sH � j �� }�|d< �j|d< tt� �|d< � �fdd�}� �|��|�S )Nr r r� c s �� tjd� j d� d S )Nrw z.:You need to be a channel operator to do that.)rs r ZERR_CHANOPRIVSNEEDEDr r� rV r r �ebSet� s
�z1IRCUser._setTopic.<locals>.cbGroup.<locals>.ebSet)r �copyr �intr rG r4 )rW ZnewMetar� )r r r� r r� � s
z"IRCUser._setTopic.<locals>.cbGroupc s" | � tj� ��tjd� d� d S r� r� r� r� r r r� � s �z"IRCUser._setTopic.<locals>.ebGroup)rQ r� r� )r r� r r� r� r )r� r r r r� � s zIRCUser._setTopicc C s< |D ]$\}}}| � tj|t|�d| � q| � tjd� dS )z�
Send a group of LIST response lines
@type channel: C{list} of C{(str, int, str)}
@param channel: Information about the channels being sent:
their name, the number of participants, and their topic.
r� z
:End of /LISTN)rs r ZRPL_LIST�strZ RPL_LISTEND)r �channelsr rA r r r r rn � s z IRCUser.listc s� |r�z,|d }t |t�r$|�� j�}|�d�}W n* tk
rZ � �tj|d d� Y dS X g }|D ],}|� d�r~|dd� }|�
� j � |�� qdt
j|dd�}|�d d
� � n
� j �� }� fd d �}|�|� dS )
z�
List query
Return information about the indicated channels, or about all
channels if none are specified.
Parameters: [ <channel> *( "," <channel> ) [ <target> ] ]
r �,r� Nrw r� T)Z
consumeErrorsc S s dd� | D �S )Nc S s g | ]\}}|r|�qS r r �r� �s�rr r r r� s z6IRCUser.irc_LIST.<locals>.<lambda>.<locals>.<listcomp>r )Zgsr r r r� r� z"IRCUser.irc_LIST.<locals>.<lambda>c s6 dd� � t �� fdd�| D ��}|��fdd�� |S )Nc S s |j | |j�d�fS )Nr )r r r} )rA rW r r r �gotSize" s z3IRCUser.irc_LIST.<locals>.cbGroups.<locals>.gotSizec s g | ]}|� � �� |��qS r )rA r7 �r� rW �r� r r r� $ s z6IRCUser.irc_LIST.<locals>.cbGroups.<locals>.<listcomp>c s � � dd� | D ��S )Nc S s g | ]\}}|r|�qS r r r� r r r r� & s zHIRCUser.irc_LIST.<locals>.cbGroups.<locals>.<lambda>.<locals>.<listcomp>)rn )r* r@ r r r� & r� z4IRCUser.irc_LIST.<locals>.cbGroups.<locals>.<lambda>)r r6 r7 )rO r9 r@ r� r �cbGroups! s �z"IRCUser.irc_LIST.<locals>.cbGroups)ro rp rq rm �splitr� rs r r� r� r5 rQ r� r r6 r7 r] )r rj r� Z allChannelsr� rO Zchr� r r@ r �irc_LIST� s.
�
zIRCUser.irc_LISTc s, � � � jd|j � fdd�|�� D �� d S )Nrw c s* g | ]"}|j � j� jj |j d d|j f�qS )�Hr )r re rQ )r� �mr@ r r r� - s z'IRCUser._channelWho.<locals>.<listcomp>)Zwhor rJ �r rW r r@ r � _channelWho+ s �zIRCUser._channelWhoc C s | � tjd� d S )Nz:User /WHO not implemented)rs r � RPL_ENDOFWHO�r r, r r r �_userWho0 s �zIRCUser._userWhoc s� |s�� tjd� dS z"|d � t� t�r6� ��j�� W n* tk
rb �� tj|d d� Y dS X � �d�r�� �fdd�}�j �
� dd� �}|� �j |� n(� �fd d
�}�j �
� �}|� �j|� dS ) zC
Who query
Parameters: [ <mask> [ "o" ] ]
z:/WHO not supported.Nr z2:End of /WHO list (could not decode your unicode!)rw c s | � tj� ��tj� d� d S �Nz:End of /WHO list.)r� r r� rs r r� r� �r� r r r r� S s �z IRCUser.irc_WHO.<locals>.ebGroupr� c s | � tj� ��tj� d� d S r� )r� r �
NoSuchUserrs r r� r� r� r r r� [ s �z IRCUser.irc_WHO.<locals>.ebUser)rs r r� ro rp rq rm r� r� rQ r� r� r� r� r� )r rj r� r� r9 r� r r� r �irc_WHO5 s*
�
zIRCUser.irc_WHOc s� �fdd�}� �fdd�}z"� d }t |t�r:|��j�}W n* tk
rf ��tj� d d� Y dS X �j� |��
||� dS )zV
Whois query
Parameters: [ <target> ] <mask> *( "," <mask> )
c sN � � � j| j| j� jj| j� jjddtt� | j �| jdd� | �� D �� d S )NzHi mom!Fc S s g | ]}d |j �qS )rw r� r� r r r r� q s z5IRCUser.irc_WHOIS.<locals>.cbUser.<locals>.<listcomp>)Zwhoisr rQ r� r rP rS r] r� r@ r r �cbUserk s �z!IRCUser.irc_WHOIS.<locals>.cbUserc s$ | � tj� ��tj� d d� d S )Nr �:No such nick/channel)r� r r� rs r r� r� r� r r r� s s �z!IRCUser.irc_WHOIS.<locals>.ebUserr r� N) ro rp rq rm r� rs r r� rQ r� r� )r rj r� r� r� r, r r� r � irc_WHOISe s
�zIRCUser.irc_WHOISc C s | � tjd� dS )zE
Oper message
Parameters: <name> <password>
z:O-lines not applicableN)rs r ZERR_NOOPERHOSTr� r r r �irc_OPER� s zIRCUser.irc_OPER)N)N)N)7rK rL rM �__doc__rO r_ rg rQ rm rf ri rs r3 r= rB rF r� r� r� r� r� rb r� r Z RPL_WELCOMEZ RPL_YOURHOSTZ RPL_CREATEDZ
RPL_MYINFOr� Z
RPL_MOTDSTARTZ
RPL_ENDOFMOTDr� r� r� r� r� r� r� r� r� rc r� r� r� r� r� r� r� rn r� r� r� r� r� r� r r r r r` � s~
% ��������
* "%)'
00$r` c @ s e Zd ZdZeZdd� ZdS )�
IRCFactorya
IRC server that creates instances of the L{IRCUser} protocol.
@ivar _serverInfo: A dictionary mapping:
"serviceName" to the name of the server,
"serviceVersion" to the copyright version,
"creationDate" to the time that the server was started.
c C s& || _ || _| j jtjt� d�| _d S )N)Z serviceNameZserviceVersionZ creationDate)rQ r r r �versionr r� )r rQ r r r r r � s �zIRCFactory.__init__N)rK rL rM r� r` r
r r r r r r� � s r� c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�PBMindc C s d S r! r r@ r r r r � s zPBMind.__init__c C s. t �t�}t|t�r |�d�}||j�| �fS �Nra )r
�qualr� ro r rl �invoker�registerReference�r �jellierr r r r �jellyFor� s
zPBMind.jellyForc C s d S r! r )r r, rW r r r �remote_userJoined� s zPBMind.remote_userJoinedc C s d S r! r )r r, rW r> r r r �remote_userLeft� s zPBMind.remote_userLeftc C s d S r! r )r rC rD rE r r r �remote_receive� s zPBMind.remote_receivec C s d S r! r �r rW r r r r �remote_groupMetaUpdate� s z PBMind.remote_groupMetaUpdateN) rK rL rM r r r r r r r r r r r� � s r� c @ s. e Zd Zdd� Zdd� Zdd� Zd
dd �ZdS ) �PBMindReferencec C sJ t j�|�r t| j| j|�}nt| j| j|�}| �dt| j| j|�||�S )NrB )r r| r0 �PBGrouprQ rg �PBUser�
callRemote)r rC rD rE Zrecr r r rB � s �zPBMindReference.receivec C s | � dt| j| j|�|�S )NrF )r r
rQ rg r
r r r rF � s
�z PBMindReference.groupMetaUpdatec C s& | � dt| j| j|�t| j| j|��S )Nr3 �r r
rQ rg r rx r r r r3 � s
�zPBMindReference.userJoinedNc C s( | � dt| j| j|�t| j| j|�|�S )Nr= r rz r r r r= � s �zPBMindReference.userLeft)N)rK rL rM rB rF r3 r= r r r r r � s r c @ s6 e Zd Zdd� Zdd� Zdd� Zd dd �Zd
d � ZdS )
r
c C s || _ || _|| _d S r! )rQ rg rW )r rQ rg rW r r r r � s zPBGroup.__init__c C s t | jj| jj| jjf�S r! )�hashrQ r rg rW r@ r r r �processUniqueID� s zPBGroup.processUniqueIDc C sN t �| j�}t|t�r |�d�}| jj}t|t�r<|�d�}|||j� | �fS r )
r
r � __class__ro r rl rW r r r )r r r rW r r r r � s
zPBGroup.jellyForNc C s | j �| j|�S r! )rg r[ rW rh r r r � remote_leave� s zPBGroup.remote_leavec C s | j �| j|�S r! )rg r\ rW �r rE r r r � remote_send� s zPBGroup.remote_send)N)rK rL rM r r r r r r r r r r
� s
r
c @ s& e Zd Zdd� Zddd�Zdd� ZdS ) �PBGroupReferencec C sF |\}}}|| _ ttkr2t| j t�r2| j �d�| _ tj�| |||g�S r )r rp r� ro rq r �RemoteReference�
unjellyFor)r Z unjellierZ unjellyListZclsNamer �refr r r r s
zPBGroupReference.unjellyForNc C s | � d|�S )Nr[ �r rh r r r r[ s zPBGroupReference.leavec C s | � d|�S )Nr\ r r r r r r\
s zPBGroupReference.send)N)rK rL rM r r[ r\ r r r r r � s
r c @ s e Zd Zdd� Zdd� ZdS )r c C s || _ || _|| _d S r! )rQ rg r, )r rQ rg r, r r r r s zPBUser.__init__c C s t | jj| jj| jjf�S r! )r rQ r rg r, r@ r r r r s zPBUser.processUniqueIDN)rK rL rM r r r r r r r s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�
ChatAvatarc C s
|| _ d S r! )rg )r rg r r r r s zChatAvatar.__init__c C s0 t �| j�}t|t�r |�d�}||j�| �fS r )r
r r ro r rl r r r r r r r s
zChatAvatar.jellyForc s( � fdd�}� j j�|�}|�|� |S )Nc s( � �fdd�}�j �� �}|�|� |S )Nc s t �jj�j� �S r! )r
rg rQ )ZignoredrV r r rX ' s z7ChatAvatar.remote_join.<locals>.cbGroup.<locals>.cbJoinr� )rW rX r9 r@ r� r r� & s
z'ChatAvatar.remote_join.<locals>.cbGroup)rg rQ r� r7 )r r� r� r9 r r@ r � remote_join% s
zChatAvatar.remote_joinN)rK rL rM r r r r r r r r s r c @ s e Zd Zdd� Zdd� ZdS )�AvatarReferencec C s | � d|�S )NrY r )r r� r r r rY 2 s zAvatarReference.joinc s, t �� � | j�� fdd�� | jj�� � S )Nc s
� � d �S r! )�callbackr �r9 r r r� 7 r� z&AvatarReference.quit.<locals>.<lambda>)r ZDeferredZbrokerZnotifyOnDisconnectr� r� r@ r r r �quit5 s zAvatarReference.quitN)rK rL rM rY r! r r r r r 1 s r c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd Z d
Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zd d � Zd S ) �
WordsRealmra c C s
|| _ d S r! r� r r r r r B s zWordsRealm.__init__c C s t |�S r! )rN r r r r � userFactoryF s zWordsRealm.userFactoryc C s t |�S r! )r r r r r � groupFactoryJ s zWordsRealm.groupFactoryc s � �fdd�}|S )Nc s" t �ddd� �� d � _� _d S )Nr_ c S s d S r! r r r r r r� Q r� z:WordsRealm.logoutFactory.<locals>.logout.<locals>.<lambda>)�getattrrQ rR r �rg �facetr r r_ O s z(WordsRealm.logoutFactory.<locals>.logoutr )r rg r' r_ r r& r �
logoutFactoryN s zWordsRealm.logoutFactoryc s8 t � t�r� ��j�� � ���fdd�}��� ��|�S )Nc sp | j d k rt�� ��D ]J}|| d �}|d k r| ���� � �_��_ | �_||��| |�f S qt����d S r! )rQ r r� rT r rg r( �NotImplementedError)rg r� r' ��avatarId�
interfacesrR r r r � gotAvatarZ s
z+WordsRealm.requestAvatar.<locals>.gotAvatar)ro rp rq � _encoding�getUserr7 )r r+ rR r, r- r r* r �
requestAvatarV s
zWordsRealm.requestAvatarFTc C s t �d S r! �r) r r r r r� n s zWordsRealm.lookupUserc C s t �d S r! r1 r� r r r r� r s zWordsRealm.lookupGroupc C s t �dS )a�
Add the given user to this service.
This is an internal method intended to be overridden by
L{WordsRealm} subclasses, not called by external code.
@type user: L{IUser}
@rtype: L{twisted.internet.defer.Deferred}
@return: A Deferred which fires with L{None} when the user is
added, or which fails with
L{twisted.words.ewords.DuplicateUser} if a user with the
same name exists already.
Nr1 r� r r r �addUserv s zWordsRealm.addUserc C s t �dS )aY
Add the given group to this service.
@type group: L{IGroup}
@rtype: L{twisted.internet.defer.Deferred}
@return: A Deferred which fires with L{None} when the group is
added, or which fails with
L{twisted.words.ewords.DuplicateGroup} if a group with the
same name exists already.
Nr1 r� r r r �addGroup� s zWordsRealm.addGroupc s. �j r$� �fdd�}��� ��|�S ��� �S )Nc s | � tj� ��� �S r! )r� r �DuplicateGroupr� r� �r r r r r� � s z$WordsRealm.getGroup.<locals>.ebGroup)�createGroupOnRequest� createGroupr4 r� )r r r� r r5 r r� � s zWordsRealm.getGroupc s. �j r$� �fdd�}��� ��|�S ��� �S )Nc s | � tj� ��� �S r! )r� r �
DuplicateUserr� r� r5 r r r� � s z"WordsRealm.getUser.<locals>.ebUser)�createUserOnRequest�
createUserr4 r� )r r r� r r5 r r/ � s zWordsRealm.getUserc sH � fdd�}� �fdd�}� � � � ��� �}|�||� |��j� |S )Nc s t �t�� ��S r! )r r" r r8 r� r� r r �cbLookup� s z'WordsRealm.createUser.<locals>.cbLookupc s | � tj� ��� �S r! )r� r r� r# r� r5 r r �ebLookup� s z'WordsRealm.createUser.<locals>.ebLookup)r� r� r� r7 r2 �r r r; r< r9 r r5 r r: � s
zWordsRealm.createUserc sH � fdd�}� �fdd�}� � � � ��� �}|�||� |��j� |S )Nc s t �t�� ��S r! )r r" r r4 r� r� r r r; � s z(WordsRealm.createGroup.<locals>.cbLookupc s | � tj� ��� �S r! )r� r r� r$ r� r5 r r r< � s z(WordsRealm.createGroup.<locals>.ebLookup)r� r� r� r7 r3 r= r r5 r r7 � s
zWordsRealm.createGroupN)rK rL rM r. r r# r$ r( r0 r6 r9 r� r� r2 r3 r� r/ r: r7 r r r r r" > s r" c sD e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Z� Z S )
�InMemoryWordsRealmc s" t t| �j||� i | _i | _d S r! )�superr> r r rO )r �art �r r r r � s zInMemoryWordsRealm.__init__c C s t �t| j��S r! )r r8 r rO r@ r r r r] � s z InMemoryWordsRealm.itergroupsc C s6 |j | jkr t�t�t�� ��S || j|j < t�|�S r! ) r r r �failr r" r r8 r8 r� r r r r2 � s zInMemoryWordsRealm.addUserc C s6 |j | jkr t�t�t�� ��S || j|j < t�|�S r! ) r rO r rB r r" r r4 r8 r� r r r r3 � s zInMemoryWordsRealm.addGroupc
C sP |� � }z| j| }W n* tk
r@ t�t�t�|��� Y S X t� |�S d S r! )
r� r r< r rB r r" r r� r8 )r r r, r r r r� � s z InMemoryWordsRealm.lookupUserc
C sP |� � }z| j| }W n* tk
r@ t�t�t�|��� Y S X t� |�S d S r! )
r� rO r< r rB r r" r r� r8 )r r rW r r r r� � s z InMemoryWordsRealm.lookupGroup)
rK rL rM r r] r2 r3 r� r� �
__classcell__r r rA r r> � s
r> N):r� r r Zzope.interfacer Ztwistedr Z twisted.credr r r r� Ztwisted.internetr r
Ztwisted.pythonr r r
Ztwisted.python.compatr r Ztwisted.python.componentsr Ztwisted.spreadr Z
twisted.wordsr r Ztwisted.words.protocolsr r| �objectr r� rN r� r/ rr r` Z
ServerFactoryr� Z
Referenceabler� r r ZsetUnjellyableForClassr
r r r Z IPerspectiver ZIRealmZ IChatServicer" r> �__all__r r r r �<module> s^ S, e
- �