Changeset 68 for remote_control


Ignore:
Timestamp:
06/27/10 05:37:11 (11 years ago)
Author:
sc
Message:

thinkgear_client:

  • massive whitespace cleanup

client_interface_qt:

  • tcpSocket renamed in preparation for Think Gear connection
Location:
remote_control
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • remote_control/puzzlebox_brainstorms_client_interface_qt.py

    r67 r68  
    178178        def configureNetwork(self): 
    179179                 
    180                 self.blockSize = 0 
    181                 self.tcpSocket = QtNetwork.QTcpSocket(self) 
    182                  
    183                 self.tcpSocket.readyRead.connect(self.printReply) 
    184                 self.tcpSocket.error.connect(self.displayError) 
     180                #self.blockSize = 0 
     181                self.brainstormsClientTcpSocket = QtNetwork.QTcpSocket(self) 
     182                 
     183                self.brainstormsClientTcpSocket.readyRead.connect(self.printReply) 
     184                self.brainstormsClientTcpSocket.error.connect(self.displayError) 
    185185         
    186186         
     
    215215                else: 
    216216                        QtGui.QMessageBox.information(self, "Puzzlebox Brainstorms Client", 
    217                                           "The following error occurred: %s." % self.tcpSocket.errorString()) 
     217                                          "The following error occurred: %s." % self.brainstormsClientTcpSocket.errorString()) 
    218218                 
    219219                self.getFortuneButton.setEnabled(True) 
     
    252252                        print command 
    253253                 
    254                 self.blockSize = 0 
    255                 self.tcpSocket.abort() 
    256                 self.tcpSocket.connectToHost(SERVER_HOST, SERVER_PORT) 
     254                #self.blockSize = 0 
     255                self.brainstormsClientTcpSocket.abort() 
     256                self.brainstormsClientTcpSocket.connectToHost(SERVER_HOST, SERVER_PORT) 
    257257                 
    258258                data = json.dumps(command) 
    259                 self.tcpSocket.write(data) 
     259                self.brainstormsClientTcpSocket.write(data) 
    260260         
    261261         
  • remote_control/puzzlebox_thinkgear_client.py

    r64 r68  
    4949         
    5050        def __init__(self, log, \ 
    51                           server_host=SERVER_HOST, \ 
    52                           server_port=SERVER_PORT, \ 
    53                           DEBUG=DEBUG): 
     51                          server_host=SERVER_HOST, \ 
     52                          server_port=SERVER_PORT, \ 
     53                          DEBUG=DEBUG): 
    5454                 
    5555                self.log = log 
     
    5959                self.server_port = server_port 
    6060                self.max_connection_attempts = MAX_CONNECTION_ATTEMPTS 
    61  
    62                 self.is_authorized = True 
    63                  
    64  
    65         ################################################################## 
    66  
     61                 
     62                self.is_authorized = True 
     63         
     64         
     65        ################################################################## 
     66         
    6767        def authorize_and_send_parameters(self,\ 
    6868                                          thinkgear_parameters, \ 
    6969                                          authorization_request): 
    70  
     70                 
    7171                if self.DEBUG: 
    7272                        print "--> [ThinkGear Client] Sending Authorization Request:", 
    7373                        print authorization_request 
    74  
    75                          
     74                 
     75                 
    7676                d = self.send_parameters(thinkgear_parameters, authorization_request) 
    7777                d.addCallback(self.update_authorization) 
    78  
    79  
    80         ################################################################## 
    81  
     78         
     79         
     80        ################################################################## 
     81         
    8282        def update_authorization(self, authorization): 
    83  
     83                 
    8484                if self.DEBUG: 
    8585                        print "--> [ThinkGear Client] Authorization:", 
    8686                        print authorization 
    87                          
     87                 
    8888                self.is_authorized = authorization 
    89  
    90                  
    91         ################################################################## 
    92  
     89         
     90         
     91        ################################################################## 
     92         
    9393        def send_parameters(self, \ 
    94                          parameters, \ 
    95                          authentication=None, \ 
    96                          max_connection_attempts=MAX_CONNECTION_ATTEMPTS): 
    97                  
    98                 self.factory = puzzlebox_thinkgear_client_factory(self.log, \ 
    99                              parameters, \ 
    100                              authentication, \ 
    101                              self.server_host, \ 
    102                              self.server_port, \ 
    103                              max_connection_attempts, \ 
    104                              self.DEBUG) 
     94                                 parameters, \ 
     95                                 authentication=None, \ 
     96                                 max_connection_attempts=MAX_CONNECTION_ATTEMPTS): 
     97                 
     98                self.factory = puzzlebox_thinkgear_client_factory( \ 
     99                                  self.log, \ 
     100                                  parameters, \ 
     101                                  authentication, \ 
     102                                  self.server_host, \ 
     103                                  self.server_port, \ 
     104                                  max_connection_attempts, \ 
     105                                  self.DEBUG) 
    105106                 
    106107                reactor.connectTCP(self.server_host, self.server_port, self.factory) 
    107  
     108                 
    108109                return self.factory.replyDefer 
    109  
    110  
    111         ################################################################## 
    112  
     110         
     111         
     112        ################################################################## 
     113         
    113114        def send_parameters_and_print_response(self, parameters): 
    114  
     115                 
    115116                if self.DEBUG: 
    116117                        print "----> [ThinkGear Client] Sending:", 
    117118                        print parameters 
    118  
    119                          
     119                 
     120                 
    120121                d = self.send_parameters(parameters) 
    121122                d.addCallback(self.print_response) 
    122  
    123  
    124         ################################################################## 
    125  
     123         
     124         
     125        ################################################################## 
     126         
    126127        def print_response(self, response): 
    127128                 
     
    129130                        print "--> [ThinkGear Client] Server Response:", 
    130131                        print response 
    131                  
     132 
    132133 
    133134##################################################################### 
     
    135136##################################################################### 
    136137 
    137 class puzzlebox_thinkgear_client_protocol( \ 
    138         basic.LineReceiver): 
    139  
    140         delimiter = THINKGEAR_DELIMITER 
     138class puzzlebox_thinkgear_client_protocol(basic.LineReceiver): 
     139         
     140        delimiter = THINKGEAR_DELIMITER 
    141141         
    142142        def __init__(self): 
    143143                 
    144144                self.DEBUG = DEBUG 
    145  
     145         
    146146         
    147147        ################################################################## 
    148148         
    149149        def connectionMade(self): 
    150  
    151                 if self.DEBUG: 
    152                         print "----> [ThinkGear Client] Connected to %s:%i" % \ 
    153                               (self.factory.server_host, \ 
    154                               self.factory.server_port) 
    155  
    156  
     150         
     151                if self.DEBUG: 
     152                                        print "----> [ThinkGear Client] Connected to %s:%i" % \ 
     153                                                        (self.factory.server_host, \ 
     154                                                        self.factory.server_port) 
     155                 
     156                 
    157157                if (self.factory.authentication != None): 
    158158                        self.send_data(self.factory.authentication) 
    159  
     159                 
    160160                else: 
    161161                        self.send_data(self.factory.parameters) 
    162  
    163  
    164         ################################################################## 
    165  
    166         def send_data(self, data): 
    167  
     162         
     163         
     164        ################################################################## 
     165         
     166        def send_data(self, data): 
     167                 
    168168                packet = json.dumps(data) 
    169  
     169                 
    170170                if self.DEBUG: 
    171171                        print "----> [ThinkGear Client] Sending:", 
    172172                        print packet 
    173  
     173                 
    174174                 
    175175                self.sendLine(packet) 
    176176                 
    177 ##              self.factory.noReply = reactor.callLater(NO_REPLY_WAIT, self.noReply) 
     177                #self.factory.noReply = reactor.callLater(NO_REPLY_WAIT, self.noReply) 
    178178         
    179179         
     
    187187                        if self.DEBUG: 
    188188                                print "noReply failed to call callback" 
    189  
    190  
    191         ################################################################## 
    192  
     189         
     190         
     191        ################################################################## 
     192         
    193193        def lineReceived(self, line): 
    194  
     194         
    195195                # Ignore blank lines 
    196196                if not line: 
    197197                        return 
    198  
     198                 
    199199                try: 
    200200                        data = json.loads(line) 
     
    204204                                print e 
    205205                                print ")." 
    206  
     206                                 
    207207                                print "line:", 
    208208                                print line 
    209  
     209                                 
    210210                                # We've received back an unrecognized response 
    211211                                # so we'll attempt to reset the server's 
    212212                                # parameters for JSON communication 
    213213                                self.send_data(self.factory.parameters) 
     214                 
     215                else: 
     216                         
     217                        if (type(data) == type({})): 
     218                         
     219                                self.factory.process_response(data) 
     220                                #self.factory.replyDefer.callback(data) 
    214221                                 
    215                 else: 
    216  
    217                         if (type(data) == type({})): 
    218  
    219                                 self.factory.process_response(data) 
    220 ##                              self.factory.replyDefer.callback(data) 
    221  
    222222                        else: 
    223223                                if self.DEBUG: 
    224224                                        print "data:", 
    225225                                        print data 
    226  
    227  
    228         ################################################################## 
    229  
     226         
     227         
     228        ################################################################## 
     229         
    230230        def connectionLost(self, reason): 
    231  
     231                 
    232232                if self.DEBUG > 1: 
    233233                        print "Connection lost:", 
    234234                        print reason 
    235  
    236  
    237         ################################################################## 
    238  
    239         def connectionDone(self, reason): 
    240  
     235         
     236         
     237        ################################################################## 
     238         
     239        def connectionDone(self, reason): 
     240                 
    241241                if self.DEBUG > 1: 
    242242                        print "Connection done:", 
    243243                        print reason 
    244244 
    245          
     245 
    246246##################################################################### 
    247247# ThinkGear Client Factory class 
     
    252252        def __init__(self, log, \ 
    253253                     parameters, \ 
    254                      authentication, \ 
     254                     authentication, \ 
    255255                     server_host=SERVER_HOST, \ 
    256256                     server_port=SERVER_PORT, \ 
     
    272272                 
    273273                self.replyDefer = defer.Deferred() 
    274  
    275  
    276         ################################################################## 
    277  
     274         
     275         
     276        ################################################################## 
     277         
    278278        def process_response(self, response): 
    279  
     279                 
    280280                if self.DEBUG: 
    281281                        if (('rawEeg' not in response.keys()) or \ 
     
    283283                                print "<-- [ThinkGear Client] Received:", 
    284284                                print response 
    285  
    286  
     285                 
     286                 
    287287                if response.has_key('isAuthorized'): 
    288  
     288                         
    289289                        if (response['isAuthorized'] == True): 
    290290                                self.replyDefer.callback(True) 
    291291                        else: 
    292292                                self.replyDefer.callback(False) 
    293  
    294  
     293         
     294         
    295295        ################################################################## 
    296296         
     
    347347                    server_port=SERVER_PORT, \ 
    348348                    DEBUG=DEBUG) 
    349  
    350  
     349         
     350         
    351351        if ENABLE_THINKGEAR_AUTHORIZATION: 
    352352                # Use ThinkGear authentication 
     
    355355                        thinkgear_parameters, \ 
    356356                        authorization_request) 
    357  
     357         
    358358        else:    
    359359                # Do not use ThinkGear authentication 
     
    363363                        thinkgear_parameters, \ 
    364364                        authorization_request) 
    365  
    366  
     365         
     366         
    367367        reactor.run() 
    368368 
Note: See TracChangeset for help on using the changeset viewer.