frontend + endpoints wip

examples/build.gradle.kts

@@ -35,6 +35,7 @@ dependencies {
     implementation(libs.jmf)
     implementation(libs.mp3.wav.converter)
     api(libs.ktor.client)
+
 }
 
 spotless {

server/build.gradle.kts

@@ -56,6 +56,8 @@ dependencies {
     testImplementation(libs.kotest.testcontainers)
     testImplementation(libs.testcontainers.postgresql)
     testRuntimeOnly(libs.kotest.junit5)
+    implementation(libs.logback)
+    implementation(libs.klogging)
 }
 
 spotless {

server/src/main/kotlin/com/xebia/functional/xef/server/Server.kt

@@ -59,7 +59,7 @@ object Server {
             requestTimeout = 0 // disabled
           }
           install(Auth)
-          install(Logging) { level = LogLevel.INFO }
+          install(Logging) { level = LogLevel.ALL }
           install(ClientContentNegotiation)
         }
 

server/src/main/kotlin/com/xebia/functional/xef/server/http/routes/AssistantRoutes.kt

@@ -0,0 +1,88 @@
+package com.xebia.functional.xef.server.http.routes
+
+import com.xebia.functional.openai.generated.model.AssistantObject
+import com.xebia.functional.openai.generated.model.CreateAssistantRequest
+import com.xebia.functional.openai.generated.model.ListAssistantsResponse
+import com.xebia.functional.xef.Config
+import com.xebia.functional.xef.OpenAI
+import com.xebia.functional.xef.llm.assistants.Assistant
+import com.xebia.functional.xef.server.models.Token
+import io.ktor.http.*
+import io.ktor.server.application.*
+import io.ktor.server.auth.*
+import io.ktor.server.request.*
+import io.ktor.server.response.*
+import io.ktor.server.routing.*
+
+fun Routing.assistantRoutes() {
+  authenticate("auth-bearer") {
+    post("/v1/settings/assistants") {
+      try {
+        val contentType = call.request.contentType()
+        if (contentType == ContentType.Application.Json) {
+          val request = call.receive<CreateAssistantRequest>()
+          val token = call.getToken()
+          val response = createAssistant(token, request)
+          call.respond(status = HttpStatusCode.Created, response)
+        } else {
+          call.respond(
+            HttpStatusCode.UnsupportedMediaType,
+            "Unsupported content type: $contentType"
+          )
+        }
+      } catch (e: Exception) {
+        val trace = e.stackTraceToString()
+        call.respond(HttpStatusCode.BadRequest, "Invalid request: $trace")
+      }
+    }
+
+    //        put("/v1/settings/assistants/{id}") {
+    //            val request = Json.decodeFromString<AssistantRequest>(call.receive<String>())
+    //            val token = call.getToken()
+    //            val id = call.getId()
+    //            val response = updateAssistant(token, request, id)
+    //            call.respond(status = HttpStatusCode.NoContent, response)
+    //        }
+    // get("/v1/settings/assistants") {
+    //      val token = call.getToken()
+    //      val response = ListAssistantsResponse("list", emptyList(), null, null, false)
+    //      val assistantResponse = listAssistants(token, response)
+    //      call.respond(assistantResponse)
+    //    }
+    //        delete("/v1/settings/assistants/{id}") {
+    //            val token = call.getToken()
+    //            val id = call.parameters["id"]?.toIntOrNull()
+    //            if (id == null) {
+    //                call.respond(HttpStatusCode.BadRequest, "Invalid assistant id")
+    //                return@delete
+    //            }
+    //            val response = deleteAssistant(token, id)
+    //            call.respond(status = HttpStatusCode.NoContent, response)
+    //        }
+  }
+}
+
+suspend fun createAssistant(token: Token, request: CreateAssistantRequest): AssistantObject {
+  val openAIConfig = Config(token = token.value)
+  val openAI = OpenAI(openAIConfig, logRequests = true)
+  val assistants = openAI.assistants
+  val assistant = Assistant(request)
+  return assistant.get()
+}
+
+// suspend fun updateAssistant(token: String, request: AssistantRequest, id: Int): String {
+//    // Implement the logic for updating an assistant in OpenAI here
+// }
+
+suspend fun listAssistants(token: Token, response: ListAssistantsResponse): ListAssistantsResponse {
+  val openAIConfig = Config(token = token.value)
+  val openAI = OpenAI(openAIConfig)
+  val assistants = openAI.assistants
+  val listAssistants = assistants.listAssistants()
+
+  return listAssistants
+}
+
+/*suspend fun deleteAssistant(token: String, id: Int): String {
+    // Implement the logic for deleting an assistant in OpenAI here
+}*/

server/src/main/kotlin/com/xebia/functional/xef/server/http/routes/XefRoutes.kt

@@ -12,4 +12,5 @@ fun Routing.xefRoutes(logger: KLogger) {
   organizationRoutes(OrganizationRepositoryService(logger))
   projectsRoutes(ProjectRepositoryService(logger))
   tokensRoutes(TokenRepositoryService(logger))
+  assistantRoutes()
 }

server/src/main/resources/logback.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE configuration>
+
+<configuration>
+    <statusListener class="ch.qos.logback.core.status.NopStatusListener" />
+
+    <appender name="NOOP" class="ch.qos.logback.core.helpers.NOPAppender" />
+
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} -%kvp- %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="trace">
+        <appender-ref ref="STDOUT"/>
+    </root>
+
+    <logger name="com.xebia.functional.xef" level="debug">
+        <appender-ref ref="STDOUT" />
+    </logger>
+
+    <logger name="com.gargoylesoftware.htmlunit" level="off">
+        <appender-ref ref="STDOUT" />
+    </logger>
+</configuration>