new rx_handler API .. no more Engine subclassing :)

git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/trunk@1403 b32b6428-25c9-4566-ad07-03861ab6144f

devices/DummyGtkDevices/test.py

@@ -8,21 +8,25 @@ switchID = '68653832-c675-11e4-bef3-cfe5e8fb62d4'
 pboxID = '17025fb4-d3b9-11e4-a83c-71b97dd42f00'
 
 
-class Engine(xAAL.core.Engine):
-    
-    
+
+class SimpleAutomataTest(xAAL.devices.Device):
+
+    def __init__(self,eng):
+        ID = xAAL.tools.get_random_uuid()
+        xAAL.devices.Device.__init__(self,"automata.basic",ID)
+        self.eng = eng
+        self.mf = eng.get_message_factory()
+
     def drive(self,devID,action,body=None):
-        mf = self.get_message_factory()
-        msg = mf.build_msg(dev=None,targets=[devID,],msgtype='request',action=action,body=body)
-        self.queue_tx(msg)
+        msg = self.mf.build_msg(dev=None,targets=[devID,],msgtype='request',action=action,body=body)
+        self.eng.queue_tx(msg)
    
     def alert(self,devID,state):
         body = {'title':'xAAL test automata','msg':'Lamp is %s' % state }
-        mf = self.get_message_factory()
-        msg = mf.build_msg(dev=None,targets=[devID,],msgtype='request',action='notify',body=body)
-        self.queue_tx(msg)
+        msg = self.mf.build_msg(dev=None,targets=[devID,],msgtype='request',action='notify',body=body)
+        self.eng.queue_tx(msg)
     
-    def handle_request(self,msg):
+    def receive_msg(self,msg):
         if (msg.get_source() == switchID) and (msg.get_action() == 'attributesChange'):
             state = msg.body['position']
             if state : 
@@ -30,10 +34,16 @@ class Engine(xAAL.core.Engine):
                 self.alert(pboxID,'on')
             else:
                 self.drive(lampID,'off')
-
+        else:
+            self.eng.handle_request(msg)
+                
 
 if __name__ == '__main__':
-    engine = Engine()
+    engine = xAAL.core.Engine()
+    auto   = SimpleAutomataTest(engine)
+    engine.register_devices([auto,])
+    engine.set_rx_msg_handler(auto.receive_msg)
+    
     try:
         engine.run()
     except KeyboardInterrupt: