gui socket finally works

1 files changed, 23 insertions, 13 deletions

diff --git a/module/remote/ClientSocket.py b/module/remote/ClientSocket.py
index 30eaf20e0..9c52681c7 100644
--- a/module/remote/ClientSocket.py
+++ b/module/remote/ClientSocket.py
@@ -8,31 +8,41 @@ socket for connecting to the core's server
 """
 import asynchat
 import socket
+import asyncore
+import threading
+import time
 
 from ClientHandler import ClientHandler
 
+class SocketThread(threading.Thread):
+    def __init__(self, adress, port, pw, client):
+	threading.Thread.__init__(self)
+	sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+	sock.connect((adress, port))
+	self.socket = ClientSocket(sock, pw, client)
+	self.start()
+    def run(self):
+	asyncore.loop()
+	print "loop closed"
+
+
 class ClientSocket(asynchat.async_chat):    
-    def __init__(self, client):
-        asynchat.async_chat.__init__(self)
-        self.client = client
+    def __init__(self, sock, pw, client):
+        asynchat.async_chat.__init__(self, conn=sock)
         self.data = ""
-        self.handler = ClientHandler(None)
+        self.handler = ClientHandler(client, pw)
         self.set_terminator("\n")
-        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
-        
-    def handle_connect(self):
-        print "connected"
+        #self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
 
     def handle_close(self):
         print "Disconnected from", self.getpeername()
         self.close()
 
     def collect_incoming_data(self, data):
-        print "data arrived"
         self.data += data
 
     def found_terminator(self):
-        obj = self.handler.proceed(data)
-        self.push(obj)
-        print "pushed"
-        data = ""
+        obj = self.handler.proceed(self.data)
+        #self.push(obj+"\n")
+        print "data arrived"
+        self.data = ""