fix queue tests

Alchemy/Queue/Commands/WorkCommand.swift

@@ -16,6 +16,9 @@ struct WorkCommand: Command {
     /// Should the scheduler run in process, scheduling any recurring work.
     @Flag var schedule: Bool = false
 
+    /// Should the worker continue dequeuing jobs after it runs one.
+    @Flag var empty: Bool = false
+
     var queue: Queue {
         Container.require(id: name)
     }
@@ -28,7 +31,7 @@ struct WorkCommand: Command {
         }
 
         for _ in 0..<workers {
-            queue.startWorker(for: channels.components(separatedBy: ","))
+            queue.startWorker(for: channels.components(separatedBy: ","), untilEmpty: empty)
         }
 
         try await Life.runServices()

AlchemyTest/TestCase/TestCase.swift

@@ -51,6 +51,7 @@ open class TestCase<A: Application>: XCTestCase {
 
     open override func tearDown() async throws {
         try await super.tearDown()
+        await app.stop()
         try await app.didRun()
         app.container.reset()
     }

Tests/Queues/QueueTests.swift

@@ -1,7 +1,6 @@
 @testable
 import Alchemy
 import AlchemyTest
-import NIOEmbedded
 
 final class QueueTests: TestCase<TestApp> {
     private lazy var allTests = [
@@ -82,24 +81,18 @@ final class QueueTests: TestCase<TestApp> {
         let exp = expectation(description: "")
         ConfirmableJob.didRun = { exp.fulfill() }
         try await ConfirmableJob().dispatch()
-
-        let loop = EmbeddedEventLoop()
-        Q.startWorker()
-        loop.advanceTime(by: .seconds(5))
-
-        await fulfillment(of: [exp], timeout: kMinTimeout)
+        app.background("queue:work")
+        await fulfillment(of: [exp], timeout: 2)
     }
 
     private func _testFailure(file: StaticString = #filePath, line: UInt = #line) async throws {
         let exp = expectation(description: "")
         FailureJob.didFinish = { exp.fulfill() }
         try await FailureJob().dispatch()
 
-        let loop = EmbeddedEventLoop()
-        Q.startWorker()
-        loop.advanceTime(by: .seconds(5))
-
-        await fulfillment(of: [exp], timeout: kMinTimeout)
+        app.background("queue:work")
+
+        await fulfillment(of: [exp], timeout: 2)
         AssertNil(try await Q.dequeue(from: ["default"]))
     }
 
@@ -108,10 +101,8 @@ final class QueueTests: TestCase<TestApp> {
         RetryJob.didFail = { exp.fulfill() }
         try await RetryJob(foo: "bar").dispatch()
 
-        let loop = EmbeddedEventLoop()
-        Q.startWorker(untilEmpty: false)
-        loop.advanceTime(by: .seconds(5))
-        await fulfillment(of: [exp], timeout: kMinTimeout)
+        app.background("queue:work")
+        await fulfillment(of: [exp], timeout: 1.1)
 
         guard let jobData = try await Q.dequeue(from: ["default"]) else {
             XCTFail("Failed to dequeue a job.", file: file, line: line)