Disable Integration Tests

Author: Robert Winkler

kotlin-wot-integration-tests/build.gradle.kts

@@ -8,9 +8,9 @@ plugins {
     id("io.spring.dependency-management") version "1.1.7"
 }
 
-//tasks.named<Test>("test") {
-//    enabled = false
-//}
+tasks.named<Test>("test") {
+    enabled = false
+}
 
 dependencies {
     // Replace the following with the starter dependencies of specific modules you wish to use

kotlin-wot-integration-tests/src/test/kotlin/integration/QuickTest.kt

@@ -4,8 +4,8 @@ package ai.ancf.lmos.wot.integration
 import ai.ancf.lmos.sdk.agents.WotConversationalAgent
 import ai.ancf.lmos.sdk.agents.lastMessage
 import ai.ancf.lmos.sdk.agents.toAgentRequest
-import ai.ancf.lmos.sdk.model.AgentEvent
 import kotlinx.coroutines.runBlocking
+import org.eclipse.lmos.arc.agents.AgentEvent
 import java.util.concurrent.CountDownLatch
 import kotlin.test.Test
 
@@ -36,10 +36,16 @@ class QuickTest {
 
         val agent = WotConversationalAgent.create("http://localhost:8181/scraper")
 
+        /*
         agent.consumeEvent("agentEvent", AgentEvent::class) {
             println("Event: $it")
             latch.countDown()
         }
+         */
+        agent.consumeEvent("agentEvent", AgentEvent::class).collect {
+            println("Event: $it")
+            latch.countDown()
+        }
 
         //val command = "What is the state of my lamp?"
         val command = "Scrape the page https://eclipse.dev/lmos/\""

lmos-kotlin-sdk-base/src/main/kotlin/sdk/agents/ConversationalAgent.kt

@@ -3,6 +3,7 @@ package ai.ancf.lmos.sdk.agents
 import ai.ancf.lmos.sdk.model.AgentRequest
 import ai.ancf.lmos.sdk.model.AgentResult
 import ai.ancf.lmos.sdk.model.Message
+import kotlinx.coroutines.flow.Flow
 import kotlin.reflect.KClass
 
 interface ConversationalAgent {
@@ -11,6 +12,7 @@ interface ConversationalAgent {
 
 interface ConsumedConversationalAgent: ConversationalAgent {
     suspend fun <T : Any> consumeEvent(eventName: String, clazz: KClass<T>, listener: EventListener<T>)
+    suspend fun <T : Any> consumeEvent(eventName: String, clazz: KClass<T>) : Flow<T>
 }
 
 fun interface EventListener<T> {

lmos-kotlin-sdk-client/src/main/kotlin/sdk/WotConversationalAgent.kt

@@ -10,6 +10,8 @@ import ai.ancf.lmos.wot.binding.http.HttpsProtocolClientFactory
 import ai.ancf.lmos.wot.binding.websocket.WebSocketProtocolClientFactory
 import ai.ancf.lmos.wot.thing.ConsumedThing
 import io.opentelemetry.instrumentation.annotations.WithSpan
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory
 import kotlin.reflect.KClass
@@ -53,7 +55,19 @@ class WotConversationalAgent private constructor(private val thing : ConsumedThi
                 listener.handleEvent(parsedEvent)
             } catch (e: Exception) {
                 log.error("Failed to parse event", e)
+                throw e
             }
         })
     }
+
+    override suspend fun <T : Any> consumeEvent(eventName: String, clazz: KClass<T>): Flow<T> {
+        return thing.consumeEvent(eventName).map { event ->
+            try {
+                JsonMapper.instance.treeToValue(event.value(), clazz.java)
+            } catch (e: Exception) {
+                log.error("Failed to parse event", e)
+                throw e
+            }
+        }
+    }
 }