Create data class to update data via threads

backend/systembridgebackend/data.py

@@ -0,0 +1,77 @@
+"""System Bridge: Data"""
+import asyncio
+from collections.abc import Callable
+from threading import Thread
+
+from systembridgeshared.base import Base
+from systembridgeshared.database import Database
+
+from systembridgebackend.modules.update import Update
+
+
+class UpdateThread(Thread):
+    """Update thread"""
+
+    def __init__(
+        self,
+        database: Database,
+        updated_callback: Callable,
+    ) -> None:
+        """Initialize"""
+        super().__init__()
+        self._database = database
+        self._update = Update(self._database)
+        self._updated_callback = updated_callback
+
+    def run(self) -> None:
+        """Run"""
+        asyncio.run(self._update.update_data(self._updated_callback))
+
+
+class UpdateFrequentThread(Thread):
+    """Update frequent thread"""
+
+    def __init__(
+        self,
+        database: Database,
+        updated_callback: Callable,
+    ) -> None:
+        """Initialize"""
+        super().__init__()
+        self._database = database
+        self._update = Update(self._database)
+        self._updated_callback = updated_callback
+
+    def run(self) -> None:
+        """Run"""
+        asyncio.run(self._update.update_frequent_data(self._updated_callback))
+
+
+class Data(Base):
+    """Data"""
+
+    def __init__(
+        self,
+        database: Database,
+        updated_callback: Callable,
+    ) -> None:
+        """Initialize"""
+        super().__init__()
+        self._database = database
+        self._updated_callback = updated_callback
+
+    def request_update_data(self) -> None:
+        """Request update data"""
+        thread = UpdateThread(
+            self._database,
+            self._updated_callback,
+        )
+        thread.start()
+
+    def request_update_frequent_data(self) -> None:
+        """Request update frequent data"""
+        thread = UpdateFrequentThread(
+            self._database,
+            self._updated_callback,
+        )
+        thread.start()

backend/systembridgebackend/server/__init__.py

@@ -7,7 +7,6 @@
 import sys
 
 from sanic import Sanic
-from sanic.models.handler_types import ListenerType
 from sanic.request import Request
 from sanic.response import HTTPResponse, json
 from sanic_scheduler import SanicScheduler, task
@@ -16,9 +15,9 @@
 from systembridgeshared.database import Database
 from systembridgeshared.settings import Settings
 
+from systembridgebackend.data import Data
 from systembridgebackend.gui import GUIAttemptsExceededException, start_gui_threaded
 from systembridgebackend.modules.listeners import Listeners
-from systembridgebackend.modules.update import Update
 from systembridgebackend.server.auth import ApiKeyAuthentication
 from systembridgebackend.server.keyboard import handler_keyboard
 from systembridgebackend.server.mdns import MDNSAdvertisement
@@ -67,7 +66,7 @@ def __init__(
 
         SanicScheduler(self._server, utc=True)
         self._listeners = Listeners(self._database, implemented_modules)
-        self._update = Update(self._database)
+        self._data = Data(self._database, self._data_updated)
 
         auth = ApiKeyAuthentication(
             app=self._server,
@@ -95,15 +94,15 @@ async def _after_startup(_) -> None:
         )
         async def _update_data(_) -> None:
             """Update data"""
-            await self._update.update_data(self._data_updated)
+            self._data.request_update_data()
 
         @task(
             start=timedelta(seconds=10),
             period=timedelta(seconds=30),
         )
         async def _update_frequent_data(_) -> None:
             """Update frequent data"""
-            await self._update.update_frequent_data(self._data_updated)
+            self._data.request_update_frequent_data()
 
         @auth.key_required
         async def _handler_data_all(