diff --git a/src/main/kotlin/com/teamapi/palette/controller/RoomController.kt b/src/main/kotlin/com/teamapi/palette/controller/RoomController.kt index 4030fe5..526bb16 100644 --- 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 index f65049f..6030969 100644 --- 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 index 2d19f41..3cfc6a7 100644 --- 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 index d5db1a8..5fbce33 100644 --- 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) {