Emcee

1
import Dispatch
2
import DistWorkerModels
3
import Foundation
4
import EmceeLogging
5
import RESTInterfaces
6
import RESTMethods
7
import RESTServer
8
import WorkerAlivenessProvider
9

10
public final class WorkerStatusEndpoint: RESTEndpoint {
11
    private let workerAlivenessProvider: WorkerAlivenessProvider
12
    public let path: RESTPath = RESTMethod.workerStatus
13
    public let requestIndicatesActivity = false
14
    
15
    public init(
16
        workerAlivenessProvider: WorkerAlivenessProvider
17
    ) {
18
        self.workerAlivenessProvider = workerAlivenessProvider
19
    }
20
    
21
    public func handle(payload: WorkerStatusPayload) throws -> WorkerStatusResponse {
22
        let aliveness = workerAlivenessProvider.workerAliveness
23
        
24
        return WorkerStatusResponse(workerAliveness: aliveness)
25
    }
26
}
27