From 2a6aaab583eb4e71b634eed74ba6d659d9df991c Mon Sep 17 00:00:00 2001
From: Thomas Farstrike <thomasverstreken@protonmail.com>
Date: Thu, 11 Dec 2025 12:43:00 +0100
Subject: [PATCH] API: add TaskManager that wraps asyncio

---
 internal_filesystem/lib/mpos/__init__.py     |  1 +
 internal_filesystem/lib/mpos/main.py         |  3 ++
 internal_filesystem/lib/mpos/task_manager.py | 35 ++++++++++++++++++++
 3 files changed, 39 insertions(+)
 create mode 100644 internal_filesystem/lib/mpos/task_manager.py

diff --git a/internal_filesystem/lib/mpos/__init__.py b/internal_filesystem/lib/mpos/__init__.py
index 6111795a..464207b1 100644
--- a/internal_filesystem/lib/mpos/__init__.py
+++ b/internal_filesystem/lib/mpos/__init__.py
@@ -5,6 +5,7 @@ from .net.connectivity_manager import ConnectivityManager
 from .content.intent import Intent
 from .activity_navigator import ActivityNavigator
 from .content.package_manager import PackageManager
+from .task_manager import TaskManager
 
 # Common activities (optional)
 from .app.activities.chooser import ChooserActivity
diff --git a/internal_filesystem/lib/mpos/main.py b/internal_filesystem/lib/mpos/main.py
index 36ea885a..0d001278 100644
--- a/internal_filesystem/lib/mpos/main.py
+++ b/internal_filesystem/lib/mpos/main.py
@@ -1,6 +1,7 @@
 import task_handler
 import _thread
 import lvgl as lv
+import mpos
 import mpos.apps
 import mpos.config
 import mpos.ui
@@ -71,6 +72,8 @@ except Exception as e:
     # This will throw an exception if there is already a "/builtin" folder present
     print("main.py: WARNING: could not import/run freezefs_mount_builtin: ", e)
 
+mpos.TaskManager()
+
 try:
     from mpos.net.wifi_service import WifiService
     _thread.stack_size(mpos.apps.good_stack_size())
diff --git a/internal_filesystem/lib/mpos/task_manager.py b/internal_filesystem/lib/mpos/task_manager.py
new file mode 100644
index 00000000..2fd7b765
--- /dev/null
+++ b/internal_filesystem/lib/mpos/task_manager.py
@@ -0,0 +1,35 @@
+import asyncio # this is the only place where asyncio is allowed to be imported - apps should not use it directly but use this TaskManager
+import _thread
+
+class TaskManager:
+
+    task_list = [] # might be good to periodically remove tasks that are done, to prevent this list from growing huge
+
+    def __init__(self):
+        print("TaskManager starting asyncio_thread")
+        _thread.stack_size(1024) # tiny stack size is enough for this simple thread
+        _thread.start_new_thread(asyncio.run, (self._asyncio_thread(), ))
+
+    async def _asyncio_thread(self):
+        print("asyncio_thread started")
+        while True:
+            #print("asyncio_thread tick")
+            await asyncio.sleep_ms(100)  # This delay determines how quickly new tasks can be started, so keep it below human reaction speed
+        print("WARNING: asyncio_thread exited, this shouldn't happen because now asyncio.create_task() won't work anymore!")
+
+    @classmethod
+    def create_task(cls, coroutine):
+        cls.task_list.append(asyncio.create_task(coroutine))
+
+    @classmethod
+    def list_tasks(cls):
+        for index, task in enumerate(cls.task_list):
+            print(f"task {index}: ph_key:{task.ph_key} done:{task.done()} running {task.coro}")
+
+    @staticmethod
+    def sleep_ms(ms):
+        return asyncio.sleep_ms(ms)
+
+    @staticmethod
+    def sleep(s):
+        return asyncio.sleep(s)