Wrapped code from http://stackoverflow.com/questions/6692908/formatting-messages-to-send-to-socket-io-node-js-server-from-python-client/

socketIO/__init__.py

@@ -0,0 +1,68 @@
+from simplejson import dumps
+from threading import Thread, Event
+from urllib import urlopen
+from websocket import create_connection
+
+
+class SocketIO(object):
+
+    def __init__(self, host, port):
+        self.host = host
+        self.port = port
+        self.__do_handshake()
+        self.__connect()
+        self.heartbeatThread = RhythmicThread(self.heartbeatTimeout - 2, self.__send_heartbeat)
+        self.heartbeatThread.start()
+
+    def __do_handshake(self):
+        try:
+            response = urlopen('http://%s:%d/socket.io/1/' % (self.host, self.port))
+        except IOError:
+            raise SocketIOError('Could not start connection')
+        if 200 != response.getcode():
+            raise SocketIOError('Could not establish connection')
+        self.sessionID, heartbeatTimeout, connectionTimeout, supportedTransports = response.readline().split(':')
+        self.heartbeatTimeout = int(heartbeatTimeout)
+        self.connectionTimeout = int(connectionTimeout)
+        if 'websocket' not in supportedTransports.split(','):
+            raise SocketIOError('Could not parse handshake')
+
+    def __connect(self):
+        self.connection = create_connection('ws://%s:%d/socket.io/1/websocket/%s' % (self.host, self.port, self.sessionID))
+
+    def __del__(self):
+        self.heartbeatThread.cancel()
+        self.connection.close()
+
+    def __send_heartbeat(self):
+        self.connection.send('2::')
+
+    def emit(self, eventName, eventData):
+        self.connection.send('5:::' + dumps(dict(name=eventName, args=eventData)))
+
+
+class SocketIOError(Exception):
+    pass
+
+
+class RhythmicThread(Thread):
+    'Execute function every few seconds'
+
+    daemon = True
+
+    def __init__(self, intervalInSeconds, function, *args, **kw):
+        super(RhythmicThread, self).__init__()
+        self.intervalInSeconds = intervalInSeconds
+        self.function = function
+        self.args = args
+        self.kw = kw
+        self.done = Event()
+
+    def cancel(self):
+        self.done.set()
+
+    def run(self):
+        self.done.wait(self.intervalInSeconds)
+        while not self.done.is_set():
+            self.function(*self.args, **self.kw)
+            self.done.wait(self.intervalInSeconds)