Initial WebSocketProtocolServer and Tests for Properties and Actions

Author: Robert Winkler

build.gradle.kts

@@ -1,14 +1,10 @@
 plugins {
     kotlin("jvm") version "2.0.20"
-    id("org.jlleitschuh.gradle.ktlint") version "12.1.0"
     id("org.jetbrains.kotlinx.kover") version "0.8.3"
 }
 
-
-
 subprojects {
     apply(plugin = "org.jetbrains.kotlin.jvm")
-    apply(plugin = "org.jlleitschuh.gradle.ktlint")
     apply(plugin = "org.jetbrains.kotlinx.kover")
 
     group = "ai.ancf.lmos"
@@ -36,4 +32,3 @@ allprojects {
         mavenCentral()
     }
 }
-

kotlin-wot-binding-http/build.gradle.kts

@@ -4,7 +4,6 @@ plugins {
 
 dependencies {
     api(project(":kotlin-wot"))
-    //implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
     implementation("org.slf4j:slf4j-api")
     implementation("io.ktor:ktor-server-core")
     implementation("io.ktor:ktor-server-netty")
@@ -17,8 +16,7 @@ dependencies {
     implementation("io.ktor:ktor-client-content-negotiation")
     implementation("io.ktor:ktor-serialization-jackson")
     implementation("io.ktor:ktor-server-auto-head-response")
-    //implementation("io.insert-koin:koin-ktor:4.0.0")
     testImplementation("io.ktor:ktor-server-test-host")
     testImplementation("ch.qos.logback:logback-classic:1.5.12")
     testImplementation("com.marcinziolo:kotlin-wiremock:2.1.1")
-}
+}

kotlin-wot-binding-http/src/main/resources/application.conf

@@ -5,4 +5,4 @@ dependencies {
     testImplementation("ch.qos.logback:logback-classic:1.5.12")
     testImplementation("app.cash.turbine:turbine:1.2.0")
     testImplementation("org.testcontainers:testcontainers:1.20.3")
-}
+}

kotlin-wot-binding-mqtt/build.gradle.kts

@@ -4,7 +4,6 @@ plugins {
 
 dependencies {
     api(project(":kotlin-wot"))
-    //implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
     implementation("org.slf4j:slf4j-api")
     implementation("io.ktor:ktor-server-netty")
     implementation("io.ktor:ktor-server-websockets")
@@ -14,9 +13,8 @@ dependencies {
     implementation("io.ktor:ktor-client-logging")
     implementation("io.ktor:ktor-server-call-logging")
     implementation("io.ktor:ktor-serialization-jackson")
-    //implementation("io.insert-koin:koin-ktor:4.0.0")
     testImplementation("io.ktor:ktor-server-test-host")
     testImplementation("ch.qos.logback:logback-classic:1.5.12")
     testImplementation("com.marcinziolo:kotlin-wiremock:2.1.1")
     testImplementation("io.ktor:ktor-server-test-host-jvm:3.0.0")
-}
+}

kotlin-wot-binding-websocket/build.gradle.kts

@@ -9,4 +9,4 @@ data class HttpClientConfig(
     val serverKey: String,
     val serverCert: String,
     val security: SecurityScheme
-)
+)

kotlin-wot-binding-websocket/src/main/kotlin/websocket/HttpClientConfig.kt

@@ -214,4 +214,4 @@ data class ErrorMessage(
     var instance: String // URI reference to the specific occurrence of the problem
 ) : WoTMessage {
     override val messageType: String = MessageTypes.ERROR
-}
+}

kotlin-wot-binding-websocket/src/main/kotlin/websocket/Messages.kt

@@ -1,7 +1,7 @@
 package ai.ancf.lmos.wot.binding.websocket
 
 /**
- * Creates new [HttpProtocolClient] instances that allow consuming Things via HTTPS.
+ * Creates new [WebSocketProtocolClient] instances that allow consuming Things via WSS.
  */
 class SecureWebSocketProtocolClientFactory() : WebSocketProtocolClientFactory() {
 

kotlin-wot-binding-websocket/src/main/kotlin/websocket/SecureWebSocketProtocolClientFactory.kt

@@ -1,19 +1,72 @@
 package ai.ancf.lmos.wot.binding.websocket
 
+
+import ai.ancf.lmos.wot.content.Content
+import ai.ancf.lmos.wot.thing.form.Form
 import ai.anfc.lmos.wot.binding.ProtocolClient
+import ai.anfc.lmos.wot.binding.ProtocolClientException
 import io.ktor.client.*
 import io.ktor.client.engine.cio.*
+import io.ktor.client.plugins.websocket.*
+import io.ktor.http.*
+import io.ktor.serialization.jackson.*
+import io.ktor.websocket.*
+import kotlinx.coroutines.CompletableDeferred
+import org.slf4j.LoggerFactory
 
 class WebSocketProtocolClient(
     private val httpClientConfig: HttpClientConfig? = null,
-    private val client: HttpClient = HttpClient(CIO)
+    private val client: HttpClient = HttpClient(CIO) {
+        install(WebSockets){
+            contentConverter = JacksonWebsocketContentConverter()
+        }
+    }
 ) : ProtocolClient {
+    companion object {
+        private val log = LoggerFactory.getLogger(WebSocketProtocolClient::class.java)
+    }
+
+    private var session: DefaultClientWebSocketSession? = null
+
     override suspend fun start() {
-        TODO("Not yet implemented")
+        log.info("Starting WebSocketProtocolClient")
+        client.webSocket(
+            method = HttpMethod.Get,
+            host = httpClientConfig?.address ?: "localhost",
+            port = httpClientConfig?.port ?: 80,
+            path = "/ws"
+        ) {
+            session = this
+        }
     }
 
     override suspend fun stop() {
-        TODO("Not yet implemented")
+        log.info("Stopping WebSocketProtocolClient")
+        session?.close()
+        session = null
     }
 
+    override suspend fun readResource(form: Form): Content {
+        return resolveRequestToContent(form)
+    }
+
+    private suspend fun resolveRequestToContent(form: Form, content: Content? = null): Content {
+        val response = CompletableDeferred<Content>()
+
+        try {
+            session?.let {
+                it.sendSerialized(ReadPropertyMessage("test", property = "test"))
+
+                val readingMessage = it.receiveDeserialized<PropertyReadingMessage>()
+
+                val responseContent = Content(
+                    body = readingMessage.data.binaryValue()
+                )
+                response.complete(responseContent)
+            }
+        } catch (e: Exception) {
+            response.completeExceptionally(ProtocolClientException("Error during http request: ${e.message}", e))
+        }
+        return response.await()
+    }
 }

kotlin-wot-binding-websocket/src/main/kotlin/websocket/WebSocketProtocolClient.kt

@@ -11,6 +11,7 @@ open class WebSocketProtocolClientFactory(private val httpClientConfig: HttpClie
     }
     override val scheme: String
         get() = "ws"
+
     override val client: WebSocketProtocolClient
         get() = WebSocketProtocolClient(httpClientConfig)