✨ Implementing clipevery web server (#19)

composeApp/build.gradle.kts

@@ -20,6 +20,7 @@ kotlin {
             implementation("com.google.zxing:core:3.5.2")
             implementation("com.google.zxing:javase:3.5.2")
             implementation("ch.qos.logback:logback-classic:1.4.11")
+            implementation("io.javalin:javalin:5.6.3")
         }
         commonMain.dependencies {
             implementation(compose.runtime)

composeApp/src/commonMain/kotlin/com/clipevery/net/ClipServer.kt

@@ -1,5 +1,10 @@
 package com.clipevery.net
 
 interface ClipServer {
+    fun start(): ClipServer
+
+    fun stop()
+
+    fun port(): Int
 }
 

composeApp/src/desktopMain/kotlin/com/clipevery/net/DesktopClipServer.kt

@@ -0,0 +1,56 @@
+package com.clipevery.net
+
+import io.github.oshai.kotlinlogging.KotlinLogging
+import io.javalin.Javalin
+import io.javalin.apibuilder.EndpointGroup
+import io.javalin.compression.CompressionStrategy
+import io.javalin.config.JavalinConfig
+import io.javalin.http.ExceptionHandler
+import org.eclipse.jetty.server.Server
+import org.eclipse.jetty.util.thread.QueuedThreadPool
+import java.util.function.Consumer
+
+
+class DesktopClipServer: ClipServer {
+
+    private val logger = KotlinLogging.logger {}
+
+
+    private var server: Javalin? = null
+
+    private fun config(): Consumer<JavalinConfig> {
+        return Consumer<JavalinConfig> {
+            it.jetty.server { Server(QueuedThreadPool(10)) }
+            it.http.maxRequestSize = Long.MAX_VALUE
+            it.http.defaultContentType = "application/json"
+            it.http.generateEtags = true
+            it.compression.custom(CompressionStrategy.GZIP)
+        }
+    }
+
+    private fun endpoints(): EndpointGroup {
+        return EndpointGroup {
+        }
+    }
+
+    private fun exceptionHandler(): ExceptionHandler<in java.lang.Exception?> {
+        return ExceptionHandler<java.lang.Exception?> { e, ctx -> logger.error(e) { "${ctx.path()} exception" } }
+    }
+
+    override fun start(): ClipServer {
+        server = Javalin.create(config())
+            .routes(endpoints())
+            .exception(Exception::class.java, exceptionHandler())
+            .start("0.0.0.0", 0)
+        logger.info { "start server ${port()}" }
+        return this
+    }
+
+    override fun stop() {
+        server?.stop()
+    }
+
+    override fun port(): Int {
+        return server?.port() ?: 0
+    }
+}

composeApp/src/desktopMain/kotlin/main.kt

@@ -11,6 +11,7 @@ import com.clipevery.config.ConfigManager
 import com.clipevery.config.FileType
 import com.clipevery.log.initLogger
 import com.clipevery.net.ClipServer
+import com.clipevery.net.DesktopClipServer
 import com.clipevery.path.PathProvider
 import com.clipevery.path.getPathProvider
 import com.clipevery.presist.DesktopOneFilePersist
@@ -59,19 +60,10 @@ private fun getDependencies(
     ioScope: CoroutineScope
 ) = object : Dependencies() {
 
-    val logger = KotlinLogging.logger {}
-
-    override val clipServer: ClipServer = object : ClipServer {
-    }
+    override val clipServer: ClipServer = DesktopClipServer().start()
 
     override val filePersist: FilePersist = object : FilePersist {
-        override val pathProvider: PathProvider = run {
-            val innerPathProvider = getPathProvider()
-            logger.info { "userPath ${innerPathProvider.resolveUser(null)}" }
-            logger.info { "appPath ${innerPathProvider.resolveApp(null)}" }
-            logger.info { "logPath ${innerPathProvider.resolveLog(null)}" }
-            getPathProvider()
-        }
+        override val pathProvider: PathProvider = getPathProvider()
 
         override fun createOneFilePersist(path: Path): OneFilePersist {
             return DesktopOneFilePersist(path)