1 files changed, 13 insertions, 5 deletions
diff --git a/src/lua/lua_queue.cpp b/src/lua/lua_queue.cpp
index 929a7159..69d3b03d 100644
--- a/src/lua/lua_queue.cpp
+++ b/src/lua/lua_queue.cpp
@@ -21,7 +21,8 @@
 #include "index.hpp"
 #include "property.hpp"
 #include "service_locator.hpp"
-#include "source.hpp"
+#include "track.hpp"
+#include "track_queue.hpp"
 #include "ui_events.hpp"
 
 namespace lua {
@@ -32,11 +33,17 @@ static auto queue_add(lua_State* state) -> int {
   Bridge* instance = Bridge::Get(state);
 
   if (lua_isinteger(state, 1)) {
-    instance->services().track_queue().AddLast(luaL_checkinteger(state, 1));
+    database::TrackId id = luaL_checkinteger(state, 1);
+    instance->services().bg_worker().Dispatch<void>([=]() {
+      audio::TrackQueue& queue = instance->services().track_queue();
+      queue.append(id);
+    });
   } else {
     database::Iterator* it = db_check_iterator(state, 1);
-    instance->services().track_queue().IncludeLast(
-        std::make_shared<playlist::IteratorSource>(*it));
+    instance->services().bg_worker().Dispatch<void>([=]() {
+      audio::TrackQueue& queue = instance->services().track_queue();
+      queue.append(database::TrackIterator{*it});
+    });
   }
 
   return 0;
@@ -44,7 +51,8 @@ static auto queue_add(lua_State* state) -> int {
 
 static auto queue_clear(lua_State* state) -> int {
   Bridge* instance = Bridge::Get(state);
-  instance->services().track_queue().Clear();
+  audio::TrackQueue& queue = instance->services().track_queue();
+  queue.clear();
   return 0;
 }