1 files changed, 65 insertions, 0 deletions
diff --git a/extras/Kuksa_Instance.py b/extras/Kuksa_Instance.py
new file mode 100644
index 0000000..a36ae2c
--- /dev/null
+++ b/extras/Kuksa_Instance.py
@@ -0,0 +1,65 @@
+from typing import Optional
+import kuksa_client as kuksa
+import threading
+import time
+
+from extras import config
+
+class KuksaClientSingleton:
+    __instance: Optional["KuksaClientSingleton"] = None
+    __lock = threading.Lock()
+
+    @staticmethod
+    def get_instance() -> "KuksaClientSingleton":
+        if KuksaClientSingleton.__instance is None:
+            with KuksaClientSingleton.__lock:
+                if KuksaClientSingleton.__instance is None:
+                    KuksaClientSingleton.__instance = KuksaClientSingleton()
+        return KuksaClientSingleton.__instance
+
+    def __init__(self):
+        if KuksaClientSingleton.__instance is not None:
+            raise Exception("This class is a singleton!")
+        else:
+
+            self.default_Config = config.KUKSA_CONFIG
+            self.token = config.TOKEN_PATH
+
+            try:
+                self.client = kuksa.KuksaClientThread(self.default_Config)
+                self.client.authorize(self.token)
+                time.sleep(2)
+                if self.client.checkConnection() == False:
+                    self.client = None
+            except Exception as e:
+                print(e)
+                
+
+            KuksaClientSingleton.__instance = self
+
+    def reconnect_client(self, new_Config, new_Token):
+        if self.client is not None:
+            self.client.stop()
+        self.client = kuksa.KuksaClientThread(new_Config)
+        self.client.authorize(new_Token)
+        return self.client
+
+    def get_client(self):
+        return self.client        
+    
+    def get_config(self):
+        return self.default_Config
+    
+    def get_token(self):
+        return self.token
+
+    def get_status(self):
+        if self.client is not None:
+            return self.client.checkConnection()
+        else:
+            return False
+
+    def __del__(self):
+        if self.client is not None:
+            self.client.stop()
+        return None