
Hi All, I have run and edited the example provided for txWS. The writing part from server to client browser is shown only as self.transport.write() inside dataReceived function in websockets.py. how do I write on to the socket i.e. on to the browser, from a different function inside server code. The bold point below is where I want to write on to socket. How can we do that? ------------------------------------------------------- import time from twisted.internet import reactor from twisted.application import internet from twisted.application.service import Application, Service import xmlrpclib from txws import WebSocketFactory from src.protocols.websockets import WebSocketServerFactory from constants import * class WebSocketService(Service): """ A simple service that listens on port 8077 for WebSockets traffic. """ def __init__(self): self.start_time = time.time() def start_service(self, application): """ Gets the show on the road. Fires up a factory, binds the port. """ echofactory = WebSocketServerFactory(self) factory = WebSocketFactory(echofactory) ws_server = internet.TCPServer(8077, factory) ws_server.setName('ws-tcp') ws_server.setServiceParent(application) ws_server.writeSomeData(self,'abrakadabra..lol') def shutdown(self): """ Gracefully shuts down the service. """ reactor.callLater(0, reactor.stop) def listDevices(id): print "listDevice: %(id)s" % {"id": str(id)} return None def event(id, address, key, value): #websocket.send("ufffffffffuuuuuu") * #I need to write the below print statement on to browser * print "event: %(id)s: %(address)s: %(key)s = %(value)s" % {"id": str(id), "address": str(address), "key": str(key), "value": str(value)} def aSillyBlockingMethod(x): import time import xmlrpclib time.sleep(2) from SimpleXMLRPCServer import SimpleXMLRPCServer from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler from constants import * server = SimpleXMLRPCServer((SERVER_IP, SERVER_PORT), logRequests=True, allow_none=True) server.register_introspection_functions() server.register_multicall_functions() print "server started at %s" % str(SERVER_URL) server.register_function(listDevices) server.register_function(event) print 'function also got registered' server.serve_forever() .............................continues Thanks, Vinodh
participants (1)
-
vinod kumar