Mailman 3 June 2009 - Twisted-web

Test
by Philippe Lafoucrière 05 Aug '21

05 Aug '21

Hi all just a test

3 2

Re: [Twisted-web] [Twisted-Python] http.Request and JSON
by Jean-Paul Calderone 07 Jul '09

07 Jul '09

On Tue, 30 Jun 2009 13:12:05 +0100, Reza Lotun <rlotun(a)gmail.com> wrote: >Hi, > >On Tue, Jun 30, 2009 at 12:56 PM, Tristan >Seligmann<mithrandi(a)mithrandi.net> wrote: >>> To be safer, I do a request.content.getvalue() since content is a >>> cStringIO object and you can never be sure if somewhere along the >>> chain of processing someone hasn't done a .read and forgot to do a >>> .seek(0,0). >> >> You should probably do the seek/read instead, since I don't believe >> this is guaranteed to be a cStringIO; it might be an actual file on >> disk, or something else. > >If that's true then there really should be a .get_body() method on the >request object. Why can't you seek and read? Also, this discussion would be more appropriate on the twisted-web mailing list. Jean-Paul

4 12

How to know if a LIveElement is alive :)
by Juanjo Conti 02 Jul '09

02 Jul '09

Hi, I wonder know if my nevow.athena.LiveElement intances are alive. This means for example, the web browser was now closed. I've been checking the API documentation at http://buildbot.divmod.org/apidocs/nevow.athena.LiveElement.html but didn't fin any sutable method for asking this. How do you do this stuff? Thanks, -- Juanjo Conti

3 5

Soap Client through http proxy with authentication on twisted!!!!!!!
by ypena＠infomed.sld.cu 30 Jun '09

30 Jun '09

Hey, I'm working on an soap client at the moment with twisted package version 8.2.0-1. It soap client will have to work in environments where connections have to be routed through a http proxy with authentication, but I can't find any way to specify a http proxy with authentication using any of the Twisted classes. Is this possible? I assumed it was seeing as how it is a fairly common situation but the documentation/API haven't provided any useful information. Help me. ------------------------------ Infomed - Red de Salud de Cuba http://www.sld.cu/ --------------------------------------- Red Telematica de Salud - Cuba CNICM - Infomed

1 0

Athena javascript question
by Juanjo Conti 27 Jun '09

27 Jun '09

Hi all, I used Twisted to write a small server and now I am using Nevow.Athena to write a web administrative interface. I got the tutorials running and now I am changing it to reach what I want for my webapp. The problem I am having is in the javascript side. Whe I try this js: / import Nevow.Athena TempDisplay.TempWidget = Nevow.Athena.Widget.subclass('TempDisplay.TempWidget'); TempDisplay.TempWidget.methods( function __init__(self, node) { TempDisplay.TempWidget.upcall(self, "__init__", node); self.tempWidget = self.nodeByAttribute('name', 'terElement'); self.tempSalaTxt = document.createTextNode(''); self.tempSala = self.nodeByAttribute('name', 'temp_sala') self.tempSala.appendChild(self.tempSalaTxt); self.tempRetornoTxt = document.createTextNode(''); self.tempRetorno = self.nodeByAttribute('name', 'temp_retorno'); self.tempRetorno.appendChild(self.tempRetornoTxt); self.tempExteriorTxt = document.createTextNode(''); self.tempExterior = self.nodeByAttribute('name', 'temp_exterior'); self.tempExterior.appendChild(self.tempExteriorTxt); }, function doRead(self) { // ejecuta funcion read en servidor self.callRemote("read"); return false; }, function actualizarValores(self, data) { // llamada por servidor para actualizar valores var valores = data.split(','); self.tempSala.remove(self.tempSalaTxt); self.tempSalaTxt = document.createTextNode(valores[0]); self.tempSala.appendChild(self.tempSalaTxt); self.tempRetorno(self.tempRetornoTxt); self.tempRetornoTxt = document.createTextNode(valores[1]); self.tempRetorno.appendChild(self.tempRetornoTxt); self.tempExterior.remove(self.tempExteriorTxt); self.tempExteriorTxt = document.createTextNode(valores[2]); self.tempExterior.appendChild(self.tempExteriorTxt); }); When the functión actualizarValores is excecuted from the server, I get this error: Unhandled error in Deferred: Traceback (most recent call last): File "c:\Python25\lib\site-packages\nevow\js\Divmod\Runtime\__init__.js", lin 566, in ([object Event]) d.callback(result); --- <exception caught here> --- File "c:\Python25\lib\site-packages\nevow\js\Divmod\Runtime\__init__.js", lin 566, in ([object Event]) d.callback(result); File "c:\Python25\lib\site-packages\nevow\js\Divmod\__init__.js", line 249, i ([object Object]) return methodFunction.apply(this, args); File "c:\Python25\lib\site-packages\nevow\js\Divmod\Defer.js", line 258, in c llback([object Object],[object Object]) self._startRunCallbacks(result); File "c:\Python25\lib\site-packages\nevow\js\Divmod\__init__.js", line 249, i ([object Object]) return methodFunction.apply(this, args); File "c:\Python25\lib\site-packages\nevow\js\Divmod\Defer.js", line 255, in _ tartRunCallbacks([object Object],[object Object]) self._runCallbacks(); File "c:\Python25\lib\site-packages\nevow\js\Divmod\__init__.js", line 249, i () return methodFunction.apply(this, args); File "c:\Python25\lib\site-packages\nevow\js\Divmod\Defer.js", line 229, in _ unCallbacks([object Object]) self._result = callback.apply(null, args); File "c:\Python25\lib\site-packages\nevow\js\Nevow\Athena\__init__.js", line 92, in ([object Array]) self.messageReceived(result[1]); File "c:\Python25\lib\site-packages\nevow\js\Divmod\__init__.js", line 249, i ([object Array]) return methodFunction.apply(this, args); File "c:\Python25\lib\site-packages\nevow\js\Nevow\Athena\__init__.js", line 35, in messageReceived([object Object],[object Array]) self.page['action_'+actionName].apply(self.page, actionArgs); File "c:\Python25\lib\site-packages\nevow\js\Divmod\__init__.js", line 249, i ("Nevow.Athena.callByAthenaID","s2c0",[object Array]) return methodFunction.apply(this, args); File "c:\Python25\lib\site-packages\nevow\js\Nevow\Athena\__init__.js", line 48, in action_call([object Object],"Nevow.Athena.callByAthenaID","s2c0",[object Array]) result = method.apply(target, funcArgs); File "c:\Python25\lib\site-packages\nevow\js\Nevow\Athena\__init__.js", line 259, in (1,"actualizarValores",[object Array]) return method.apply(widget, varargs); File "c:\Python25\lib\site-packages\nevow\js\Divmod\__init__.js", line 249, i ("21.4,27.8,31.8") return methodFunction.apply(this, args); File "C:\Documents and Settings\Teco2006\Escritorio\line\js\TempDisplay.js", ine 34, in actualizarValores([object Object],"21.4,27.8,31.8") self.tempSala.remove(self.tempSalaTxt); nevow.athena.JSException: TypeError: self.tempSala.remove is not a function As far as I know, remove is a valid javascript function. Why can't I use it in this context? Thanks in advance! -- Juanjo Conti

4 5

Re: [Twisted-web] Multithread SSL
by Yann Pomarede 25 Jun '09

25 Jun '09

Thanks for your reply. I already thought about that but I'll have other problems if I do so: - I need some variables to be common between the instances (Maybe it's not so difficult with RPC or a DB or shared memory). - I also need to keep a pool of all the outgoing the connections (to perform some real time stats and to limit the number of connection per user) But if I do not have other choices, it's certainly what I'll have to do... Yann. On Wed, Jun 24, 2009 at 21:08, Duncan M. McGreggor<duncan.mcgreggor(a)gmail.com> wrote: > Yann Pomarede wrote: >> Hello, >> >> I used Twisted to write some kind of proxy and it's working great, >> it's so easy to develop and understand. >> >> But I have a problem. I use SSL (on both side of this app) and the >> bandwidth available is limited to the power of one of my CPU due to >> the high cost of the SSL encryption. >> I would like to use both core of my CPU to increase the bandwidth of >> this application but it does not seem easy to do. >> >> # Here is the server definition in myapp.tac >> from twisted.application import internet, service >> application = service.Application('MyApp', uid=1001, gid=1001) >> internet.SSLServer(80, serverFactory, MySSLContext(), 50, >> 'xxx.xxx.xxx.xxx').setServiceParent(service.IServiceCollection(application)) >> >> # And here the clients connections >> from twisted.internet import reactor, ssl >> mySSLContext = ssl.ClientContextFactory() >> mySSLContext.method = SSL.SSLv23_METHOD >> reactor.connectSSL(self.HOST, self.PORT, self, mySSLContext) >> >> Does anyone already have this kind of problem? Is there an easy way to >> multithread the SSL encryption part? > > > You could run two instances and load balance them... > > d > > _______________________________________________ > Twisted-web mailing list > Twisted-web(a)twistedmatrix.com > http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-web > >

4 3

Multithread SSL
by Yann Pomarede 25 Jun '09

25 Jun '09

Hello, I used Twisted to write some kind of proxy and it's working great, it's so easy to develop and understand. But I have a problem. I use SSL (on both side of this app) and the bandwidth available is limited to the power of one of my CPU due to the high cost of the SSL encryption. I would like to use both core of my CPU to increase the bandwidth of this application but it does not seem easy to do. # Here is the server definition in myapp.tac from twisted.application import internet, service application = service.Application('MyApp', uid=1001, gid=1001) internet.SSLServer(80, serverFactory, MySSLContext(), 50, 'xxx.xxx.xxx.xxx').setServiceParent(service.IServiceCollection(application)) # And here the clients connections from twisted.internet import reactor, ssl mySSLContext = ssl.ClientContextFactory() mySSLContext.method = SSL.SSLv23_METHOD reactor.connectSSL(self.HOST, self.PORT, self, mySSLContext) Does anyone already have this kind of problem? Is there an easy way to multithread the SSL encryption part? Thank you, Yann from France.

2 1

Hi everybody
by Juanjo Conti 24 Jun '09

24 Jun '09

Hi everybody. I'm new here. I'm from Argentina and I am using Twisted and Nevow. Greets! -- Juanjo Conti

2 1

Telnet chat server
by Jason St.Clair 05 Jun '09

05 Jun '09

I've got a simple little chat server set up that people can telnet into. The code is as follows: ---------- from twisted.internet import reactor from twisted.internet.protocol import ServerFactory from twisted.protocols.basic import LineOnlyReceiver import threading class ChatProtocol(LineOnlyReceiver): name = "" def getName(self): if self.name!="": return self.name return self.transport.getPeer().host def connectionMade(self): print "New connection from "+self.getName() self.sendLine("Welcome to the chat.\r\n/quit to quit.") self.factory.sendMessageToAllClients(self.getName()+" joined the chat.") self.factory.clientProtocols.append(self) def connectionLost(self, reason): print "Lost connection from "+self.getName() self.factory.clientProtocols.remove(self) self.factory.sendMessageToAllClients(self.getName()+" disconnected.") def lineReceived(self, line): if line=="/quit": self.transport.loseConnection() else: self.factory.sendMessageToAllClients(self.getName()+": "+line) def sendLine(self, line): self.transport.write(line+"\r\n") class ChatProtocolFactory(ServerFactory): protocol = ChatProtocol def __init__(self): self.clientProtocols = [] def sendMessageToAllClients(self, mesg): for client in self.clientProtocols: client.sendLine(mesg) def Test(): global test factory.sendMessageToAllClients('Hey.') test = threading.Timer(1.0, Test) test.start() test = threading.Timer(1.0, Test) test.start() print "Starting Server" factory = ChatProtocolFactory() reactor.listenTCP(3009, factory) reactor.run() ---------- The problem is that last def, "def Test()". It should send the line "Hey." to all connected users every second. It does that - however, the message only sends through if the client is typing or has entered a line. So, if a client is idle for 30 seconds, then starts typing, he will receive "Hey." 30 times in a row - one for each second he was idle. Is there any way to get this to send the message and have it show up for a client even when they're idle?

3 3