-í ™º‘;cs­dZ dkZ dkZ dkZ dkZdkZeieƒdZdkZdk Z dk l Z dk Z de i fd„ƒYZ ˜deifd„ƒYZ½d„ZÅd e fd „ƒYZèd efd „ƒYZþd efd„ƒYZdfd„ƒYZ<edjob=dkZ>dkZ?deijo*@eiidƒAdGBeƒZn DeZFdeijo GeiidƒHdZn JdZLeiGHMeeiƒdjoNeieidƒZn PdZReej oKSeedeƒZTeo(Uee_ Vdk!Z!We!e_"nnYedeƒZZei#ƒndS(s5$Id: monitor.py,v 1.2 2000/09/09 22:44:06 adamf Exp $Ni(scountersmonitor_channelcsbdZd„Z,d„Z0d„Z4d„Z7d„Z>d„ZŒd„ZRS( Nicstii||ƒ||_||_|idƒ d|_"t i di i ƒ|_ #|idt idƒ$|it idƒ%|id|ƒ&|idƒ'|iƒ(|iiƒ|_)tƒ|_*g|_dS(Ns ss__main__sPython sWelcome to %s s&[Hint: try 'from __main__ import *'] (sasynchats async_chats__init__sselfssocksserversaddrsset_terminatorsdatassyssmoduless__dict__scopys local_envspushsversions copyrightspromptstotal_sessionssas_longsnumberscounters line_counters multi_line(sselfsserverssocksaddr((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys__init__s    cs,.|idƒdS(Nsÿý"(sselfspush(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyshandle_connect,scs-01|iiiƒ2tii|ƒdS(N(sselfsserversclosed_sessionss incrementsasynchats async_chatsclose(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysclose0scs45|idƒdS(Ns>>> (sselfspush(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysprompt4scsT78|i||_9t|iƒdjo!;|idƒ<|iƒndS(NisBCNU (sselfsdataslenspushsclose_when_done(sselfsdata((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyscollect_incoming_data7scs¯>?|i|iƒ}@d|_A|iiƒC| o|i oD|iƒEdSnF|ddgjo(G|idƒH|i ƒIdSnJe i }Ke i }LzˆMe||ƒ} N| e _ O| e _ PyñXy‰Y|io [e‚n\e|e|ƒdƒ}]e||iƒ}^d} _|ej o`e|ƒGHna||id %s((sselfs clean_linesdataslines line_counters increments multi_linespromptspushsclose_when_donessyssstdoutsoldoutsstderrsolderrsoutput_producersps SyntaxErrorscompilesreprscosevals local_envsresultsmethodsNonesappendsstringsjoinswhysasyncorescompact_tracebacksfilesfunstsvstbinfoslog_infosnumberspush_with_producer(sselfstbinfoscosolderrsresultsfileslineswhysoldoutspstsvsfunsmethod((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysfound_terminator>sp             !   $(  ,cs”Œg}Žxk|DŽ]`}t|ƒ}|djo;‘|ddgjo“|d }n•|i|ƒnqW–ti|dƒSdS(Niii±iÿÿÿÿs(scharsslineschsordsocsappendsstringsjoin(sselfslineschscharssoc((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys clean_lineŒs  (s try_linemodes__init__shandle_connectsclosespromptscollect_incoming_datasfound_terminators clean_line(((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysmonitor_channels       Nsmonitor_servercsQ˜šdeZœeZžddd„Z«d„Z®d„Z´d„ZRS(NsMonitor Server (V%s)s 127.0.0.1iWcs¾žŸ||_ ||_¡|ititiƒ¢|iƒ£|i||fƒ¤|i d|i |fƒ¥|i dƒ¦d|_ §d|_ ¨tƒ|_©tƒ|_dS(Ns%s started on port %dii(shostnamesselfsports create_socketssocketsAF_INETs SOCK_STREAMsset_reuse_addrsbindslog_infos SERVER_IDENTslistenscloseds failed_authsscounterstotal_sessionssclosed_sessions(sselfshostnamesport((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys__init__žs     cs«¬dSdS(Ni((sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyswritable«scsV®¯|iƒ\}}°|id|ƒ±|i|||ƒ²|iiƒdS(Ns&Incoming monitor connection from %s:%d(sselfsacceptsconnsaddrslog_infos channel_classstotal_sessionss increment(sselfsaddrsconn((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys handle_accept®scsG´µtid|id|id|iiƒ|iiƒƒSdS(Ns

%s

s
Total Sessions: %ss
Current Sessions: %d(s producersssimple_producersselfs SERVER_IDENTstotal_sessionssas_longsclosed_sessions(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysstatus´s(sVERSIONs SERVER_IDENTsmonitor_channels channel_classs__init__swritables handle_acceptsstatus(((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysmonitor_server˜s     csW½¾tiƒ}¿|i|ƒÀtitd„tt|iƒƒƒÂdƒSdS(NcsÁtt|ƒƒdS(Ni(shexsordsx(sx((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysÁss( smd5smsupdatesssstrings joinfieldssmapsNonesdigest(sssm((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys hex_digest½s'ssecure_monitor_channelcs&ÅÆdZÈd„ZØd„ZRS(NicsÎÈÉtii||ƒÊ||_Ë||_Ì|idƒÍd|_Ïh|_ Ñt t i ƒƒ|_ Òd|_ Ótƒ|_Ôt|iiƒƒ|_Õg|_Ö|i|i dƒdS(Ns si(sasynchats async_chats__init__sselfssocksserversaddrsset_terminatorsdatas local_envsstrstimes timestampscountscounters line_countersintstotal_sessionssas_longsnumbers multi_linespush(sselfsserverssocksaddr((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys__init__Ès      csØÙ|i oÜÚtd|i|iifƒ|ijoAÛ|id|dƒÜ|iid|i_Ý|i ƒnlßd|_à|i dt i dƒá|i t i dƒâ|i d|ƒã|iƒäd|_næti|ƒdS( Ns%s%ss%s: failed authorizationswarningisPython s sWelcome to %s s(sselfs authorizeds hex_digests timestampsserverspasswordsdataslog_infos failed_authssclosespushssyssversions copyrightspromptsmonitor_channelsfound_terminator(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysfound_terminatorØs,  (s authorizeds__init__sfound_terminator(((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyssecure_monitor_channelÅs  s secure_encrypted_monitor_channelcs2èdZéëd„Zñd„Zöd„ZRS(s+Wrap send() and recv() with a stream ciphercs\ëì|i}í|ii|ƒ|_î|ii|ƒ|_ïti ||||ƒdS(N( sserverspasswordskeysciphersnewsselfsoutgoingsincomingssecure_monitor_channels__init__sconnsaddr(sselfsserversconnsaddrskey((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys__init__ës cs/ñó|ii|ƒ}ôti||ƒSdS(N(sselfsoutgoingsencryptsdatasedssecure_monitor_channelssend(sselfsdatased((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyssendñscsMö÷ti||ƒ}ø|o ù|ii|ƒ}ú|Snü|SdS(N(ssecure_monitor_channelsrecvsselfs block_sizesdatasincomingsdecryptsdd(sselfs block_sizesdatasdd((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysrecvös   (s__doc__s__init__ssendsrecv(((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys secure_encrypted_monitor_channelès   ssecure_monitor_servercs,þÿeZddd„Zd„ZRS(NsiWcs)ti|||ƒ||_dS(N(smonitor_servers__init__sselfshostnamesportspassword(sselfspasswordshostnamesport((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys__init__scs:ti|ƒ}|id|i|_ |SdS(Ns$
Failed Authorizations: %d(smonitor_serversstatussselfspsdatas failed_auths(sselfsp((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysstatuss(ssecure_monitor_channels channel_classs__init__sstatus(((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyssecure_monitor_serverþs soutput_producercsqd„Zd„Zd„Z d„Z$d„Z+d„Z.d„Z1d„Z4d „ZRS( Ncs+||_d|_||_dS(Ns(schannelsselfsdatas real_stderrsstderr(sselfschannels real_stderr((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys__init__s  cs8t|iƒdd>jo|iiƒndS(Nii(slensselfsdataschannelsclose(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys check_datascsQti|dƒ}ti|dƒ}|i||_|iƒdS(Ns s (sstrings splitfieldssdataslinessjoinsselfs check_data(sselfsdataslines((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pyswritescs+ !|i|d|_"|iƒdS(Ns (sselfsdataslines check_data(sselfsline((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys writeline scs:$%|iti|'dƒd|_)|iƒdS(Ns (sselfsdatasstrings joinfieldssliness check_data(sselfslines((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys writelines$scs+,t|iƒdjSdS(Ni(slensselfsdata(sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysready+scs ./dS(N((sself((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysflush.scs 12dS(N((sselfsargs((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys softspace1scsI45|io.6|id }7|id|_8|Sn:dSdS(Nis(sselfsdatasresult(sselfsresult((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysmore4s   ( s__init__s check_dataswrites writelines writelinessreadysflushs softspacesmore(((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pysoutput_producers        s__main__s-ssEnter password: s-eiiiWs($sRCS_IDsmd5ssocketsstringssysstimessplitsVERSIONsasyncoresasynchatscounters producerss async_chatsmonitor_channels dispatchersmonitor_servers hex_digestssecure_monitor_channels secure_encrypted_monitor_channelssecure_monitor_serversoutput_producers__name__sargvsremoves raw_inputspasswordsNonesencryptslensatoisportsss channel_classssapphiresciphersloop(sasyncoresstrings hex_digeststimes producerssVERSIONspasswordsportsmd5ssyssasynchatsencryptssocketsmonitor_serverssecure_monitor_serversmonitor_channelsRCS_IDscounterssssapphiresoutput_producers secure_encrypted_monitor_channelssecure_monitor_channel((sF/usr/ports/www/adzapper/work/adzapper-0.4.0/src/medusa-old1/monitor.pys?sR         €% #.