From 123ee485290b6d9f70707a362f140197ab4e6099 Mon Sep 17 00:00:00 2001
From: Maximilian Giller <m.giller.dev@gmail.com>
Date: Fri, 22 Dec 2023 19:09:18 +0100
Subject: [PATCH] Testing action queue

---
 src/handler/action_queue.py |  4 ++--
 src/testing.py              | 39 +++++++++++++++++++++++++++++++++++++
 2 files changed, 41 insertions(+), 2 deletions(-)
 create mode 100644 src/testing.py

diff --git a/src/handler/action_queue.py b/src/handler/action_queue.py
index 5413d47..51c3757 100644
--- a/src/handler/action_queue.py
+++ b/src/handler/action_queue.py
@@ -23,10 +23,10 @@ class ActionQueue:
         while len(self.queued_actions) > 0:
             self.state = QueueState.POPPING
             action = self.queued_actions.pop(0)
-            action[0](*(action[1]), **(action[2]))
+            await action[0](*(action[1]), **(action[2]))
 
         self.state = QueueState.IDLE
-        self.idle_action()
+        await self.idle_action()
 
     async def stop_queue(self):
         if self.background_task is None:
diff --git a/src/testing.py b/src/testing.py
new file mode 100644
index 0000000..5d5dea0
--- /dev/null
+++ b/src/testing.py
@@ -0,0 +1,39 @@
+import asyncio
+from handler.action_queue import ActionQueue
+
+
+async def idle_a():
+    while True:
+        print("Idleling ...")
+        await asyncio.sleep(1)
+
+async def action_a():
+    print("Starting action A")
+    await asyncio.sleep(1)
+    print("Ended action A")
+    
+async def action_b():
+    print("Starting action B")
+    await asyncio.sleep(1)
+    print("Ended action B")
+
+
+
+
+
+
+
+
+
+async def main():
+    queue = ActionQueue(idle_a)
+
+    await asyncio.sleep(7)
+
+    await queue.add_action_to_queue(action_a)
+    await queue.add_action_to_queue(action_b)
+
+
+    await asyncio.sleep(10)
+
+asyncio.run(main)