Add device registry

- add RegistryController
- add DeviceRegistryService
- add Helper.kt
- add device registry property
- set up registry property

src/main/kotlin/ltd/hlaeja/Application.kt

@@ -1,8 +1,13 @@
 package ltd.hlaeja
 
+import ltd.hlaeja.property.DeviceRegistryProperty
 import org.springframework.boot.autoconfigure.SpringBootApplication
+import org.springframework.boot.context.properties.EnableConfigurationProperties
 import org.springframework.boot.runApplication
 
+@EnableConfigurationProperties(
+    DeviceRegistryProperty::class,
+)
 @SpringBootApplication
 class Application
 

src/main/kotlin/ltd/hlaeja/controller/RegistryController.kt

@@ -0,0 +1,18 @@
+package ltd.hlaeja.controller
+
+import ltd.hlaeja.library.deviceRegistry.Device
+import ltd.hlaeja.service.DeviceRegistryService
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+class RegistryController(
+    private val registryService: DeviceRegistryService,
+) {
+
+    @PostMapping("/register")
+    suspend fun addDevice(
+        @RequestBody request: Device.Request,
+    ): Device.Response = registryService.registerDevice(request)
+}

src/main/kotlin/ltd/hlaeja/property/DeviceRegistryProperty.kt

@@ -0,0 +1,8 @@
+package ltd.hlaeja.property
+
+import org.springframework.boot.context.properties.ConfigurationProperties
+
+@ConfigurationProperties(prefix = "device-registry")
+data class DeviceRegistryProperty(
+    val url: String,
+)

src/main/kotlin/ltd/hlaeja/service/DeviceRegistryService.kt

@@ -0,0 +1,24 @@
+package ltd.hlaeja.service
+
+import ltd.hlaeja.library.deviceRegistry.Device
+import ltd.hlaeja.util.logCall
+import ltd.hlaeja.property.DeviceRegistryProperty
+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
+
+@Service
+class DeviceRegistryService(
+    private val webClient: WebClient,
+    private val deviceRegistryProperty: DeviceRegistryProperty,
+) {
+    suspend fun registerDevice(
+        request: Device.Request,
+    ): Device.Response = webClient.post()
+        .uri("${deviceRegistryProperty.url}/device".also(::logCall))
+        .bodyValue(request)
+        .retrieve()
+        .awaitBodyOrNull<Device.Response>() ?: throw ResponseStatusException(REQUEST_TIMEOUT)
+}

src/main/kotlin/ltd/hlaeja/util/Helper.kt

@@ -0,0 +1,9 @@
+package ltd.hlaeja.util
+
+import mu.KotlinLogging
+
+private val log = KotlinLogging.logger {}
+
+fun logCall(url: String) {
+    log.debug("calling: {}", url)
+}

src/main/resources/META-INF/additional-spring-configuration-metadata.json

@@ -19,6 +19,11 @@
       "name": "spring.application.build.os.version",
       "type": "java.lang.String",
       "description": "Application build os version."
+    },
+    {
+      "name": "device-registry.url",
+      "type": "java.lang.String",
+      "description": "Url for device registry service."
     }
   ]
 }

src/main/resources/application.yml

@@ -27,6 +27,9 @@ server:
     key-store-type: PKCS12
     key-store-password: password
 
+device-registry:
+  url: http://localhost:9010
+
 ---
 ##########################
 ### Docker environment ###
@@ -44,6 +47,9 @@ server:
     key-store-type: PKCS12
     key-store-password: password
 
+device-registry:
+  url: http://DeviceRegistry:8080
+
 ---
 ##############################
 ### Production environment ###