Handle item notifications

NationalLibraryOfNorway · Oct 9, 2024 · 82b2684 · 82b2684
1 parent d862947
commit 82b2684
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/src/main/kotlin/no/nb/mlt/wls/application/synqapi/synq/SynqController.kt b/src/main/kotlin/no/nb/mlt/wls/application/synqapi/synq/SynqController.kt
@@ -33,8 +33,7 @@ class SynqController(
         @RequestBody synqBatchItemUpdatePayload: SynqBatchItemUpdatePayload
     ): ResponseEntity<Void> {
         for (payload in synqBatchItemUpdatePayload.mapToItemPayloads()) {
-            val item = moveItem.moveItem(payload)
-            println(item)
+            moveItem.moveItem(payload)
         }
         return ResponseEntity.ok().build()
     }

diff --git a/src/main/kotlin/no/nb/mlt/wls/domain/WLSService.kt b/src/main/kotlin/no/nb/mlt/wls/domain/WLSService.kt
@@ -71,7 +71,9 @@ class WLSService(
             throw ValidationException("Location can not be blank")
         }
         val item = getItem(hostName, hostId) ?: throw ItemNotFoundException("Item with id '$hostId' does not exist for '$hostName'")
-        return itemRepository.moveItem(item.hostId, item.hostName, quantity, location)
+        itemRepository.moveItem(item.hostId, item.hostName, quantity, location)
+        inventoryNotifier.itemChanged(item)
+        return item
     }
 
     override suspend fun createOrder(orderDTO: CreateOrderDTO): Order {

diff --git a/src/main/kotlin/no/nb/mlt/wls/infrastructure/callbacks/InventoryNotifierAdapter.kt b/src/main/kotlin/no/nb/mlt/wls/infrastructure/callbacks/InventoryNotifierAdapter.kt
@@ -11,7 +11,16 @@ class InventoryNotifierAdapter(
     private val webClient: WebClient
 ) : InventoryNotifier {
     override fun itemChanged(item: Item) {
-        TODO("Future task")
+        if (item.callbackUrl != null) {
+            webClient
+                .post()
+                .uri(item.callbackUrl)
+                .bodyValue(item)
+                .retrieve()
+                .bodyToMono(Void::class.java)
+                .retry(5)
+                .subscribe()
+        }
     }
 
     override fun orderChanged(order: Order) {