서버 로깅 구현

app-server/subprojects/bounded_context/user/application/build.gradle.kts

@@ -0,0 +1,3 @@
+dependencies {
+    implementation(projects.crossCuttingConcern.application.serverLog)
+}

app-server/subprojects/bounded_context/user/application/src/main/kotlin/club/staircrusher/user/application/port/in/UserApplicationService.kt

@@ -1,5 +1,7 @@
 package club.staircrusher.user.application.port.`in`
 
+import club.staircrusher.application.server_log.port.`in`.SccServerLogger
+import club.staircrusher.domain.server_log.NewsletterSubscribedOnSignupPayload
 import club.staircrusher.stdlib.clock.SccClock
 import club.staircrusher.stdlib.di.annotation.Component
 import club.staircrusher.stdlib.domain.SccDomainException
@@ -25,6 +27,7 @@ class UserApplicationService(
     private val passwordEncryptor: PasswordEncryptor,
     private val userAuthInfoRepository: UserAuthInfoRepository,
     private val stibeeSubscriptionService: StibeeSubscriptionService,
+    private val sccServerLogger: SccServerLogger,
 ) {
 
     @Deprecated("닉네임 로그인은 사라질 예정")
@@ -133,7 +136,7 @@ class UserApplicationService(
 
         if (isNewsLetterSubscriptionAgreed) {
             transactionManager.doAfterCommit {
-                user.email?.let { subscribeToNewsLetter(it, user.nickname) }
+                user.email?.let { subscribeToNewsLetter(user.id, it, user.nickname) }
             }
         }
 
@@ -162,7 +165,8 @@ class UserApplicationService(
         return userRepository.findAll()
     }
 
-    private fun subscribeToNewsLetter(email: String, name: String) {
+    private fun subscribeToNewsLetter(userId: String, email: String, name: String) {
+        sccServerLogger.record(NewsletterSubscribedOnSignupPayload(userId))
         runBlocking {
             stibeeSubscriptionService.registerSubscriber(
                 email = email,

app-server/subprojects/bounded_context/user/infra/build.gradle.kts

@@ -9,6 +9,7 @@ dependencies {
 
     api(projects.apiSpecification.api)
     implementation(projects.crossCuttingConcern.infra.persistenceModel)
+    implementation(projects.crossCuttingConcern.infra.serverLog)
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("org.springframework:spring-webflux")
     implementation("io.projectreactor.netty:reactor-netty")

app-server/subprojects/bounded_context/user/infra/src/integrationTest/kotlin/club/staircrusher/user/infra/adapter/in/controller/UpdateUserInfoTest.kt

@@ -3,6 +3,8 @@ package club.staircrusher.user.infra.adapter.`in`.controller
 import club.staircrusher.api.spec.dto.ApiErrorResponse
 import club.staircrusher.api.spec.dto.UpdateUserInfoPost200Response
 import club.staircrusher.api.spec.dto.UpdateUserInfoPostRequest
+import club.staircrusher.application.server_log.port.`in`.SccServerLogger
+import club.staircrusher.domain.server_log.NewsletterSubscribedOnSignupPayload
 import club.staircrusher.stdlib.testing.SccRandom
 import club.staircrusher.user.application.port.out.web.subscription.StibeeSubscriptionService
 import club.staircrusher.user.domain.model.UserMobilityTool
@@ -16,13 +18,17 @@ import org.mockito.kotlin.any
 import org.mockito.kotlin.atLeastOnce
 import org.mockito.kotlin.eq
 import org.mockito.kotlin.never
+import org.mockito.kotlin.verify
 import org.mockito.kotlin.verifyBlocking
 import org.springframework.boot.test.mock.mockito.MockBean
 
 class UpdateUserInfoTest : UserITBase() {
     @MockBean
     lateinit var stibeeSubscriptionService: StibeeSubscriptionService
 
+    @MockBean
+    lateinit var sccServerLogger: SccServerLogger
+
     @Test
     fun updateUserInfoTest() {
         val user = transactionManager.doInTransaction {
@@ -196,6 +202,7 @@ class UpdateUserInfoTest : UserITBase() {
             }
             .apply {
                 verifyBlocking(stibeeSubscriptionService, atLeastOnce()) { registerSubscriber(eq(changedEmail), eq(changedNickname), any()) }
+                verify(sccServerLogger, atLeastOnce()).record(NewsletterSubscribedOnSignupPayload(user.id))
             }
     }
 
@@ -230,6 +237,7 @@ class UpdateUserInfoTest : UserITBase() {
             }
             .apply {
                 verifyBlocking(stibeeSubscriptionService, never()) { registerSubscriber(eq(changedEmail), eq(changedNickname), any()) }
+                verify(sccServerLogger, never()).record(NewsletterSubscribedOnSignupPayload(user.id))
             }
     }
 
@@ -265,6 +273,7 @@ class UpdateUserInfoTest : UserITBase() {
             }
             .apply {
                 verifyBlocking(stibeeSubscriptionService, never()) { registerSubscriber(eq(changedEmail), eq(changedNickname), any()) }
+                verify(sccServerLogger, never()).record(NewsletterSubscribedOnSignupPayload(user.id))
             }
     }
 }

app-server/subprojects/cross_cutting_concern/application/server_log/build.gradle.kts

@@ -0,0 +1,4 @@
+dependencies {
+    implementation(rootProject.projects.crossCuttingConcern.stdlib)
+    api(rootProject.projects.crossCuttingConcern.domain.serverLog)
+}

app-server/subprojects/cross_cutting_concern/application/server_log/src/main/kotlin/club/staircrusher/application/server_log/port/in/SccServerLogger.kt

@@ -0,0 +1,7 @@
+package club.staircrusher.application.server_log.port.`in`
+
+import club.staircrusher.domain.server_log.ServerLogPayload
+
+interface SccServerLogger {
+    fun record(payload: ServerLogPayload)
+}

app-server/subprojects/cross_cutting_concern/application/server_log/src/main/kotlin/club/staircrusher/application/server_log/port/in/SccServerPersistentLogger.kt

@@ -0,0 +1,27 @@
+package club.staircrusher.application.server_log.port.`in`
+
+import club.staircrusher.application.server_log.port.out.persistence.ServerLogRepository
+import club.staircrusher.domain.server_log.ServerLog
+import club.staircrusher.domain.server_log.ServerLogPayload
+import club.staircrusher.stdlib.clock.SccClock
+import club.staircrusher.stdlib.di.annotation.Component
+import club.staircrusher.stdlib.domain.entity.EntityIdGenerator
+import club.staircrusher.stdlib.persistence.TransactionManager
+
+@Component
+class SccServerPersistentLogger(
+    private val transactionManager: TransactionManager,
+    private val serverLogRepository: ServerLogRepository,
+) : SccServerLogger {
+    override fun record(payload: ServerLogPayload) = transactionManager.doInTransaction {
+        val serverLog = ServerLog(
+            id = EntityIdGenerator.generateRandom(),
+            type = payload.type,
+            payload = payload,
+            createdAt = SccClock.instant(),
+        )
+
+        serverLogRepository.save(serverLog)
+        Unit
+    }
+}

app-server/subprojects/cross_cutting_concern/application/server_log/src/main/kotlin/club/staircrusher/application/server_log/port/out/persistence/ServerLogRepository.kt

@@ -0,0 +1,7 @@
+package club.staircrusher.application.server_log.port.out.persistence
+
+import club.staircrusher.domain.server_log.ServerLog
+
+interface ServerLogRepository {
+    fun save(entity: ServerLog): ServerLog
+}

app-server/subprojects/cross_cutting_concern/domain/server_log/build.gradle.kts

@@ -0,0 +1,4 @@
+dependencies {
+    val kotlinxSerializationVersion: String by project
+    implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:$kotlinxSerializationVersion")
+}

app-server/subprojects/cross_cutting_concern/domain/server_log/src/main/kotlin/club/staircrusher/domain/server_log/NewsletterSubscribedOnSignupPayload.kt

@@ -0,0 +1,7 @@
+package club.staircrusher.domain.server_log
+
+data class NewsletterSubscribedOnSignupPayload(
+    val userId: String,
+) : ServerLogPayload {
+    override val type = ServerLogType.NEWSLETTER_SUBSCRIBED_ON_SIGN_UP
+}

app-server/subprojects/cross_cutting_concern/domain/server_log/src/main/kotlin/club/staircrusher/domain/server_log/ServerLog.kt

@@ -0,0 +1,10 @@
+package club.staircrusher.domain.server_log
+
+import java.time.Instant
+
+data class ServerLog(
+    val id: String,
+    val type: ServerLogType,
+    val payload: ServerLogPayload,
+    val createdAt: Instant,
+)

app-server/subprojects/cross_cutting_concern/domain/server_log/src/main/kotlin/club/staircrusher/domain/server_log/ServerLogPayload.kt

@@ -0,0 +1,5 @@
+package club.staircrusher.domain.server_log
+
+interface ServerLogPayload {
+    val type: ServerLogType
+}

app-server/subprojects/cross_cutting_concern/domain/server_log/src/main/kotlin/club/staircrusher/domain/server_log/ServerLogType.kt

@@ -0,0 +1,5 @@
+package club.staircrusher.domain.server_log
+
+enum class ServerLogType {
+    NEWSLETTER_SUBSCRIBED_ON_SIGN_UP,
+}

app-server/subprojects/cross_cutting_concern/infra/persistence_model/build.gradle.kts

@@ -9,6 +9,7 @@ dependencies {
     implementation(projects.boundedContext.challenge.domain)
     implementation(projects.boundedContext.quest.domain)
     implementation(projects.boundedContext.user.domain)
+    implementation(projects.crossCuttingConcern.domain.serverLog)
 
     val sqlDelightVersion: String by project
     api("app.cash.sqldelight:runtime-jvm:$sqlDelightVersion")

app-server/subprojects/cross_cutting_concern/infra/persistence_model/src/main/kotlin/club/staircrusher/infra/persistence/sqldelight/DB.kt

@@ -1,6 +1,9 @@
 package club.staircrusher.infra.persistence.sqldelight
 
+import app.cash.sqldelight.ColumnAdapter
 import club.staircrusher.challenge.domain.model.ChallengeCondition
+import club.staircrusher.domain.server_log.ServerLogPayload
+import club.staircrusher.domain.server_log.ServerLogType
 import club.staircrusher.infra.persistence.sqldelight.column_adapter.AccessibilityImageListStringColumnAdapter
 import club.staircrusher.infra.persistence.sqldelight.column_adapter.ClubQuestPurposeTypeStringColumnAdapter
 import club.staircrusher.infra.persistence.sqldelight.column_adapter.EntranceDoorTypeListStringColumnAdapter
@@ -19,6 +22,7 @@ import club.staircrusher.infra.persistence.sqldelight.migration.Club_quest
 import club.staircrusher.infra.persistence.sqldelight.migration.Place
 import club.staircrusher.infra.persistence.sqldelight.migration.Place_accessibility
 import club.staircrusher.infra.persistence.sqldelight.migration.Scc_user
+import club.staircrusher.infra.persistence.sqldelight.migration.Server_log
 import club.staircrusher.infra.persistence.sqldelight.migration.User_auth_info
 import club.staircrusher.stdlib.di.annotation.Component
 import club.staircrusher.stdlib.persistence.Transaction
@@ -79,6 +83,26 @@ class DB(dataSource: DataSource) : TransactionManager {
         ),
         club_questAdapter = Club_quest.Adapter(
             purpose_typeAdapter = ClubQuestPurposeTypeStringColumnAdapter,
+        ),
+        server_logAdapter = Server_log.Adapter(
+            typeAdapter = object : ColumnAdapter<ServerLogType, String> {
+                override fun decode(databaseValue: String): ServerLogType {
+                    return ServerLogType.valueOf(databaseValue)
+                }
+
+                override fun encode(value: ServerLogType): String {
+                    return value.name
+                }
+            },
+            payloadAdapter = object : ColumnAdapter<ServerLogPayload, String> {
+                override fun decode(databaseValue: String): ServerLogPayload {
+                    return objectMapper.readValue(databaseValue)
+                }
+
+                override fun encode(value: ServerLogPayload): String {
+                    return objectMapper.writeValueAsString(value)
+                }
+            }
         )
     )
 
@@ -102,6 +126,7 @@ class DB(dataSource: DataSource) : TransactionManager {
     val challengeContributionQueries = scc.challengeContributionQueries
     val challengeParticipationQueries = scc.challengeParticipationQueries
     val challengeRankQueries = scc.challengeRankQueries
+    val serverLogQueries = scc.serverLogQueries
 
 
     override fun <T> doInTransaction(block: Transaction<T>.() -> T): T {

app-server/subprojects/cross_cutting_concern/infra/persistence_model/src/main/sqldelight/club/staircrusher/infra/persistence/sqldelight/migration/V26__add_server_log.sqm

@@ -0,0 +1,12 @@
+import club.staircrusher.domain.server_log.ServerLogPayload;
+import club.staircrusher.domain.server_log.ServerLogType;
+
+CREATE TABLE IF NOT EXISTS server_log (
+    id VARCHAR(36) NOT NULL,
+    type VARCHAR(64) AS ServerLogType NOT NULL,
+    payload TEXT AS ServerLogPayload NOT NULL DEFAULT '',
+    created_at TIMESTAMP(6) WITH TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    PRIMARY KEY (id)
+);
+
+CREATE INDEX idx_server_log_1 ON server_log(type, created_at);

app-server/subprojects/cross_cutting_concern/infra/persistence_model/src/main/sqldelight/club/staircrusher/infra/persistence/sqldelight/query/server_log/ServerLog.sq

@@ -0,0 +1,8 @@
+save:
+INSERT INTO server_log
+VALUES :server_log
+ON CONFLICT(id) DO UPDATE SET
+    id = EXCLUDED.id,
+    type = EXCLUDED.type,
+    payload = EXCLUDED.payload,
+    created_at = EXCLUDED.created_at;

app-server/subprojects/cross_cutting_concern/infra/server_log/build.gradle.kts

@@ -0,0 +1,6 @@
+dependencies {
+    implementation(projects.crossCuttingConcern.stdlib)
+    implementation(projects.crossCuttingConcern.infra.persistenceModel)
+    api(rootProject.projects.crossCuttingConcern.domain.serverLog)
+    api(rootProject.projects.crossCuttingConcern.application.serverLog)
+}

app-server/subprojects/cross_cutting_concern/infra/server_log/src/main/kotlin/club/staircrusher/infra/server_log/out/persistence/ServerLogRepository.kt

@@ -0,0 +1,19 @@
+package club.staircrusher.infra.server_log.out.persistence
+
+import club.staircrusher.application.server_log.port.out.persistence.ServerLogRepository
+import club.staircrusher.domain.server_log.ServerLog
+import club.staircrusher.infra.persistence.sqldelight.DB
+import club.staircrusher.infra.server_log.out.persistence.sqldelight.toPersistenceModel
+import club.staircrusher.stdlib.di.annotation.Component
+
+@Component
+class ServerLogRepository(
+    db: DB,
+) : ServerLogRepository {
+    private val queries = db.serverLogQueries
+
+    override fun save(entity: ServerLog): ServerLog {
+        queries.save(entity.toPersistenceModel())
+        return entity
+    }
+}

app-server/subprojects/cross_cutting_concern/infra/server_log/src/main/kotlin/club/staircrusher/infra/server_log/out/persistence/sqldelight/Converters.kt

@@ -0,0 +1,19 @@
+package club.staircrusher.infra.server_log.out.persistence.sqldelight
+
+import club.staircrusher.domain.server_log.ServerLog
+import club.staircrusher.infra.persistence.sqldelight.migration.Server_log
+import club.staircrusher.stdlib.time.toOffsetDateTime
+
+fun ServerLog.toPersistenceModel() = Server_log(
+    id = id,
+    type = type,
+    payload = payload,
+    created_at = createdAt.toOffsetDateTime(),
+)
+
+fun Server_log.toDomainModel() = ServerLog(
+    id = id,
+    type = type,
+    payload = payload,
+    createdAt = created_at.toInstant(),
+)

app-server/subprojects/cross_cutting_concern/infra/spring_web/build.gradle.kts

@@ -18,4 +18,5 @@ dependencies {
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin:$jacksonModuleKotlinVersion")
     integrationTestImplementation("com.fasterxml.jackson.module:jackson-module-kotlin:$jacksonModuleKotlinVersion")
     integrationTestImplementation("org.springframework.boot:spring-boot-starter-test")
+    integrationTestImplementation(projects.crossCuttingConcern.application.serverLog)
 }

app-server/subprojects/cross_cutting_concern/infra/spring_web/src/integrationTest/kotlin/club/staircrusher/spring_web/mock/MockServerLogRepository.kt

@@ -0,0 +1,17 @@
+package club.staircrusher.spring_web.mock
+
+import club.staircrusher.application.server_log.port.out.persistence.ServerLogRepository
+import club.staircrusher.domain.server_log.ServerLog
+import club.staircrusher.stdlib.di.annotation.Component
+
+@Component
+class MockServerLogRepository : ServerLogRepository {
+    override fun save(entity: ServerLog): ServerLog {
+        return ServerLog(
+            id = entity.id,
+            type = entity.type,
+            payload = entity.payload,
+            createdAt = entity.createdAt
+        )
+    }
+}