Changeset 71 for remote_control/puzzlebox_brainstorms_client_interface_qt.py

Timestamp:

06/28/10 13:24:11 (12 years ago)

Author:

sc

Message:

client_interface_qt:

• ThinkGear? networking added
• ThinkGear? Concentration and Relaxation processing added

File:

• remote_control/puzzlebox_brainstorms_client_interface_qt.py (modified) (5 diffs)

remote_control/puzzlebox_brainstorms_client_interface_qt.py

@@ -44 +44 @@
 SERVER_PORT = configuration.SERVER_PORT
 
+THINKGEAR_SERVER_HOST = configuration.THINKGEAR_SERVER_HOST
+THINKGEAR_SERVER_PORT = configuration.THINKGEAR_SERVER_PORT 
+
+THINKGEAR_DELIMITER = '\r'
+
+THINKGEAR_PARAMETERS = {"enableRawOutput": False, "format": "Json"}
+
 #####################################################################
 # Classes
@@ -165 +172 @@
                 #self.blockSize = 0
                 self.brainstormsClientTcpSocket = QtNetwork.QTcpSocket(self)
+                self.brainstormsClientTcpSocket.name = 'Brainstorms Server'
                 
                 #self.brainstormsClientTcpSocket.readyRead.connect(self.printReply)
@@ -171 +179 @@
                 
                 self.thinkgearClientTcpSocket = QtNetwork.QTcpSocket(self)
+                self.thinkgearClientTcpSocket.name = 'ThinkGear Server'
                 
                 self.thinkgearClientTcpSocket.readyRead.connect(self.printReply)
                 self.thinkgearClientTcpSocket.error.connect(self.displayError)
+
+                self.sendCommand(THINKGEAR_PARAMETERS, self.thinkgearClientTcpSocket, THINKGEAR_SERVER_HOST, THINKGEAR_SERVER_PORT)
         
         
@@ -179 +190 @@
         
         def printReply(self, reply=None):
-                
-                if (reply != None):
-                
-                        print "reply:",
-                        print reply
-        
-        
+
+                socket = self.thinkgearClientTcpSocket
+
+                socket_buffer = socket.readAll()
+
+                for packet in socket_buffer.split(THINKGEAR_DELIMITER):
+
+                        if packet != '':
+                                
+                                data = json.loads(packet.data())
+
+                                if self.DEBUG:
+                                        print "<-- [%s] Received:" % socket.name,
+                                        print data
+
+                                self.processPacketThinkGear(data)
+        
+        
+        ##################################################################
+
+        def processPacketThinkGear(self, packet):
+
+                if ('eSense' in packet.keys()):
+
+                        if ('attention' in packet['eSense'].keys()):
+                                self.progressBarConcentration.setValue(packet['eSense']['attention'])
+
+                        if ('meditation' in packet['eSense'].keys()):
+                                self.progressBarRelaxation.setValue(packet['eSense']['meditation'])                     
+
+                
         ##################################################################
         
@@ -212 +247 @@
         
         def turnLeft(self):
-                self.sendCommand('turn_left')
+                self.sendCommand('turn_left', self.brainstormsClientTcpSocket)
         
         def driveForward(self):
-                self.sendCommand('drive_forward')
+                self.sendCommand('drive_forward', self.brainstormsClientTcpSocket)
         
         def turnRight(self):
-                self.sendCommand('turn_right')
+                self.sendCommand('turn_right', self.brainstormsClientTcpSocket)
         
         def turnLeftInReverse(self):
-                self.sendCommand('turn_left_in_reverse')
+                self.sendCommand('turn_left_in_reverse', self.brainstormsClientTcpSocket)
         
         def driveReverse(self):
-                self.sendCommand('drive_reverse')
+                self.sendCommand('drive_reverse', self.brainstormsClientTcpSocket)
         
         def turnRightInReverse(self):
-                self.sendCommand('turn_right_in_reverse')
+                self.sendCommand('turn_right_in_reverse', self.brainstormsClientTcpSocket)
         
         def stopMotors(self):
-                self.sendCommand('stop_motors')
-        
-        
-        ##################################################################
-        
-        def sendCommand(self, command):
+                self.sendCommand('stop_motors', self.brainstormsClientTcpSocket)
+        
+        
+        ##################################################################
+        
+        def sendCommand(self, command, socket, host=SERVER_HOST, port=SERVER_PORT):
                 
                 if self.DEBUG:
-                        print "Sending:",
+                        print "--> [%s] Sending:" % socket.name,
                         print command
                 
                 #self.blockSize = 0
-                self.brainstormsClientTcpSocket.abort()
-                self.brainstormsClientTcpSocket.connectToHost(SERVER_HOST, SERVER_PORT)
+##              self.brainstormsClientTcpSocket.abort()
+##              self.brainstormsClientTcpSocket.connectToHost(SERVER_HOST, SERVER_PORT)
+##              
+##              data = json.dumps(command)
+##              self.brainstormsClientTcpSocket.write(data)
+
+                socket.abort()
+                socket.connectToHost(host, port)
                 
                 data = json.dumps(command)
-                self.brainstormsClientTcpSocket.write(data)
+                socket.write(data)