package ltd.hlaeja.service

import java.util.UUID
import ltd.hlaeja.library.deviceRegistry.Devices
import ltd.hlaeja.library.deviceRegistry.Nodes
import ltd.hlaeja.library.deviceRegistry.Type
import ltd.hlaeja.library.deviceRegistry.Types
import ltd.hlaeja.property.DeviceRegistryProperty
import ltd.hlaeja.util.deviceRegistryDevices
import ltd.hlaeja.util.deviceRegistryNodes
import ltd.hlaeja.util.deviceRegistryType
import ltd.hlaeja.util.deviceRegistryTypes
import ltd.hlaeja.util.deviceRegistryTypesCreate
import ltd.hlaeja.util.deviceRegistryTypesUpdate
import ltd.hlaeja.util.hlaejaErrorHandler
import ltd.hlaeja.util.responseErrorHandler
import org.springframework.stereotype.Service
import org.springframework.web.reactive.function.client.WebClient
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

@Service
class DeviceRegistryService(
    private val webClient: WebClient,
    private val property: DeviceRegistryProperty,
) {

    fun getTypes(
        page: Int,
        show: Int,
    ): Flux<Types.Response> = webClient.deviceRegistryTypes(page, show, property)

    fun createType(
        request: Type.Request,
    ): Mono<Type.Response> = webClient.deviceRegistryTypesCreate(request, property)
        .onErrorResume(::hlaejaErrorHandler)

    fun getType(
        type: UUID,
    ): Mono<Type.Response> = webClient.deviceRegistryType(type, property)
        .onErrorResume(::responseErrorHandler)

    fun updateType(
        type: UUID,
        request: Type.Request,
    ): Mono<Type.Response> = webClient.deviceRegistryTypesUpdate(type, request, property)
        .onErrorResume(::hlaejaErrorHandler)

    fun getDevices(
        page: Int,
        show: Int,
    ): Flux<Devices.Response> = webClient.deviceRegistryDevices(page, show, property)

    fun getNodes(
        page: Int,
        show: Int,
    ): Flux<Nodes.Response> = webClient.deviceRegistryNodes(page, show, property)
}