New update manager endpoints

Author: Jared-Gross

config/environments.py

@@ -11,3 +11,4 @@ def __init__(self):
 
     DATA_PATH = os.getcwd()
     APP_ENV = os.environ.get("APP_ENV", "production")
+    SOFTWARE_API_BASE = os.environ.get("SOFTWARE_API_BASE", "http://invi.go/api/software")

ui/windows/main_window.py

@@ -3301,7 +3301,7 @@ def send_email_response(self, response: str):
 
     def start_check_for_updates_thread(self):
         check_for_updates_thread = CheckForUpdatesThread(self, __version__)
-        check_for_updates_thread.signal.connect(self.update_available_thread_response)
+        check_for_updates_thread.update_available.connect(self.update_available_thread_response)
         self.threads.append(check_for_updates_thread)
         check_for_updates_thread.start()
 

update_gui.py

@@ -17,6 +17,7 @@
 )
 from PyQt6.QtGui import QColor, QPainter
 from PyQt6.QtWidgets import QApplication, QLabel, QVBoxLayout, QWidget
+from config.environments import Environment
 
 
 class DownloadThread(QThread):
@@ -193,7 +194,7 @@ def __init__(self):
 
         self.threads = []
 
-        download_thread = DownloadThread(url="http://10.0.0.10:5051/download")
+        download_thread = DownloadThread(url=f"{Environment.SOFTWARE_API_BASE}/download")
         QApplication.setOverrideCursor(Qt.CursorShape.WaitCursor)
         self.start_thread(download_thread)
 

utils/threads/check_for_updates_thread.py

@@ -1,28 +1,46 @@
 import time
-
 import requests
 from PyQt6.QtCore import QThread, pyqtSignal
 
+from config.environments import Environment
+
 
 class CheckForUpdatesThread(QThread):
-    signal = pyqtSignal(object, object)
+    update_available = pyqtSignal(dict)
 
     def __init__(self, parent, current_version: str):
-        self.parent = parent
+        super().__init__(parent)
         self.current_version = current_version
-        QThread.__init__(self)
+        self._running = True
+
+    def stop(self):
+        self._running = False
 
     def run(self):
-        while True:
+        while self._running:
             try:
-                response_version = requests.get("http://10.0.0.10:5051/version", timeout=10)
-                response_message = requests.get("http://10.0.0.10:5051/update_message", timeout=10)
-                if response_version.status_code != 200 or response_message.status_code != 200:
+                resp = requests.get(
+                    f"{Environment.SOFTWARE_API_BASE}/version",
+                    timeout=10,
+                )
+
+
+                if resp.status_code != 200:
+                    time.sleep(60)
                     continue
-                version = response_version.text
-                message = response_message.text
-                if version != self.current_version:
-                    self.signal.emit(version, message)
+
+                data = resp.json()
+                latest_version = data.get("version")
+                changelog = data.get("changelog")
+
+                if not latest_version:
+                    time.sleep(60)
+                    continue
+
+                if latest_version != self.current_version:
+                    self.update_available.emit(latest_version, changelog)
+
             except Exception:
-                continue
+                pass
+
             time.sleep(60)