From 893423c5869e21a1bbfe26ddf304c175069c17f3 Mon Sep 17 00:00:00 2001
From: Swordsteel <swordsteel@gmail.com>
Date: Sat, 30 Nov 2024 18:37:00 +0100
Subject: [PATCH] add DeviceConfigurationService

---
 .../service/DeviceConfigurationService.kt     | 34 +++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 src/main/kotlin/ltd/hlaeja/service/DeviceConfigurationService.kt

diff --git a/src/main/kotlin/ltd/hlaeja/service/DeviceConfigurationService.kt b/src/main/kotlin/ltd/hlaeja/service/DeviceConfigurationService.kt
new file mode 100644
index 0000000..765d8c7
--- /dev/null
+++ b/src/main/kotlin/ltd/hlaeja/service/DeviceConfigurationService.kt
@@ -0,0 +1,34 @@
+package ltd.hlaeja.service
+
+import java.util.UUID
+import ltd.hlaeja.library.deviceConfiguration.Node
+import ltd.hlaeja.property.DeviceConfigurationProperty
+import mu.KotlinLogging
+import org.springframework.http.HttpStatus.NOT_FOUND
+import org.springframework.http.HttpStatus.NO_CONTENT
+import org.springframework.http.HttpStatus.REQUEST_TIMEOUT
+import org.springframework.stereotype.Service
+import org.springframework.web.reactive.function.client.WebClient
+import org.springframework.web.reactive.function.client.awaitBodyOrNull
+import org.springframework.web.server.ResponseStatusException
+
+private val log = KotlinLogging.logger {}
+
+@Service
+class DeviceConfigurationService(
+    private val webClient: WebClient,
+    private val deviceConfigurationProperty: DeviceConfigurationProperty,
+) {
+
+    suspend fun getConfiguration(
+        node: UUID,
+    ): Node.Response = webClient.get()
+        .uri("${deviceConfigurationProperty.url}/node-$node".also(::logCall))
+        .retrieve()
+        .onStatus(NOT_FOUND::equals) { throw ResponseStatusException(NO_CONTENT) }
+        .awaitBodyOrNull<Node.Response>() ?: throw ResponseStatusException(REQUEST_TIMEOUT)
+
+    private fun logCall(url: String) {
+        log.debug("calling: {}", url)
+    }
+}