Mailman 3 August 2008 - Twisted

[Twisted-Python] twisted.words.msn broken ?
by Joaquin Keller 23 Aug '08

23 Aug '08

Hi all, when running msn_example.py I get this: 2008/08/22 17:29 +0200 [-] Log opened. 2008/08/22 17:29 +0200 [-] Starting factory <twisted.internet.protocol.ClientFactory instance at 0x83d552c> 2008/08/22 17:29 +0200 [Dispatch,client] Error in line: VER 1 MSNP8 (Invalid version response) 2008/08/22 17:29 +0200 [Dispatch,client] Stopping factory <twisted.internet.protocol.ClientFactory instance at 0x83d552c> 1 or 2 months ago, it was working perfectly fine. I suspect that something has changed on messenger.hotmail.com side bonus: this two-week old bug (closed now) seems to be related and claims to have a solution: http://bugs.debian.org/cgi-bin/bugreport.cgi?bug=493908 [...] their response to the CVR command has changed [...] Hopefully, it might be only that... Thanks, -- Joaquin

3 4

[Twisted-Python] twisted.web session expiry
by Daniel Browne 22 Aug '08

22 Aug '08

I need someone to help me with twisted.web. How can I do something (eg. redirect) once a users session has expired? At the point when the session expires your request is finished and your session is expired. I have added the notification callback but I can't really do anything inside it without a session to store information in or a request to redirect with, so I just print a message to the console. Can anyone help me understand what I'm doing wrong here? Thanks Daniel Browne

4 3

[Twisted-Python] wxPython + Twisted = signals no longer caught
by Gabriel Rossetti 22 Aug '08

22 Aug '08

Hello everyone, I am writing a (Twisted) program that intercepts some signals using , such as Ctrl+C, and stops the reactor. I have a base class that sets-up signal handlers and it works great. The handlers are in my base factory class (we'll call it MyBaseFactory). Here's the code in the MyBaseFactory's __init__() : def __init__(self, proto, *args, **kwargs): self.protocol = proto if signal.getsignal(signal.SIGINT) == signal.default_int_handler: # only handle if there isn't already a handler, e.g. for Pdb. signal.signal(signal.SIGINT, self._sigHandler) signal.signal(signal.SIGTERM, self._sigHandler) # Catch Ctrl-Break in windows if hasattr(signal, "SIGBREAK"): signal.signal(signal.SIGBREAK, self._sigHandler) def _sigHandler(self, signum, frame): if(signum == signal.SIGINT or signal.SIGTERM): reactor.callLater(0, reactor.stop) # Catch Ctrl-Break in windows elif hasattr(signal, "SIGBREAK") and signum == signal.SIGBREAK: reactor.callLater(0, reactor.stop) I've recently had to integrate wxPython in parts of my application and I've inherited from MyBaseFactory and wx.App. When the Gui starts, it creates a wx.Dialog descendant/child that creates a wx.TaskBarIcon. I use the wxPython integration reactor code. Also, I have tried using wx.Frame instead of wx.Dialog but it doesn't change anything. The interface works great, I can use twisted, I get and receive msgs, etc, but when I'm in the terminal were the program was run from, and I send SIGINT (Ctrl+C) nothing happens. Does anyone know why wxPython or Twisted eats my Ctrl+C in the terminal? This code (MyBaseFactory) works without the wxPython (I've been using it for several months). Thank you, Gabriel PS I've also posted before to the wxPython mailing list without mentioning the twisted part, but apparently pure wxPython does not do this. I've also tested it (removed all the twisted stuff) and it does close when a SIGINT is sent.

1 0

[Twisted-Python] dont get ssl Server working
by fhauck＠srcpsolutions.com 21 Aug '08

21 Aug '08

I will be out of the office from 08/15/2008 to 08/25/2008 If this is urgent please contact rgrizzaffi(a)srcpsolutions.com

3 2

[Twisted-Python] Multithreaded UDP server in Twisted?
by John Doe 21 Aug '08

21 Aug '08

Hi everyone, I am trying to implement a multithreaded UDP server in Twisted: from twisted.internet.protocol import DatagramProtocol from twisted.internet import threads, reactor from twisted.python import threadable threadable.init(1) reactor.suggestThreadPoolSize(32) class EchoUDP(DatagramProtocol): def echoDatagram (self, datagram): print datagram def datagramReceived(self, datagram, address): self.transport.write(datagram, address) reactor.callInThread(self.echoDatagram(datagram)) def main(): reactor.listenUDP(8000, EchoUDP()) reactor.run() if __name__ == '__main__': main() although it is working it gives me following error: Traceback (most recent call last): File "C:\Python25\lib\threading.py", line 460, in __bootstrap self.run() File "C:\Python25\lib\threading.py", line 440, in run self.__target(*self.__args, **self.__kwargs) --- <exception caught here> --- File "C:\Python25\lib\site-packages\twisted\python\threadpool.py", line 148, in _worker context.call(ctx, function, *args, **kwargs) File "C:\Python25\lib\site-packages\twisted\python\context.py", line 59, in callWithContext return self.currentContext().callWithContext(ctx, func, *args, **kw) File "C:\Python25\lib\site-packages\twisted\python\context.py", line 37, in callWithContext return func(*args,**kw) exceptions.TypeError: 'NoneType' object is not callable Does anybody know what is wrong? Any help is *greatly* appreciated! ;) Thanks in advance! Cheers Carlo

2 1

Re: [Twisted-Python] twisted python conch SSH shell?
by Eli Criffield 21 Aug '08

21 Aug '08

conchClient.py is libarary. Running it from the command line was an afterthought just for testing. To run multiple commands in the same session you just give sshCmds a list of commands to run and it will return the output of all of them. Here is an example script that creates a function to up a port and another to return the wwn (this is from a SAN switch) of a port. #!/usr/bin/env python # Eli Criffield __version__ = 0.1186070837 __author__ = 'Eli Criffield <python AT zendo.net>' import sys import re import time import os from conchClient import sshCmds dryRun = False Confirm = True echo = False class reError(Exception): pass def execList(switch,cmds,change=False): global echo, dryRun, Confirm # if change is False, the commands arn't suppose to do any damage # always exec them, they need the info if not change: return sshCmds(switch,cmds,echo=echo) if dryRun: print 'DRY RUN' print 'ssh %s'%switch for cmd in cmds: print cmd print 'ENTER to continue:', sys.stdin.readline() return ('dryrun','') if Confirm: print "I'm going to run:" print '\nssh %s'%switch for cmd in cmds: print cmd ans = raw_input('Does that look ok (yes/no)? ') while ans.lower() not in ('yes', 'no'): ans = raw_input("Please type 'yes' or 'no': ") if ans == 'no': print 'exiting out' sys.exit(1) else: return sshCmds(switch,cmds,echo=echo) # No dryRun or Confirm just execute it return sshCmds(switch,cmds,echo=echo) def upPort(switch,port): cmds=[ 'config term', 'interface fc%s'%port, 'no shutdown' ,'end' ,'exit' ] execList(switch,cmds,change=True) def wwnFromPort(switch,port): portre = re.compile(r'%s '%port) linere = re.compile(r'(\S*)\s*(\S*)\s*(\S*)\s*(\S*)\s*(\S*)') (out,err) = execList(switch,['show flogi database']) for line in out.split('fc'): if portre.match(line): #print 'line:',line #DEBUG wwn = linere.match(line).groups()[3] #print wwn #DEBUG return wwn On Thu, Aug 21, 2008 at 2:07 AM, The Noob <thenoob06(a)gmail.com> wrote: > Hello, > > If I understand your code, you can't find a way to run a real shell on Cisco > ? > For example if I connect to a router, I send a "sh log" , " conf t " > commands but I do not know them before. With the actual script: > conchClient.py 192.168.0.254 sh log > The script disconnects us from the router > conchClient.py 192.168.0.254 conf t > The script disconnects us disconnect from the router > I think the problem with your script it is for each command you are > disconnected The best will be to find a solution to do this: > conchClient.py 192.168.0.254 sh log > conchClient.py 192.168.0.254 conf t > conchClient.py 192.168.0.254 exit > disconnect from server > > I try to do this with a custom ssh server which permits to connect to others > ssh servers and have a shell. But I don't know how to communicate between my > custom ssh server and my child ( an expect script which launch ssh root@host > and permits to have a real shell) > > > Best Regards > TheNoob06 > > > 2008/8/21 Eli Criffield <elicriffield(a)gmail.com> >> >> check out >> >> http://twistedmatrix.com/pipermail/twisted-python/2007-July/015793.html >> >> Eli Criffield >> >> On Tue, Aug 12, 2008 at 3:40 PM, Bill Zeller <wzeller(a)cs.princeton.edu> >> wrote: >> > Hi, >> > >> > I've been playing around with Twisted's Conch client (which looks >> > extremely >> > well done, thanks!). I've been able to connect to a conch server and >> > also >> > connect to other ssh servers and execuate various commands. I'd like to >> > be >> > able to connect to an arbitrary SSH server and run /bin/bash. >> > >> > I'm able to execute a command like so: >> > >> > --------------------- >> > class CommandChannel(channel.SSHChannel): >> > .... >> > def channelOpen(self, data): >> > self.conn.sendRequest( >> > self, 'exec', common.NS(self.command), >> > wantReply=True).addCallback( >> > self._gotResponse) >> > --------------------- >> > >> > Looking through the SSH spec (connect protocol, rfc4254), it looks like >> > shells are opened with this command. >> > >> > --------------------- >> > >> > byte SSH_MSG_CHANNEL_REQUEST >> > >> > uint32 recipient channel >> > string "shell" >> > boolean want reply >> > >> > --------------------- >> > >> > It doesn't look like Conch supports these requests (here's how >> > CHANNEL_REQUESTs are currently sent out) >> > >> > --------------------- >> > (Twisted-8.1.0) >> > twisted/conch/ssh/connection.py (413): >> > self.transport.sendPacket(MSG_CHANNEL_REQUEST, struct.pack('>L', >> > >> > self.channelsToRemoteChannel[channel]) >> > + >> > common.NS(requestType)+chr(wantReply) >> > + data) >> > --------------------- >> > >> > I may be misunderstanding how remote shells are started, so any help >> > would >> > be appreciated. >> > >> > Again, I'm trying to launch an interactive /bin/bash shell from a Conch >> > SSH >> > client on an arbitrary remote SSH server. >> > >> > Thanks for your time. >> > >> > Best Regards, >> > Bill Zeller >> > >> > _______________________________________________ >> > Twisted-Python mailing list >> > Twisted-Python(a)twistedmatrix.com >> > http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python >> > >> > >> >> _______________________________________________ >> Twisted-Python mailing list >> Twisted-Python(a)twistedmatrix.com >> http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python > >

1 0

[Twisted-Python] dont get ssl Server working
by arne-weiss＠web.de 21 Aug '08

21 Aug '08

I tried to use ssl via twisted and I don't know why it doesn't work. If a client tries to connect ConnectionLost says: [('SSL routines', 'SSL3_READ_BYTES', 'sslv3 alert bad certificate'), ('SSL routines', 'SSL3_READ_BYTES', 'ssl handshake failure')] I tried different CAs, so there schould be no failure. Do I have to do something else like SSL.Context(method).set_accept_state() manually? My Code in basic looks like the following: http://nopaste.info/8bd9bd8536.html # class TLSProtocol(protocol.Protocol, ssl.Server): # # def connectionLost(self, reason): # print "Connection Lost:" # print reason.getErrorMessage() # # def dataReceived(self, data): # print "Data Received: %s"%data # # # # class Factory(protocol.ServerFactory): # protocol = TLSProtocol # # def buildProtocol(self, addr): # p = self.protocol() # return p # # def clientConnectionLost(self, transport, reason): # print "Connection Lost: %s"%reason.getErrorMessage() # reactor.stop( ) # # def clientConnectionFailed(self, transport, reason): # print "connection Failed: %s"%reason.getErrorMessage( ) # reactor.stop( ) # # # # class ContextFactory(ssl.ContextFactory): # # def __init__(self): # sslmethod = SSL.TLSv1_METHOD # # ctx = SSL.Context(sslmethod) # ctx.use_certificate_file('ssl.crt') # ctx.use_privatekey_file('ssl.key') # # self._context = ctx # # def getContext(self): # "Create an SSL context" # # return self._context # # # # reactor.listenSSL(8601, Factory(), ContextFactory()) # reactor.run() _______________________________________________________________________ EINE FÜR ALLE: die kostenlose WEB.DE-Plattform für Freunde und Deine Homepage mit eigenem Namen. Jetzt starten! http://unddu.de/?kid=kid@mf2

2 1

[Twisted-Python] Yahoo! Auto Response
by leszczynscy＠yahoo.com 21 Aug '08

21 Aug '08

Ten adres bedzie sprawdzany do konca lutego 2008. Prosze uzywac mojego nowego adresu. This e-mail will be in use until end of February 2008. Please use my new one instead. andy.leszczynski gmail com

1 0

[Twisted-Python] twisted python conch SSH shell?
by Bill Zeller 20 Aug '08

20 Aug '08

Hi, I've been playing around with Twisted's Conch client (which looks extremely well done, thanks!). I've been able to connect to a conch server and also connect to other ssh servers and execuate various commands. I'd like to be able to connect to an arbitrary SSH server and run /bin/bash. I'm able to execute a command like so: --------------------- class CommandChannel(channel.SSHChannel): .... def channelOpen(self, data): self.conn.sendRequest( self, 'exec', common.NS(self.command), wantReply=True).addCallback( self._gotResponse) --------------------- Looking through the SSH spec (connect protocol, rfc4254), it looks like shells are opened with this command. --------------------- byte SSH_MSG_CHANNEL_REQUEST uint32 recipient channel string "shell" boolean want reply --------------------- It doesn't look like Conch supports these requests (here's how CHANNEL_REQUESTs are currently sent out) --------------------- (Twisted-8.1.0) twisted/conch/ssh/connection.py (413): self.transport.sendPacket(MSG_CHANNEL_REQUEST, struct.pack('>L', self.channelsToRemoteChannel[channel]) + common.NS(requestType)+chr(wantReply) + data) --------------------- I may be misunderstanding how remote shells are started, so any help would be appreciated. Again, I'm trying to launch an interactive /bin/bash shell from a Conch SSH client on an arbitrary remote SSH server. Thanks for your time. Best Regards, Bill Zeller

2 1

[Twisted-Python] Abouth threads in twisted.
by Peter Cai 19 Aug '08

19 Aug '08

Hi All, QUESTION 1 : callFromThread ~~~~~~~~~~~~~~~~~~~~~~~~~~~ I found this code snippet in twisted manual book. But I don't quite get it. What does "run 'notThreadSafe(3)' in the event loop" means? Does the reactor promise that all those "notThreadSafe" functions be called one by one so they won't interfere each other? #====================================== from twisted.internet import reactor def notThreadSafe(x): """do something that isn't thread-safe""" # ... def threadSafeScheduler(): """Run in thread-safe manner.""" reactor.callFromThread(notThreadSafe, 3) # will run 'notThreadSafe(3)' in the event loop #====================================== QUESTION 2 : Integrated with a threaded 3rd party library. ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ I have a C library which using a work threaded pool model. It's interface is like this. void runWorkAsyn(int args, void pcallbackfunc(int)); When runWorkAsyn is called, it dispatch work to a thread in its own thread pool and call 'pcallbackfunc' in that thread when it's done. I really got confused by how use this lib from twisted in a thread safe way. If I use a python callback function as pcallbackfunc and touch the reactor from it, it might damage the event look as most twisted APIs are not thread safe.

2 2