Updated the main code

1 files changed, 44 insertions, 42 deletions

diff --git a/macropad.pyw b/macropad.pyw
index 3a3b7e2..35bd77a 100755
--- a/macropad.pyw
+++ b/macropad.pyw
@@ -8,8 +8,8 @@ import pystray
 from pystray import MenuItem as item
 from PIL import Image, ImageTk
 
+from typing import Dict
 import threading
-from os import path
 import sys
 
 from zope import component
@@ -19,6 +19,7 @@ from interfaces.message import IMessage, Debug
 
 import configparser
 
+from os import path
 script_path = path.dirname(path.realpath(__file__))
 config_file = path.join(script_path, "config.ini")
 
@@ -27,8 +28,9 @@ config.read(config_file)
 
 from collections import OrderedDict
 
-init_mapping = config["mapping"]
-mapping = OrderedDict(init_mapping)
+from configuration import Mapping

+mapping = Mapping(config)

+
 
 from queue import Queue
 q = Queue()
@@ -39,19 +41,6 @@ component.provideAdapter(interfaces.endpoint.EndPoint)
 # Guess the platform and the load the corresponding event listener
 #
 
-from sys import platform
-if platform == "win32":
-    import win32
-    window_listener = win32.Listener(mapping, q)
-    component.provideUtility(window_listener, interfaces.desktopEvent.IDesktop)
-    window_listener.start()
-
-elif platform == 'linux':
-    import xlib
-    xlib_listener = xlib.Listener(mapping, q)
-    component.provideUtility(xlib_listener, interfaces.desktopEvent.IDesktop)
-    xlib_listener.start()
-
 #
 # How to connect to the peripherical
 #
@@ -111,13 +100,8 @@ class Icon(object):
         self.show_hide.set()
 
     def reset(self):
-        # Create a copy of the dictonnary before updating the keys
-        tmp_mapping = dict(mapping)
-        for key in tmp_mapping.keys() :
-            if key not in init_mapping.keys():
-                del mapping[key]
+        mapping.reset()
 
-import json
 class Application(object):
 
     def __init__(self):
@@ -149,13 +133,31 @@ class Application(object):
         self.icon.start()
         component.handle(Debug("Started"))
 
+
+    def connect_desktop(self):
+        """ Launch the thread listening events from the desktop
+        """
+        from sys import platform
+        component.handle(Debug(platform))
+        if platform == "win32":
+            import win32
+            window_listener = win32.Listener(mapping, q)
+            component.provideUtility(window_listener, interfaces.desktopEvent.IDesktop)
+            window_listener.start()
+
+        elif platform == 'linux':
+            import xlib
+            xlib_listener = xlib.Listener(mapping, q)
+            component.provideUtility(xlib_listener, interfaces.desktopEvent.IDesktop)
+            component.handle(Debug("Starting xlib"))
+            xlib_listener.start()
+
     def hide(self):
         self.icon.show_hide.clear()
         self.visible = False
         self.window.withdraw()
         self.update()
 
-
     def update(self):
         if self.icon.stop.is_set():
             self.icon.quit()
@@ -176,42 +178,37 @@ class Application(object):
     def log(self, message : str):
         print(message.content)
         try:
-            f = open("/tmp/macropad.log", "a")
-            f.write(message.content)
-            f.write("\n")
-            f.close()
             self.text.insert("1.0", "\n")
             self.text.insert("1.0", message.content)
             self.text.delete("200.0", "end")
         except Exception as e:
             print(e)
 
-    """ Send the message to the endpoint.
-        If the content is the same, ignore the message and return.
-    """
+
     def send(self, data: str):
+        """ Send the configuration to the device.
+            The configuration can be either
+            - a dictionnary, and will be send as is
+            - a string, and will be load in a file
+            If the content is the same, ignore the message and return.
+        """
         if data == self.last_layout:
             return
+        # Merge the new layout with the previous one, ignoring all the null.
         self.last_layout = data
 
         conn = component.queryUtility(interfaces.endpoint.IEndpoint)
         if isinstance(data, dict):
             conn.send(data)
-            return
         elif isinstance(data, str):
-            if not path.exists(data):
-                print("The file '%s' does not exists" % data)
-                return
-            with open(data, "r") as json_file:
-                json_data = json_file.read()
-                j = json.loads(json_data)
-                content = json.dumps(j)
-    
-                conn.send(j)
+            layer = mapping.get(data, None)
+            if layer is not None:
+                conn.send(layer)
 
-    def associate(self, layout: str, name: str):
+    def associate(self, layout: Dict, name: str):
       mapping[name] = layout
-      component.handle(Debug("Associating %s with %s" % (name, layout)))
+      for key in layout.keys():
+        component.handle(Debug("Associating %s with %s" % (name, key)))
 
     def exec(self):
         try:
@@ -241,11 +238,16 @@ class Application(object):
             self.send(last_layout)
             if app_ is not None: self.associate(last_layout, app_)
 
+
 if __name__ == '__main__':
+    # Start the main application, Initializing the message listener before
+    # listening desktop events
     app = Application()
+    app.connect_desktop()
 
     # Initialize the main loop
     app.exec()
+    component.handle(Debug("Exec runned first"))
     try:
         app.window.mainloop()
     except: