Legend:
- Unmodified
- Added
- Removed
-
tabled.py
r35 r36 23 23 def __init__(self): 24 24 self.table = None 25 self. id = None25 self.__id = None 26 26 27 def send Message(self, data):27 def sendData(self, data): 28 28 self.sendMessageViaTransport( data ) 29 29 d = defer.Deferred() 30 d.addCallback(self.send Message)31 self.table.addDeferred(self. id, d)30 d.addCallback(self.sendData) 31 self.table.addDeferred(self.__id, d) 32 32 33 33 def sendMessageViaTransport(self,data): … … 35 35 pass 36 36 37 def dataRec ieved(self,data):37 def dataReceived(self,data): 38 38 39 39 if data == None or "method" not in data: … … 43 43 else: method = data["method"] 44 44 if method == "connect": 45 if self.table or self. id:45 if self.table or self.__id: 46 46 self.sendMessageViaTransport( 47 47 protocol.MakeError(103,"Already connected")) … … 58 58 return 59 59 else: 60 self. id = data['client_id']60 self.__id = data['client_id'] 61 61 d = defer.Deferred() 62 d.addCallback(self.send Message)62 d.addCallback(self.sendData) 63 63 self.table.addPlayer(data, d) 64 64 elif method == "action": … … 66 66 if value == "null": value = None 67 67 if value != None: value = float(value) 68 self.table.action(self. id, data["action"],value)68 self.table.action(self.__id, data["action"],value) 69 69 else: 70 70 self.sendMessageViaTransport( protocol.MakeError(102,"Unknown Method")) … … 77 77 78 78 def stringReceived(self, data): 79 self.dataRec ieved(decodejson(data))79 self.dataReceived(decodejson(data)) 80 80 81 81 def connectionLost(self, reason): … … 85 85 86 86 class WebClient(cometd.Client,BasePokerTableHandler): 87 88 def __init__(self, id=None, authSuccessful=False, authToken=None, lastError=""): 89 cometd.Client.__init__(self,id,authSuccessful,authToken,lastError) 90 print "INITIALIZING WEB CLIENT ((((" 91 BasePokerTableHandler.__init__(self) 87 92 88 93 def messageReceived(self,message): 89 print "FFFFFFFFFFFFFFFFFFFFFFFFF" 90 print "FFFFFFFFFFFFFFFFFFFFFFFFF" 91 print "FFFFFFFFFFFFFFFFFFFFFFFFF" 92 self.dataRecieved(message) 94 print "########### Hey we recieved a message %s" % message 95 self.dataReceived(message["data"]) 93 96 94 97 def sendMessageViaTransport(self,data): 95 self.sendMessage(data) 98 print "##########3Sending Message %s" % data 99 cometd.Client.sendMessage(self,{"data":data,"channel":"/poker"}) 100 96 101 97 102 … … 144 149 145 150 if "method" in nargs and not nargs["method"] == "get_update": 146 self.dataRec ieved(encodejson(nargs))151 self.dataReceived(encodejson(nargs)) 147 152 148 153 self.checkWaiting() … … 180 185 181 186 """ 182 187 #cometd.verbose = False 183 188 184 189 port = 8007#int(sys.argv[1]) … … 189 194 190 195 comet = cometd.cometd() 196 comet.ClientType = WebClient 191 197 192 198 site = server.Site(comet)
