chore :: import fixes, logging scope change

API-Team-Organization · Oct 22, 2024 · 4b4b594 · 4b4b594
1 parent 48a4b62
commit 4b4b594
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 7 deletions.
diff --git a/src/main/kotlin/com/teamapi/palette/controller/RoomController.kt b/src/main/kotlin/com/teamapi/palette/controller/RoomController.kt
@@ -29,6 +29,11 @@ class RoomController(
         return ResponseBody.ok("룸 조회 성공", it)
     }
 
+    @PostMapping("/{roomId}/regen")
+    suspend fun regenerate(@PathVariable roomId: Long) {
+        roomService.regenerate(roomId)
+    }
+
     @PatchMapping("/{roomId}/title")
     suspend fun updateRoomTitle(
         @PathVariable roomId: Long,

diff --git a/src/main/kotlin/com/teamapi/palette/service/infra/GenerativeImageService.kt b/src/main/kotlin/com/teamapi/palette/service/infra/GenerativeImageService.kt
@@ -6,7 +6,6 @@ import com.teamapi.palette.entity.consts.ChatState
 import com.teamapi.palette.entity.qna.ChatAnswer
 import com.teamapi.palette.entity.qna.PromptData
 import com.teamapi.palette.entity.qna.QnA
-import com.teamapi.palette.response.exception.CustomException
 import com.teamapi.palette.service.adapter.BlobSaveAdapter
 import com.teamapi.palette.service.adapter.ChatEmitAdapter
 import com.teamapi.palette.service.adapter.GenerativeChatAdapter

diff --git a/src/main/kotlin/com/teamapi/palette/util/ExceptionReporter.kt b/src/main/kotlin/com/teamapi/palette/util/ExceptionReporter.kt
@@ -5,7 +5,6 @@ import com.teamapi.palette.dto.infra.req.*
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.asCoroutineDispatcher
 import kotlinx.coroutines.async
-import kotlinx.coroutines.reactor.awaitSingle
 import kotlinx.coroutines.reactor.awaitSingleOrNull
 import kotlinx.datetime.Clock
 import kotlinx.serialization.encodeToString

diff --git a/src/main/kotlin/com/teamapi/palette/ws/actor/SinkActor.kt b/src/main/kotlin/com/teamapi/palette/ws/actor/SinkActor.kt
@@ -10,7 +10,6 @@ import kotlinx.coroutines.channels.actor
 import kotlinx.coroutines.flow.cancellable
 import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.onCompletion
-import kotlinx.coroutines.flow.onEmpty
 import kotlinx.coroutines.reactive.asFlow
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.DisposableBean
@@ -32,14 +31,11 @@ class SinkActor(
                 .asFlow()
                 .cancellable()
                 .onCompletion {
-                    println("WTH?!?!?!?")
+                    log.warn("Sink worker is closed")
                 }
                 .catch {
                     it.printStackTrace()
                 }
-                .onEmpty {
-                    println("AAA")
-                }
                 .collect {
                     log.info("{}: {}", it.roomId, it.message)
                     for (actor in roomActors) {