From 69151a450be4432feeb28bde56edd5f5476ea9f8 Mon Sep 17 00:00:00 2001
From: June Tate-Gans <june@theonelab.com>
Date: Tue, 4 May 2021 01:43:32 -0500
Subject: [PATCH] manager: Setup as an observer

It would make sense that when the profile changes that the manager should
automatically reconfigure for the new profile. This changes the Manager into an
Observer and registers for profile and LCD color changes.
---
 g13gui/g13gui/g13/manager.py | 41 ++++++++++++++++++++++++++++++++++--
 1 file changed, 39 insertions(+), 2 deletions(-)

diff --git a/g13gui/g13gui/g13/manager.py b/g13gui/g13gui/g13/manager.py
index b67a0f0..3d7b861 100644
--- a/g13gui/g13gui/g13/manager.py
+++ b/g13gui/g13gui/g13/manager.py
@@ -13,6 +13,7 @@ from evdev import UInput
 from evdev import AbsInfo
 from evdev import ecodes as e
 
+from g13gui.observer.observer import Observer
 from g13gui.model.bindings import StickMode
 from g13gui.g13.common import G13NormalKeys
 from g13gui.g13.common import G13SpecialKeys
@@ -47,7 +48,7 @@ class StateError(RuntimeError):
     pass
 
 
-class Manager(threading.Thread):
+class Manager(threading.Thread, Observer):
     class State(enum.Enum):
         DISCOVERING = 0
         FOUND = 1
@@ -55,6 +56,8 @@ class Manager(threading.Thread):
 
     def __init__(self, prefs):
         threading.Thread.__init__(self, daemon=True)
+        Observer.__init__(self)
+
         self._prefs = prefs
         self._state = Manager.State.DISCOVERING
         self._device = None
@@ -65,6 +68,38 @@ class Manager(threading.Thread):
                               product=PRODUCT_ID)
         self._lastKeyState = {}
         self._commandQueue = queue.Queue()
+        self._lastProfile = None
+
+        self._prefs.registerObserver(self, {'selectedProfile'})
+        self._updateProfileRegistration()
+        self.changeTrigger(self.onSelectedProfileChanged,
+                           keys={'selectedProfile'})
+        self.changeTrigger(self.onLcdColorChanged,
+                           keys={'lcdColor'})
+
+    def _updateProfileRegistration(self):
+        if self._lastProfile is not None:
+            self._lastProfile.removeObserver(self)
+
+        self._lastProfile = self._prefs.selectedProfile()
+        self._lastProfile.registerObserver(self, {'lcdColor'})
+
+    def onSelectedProfileChanged(self, subject, changeType, key, data):
+        print('onSelectedProfileChanged')
+        self._updateProfileRegistration()
+
+        if self._state == Manager.State.FOUND:
+            self._updateLcdColor()
+
+    def onLcdColorChanged(self, subject, changeType, key, data):
+        print('onLcdColorChanged')
+        if self._state == Manager.State.FOUND:
+            self._updateLcdColor()
+
+    def _updateLcdColor(self):
+        lcdColor = self._prefs.selectedProfile().lcdColor
+        lcdColor = [int(x * 255) for x in lcdColor]
+        self.setBacklightColor(*lcdColor)
 
     @property
     def state(self):
@@ -160,7 +195,7 @@ class Manager(threading.Thread):
         self._commandQueue.put([self._setBacklightColor, (r, g, b)])
 
     def _setBacklightColor(self, r, g, b):
-        data = [5, r, g, b, 0]
+        data = [5, int(r), int(g), int(b), 0]
         type = usb.util.CTRL_TYPE_CLASS | usb.util.CTRL_RECIPIENT_INTERFACE
 
         self._device.ctrl_transfer(
@@ -201,6 +236,8 @@ class Manager(threading.Thread):
             self._discover()
             print('Got device')
 
+            self._updateLcdColor()
+
             while self._state == Manager.State.FOUND:
                 try:
                     count = self._readKeys(reportBuffer)