| Server IP : 182.53.201.61 / Your IP : 216.73.217.175 Web Server : Apache/2.2.15 (Fedora) System : Linux km10.dyndns.org 2.6.31.5-127.fc12.i686.PAE #1 SMP Sat Nov 7 21:25:57 EST 2009 i686 User : apache ( 48) PHP Version : 5.3.3 Disable Function : NONE MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib/python2.6/site-packages/papyon/ |
Upload File : |
Ñò
O Jc
@ sÀ d Z d d k Z d d k Z d d k Z d d k i Z d d k l Z d d k l Z d d k
l Z l Z l
Z
d g Z e i d ƒ Z d e f d „ ƒ YZ d e i f d
„ ƒ YZ d S( s› Switchboard Manager
The switchboard manager is responsible for managing all the switchboards in
use, it simplifies the complexity of the switchboard crack.iÿÿÿÿN( t
ServerType( t WeakSet( t ConversationErrorTypet ContactInviteErrort MessageErrort SwitchboardManagers# papyon.protocol.switchboard_managert SwitchboardClientc B sû e Z d d „ Z e d d „ ƒ Z e d „ ƒ Z d „ Z d „ Z e e e ƒ Z
e e ƒ Z h e i
i d d d „ Z d „ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( ic c C s› | | _ t i | i i ƒ | _ d | _ t | _ | | _ t | ƒ | _
g | _ | i i d j o | i
i
| i i ƒ n t ƒ | _ | i ƒ d S( Ni ( t _clientt weakreft proxyt _switchboard_managert Nonet _SwitchboardClient__switchboardt Falset _switchboard_requestedt _switchboard_priorityt sett _pending_invitest _pending_messagest protocol_versiont addt profilet participantst _process_pending_queues( t selft clientt contactst priority( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __init__( s c C s t S( N( R
( t messaget switchboard_client( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _can_handle_message8 s c C s | i | i BS( N( R R ( R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt total_participants= s c C s | i S( N( R ( R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __get_switchboardA s c sì t i | ƒ ˆ _ t ˆ _ t | i i ƒ ƒ ˆ _ ˆ i i d ‡ f d † ƒ ˆ i i d ‡ f d † ƒ ˆ i i d ‡ f d † ƒ ˆ i i d ‡ f d † ƒ ˆ i i d ‡ f d
† ƒ t
i d ƒ ‡ f d † } t i
| ƒ d S(
Ns notify::invitingc s
ˆ i ƒ S( ( t, _SwitchboardClient__on_user_inviting_changed( t sbt pspec( R ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt <lambda>I s s user-joinedc s
ˆ i | ƒ S( ( t" _SwitchboardClient__on_user_joined( R# t contact( R ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR% K s s user-leftc s
ˆ i | ƒ S( ( t _SwitchboardClient__on_user_left( R# R' ( R ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR% M s s user-invitation-failedc s
ˆ i | ƒ S( ( t- _SwitchboardClient__on_user_invitation_failed( R# R' ( R ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR% O s s message-undeliveredc s
ˆ i | ƒ S( ( t* _SwitchboardClient__on_message_undelivered( R# t command( R ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR% Q s s New switchboard attachedc s ˆ i ƒ t S( N( R R
( ( R ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt process_pending_queuesS s
( R R R R
R R R t valuest switchboardt connectt loggert infot gobjectt idle_add( R R. R, ( ( R s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __set_switchboardC s
c
C sŽ t i | i i ƒ } | i d d ƒ | | _ x* | i ƒ D] \ } } | i | | ƒ q; W| | _ | i i | | | | f ƒ | i
ƒ d S( Ns MIME-Versions 1.0( t msnpt MessageR R t
add_headert content_typet iteritemst bodyR t appendR (
R R8 R: t headerst ackt callbackt cb_argsR t keyt value( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt
_send_message\ s
c C s | i i | ƒ | i ƒ d S( N( R R R ( R R' ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _invite_userh s c C s | i i | ƒ d S( N( R
t
close_handler( R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _leavel s c C s
t ‚ d S( N( t NotImplementedError( R R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _on_message_receivedp s c C s
t ‚ d S( N( RF ( R R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _on_message_sents s c C s
t ‚ d S( N( RF ( R R' ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _on_contact_joinedv s c C s
t ‚ d S( N( RF ( R R' ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _on_contact_lefty s c C s
t ‚ d S( N( RF ( R t
error_typet error( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt _on_error| s c C s | i i p | i ƒ n d S( N( R. t invitingR ( R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __on_user_inviting_changed€ s
c C s1 | i i | ƒ | i i | ƒ | i | ƒ d S( N( R R R t discardRI ( R R' ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __on_user_joined„ s c C sf | i | ƒ | i i | ƒ t | i ƒ d j o/ | i i | ƒ y | i i ƒ Wqb qb Xn d S( Ni ( RJ R t removet lenR R t _switchboardt leave( R R' ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __on_user_left‰ s
c C s* | i i | ƒ | i t i t i ƒ d S( N( R RP RM R t CONTACT_INVITER t
NOT_AVAILABLE( R R' ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __on_user_invitation_failed“ s c C s | i t i t i ƒ d S( N( RM R t MESSAGER t DELIVERY_FAILED( R R+ ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt __on_message_undelivered˜ s c C sÞ t | i ƒ d j o t | i ƒ d j o d S| i ƒ o d Sx5 | i D]* } | | i j o | i i | ƒ qM qM Wt ƒ | _ | i i pF x6 | i D]+ \ } } } } | i i | | | | ƒ qž Wg | _ n d S( Ni (
RS R R t _request_switchboardR R. t invite_userR RN t send_message( R R' R R= R> R? ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR s
c C sŽ | i d j o | i i t i i j o t S| i o t St i
d ƒ t | _ | i | i O_ t
ƒ | _ | i i | | i ƒ | i S( Ns requesting new switchboard( R. R t stateR5 t
ProtocolStatet OPENR
R t TrueR0 R1 R R R R
t request_switchboardR ( R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR] ¯ s
N( ( t __name__t
__module__R t staticmethodR R t propertyR t# _SwitchboardClient__get_switchboardt# _SwitchboardClient__set_switchboardRT R. R5 t MessageAcknowledgementt HALFRB RC RE RG RH RI RJ RM R" R& R( R) R* R R] ( ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR ' s0
c B s e Z d Z h e i e i e e f f d 6Z d „ Z d „ Z d „ Z
d d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z d „ Z RS(
s” Switchboard management
@undocumented: do_get_property, do_set_property
@group Handlers: _handle_*, _default_handler, _error_handlers handler-createdc C su t i i | ƒ t i | ƒ | _ t ƒ | _ t ƒ | _ h | _
t ƒ | _ h | _ | i i
i d | i ƒ d S( s@ Initializer
@param client: the main Client instances switchboard-invitation-receivedN( R2 t GObjectR R R R R t _handlers_classR t _orphaned_handlerst
_switchboardst _orphaned_switchboardst _pending_switchboardst _protocolR/ t _ns_switchboard_invite( R R ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR È s c C s^ x | i D] } | i ƒ q
Wx | i D] } | i ƒ q( Wx | i D] } | i ƒ qF Wd S( N( Rq RU Rr Rp ( R R. ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt closeØ s
c G s | i i | | f ƒ d S( N( Rn R ( R t
handler_classt extra_arguments( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt register_handlerà s ic c
C so | i } | i i | ƒ x[ | i i ƒ D]J } t | i i ƒ ƒ } | | j o" | i | i | ƒ | | _ d Sq) Wxm t
| i ƒ D]\ } t | i i ƒ ƒ } | | j o4 t | g ƒ | i | <| i i | ƒ | | _ d Sq‡ Wxe | i i
ƒ D]T \ } } | i ƒ } | i | ƒ | i } | | j o | i | i | ƒ d Sq÷ W| i i i | | i | ƒ d S( N( R Ro RP Rp t keysR R R- R RT t listRq Rr R9 t popR Rs Rd t _ns_switchboard_request_response( R t handlerR t handler_participantsR. t switchboard_participantst handlerst pending_handler( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyRd ã s6
c C sè | i i | ƒ xl | i i ƒ D][ } | i | } | i | ƒ t | ƒ d j o( | i ƒ | i | =| i i | ƒ q q Wxb | i i ƒ D]Q } | i | } | i | ƒ t | ƒ d j o | i | =| i i | ƒ q q Wd S( Ni ( Ro RP Rp Ry RS RU Rq R Rr ( R R} R. R€ ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyRD s
c C s) | i | ƒ } t | g ƒ | i | <d S( N( t _build_switchboardR Rr ( R t sessionR} R. ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR| s c C s# | i | ƒ } | i i | ƒ d S( N( R‚ Rq R ( R t protocolRƒ t inviterR. ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyRt s c
C sŽ | \ } } } | i } | i } | i } | | t i | ƒ } t i | | | | | ƒ } | i d | i ƒ | i d | i ƒ | i
ƒ | S( Ns
notify::states message-received( R t _proxiest _transport_classR t SWITCHBOARDR5 t SwitchboardProtocolR/ t _sb_state_changedt _sb_message_receivedt establish_connection(
R Rƒ t servert
session_idR@ R t proxiest transport_classt transportR. ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR‚ s
c C sã | i } | t i i j oPt ƒ | i | <| | i j on | i | } xP t oH y- | i ƒ } | i | i | ƒ | | _
WqL t j
o PqL XqL W| i | =n xƒ t | i
ƒ D]r } t | i i ƒ ƒ } | i } | | j oA | i | i | ƒ | i
i | ƒ | i i | ƒ | | _
qº qº Wt | i | ƒ d j o | i | =| i i | ƒ qßnt | t i i j o` | | i i ƒ j o6 x% | i | D] } | i
i | ƒ q£W| i | =n | i i | ƒ n d S( Ni ( R` R5 Ra Rb R Rp Rr Rc R{ R RT t KeyErrorRz Ro R R- R RP Rq RS t CLOSEDRy ( R R. t
param_specR` R€ R} R R~ ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyRŠ - sB
c
C sä t | i i ƒ ƒ } | | i i ƒ j o| i | } g } | D] } | t | ƒ qC ~ } x; t | ƒ D]- } | i | | ƒ p ql n | i | ƒ ql Wx‘ | i D]‚ \ } } | | j o q§ n | i | ƒ p q§ n | | i
d | Œ } | i | ƒ | | _ | i
d | | ƒ | i | ƒ q§ Wn | t | i ƒ j o™ x– | i D]‡ \ } } | i | ƒ p qQn | | i
d | Œ } t | g ƒ | i | <| i i | ƒ | | _ | i
d | | ƒ | i | ƒ qQWn d S( Ns handler-created( ( ( R R R- Rp Ry t typeRz R RG Rn R R RT t emitRq RP (
R R. R R R€ t _[1]R} t handlers_classRv t
extra_args( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR‹ T s>
'
( Re Rf t __doc__R2 t SIGNAL_RUN_FIRSTt TYPE_NONEt objectt __gsignals__R Ru Rx Rd RD R| Rt R‚ RŠ R‹ ( ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyR ½ s # '( Rš t loggingR2 R t papyon.msnpR5 t papyon.transportR t papyon.util.weakR t papyon.eventR R R t __all__t getLoggerR0 R R Rm R ( ( ( s> /usr/lib/python2.6/site-packages/papyon/switchboard_manager.pyt <module> s –