Emcee

1
import BalancingBucketQueue
2
import Foundation
3
import RESTInterfaces
4
import RESTMethods
5
import RESTServer
6

7
public final class JobStateEndpoint: RESTEndpoint {
8
    private let stateProvider: JobStateProvider
9
    public let path: RESTPath = JobStateRESTMethod()
10
    public let requestIndicatesActivity = false
11

12
    public init(stateProvider: JobStateProvider) {
13
        self.stateProvider = stateProvider
14
    }
15
    
16
    public func handle(payload: JobStatePayload) throws -> JobStateResponse {
17
        let jobState = try stateProvider.state(jobId: payload.jobId)
18
        return JobStateResponse(jobState: jobState)
19
    }
20
}
21