Changeset 42 for tabled.tac

Timestamp:

02/07/08 15:46:20 (4 years ago)

Author:

mike

Message:

updated stuff

Files:

• tabled.tac (modified) (2 diffs)

tabled.tac

@@ -85 +85 @@
 clientChannels = [ r"\/poker" ]
 
-class WebClient(cometd.Client,BasePokerTableHandler):
+class PokerSubscription(cometd.ClientSubscription, BasePokerTableHandler):
+    def __init__(self, channel):
+        BasePokerTableHandler.__init__(self)
+        cometd.ClientSubscription.__init__(self, channel)
+
+    def messageReceived(self,message):
+        self.dataReceived(message)
+
+    def sendMessageViaTransport(self,data):
+        self.sendMessage(data)
+
+class WebClient(cometd.Client):
     
-    def __init__(self, id=None, authSuccessful=False, authToken=None, lastError=""):
-        cometd.Client.__init__(self,id,authSuccessful,authToken,lastError)
-        print "INITIALIZING WEB CLIENT (((("
-        BasePokerTableHandler.__init__(self)
-
-    def messageReceived(self,message,channel):
-        self.dataReceived(message)
-
-    def sendMessageViaTransport(self,data):
-        cometd.Client.sendMessage(self,data,"/poker")
+    def generateSubscription(self, channel):
+        return PokerSubscription( channel )
+
+    def subscribe(self, channel):
+        #we only want poker channels
+        print "SUB ---------------- CHAN " + channel
+        if channel == "/poker":
+            return cometd.Client.subscribe(self,channel)
+        else: return False
 
 
@@ -217 +227 @@
 print "Listening on localhost:%d(tcp) %d(http)" % (port, port2)
 
-
+# vim:filetype=python