Emcee

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

7
public final class JobResultsEndpoint: RESTEndpoint {
8
    private let jobResultsProvider: JobResultsProvider
9
    public let path: RESTPath = JobResultsRESTMethod()
10
    public let requestIndicatesActivity = true
11

12
    public init(jobResultsProvider: JobResultsProvider) {
13
        self.jobResultsProvider = jobResultsProvider
14
    }
15
    
16
    public func handle(payload: JobResultsPayload) throws -> JobResultsResponse {
17
        let jobResults = try jobResultsProvider.results(jobId: payload.jobId)
18
        return JobResultsResponse(jobResults: jobResults)
19
    }
20
}
21