[IDLE-466] 웹소켓 연결 및 해제, 데이터 파이프 라인 연결, 에러가 났을 경우 Crashlytics로 로깅하도록 구현

app/build.gradle.kts

@@ -58,6 +58,7 @@ dependencies {
     implementation(projects.core.data)
     implementation(projects.core.domain)
     implementation(projects.presentation)
+    implementation(projects.core.analytics)
 
     implementation(libs.firebase.messaging)
 }

core/analytics/src/main/java/com/idle/analytics/helper/AmplitudeAnalyticsHelper.kt → core/analytics/src/main/java/com/idle/analytics/businessmetric/AmplitudeAnalyticsHelper.kt

@@ -1,4 +1,4 @@
-package com.idle.analytics.helper
+package com.idle.analytics.businessmetric
 
 import com.amplitude.android.Amplitude
 import com.amplitude.core.events.BaseEvent

core/analytics/src/main/java/com/idle/analytics/helper/AnalyticsHelper.kt → core/analytics/src/main/java/com/idle/analytics/businessmetric/AnalyticsHelper.kt

@@ -1,4 +1,4 @@
-package com.idle.analytics.helper
+package com.idle.analytics.businessmetric
 
 import androidx.compose.runtime.Composable
 import androidx.compose.runtime.LaunchedEffect

core/analytics/src/main/java/com/idle/analytics/helper/DebugAnalyticsHelper.kt → core/analytics/src/main/java/com/idle/analytics/businessmetric/DebugAnalyticsHelper.kt

@@ -1,4 +1,4 @@
-package com.idle.analytics.helper
+package com.idle.analytics.businessmetric
 
 import android.util.Log
 import com.idle.analytics.AnalyticsEvent

core/analytics/src/main/java/com/idle/analytics/helper/LocalAnalyticsHelper.kt → core/analytics/src/main/java/com/idle/analytics/businessmetric/LocalAnalyticsHelper.kt

@@ -1,4 +1,4 @@
-package com.idle.analytics.helper
+package com.idle.analytics.businessmetric
 
 import androidx.compose.runtime.staticCompositionLocalOf
 

core/analytics/src/main/java/com/idle/analytics/helper/NoOpAnalyticsHelper.kt → core/analytics/src/main/java/com/idle/analytics/businessmetric/NoOpAnalyticsHelper.kt

@@ -1,4 +1,4 @@
-package com.idle.analytics.helper
+package com.idle.analytics.businessmetric
 
 import com.idle.analytics.AnalyticsEvent
 

core/analytics/src/main/java/com/idle/analytics/di/AnalyticsModule.kt

@@ -3,10 +3,14 @@ package com.idle.analytics.di
 import android.content.Context
 import com.amplitude.android.Amplitude
 import com.amplitude.android.Configuration
+import com.google.firebase.crashlytics.FirebaseCrashlytics
 import com.idle.analytics.BuildConfig
-import com.idle.analytics.helper.AmplitudeAnalyticsHelper
-import com.idle.analytics.helper.AnalyticsHelper
-import com.idle.analytics.helper.DebugAnalyticsHelper
+import com.idle.analytics.businessmetric.AmplitudeAnalyticsHelper
+import com.idle.analytics.businessmetric.AnalyticsHelper
+import com.idle.analytics.businessmetric.DebugAnalyticsHelper
+import com.idle.analytics.error.CrashlyticsErrorLoggingHelper
+import com.idle.analytics.error.DebugErrorLoggingHelper
+import com.idle.analytics.error.ErrorLoggingHelper
 import dagger.Module
 import dagger.Provides
 import dagger.hilt.InstallIn
@@ -19,6 +23,10 @@ import javax.inject.Singleton
 @InstallIn(SingletonComponent::class)
 object AnalyticsModule {
 
+    @Provides
+    @Singleton
+    fun provideFirebaseCrashlytics(): FirebaseCrashlytics = FirebaseCrashlytics.getInstance()
+
     @Provides
     @Singleton
     fun providesAmplitude(@ApplicationContext context: Context): Amplitude = Amplitude(
@@ -30,34 +38,59 @@ object AnalyticsModule {
 
     @Provides
     @Singleton
-    @DebugLogger
+    @DebugHelper
     fun provideDebugAnalyticsHelper(): AnalyticsHelper = DebugAnalyticsHelper()
 
     @Provides
     @Singleton
-    @ReleaseLogger
-    fun provideReleaseAnalyticsHelper(
-        amplitude: Amplitude
-    ): AnalyticsHelper = AmplitudeAnalyticsHelper(amplitude)
+    @ReleaseHelper
+    fun provideReleaseAnalyticsHelper(amplitude: Amplitude): AnalyticsHelper =
+        AmplitudeAnalyticsHelper(amplitude)
 
     @Provides
     @Singleton
     fun provideAnalyticsHelper(
-        @DebugLogger debugHelper: AnalyticsHelper,
-        @ReleaseLogger releaseHelper: AnalyticsHelper
+        @DebugHelper debugHelper: AnalyticsHelper,
+        @ReleaseHelper releaseHelper: AnalyticsHelper
     ): AnalyticsHelper {
-        return if (BuildConfig.BUILD_TYPE == "RELEASE") {
-            releaseHelper
-        } else {
-            debugHelper
-        }
+        return if (BuildConfig.BUILD_TYPE == "RELEASE") releaseHelper
+        else debugHelper
+    }
+
+    @Provides
+    @Singleton
+    @DebugErrorHelper
+    fun provideDebugErrorLoggingHelper(): ErrorLoggingHelper = DebugErrorLoggingHelper()
+
+    @Provides
+    @Singleton
+    @ReleaseErrorHelper
+    fun provideReleaseErrorLoggingHelper(firebaseCrashlytics: FirebaseCrashlytics): ErrorLoggingHelper =
+        CrashlyticsErrorLoggingHelper(firebaseCrashlytics)
+
+    @Provides
+    @Singleton
+    fun provideErrorLoggingHelper(
+        @DebugErrorHelper debugErrorHelper: ErrorLoggingHelper,
+        @ReleaseErrorHelper releaseErrorHelper: ErrorLoggingHelper,
+    ): ErrorLoggingHelper {
+        return if (BuildConfig.BUILD_TYPE == "RELEASE") releaseErrorHelper
+        else debugErrorHelper
     }
 }
 
 @Qualifier
 @Retention(AnnotationRetention.BINARY)
-annotation class DebugLogger
+annotation class DebugHelper
+
+@Qualifier
+@Retention(AnnotationRetention.BINARY)
+annotation class ReleaseHelper
+
+@Qualifier
+@Retention(AnnotationRetention.BINARY)
+annotation class DebugErrorHelper
 
 @Qualifier
 @Retention(AnnotationRetention.BINARY)
-annotation class ReleaseLogger
+annotation class ReleaseErrorHelper

core/analytics/src/main/java/com/idle/analytics/error/CrashlyticsErrorLoggingHelper.kt

@@ -0,0 +1,12 @@
+package com.idle.analytics.error
+
+import com.google.firebase.crashlytics.FirebaseCrashlytics
+import javax.inject.Inject
+
+class CrashlyticsErrorLoggingHelper @Inject constructor(
+    private val firebaseCrashlytics: FirebaseCrashlytics,
+) : ErrorLoggingHelper {
+    override fun logError(exception: Throwable) {
+        firebaseCrashlytics.recordException(exception)
+    }
+}

core/analytics/src/main/java/com/idle/analytics/error/DebugErrorLoggingHelper.kt

@@ -0,0 +1,10 @@
+package com.idle.analytics.error
+
+import android.util.Log
+import javax.inject.Inject
+
+class DebugErrorLoggingHelper @Inject constructor() : ErrorLoggingHelper {
+    override fun logError(exception: Throwable) {
+        Log.e("DebugErrorLoggingHelper", exception.stackTraceToString())
+    }
+}

core/analytics/src/main/java/com/idle/analytics/error/ErrorLoggingHelper.kt

@@ -0,0 +1,5 @@
+package com.idle.analytics.error
+
+interface ErrorLoggingHelper {
+    fun logError(exception: Throwable)
+}

core/common-ui/binding/src/main/java/com/idle/binding/base/BaseBindingFragment.kt

@@ -6,7 +6,7 @@ import android.view.View
 import android.view.ViewGroup
 import androidx.databinding.ViewDataBinding
 import androidx.fragment.app.Fragment
-import com.idle.analytics.helper.AnalyticsHelper
+import com.idle.analytics.businessmetric.AnalyticsHelper
 import javax.inject.Inject
 
 typealias Inflate<T> = (LayoutInflater, ViewGroup?, Boolean) -> T

core/common-ui/compose/src/main/java/com/idle/compose/base/BaseComposeFragment.kt

@@ -10,8 +10,8 @@ import androidx.compose.runtime.Composable
 import androidx.compose.runtime.CompositionLocalProvider
 import androidx.compose.ui.platform.ComposeView
 import androidx.fragment.app.Fragment
-import com.idle.analytics.helper.AnalyticsHelper
-import com.idle.analytics.helper.LocalAnalyticsHelper
+import com.idle.analytics.businessmetric.AnalyticsHelper
+import com.idle.analytics.businessmetric.LocalAnalyticsHelper
 import com.idle.binding.base.BaseViewModel
 import javax.inject.Inject
 

core/data/src/main/java/com/idle/data/di/DataModule.kt

@@ -3,12 +3,14 @@ package com.idle.data.di
 import com.idle.data.repository.auth.AuthRepositoryImpl
 import com.idle.data.repository.auth.TokenManagerImpl
 import com.idle.data.repository.auth.TokenRepositoryImpl
+import com.idle.data.repository.chatting.ChattingRepositoryImpl
 import com.idle.data.repository.config.ConfigRepositoryImpl
 import com.idle.data.repository.jobposting.JobPostingRepositoryImpl
 import com.idle.data.repository.notification.NotificationRepositoryImpl
 import com.idle.data.repository.profile.ProfileRepositoryImpl
 import com.idle.domain.repositorry.auth.AuthRepository
 import com.idle.domain.repositorry.auth.TokenRepository
+import com.idle.domain.repositorry.chatting.ChattingRepository
 import com.idle.domain.repositorry.config.ConfigRepository
 import com.idle.domain.repositorry.jobposting.JobPostingRepository
 import com.idle.domain.repositorry.notification.NotificationRepository
@@ -59,6 +61,12 @@ abstract class DataModule {
         notificationRepositoryImpl: NotificationRepositoryImpl,
     ): NotificationRepository
 
+    @Binds
+    @Singleton
+    abstract fun bindsChattingRepository(
+        chattingRepositoryImpl: ChattingRepositoryImpl,
+    ): ChattingRepository
+
     @Binds
     @Singleton
     abstract fun bindsTokenProvider(

core/data/src/main/java/com/idle/data/repository/chatting/ChattingRepositoryImpl.kt

@@ -0,0 +1,23 @@
+package com.idle.data.repository.chatting
+
+import com.idle.domain.model.chatting.ChatMessage
+import com.idle.domain.repositorry.chatting.ChattingRepository
+import com.idle.network.source.websocket.WebSocketDataSource
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.filterNotNull
+import kotlinx.coroutines.flow.map
+import javax.inject.Inject
+
+class ChattingRepositoryImpl @Inject constructor(
+    private val webSocketDataSource: WebSocketDataSource,
+) : ChattingRepository {
+    override suspend fun connectWebSocket(): Result<Unit> = webSocketDataSource.connectWebSocket()
+
+    override suspend fun disconnectWebSocket(): Result<Unit> =
+        webSocketDataSource.disconnectWebSocket()
+
+    override fun subscribeChatMessage(): Flow<ChatMessage> =
+        webSocketDataSource.getChatMessageFlow()
+            .filterNotNull()
+            .map { it.toVO() }
+}

core/data/src/main/java/com/idle/data/repository/profile/ProfileRepositoryImpl.kt

@@ -104,6 +104,8 @@ class ProfileRepositoryImpl @Inject constructor(
             }
 
         WorkerProfile(
+            workerId = properties["workerId"]
+                ?: throw IllegalArgumentException("Missing workerId"),
             workerName = properties["workerName"]
                 ?: throw IllegalArgumentException("Missing workerName"),
             age = properties["age"]?.toInt() ?: throw NumberFormatException("Invalid age format"),

core/data/src/test/java/com/idle/data/repository/profile/ProfileRepositoryImplTest.kt

@@ -41,6 +41,7 @@ class ProfileRepositoryImplTest {
     )
 
     private val workerProfile = WorkerProfile(
+        workerId = "test",
         workerName = "Test Worker",
         age = 30,
         gender = Gender.MAN,

core/domain/src/main/kotlin/com/idle/domain/model/chatting/ChatMessage.kt

@@ -9,17 +9,31 @@ data class ChatMessage(
     val senderType: SenderType,
     val contents: List<Content>,
     val createdAt: LocalDateTime,
-)
+) {
+    fun printPlainContents(): String = contents.joinToString { it.value }
+}
 
 data class Content(
     val type: ContentType,
     val value: String,
 )
 
 enum class SenderType {
-    USER,
+    USER, UNKNOWN;
+
+    companion object {
+        fun create(value: String?): SenderType {
+            return SenderType.entries.firstOrNull { it.name == value } ?: UNKNOWN
+        }
+    }
 }
 
 enum class ContentType {
-    TEXT, IMAGE;
+    TEXT, IMAGE, UNKNOWN;
+
+    companion object {
+        fun create(value: String?): ContentType {
+            return ContentType.entries.firstOrNull { it.name == value } ?: UNKNOWN
+        }
+    }
 }

core/domain/src/main/kotlin/com/idle/domain/model/chatting/ChatRoom.kt

@@ -10,5 +10,5 @@ data class ChatRoom(
     val lastMessage: String,
     val lastSentAt: LocalDateTime,
     val unReadMessageCount: Int,
-    val profileImageUrl: String,
+    val profileImageUrl: String?,
 )

core/domain/src/main/kotlin/com/idle/domain/model/error/ErrorHandlerHelper.kt → core/domain/src/main/kotlin/com/idle/domain/model/error/ErrorHandler.kt

@@ -6,7 +6,7 @@ import javax.inject.Inject
 import javax.inject.Singleton
 
 @Singleton
-class ErrorHandlerHelper @Inject constructor() {
+class ErrorHandler @Inject constructor() {
     private val _errorEvent = MutableSharedFlow<Throwable>(extraBufferCapacity = 1)
     val errorEvent = _errorEvent.asSharedFlow()
 

core/domain/src/main/kotlin/com/idle/domain/model/profile/WorkerProfile.kt

@@ -3,6 +3,7 @@ package com.idle.domain.model.profile
 import com.idle.domain.model.auth.Gender
 
 data class WorkerProfile(
+    val workerId: String,
     val workerName: String,
     val age: Int,
     val gender: Gender,

core/domain/src/main/kotlin/com/idle/domain/repositorry/chatting/ChattingRepository.kt

@@ -0,0 +1,10 @@
+package com.idle.domain.repositorry.chatting
+
+import com.idle.domain.model.chatting.ChatMessage
+import kotlinx.coroutines.flow.Flow
+
+interface ChattingRepository {
+    suspend fun connectWebSocket(): Result<Unit>
+    suspend fun disconnectWebSocket(): Result<Unit>
+    fun subscribeChatMessage(): Flow<ChatMessage>
+}

core/domain/src/main/kotlin/com/idle/domain/usecase/chatting/ConnectWebSocketUseCase.kt

@@ -0,0 +1,10 @@
+package com.idle.domain.usecase.chatting
+
+import com.idle.domain.repositorry.chatting.ChattingRepository
+import javax.inject.Inject
+
+class ConnectWebSocketUseCase @Inject constructor(
+    private val chattingRepository: ChattingRepository,
+) {
+    suspend operator fun invoke(): Result<Unit> =  chattingRepository.connectWebSocket()
+}

core/domain/src/main/kotlin/com/idle/domain/usecase/chatting/DisconnectWebSocketUseCase.kt

@@ -0,0 +1,10 @@
+package com.idle.domain.usecase.chatting
+
+import com.idle.domain.repositorry.chatting.ChattingRepository
+import javax.inject.Inject
+
+class DisconnectWebSocketUseCase @Inject constructor(
+    private val chattingRepository: ChattingRepository,
+) {
+    suspend operator fun invoke() = chattingRepository.disconnectWebSocket()
+}

core/domain/src/main/kotlin/com/idle/domain/usecase/chatting/SubscribeChatMessageUseCase.kt

@@ -0,0 +1,12 @@
+package com.idle.domain.usecase.chatting
+
+import com.idle.domain.model.chatting.ChatMessage
+import com.idle.domain.repositorry.chatting.ChattingRepository
+import kotlinx.coroutines.flow.Flow
+import javax.inject.Inject
+
+class SubscribeChatMessageUseCase @Inject constructor(
+    private val chattingRepository: ChattingRepository,
+) {
+    operator fun invoke(): Flow<ChatMessage> = chattingRepository.subscribeChatMessage()
+}

core/network/build.gradle.kts

@@ -19,14 +19,23 @@ android {
                 "CARE_BASE_URL",
                 "\"${properties["CARE_DEV_BASE_URL"]}\"",
             )
+            buildConfigField(
+                "String",
+                "CARE_WEBSOCKET_URL",
+                "\"${properties["CARE_DEV_WEBSOCKET_URL"]}\"",
+            )
         }
         release {
             buildConfigField(
                 "String",
                 "CARE_BASE_URL",
                 "\"${properties["CARE_PROD_BASE_URL"]}\"",
             )
-
+            buildConfigField(
+                "String",
+                "CARE_WEBSOCKET_URL",
+                "\"${properties["CARE_PROD_WEBSOCKET_URL"]}\"",
+            )
         }
     }