func dispatched()

in Sources/XCMetricsBackendLib/UploadMetrics/Jobs/JobLogEventDelegate.swift [30:47]

• 18 lines of code
• 2 McCabe index (conditional complexity)

    func dispatched(job: JobEventData, eventLoop: EventLoop) -> EventLoopFuture<Void> {
        if job.xcm_isProcessMetricsJob() {
            guard let request = try? JSONDecoder().decode(UploadMetricsRequest.self, from: Data(job.payload)) else {
                logger.error("Couldn't decode UploadMetricsRequest in JobLogEventDelegate")
                return eventLoop.future()
            }
            let entry = JobLogEntry(id: job.id,
                                    logFile: request.logURL.lastPathComponent,
                                    logURL: request.logURL.absoluteString,
                                    status: .pending,
                                    error: nil,
                                    queuedAt: job.queuedAt,
                                    dequeuedAt: nil,
                                    finishedAt: nil)
            return repository.create(entry, using: eventLoop.next())
        }
        return eventLoop.future()
    }