ty-demeter-blog-6

BatchEventOperation.kt

internal class BatchEventOperation : Operation {

    override suspend fun operate(demeter: Demeter) {
        val events = demeter.eventDataProvider.fetchAwaitingEvents(FETCH_EVENT_SIZE)
        
        ...

        demeter.eventDataProvider.updateEventStatus(
            events = events,
            eventStatus = EventStatus.PROCESSING,
        )
        val eventRequest = BatchEventRequest.newEventRequest(
            baseUrl = demeter.baseUrl,
            payloads = events,
            converterFactory = demeter.converterFactory,
        )
        val eventCall = RealEventCall.newEventCall(demeter.httpClient, eventRequest)
        val callResult = eventCall.enqueue()

        if (callResult.isSuccess) {
            demeter.eventDataProvider.deleteEvents(events)
            demeter.eventResultReporter.report(callResult)
        } else {
            demeter.eventDataProvider.updateEventStatus(EventStatus.AWAITING, events)
            demeter.eventResultReporter.report(callResult)
        }
    }
}