Reflection

Author: Robert Winkler

.idea/gradle.xml

@@ -2,6 +2,7 @@ dependencies {
     api(project(":kotlin-wot"))
     api(project(":kotlin-wot-binding-http"))
     api(project(":kotlin-wot-binding-mqtt"))
+    api(project(":kotlin-wot-reflection"))
     api("ch.qos.logback:logback-classic:1.5.12")
     implementation("ai.ancf.lmos:arc-agents:0.98.0")
     implementation("ai.ancf.lmos:arc-langchain4j-client:0.98.0")

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

@@ -1,15 +1,15 @@
 package ai.ancf.lmos.wot.integration
 
 import ai.ancf.lmos.wot.Wot
-import kotlinx.coroutines.Dispatchers
+import ai.ancf.lmos.wot.reflection.annotations.ThingAgent
 import kotlinx.coroutines.Job
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 
 
 fun main(): Unit = runBlocking {
 
-    val agent = Agent()
+    val agent = ThingAgent()
 
     // Protocol can be "HTTP" or "MQTT"
     val servient = createServient("HTTP")

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

@@ -1,11 +1,14 @@
 package ai.ancf.lmos.wot.integration
 
 import ai.ancf.lmos.wot.Wot
-import kotlinx.coroutines.*
+import ai.ancf.lmos.wot.reflection.annotations.ThingAgent
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
 
 
 fun main(): Unit = runBlocking {
-    val agent = Agent()
+    val agent = ThingAgent()
 
     // Protocol can be "HTTP" or "MQTT"
     val servient = createServient("MQTT")

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

@@ -0,0 +1,26 @@
+package ai.ancf.lmos.wot.reflection.annotations
+
+import dev.langchain4j.model.azure.AzureOpenAiChatModel
+
+
+@Thing(id= "agent", title="Agent",
+    description= "A simple agent.")
+class ThingAgent() {
+
+    private val model: AzureOpenAiChatModel = AzureOpenAiChatModel.builder()
+        .apiKey("af12dab9c046453e82dcf4b24af90bca")
+        .deploymentName("GPT35T-1106")
+        .endpoint("https://gpt4-uk.openai.azure.com/")
+        .build();
+
+    @Property(name = "modelTemperature", readOnly = true)
+    var modelTemperature: ModelConfiguration = ModelConfiguration(0.5, 50)
+
+    @Action(name = "ask")
+    fun ask(message : String) : String {
+        return model.generate(message)
+    }
+}
+
+data class ModelConfiguration(val modelTemperature: Double, val maxTokens: Int)
+

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

@@ -6,6 +6,7 @@ import ai.ancf.lmos.wot.binding.http.HttpProtocolClientFactory
 import ai.ancf.lmos.wot.binding.http.HttpProtocolServer
 import ai.ancf.lmos.wot.binding.mqtt.MqttClientConfig
 import ai.ancf.lmos.wot.binding.mqtt.MqttProtocolServer
+import ai.ancf.lmos.wot.reflection.annotations.ThingAgent
 import ai.ancf.lmos.wot.thing.ExposedThing
 import ai.ancf.lmos.wot.thing.Type
 import ai.ancf.lmos.wot.thing.schema.*
@@ -33,7 +34,7 @@ fun createServient(protocol: String): Servient {
     }
 }
 
-fun createExposedThing(wot: Wot, agent: Agent): ExposedThing {
+fun createExposedThing(wot: Wot, agent: ThingAgent): ExposedThing {
     return wot.produce {
         id = "agent"
         title = "Agent"

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

@@ -0,0 +1,49 @@
+package 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.HttpProtocolServer
+import ai.ancf.lmos.wot.reflection.annotations.ThingAgent
+import ai.ancf.lmos.wot.reflection.annotations.ThingBuilder
+import ai.ancf.lmos.wot.thing.schema.WoTExposedThing
+import ai.ancf.lmos.wot.thing.schema.toInteractionInputValue
+import kotlinx.coroutines.test.runTest
+import kotlin.test.Test
+
+class AgentBuilderTest {
+
+    @Test
+    fun `Should create thing description from class`() = runTest {
+
+        val servient =  Servient(
+            servers = listOf(HttpProtocolServer()),
+            clientFactories = listOf(
+                HttpProtocolClientFactory()
+            )
+        )
+        servient.start()
+
+        val wot = Wot.create(servient)
+        val exposedThing = ThingBuilder()
+            .createThingDescription(wot, ThingAgent(), ThingAgent::class)
+        if(exposedThing != null){
+
+
+            servient.addThing(exposedThing as WoTExposedThing)
+            servient.expose("agent")
+
+
+            println("Thing:${exposedThing.toJson()}")
+
+            val httpAgentTD = wot
+                .requestThingDescription("http://localhost:8080/agent")
+            val httpAgent = wot.consume(httpAgentTD)
+            val output = httpAgent.invokeAction("ask",
+                "What is Paris?".toInteractionInputValue())
+            println(output.value())
+        }
+
+    }
+}

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

@@ -0,0 +1,7 @@
+dependencies {
+    api(project(":kotlin-wot"))
+    implementation("ch.qos.logback:logback-classic:1.5.12")
+    implementation("org.jetbrains.kotlin:kotlin-reflect")
+    testImplementation("io.mockk:mockk:1.13.13")
+    testImplementation(project(":kotlin-wot-binding-http"))
+}