Emcee

1
import Deployer
2
import EmceeLogging
3
import QueueCommunication
4
import RESTInterfaces
5
import RESTMethods
6
import RESTServer
7

8
public final class WorkersToUtilizeEndpoint: RESTEndpoint {
9
    public let path: RESTPath = RESTMethod.workersToUtilize
10
    public let requestIndicatesActivity = false
11
    
12
    private let logger: ContextualLogger
13
    private let service: WorkersToUtilizeService
14
    
15
    public init(
16
        logger: ContextualLogger,
17
        service: WorkersToUtilizeService
18
    ) {
19
        self.logger = logger
20
        self.service = service
21
    }
22
    
23
    public func handle(payload: WorkersToUtilizePayload) throws -> WorkersToUtilizeResponse {
24
        logger.debug("Received workers to utilize payload: \(payload)")
25
        return .workersToUtilize(
26
            workerIds: service.workersToUtilize(
27
                initialWorkerIds: payload.workerIds,
28
                queueInfo: payload.queueInfo
29
            )
30
        )
31
    }
32
}
33