Refactored Integration Tests

Author: Robert Winkler

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

@@ -5,16 +5,16 @@ plugins {
 }
 
 dependencies {
-    api(project(":kotlin-wot"))
     api(project(":kotlin-wot-binding-http"))
+    //api(project(":kotlin-wot-binding-websocket"))
     api(project(":kotlin-wot-binding-mqtt"))
-    api(project(":kotlin-wot-reflection"))
     api(project(":kotlin-wot-spring-boot-starter"))
     implementation("ai.ancf.lmos:arc-azure-client:0.111.0")
     api("ai.ancf.lmos:arc-spring-boot-starter:0.111.0")
 
     //implementation("dev.langchain4j:langchain4j-azure-open-ai:0.35.0")
     //implementation("dev.langchain4j:langchain4j:0.35.0")
+    testImplementation("org.springframework.boot:spring-boot-starter-test")
     testImplementation("com.hivemq:hivemq-mqtt-client:1.3.3")
     implementation("org.testcontainers:testcontainers:1.20.3")
 }

kotlin-wot-integration-tests/src/main/kotlin/integration/AgentConfiguration.kt

@@ -2,6 +2,8 @@ package ai.ancf.lmos.wot.integration
 
 import ai.ancf.lmos.arc.spring.Agents
 import ai.ancf.lmos.arc.spring.Functions
+import ai.ancf.lmos.wot.Wot
+import ai.ancf.lmos.wot.thing.schema.genericReadProperty
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 
@@ -12,18 +14,40 @@ class AgentConfiguration {
     @Bean
     fun myAgent(agent: Agents) = agent {
         name = "My Agent"
-        prompt { "you are a helpful weather agent." }
+        prompt { "You are a helpful agent which can control devices." }
         model = { "GPT-4o" }
+        tools {
+            +"getResources"
+        }
     }
 
 
     @Bean
-    fun myFunction(function: Functions) = function(
-        name = "g",
-        description = "Returns real-time weather information for any location",
+    fun getResources(function: Functions, wot: Wot) = function(
+        name = "getResources",
+        description = "Returns the resources available in the coffee machine.",
     ) {
+
+        val thingDescription =
+            wot.requestThingDescription("http://remotelab.esi.cit.tum.de:8080/virtual-coffee-machine-1_1")
+
+        val testThing = wot.consume(thingDescription)
+
+        val availableResources = testThing.genericReadProperty<Resources>("allAvailableResources")
+
+        """
+            The coffee machine has the following resources available:
+            - Milk: ${availableResources.milk} ml
+            - Water: ${availableResources.water} ml
+            - Chocolate: ${availableResources.chocolate} grams
+            - Coffee Beans: ${availableResources.coffeeBeans} grams
         """
-        The weather is good in Berlin. It is 20 degrees celsius.
-    """
     }
-}
+}
+
+data class Resources(
+    val milk: Int,
+    val water: Int ,
+    val chocolate : Int,
+    val coffeeBeans: Int
+)

kotlin-wot-integration-tests/src/main/kotlin/integration/HttpAgent.kt

@@ -9,6 +9,10 @@ arc:
 
 wot:
   servient:
+    http:
+      server:
+        host: localhost
+        port: 8080
     mqtt:
       server:
         enabled: false

kotlin-wot-integration-tests/src/main/kotlin/integration/MqttAgent.kt

@@ -0,0 +1,37 @@
+package ai.ancf.lmos.wot.integration
+
+import ai.ancf.lmos.wot.Wot
+import ai.ancf.lmos.wot.thing.schema.genericReadProperty
+import kotlinx.coroutines.test.runTest
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
+import kotlin.test.Test
+import kotlin.test.assertNotNull
+
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
+class ThingAgentApplicationTest {
+
+    private var port: Int = 8080
+
+    @Autowired
+    private lateinit var wot: Wot
+
+    @Test
+    fun testGenericReadProperty() = runTest {
+        // Construct the dynamic server URL
+        val serverUrl = "http://localhost:$port/agent"
+
+        // Request the Thing Description
+        val thingDescription = wot.requestThingDescription(serverUrl)
+        // Consume the Thing
+        val testThing = wot.consume(thingDescription)
+
+        // Read the Model Configuration property
+        val modelConfiguration = testThing.genericReadProperty<ModelConfiguration>("modelConfiguration")
+        assertNotNull(modelConfiguration, "Model Configuration should not be null")
+
+        println("Model Configuration: $modelConfiguration")
+
+
+    }
+}

kotlin-wot-integration-tests/src/main/kotlin/integration/Util.kt

@@ -1,10 +1,10 @@
-package integration
+package ai.ancf.lmos.wot.integration
 
 import ai.ancf.lmos.wot.Servient
 import ai.ancf.lmos.wot.Wot
 import ai.ancf.lmos.wot.binding.http.HttpProtocolClientFactory
 import ai.ancf.lmos.wot.binding.http.HttpsProtocolClientFactory
-import ai.ancf.lmos.wot.thing.schema.DataSchemaValue
+import ai.ancf.lmos.wot.thing.schema.genericReadProperty
 import kotlinx.coroutines.test.runTest
 import kotlin.test.Test
 
@@ -19,11 +19,21 @@ class TestSimpleCoffeeMachine {
         val wot = Wot.create(servient)
 
         val thingDescription =
-            wot.requestThingDescription("https://zion.vaimee.com/things/urn:uuid:7ba2bca0-a7f6-47b3-bdce-498caa33bbaf")
+            wot.requestThingDescription("http://remotelab.esi.cit.tum.de:8080/virtual-coffee-machine-1_1")
 
-        val coffeeMachine = wot.consume(thingDescription)
-        val resources = coffeeMachine.readProperty("resources").value() as DataSchemaValue.ObjectValue
+        val testThing = wot.consume(thingDescription)
+        val status = testThing.genericReadProperty<String>("status")
 
-        println(resources)
+        val availableResources = testThing.genericReadProperty<Resources>("allAvailableResources")
+
+        println(status)
+        println(availableResources)
     }
-}
+}
+
+data class Resources(
+    val milk: Int,
+    val water: Int ,
+    val chocolate : Int,
+    val coffeeBeans: Int
+)

kotlin-wot-integration-tests/src/main/resources/application.yaml

@@ -471,6 +471,7 @@ object ExposedThingBuilder {
         } else{
             exposedThing.setPropertyReadHandler(name) { _ ->
                 val value = property.getter.call(instance)
+
                 InteractionInput.Value(DataSchemaValue.toDataSchemaValue(value))
             }
         }