Changeset 68 for remote_control/puzzlebox_thinkgear_client.py

Timestamp:

06/27/10 05:37:11 (12 years ago)

Author:

sc

Message:

thinkgear_client:

• massive whitespace cleanup

client_interface_qt:

• tcpSocket renamed in preparation for Think Gear connection

File:

• remote_control/puzzlebox_thinkgear_client.py (modified) (12 diffs)

remote_control/puzzlebox_thinkgear_client.py

@@ -49 +49 @@
         
         def __init__(self, log, \
-                          server_host=SERVER_HOST, \
-                          server_port=SERVER_PORT, \
-                          DEBUG=DEBUG):
+                          server_host=SERVER_HOST, \
+                          server_port=SERVER_PORT, \
+                          DEBUG=DEBUG):
                 
                 self.log = log
@@ -59 +59 @@
                 self.server_port = server_port
                 self.max_connection_attempts = MAX_CONNECTION_ATTEMPTS
-
-                self.is_authorized = True
-                
-
-        ##################################################################
-
+                
+                self.is_authorized = True
+        
+        
+        ##################################################################
+        
         def authorize_and_send_parameters(self,\
                                           thinkgear_parameters, \
                                           authorization_request):
-
+                
                 if self.DEBUG:
                         print "--> [ThinkGear Client] Sending Authorization Request:",
                         print authorization_request
-
-                        
+                
+                
                 d = self.send_parameters(thinkgear_parameters, authorization_request)
                 d.addCallback(self.update_authorization)
-
-
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def update_authorization(self, authorization):
-
+                
                 if self.DEBUG:
                         print "--> [ThinkGear Client] Authorization:",
                         print authorization
-                        
+                
                 self.is_authorized = authorization
-
-                
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def send_parameters(self, \
-                         parameters, \
-                         authentication=None, \
-                         max_connection_attempts=MAX_CONNECTION_ATTEMPTS):
-                
-                self.factory = puzzlebox_thinkgear_client_factory(self.log, \
-                             parameters, \
-                             authentication, \
-                             self.server_host, \
-                             self.server_port, \
-                             max_connection_attempts, \
-                             self.DEBUG)
+                                 parameters, \
+                                 authentication=None, \
+                                 max_connection_attempts=MAX_CONNECTION_ATTEMPTS):
+                
+                self.factory = puzzlebox_thinkgear_client_factory( \
+                                  self.log, \
+                                  parameters, \
+                                  authentication, \
+                                  self.server_host, \
+                                  self.server_port, \
+                                  max_connection_attempts, \
+                                  self.DEBUG)
                 
                 reactor.connectTCP(self.server_host, self.server_port, self.factory)
-
+                
                 return self.factory.replyDefer
-
-
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def send_parameters_and_print_response(self, parameters):
-
+                
                 if self.DEBUG:
                         print "----> [ThinkGear Client] Sending:",
                         print parameters
-
-                        
+                
+                
                 d = self.send_parameters(parameters)
                 d.addCallback(self.print_response)
-
-
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def print_response(self, response):
                 
@@ -129 +130 @@
                         print "--> [ThinkGear Client] Server Response:",
                         print response
-                
+
 
 #####################################################################
@@ -135 +136 @@
 #####################################################################
 
-class puzzlebox_thinkgear_client_protocol( \
-        basic.LineReceiver):
-
-        delimiter = THINKGEAR_DELIMITER
+class puzzlebox_thinkgear_client_protocol(basic.LineReceiver):
+        
+        delimiter = THINKGEAR_DELIMITER
         
         def __init__(self):
                 
                 self.DEBUG = DEBUG
-
+        
         
         ##################################################################
         
         def connectionMade(self):
-
-                if self.DEBUG:
-                        print "----> [ThinkGear Client] Connected to %s:%i" % \
-                              (self.factory.server_host, \
-                               self.factory.server_port)
-
-
+        
+                 if self.DEBUG:
+                                        print "----> [ThinkGear Client] Connected to %s:%i" % \
+                                                        (self.factory.server_host, \
+                                                         self.factory.server_port)
+                
+                
                 if (self.factory.authentication != None):
                         self.send_data(self.factory.authentication)
-
+                
                 else:
                         self.send_data(self.factory.parameters)
-
-
-        ##################################################################
-
-        def send_data(self, data):
-
+        
+        
+        ##################################################################
+        
+        def send_data(self, data):
+                
                 packet = json.dumps(data)
-
+                
                 if self.DEBUG:
                         print "----> [ThinkGear Client] Sending:",
                         print packet
-
+                
                 
                 self.sendLine(packet)
                 
-##              self.factory.noReply = reactor.callLater(NO_REPLY_WAIT, self.noReply)
+                #self.factory.noReply = reactor.callLater(NO_REPLY_WAIT, self.noReply)
         
         
@@ -187 +187 @@
                         if self.DEBUG:
                                 print "noReply failed to call callback"
-
-
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def lineReceived(self, line):
-
+        
                 # Ignore blank lines
                 if not line:
                         return
-
+                
                 try:
                         data = json.loads(line)
@@ -204 +204 @@
                                 print e
                                 print ")."
-
+                                
                                 print "line:",
                                 print line
-
+                                
                                 # We've received back an unrecognized response
                                 # so we'll attempt to reset the server's
                                 # parameters for JSON communication
                                 self.send_data(self.factory.parameters)
+                
+                else:
+                        
+                        if (type(data) == type({})):
+                        
+                                self.factory.process_response(data)
+                                #self.factory.replyDefer.callback(data)
                                 
-                else:
-
-                        if (type(data) == type({})):
-
-                                self.factory.process_response(data)
-##                              self.factory.replyDefer.callback(data)
-
                         else:
                                 if self.DEBUG:
                                         print "data:",
                                         print data
-
-
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def connectionLost(self, reason):
-
+                
                 if self.DEBUG > 1:
                         print "Connection lost:",
                         print reason
-
-
-        ##################################################################
-
-        def connectionDone(self, reason):
-
+        
+        
+        ##################################################################
+        
+        def connectionDone(self, reason):
+                
                 if self.DEBUG > 1:
                         print "Connection done:",
                         print reason
 
-        
+
 #####################################################################
 # ThinkGear Client Factory class
@@ -252 +252 @@
         def __init__(self, log, \
                      parameters, \
-                     authentication, \
+                     authentication, \
                      server_host=SERVER_HOST, \
                      server_port=SERVER_PORT, \
@@ -272 +272 @@
                 
                 self.replyDefer = defer.Deferred()
-
-
-        ##################################################################
-
+        
+        
+        ##################################################################
+        
         def process_response(self, response):
-
+                
                 if self.DEBUG:
                         if (('rawEeg' not in response.keys()) or \
@@ -283 +283 @@
                                 print "<-- [ThinkGear Client] Received:",
                                 print response
-
-
+                
+                
                 if response.has_key('isAuthorized'):
-
+                        
                         if (response['isAuthorized'] == True):
                                 self.replyDefer.callback(True)
                         else:
                                 self.replyDefer.callback(False)
-
-
+        
+        
         ##################################################################
         
@@ -347 +347 @@
                     server_port=SERVER_PORT, \
                     DEBUG=DEBUG)
-
-
+        
+        
         if ENABLE_THINKGEAR_AUTHORIZATION:
                 # Use ThinkGear authentication
@@ -355 +355 @@
                         thinkgear_parameters, \
                         authorization_request)
-
+        
         else:   
                 # Do not use ThinkGear authentication
@@ -363 +363 @@
                         thinkgear_parameters, \
                         authorization_request)
-
-
+        
+        
         reactor.run()