Emcee

1
import BalancingBucketQueue
2
import BucketQueueTestHelpers
3
import DateProviderTestHelpers
4
import Foundation
5
import MetricsExtensions
6
import MetricsTestHelpers
7
import QueueModels
8
import TestHelpers
9
import XCTest
10

11
final class MultipleQueuesJobManipulatorTests: XCTestCase {
12
    private lazy var container = MultipleQueuesContainer()
13
    private lazy var manipulator = MultipleQueuesJobManipulator(
14
        dateProvider: DateProviderFixture(),
15
        hostname: "hostname",
16
        specificMetricRecorderProvider: NoOpSpecificMetricRecorderProvider(),
17
        multipleQueuesContainer: container,
18
        emceeVersion: Version(value: "version")
19
    )
20
    
21
    func test___deleting_non_existing_job___throws() {
22
        assertThrows {
23
            try manipulator.delete(jobId: "jobId")
24
        }
25
    }
26
    
27
    func test___deleting_existing_job() {
28
        container.add(runningJobQueue: createJobQueue(job: createJob(jobId: "jobId")))
29
        
30
        assertDoesNotThrow {
31
            try manipulator.delete(jobId: "jobId")
32
        }
33
        
34
        XCTAssertTrue(container.allRunningJobQueues().isEmpty)
35
        
36
        XCTAssertEqual(
37
            container.allDeletedJobQueues().map { $0.job.jobId },
38
            [JobId("jobId")]
39
        )
40
        XCTAssertEqual(
41
            container.trackedJobGroups().map { $0.jobGroupId },
42
            []
43
        )
44
    }
45
}
46