feature: 채팅 기능 구현

CatchMate/app/src/main/AndroidManifest.xml

@@ -49,13 +49,6 @@
             </intent-filter>
         </service>
 
-        <meta-data
-            android:name="com.google.firebase.messaging.default_notification_icon"
-            android:resource="@drawable/ic_notification" />
-        <meta-data
-            android:name="com.google.firebase.messaging.default_notification_color"
-            android:resource="@color/brand500"/>
-
         <provider
             android:authorities="com.catchmate.android"
             android:name="androidx.core.content.FileProvider"

CatchMate/data/build.gradle.kts

@@ -15,10 +15,12 @@ android {
 
     val googleWebClientId = properties["google_web_client_id"] as? String ?: ""
     val serverDomain = properties["server_domain"] as? String ?: ""
+    val serverSocketUrl = properties["server_socket_url"] as? String ?: ""
 
     defaultConfig {
         buildConfigField("String", "GOOGLE_WEB_CLIENT_ID", googleWebClientId)
         buildConfigField("String", "SERVER_DOMAIN", serverDomain)
+        buildConfigField("String", "SERVER_SOCKET_URL", serverSocketUrl)
     }
 
     buildFeatures {
@@ -49,4 +51,8 @@ dependencies {
     implementation(libs.logging.interceptor)
 
     implementation(libs.androidx.security.crypto.ktx)
+
+    implementation(libs.rxjava)
+    implementation(libs.rxandroid)
+    implementation(libs.stomp)
 }

CatchMate/data/src/main/java/com/catchmate/data/datasource/remote/ChatWebSocketClient.kt

@@ -0,0 +1,29 @@
+package com.catchmate.data.datasource.remote
+
+import com.catchmate.data.BuildConfig
+import com.gmail.bishoybasily.stomp.lib.StompClient
+import okhttp3.OkHttpClient
+import okhttp3.logging.HttpLoggingInterceptor
+import javax.inject.Inject
+
+class ChatWebSocketClient
+    @Inject
+    constructor() {
+        private val intervalMillis = 1000L
+
+        private val loggingInterceptor =
+            HttpLoggingInterceptor().apply {
+                level = HttpLoggingInterceptor.Level.BODY
+            }
+
+        private val okHttpClient =
+            OkHttpClient
+                .Builder()
+                .addInterceptor(loggingInterceptor)
+                .build()
+
+        val stompClient =
+            StompClient(okHttpClient, intervalMillis).apply {
+                url = BuildConfig.SERVER_SOCKET_URL
+            }
+    }

CatchMate/data/src/main/java/com/catchmate/data/datasource/remote/ChattingService.kt

@@ -0,0 +1,60 @@
+package com.catchmate.data.datasource.remote
+
+import com.catchmate.data.dto.chatting.ChatRoomInfoDTO
+import com.catchmate.data.dto.chatting.DeleteChattingCrewKickOutResponseDTO
+import com.catchmate.data.dto.chatting.DeleteChattingRoomResponseDTO
+import com.catchmate.data.dto.chatting.GetChattingCrewListResponseDTO
+import com.catchmate.data.dto.chatting.GetChattingHistoryResponseDTO
+import com.catchmate.data.dto.chatting.GetChattingRoomListResponseDTO
+import com.catchmate.data.dto.chatting.PatchChattingRoomImageResponseDTO
+import okhttp3.MultipartBody
+import retrofit2.Response
+import retrofit2.http.DELETE
+import retrofit2.http.GET
+import retrofit2.http.Multipart
+import retrofit2.http.PATCH
+import retrofit2.http.Part
+import retrofit2.http.Path
+import retrofit2.http.Query
+
+interface ChattingService {
+    @GET("chat-rooms/list")
+    suspend fun getChattingRoomList(
+        @Query("page") page: Int,
+    ): Response<GetChattingRoomListResponseDTO?>
+
+    @GET("chat-rooms/{chatRoomId}/user-list")
+    suspend fun getChattingCrewList(
+        @Path("chatRoomId") chatRoomId: Long,
+    ): Response<GetChattingCrewListResponseDTO?>
+
+    @GET("chat-rooms/{chatRoomId}")
+    suspend fun getChattingRoomInfo(
+        @Path("chatRoomId") chatRoomId: Long,
+    ): Response<ChatRoomInfoDTO?>
+
+    @Multipart
+    @PATCH("chat-rooms/{chatRoomId}/image")
+    suspend fun patchChattingRoomImage(
+        @Path("chatRoomId") chatRoomId: Long,
+        @Part chatRoomImage: MultipartBody.Part,
+    ): Response<PatchChattingRoomImageResponseDTO?>
+
+    @DELETE("chat-rooms/{chatRoomId}")
+    suspend fun deleteChattingRoom(
+        @Path("chatRoomId") chatRoomId: Long,
+    ): Response<DeleteChattingRoomResponseDTO?>
+
+    @DELETE("chat-rooms/{chatRoomId}/users/{userId}")
+    suspend fun deleteChattingCrewKickOut(
+        @Path("chatRoomId") chatRoomId: Long,
+        @Path("userId") userId: Long,
+    ): Response<DeleteChattingCrewKickOutResponseDTO?>
+
+    @GET("chats/{chatRoomId}")
+    suspend fun getChattingHistory(
+        @Path("chatRoomId") chatRoomId: Long,
+        @Query("page") page: Int,
+        @Query("size") size: Int?, // default = 20
+    ): Response<GetChattingHistoryResponseDTO?>
+}

CatchMate/data/src/main/java/com/catchmate/data/datasource/remote/FCMTokenService.kt

@@ -50,7 +50,9 @@ class FCMTokenService : FirebaseMessagingService() {
 
         val data = message.data
 
-        Log.e("MSG", "${data["boardId"]} / ${data["acceptStatus"]} / $title / $body")
+        // 채팅 알림 - data = {chatRoomId}
+        // 직관 신청 알림 - data = {boardId, acceptStatus}
+        Log.e("MSG", "$data / $title / $body")
         if (title.isNotEmpty() && body.isNotEmpty()) {
             showNotification(data, title, body)
         }
@@ -92,15 +94,28 @@ class FCMTokenService : FirebaseMessagingService() {
         title: String,
         body: String,
     ) {
-        val notificationBuilder = getNotificationBuilder(PUST_NOTIFICATION_CHANNEL_ID)
+        var channelId: String = ""
+        var channelName: String = ""
+        if (data.containsKey("acceptStatus")) { // 직관 신청 알림
+            channelId = ENROLL_CHANNEL_ID
+            channelName = ENROLL_CHANNEL_NAME
+        } else { // 채팅 알림
+            channelId = CHATTING_CHANNEL_ID
+            channelName = CHATTING_CHANNEL_NAME
+        }
+        val notificationBuilder = getNotificationBuilder(channelId)
         val builder = notificationHandler.createNotificationBuilder(data, title, body, notificationBuilder)
-        createNotificationChannel(PUST_NOTIFICATION_CHANNEL_ID, PUST_NOTIFICATION_CHANNEL_NAME, builder)
+        createNotificationChannel(channelId, channelName, builder)
     }
 
     suspend fun getToken(): String = FirebaseMessaging.getInstance().token.await()
 
     companion object {
-        const val PUST_NOTIFICATION_CHANNEL_ID = "CatchmateNotificationChannel"
-        const val PUST_NOTIFICATION_CHANNEL_NAME = "CatchmateNotificationChannel"
+        const val ENROLL_CHANNEL_ID = "EnrollChannel"
+        const val ENROLL_CHANNEL_NAME = "직관 신청 알림"
+        const val CHATTING_CHANNEL_ID = "ChattingChannel"
+        const val CHATTING_CHANNEL_NAME = "채팅 알림"
+        const val EVENT_CHANNEL_ID = "EventChannel"
+        const val EVENT_CHANNEL_NAME = "이벤트 알림"
     }
 }

CatchMate/data/src/main/java/com/catchmate/data/di/ChatWebSocketModule.kt

@@ -0,0 +1,22 @@
+package com.catchmate.data.di
+
+import com.catchmate.data.datasource.remote.ChatWebSocketClient
+import com.catchmate.data.repository.ChatWebSocketRepositoryImpl
+import com.catchmate.domain.repository.ChatWebSocketRepository
+import dagger.Module
+import dagger.Provides
+import dagger.hilt.InstallIn
+import dagger.hilt.components.SingletonComponent
+import javax.inject.Singleton
+
+@Module
+@InstallIn(SingletonComponent::class)
+object ChatWebSocketModule {
+    @Provides
+    fun provideChatWebSocketRepository(chatWebSocketRepositoryImpl: ChatWebSocketRepositoryImpl): ChatWebSocketRepository =
+        chatWebSocketRepositoryImpl
+
+    @Provides
+    @Singleton
+    fun provideChatWebSocketClient(): ChatWebSocketClient = ChatWebSocketClient()
+}

CatchMate/data/src/main/java/com/catchmate/data/di/ChattingModule.kt

@@ -0,0 +1,15 @@
+package com.catchmate.data.di
+
+import com.catchmate.data.repository.ChattingRepositoryImpl
+import com.catchmate.domain.repository.ChattingRepository
+import dagger.Module
+import dagger.Provides
+import dagger.hilt.InstallIn
+import dagger.hilt.components.SingletonComponent
+
+@Module
+@InstallIn(SingletonComponent::class)
+object ChattingModule {
+    @Provides
+    fun provideChattingRepository(chattingRepositoryImpl: ChattingRepositoryImpl): ChattingRepository = chattingRepositoryImpl
+}

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/ChatMessageIdDTO.kt

@@ -0,0 +1,6 @@
+package com.catchmate.data.dto.chatting
+
+data class ChatMessageIdDTO(
+    val timestamp: Long? = null,
+    val date: String,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/ChatMessageInfoDTO.kt

@@ -0,0 +1,9 @@
+package com.catchmate.data.dto.chatting
+
+data class ChatMessageInfoDTO(
+    val id: ChatMessageIdDTO,
+    val roomId: Long? = null,
+    val content: String,
+    val senderId: Long,
+    val messageType: String,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/ChatRoomInfoDTO.kt

@@ -0,0 +1,12 @@
+package com.catchmate.data.dto.chatting
+
+import com.catchmate.data.dto.board.BoardDTO
+
+data class ChatRoomInfoDTO(
+    val chatRoomId: Long,
+    val boardInfo: BoardDTO,
+    val participantCount: Int,
+    val lastMessageAt: String?,
+    val lastMessageContent: String?,
+    val chatRoomImage: String,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/DeleteChattingCrewKickOutResponseDTO.kt

@@ -0,0 +1,5 @@
+package com.catchmate.data.dto.chatting
+
+data class DeleteChattingCrewKickOutResponseDTO(
+    val state: Boolean,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/DeleteChattingRoomResponseDTO.kt

@@ -0,0 +1,5 @@
+package com.catchmate.data.dto.chatting
+
+data class DeleteChattingRoomResponseDTO(
+    val state: Boolean,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/GetChattingCrewListResponseDTO.kt

@@ -0,0 +1,7 @@
+package com.catchmate.data.dto.chatting
+
+import com.catchmate.data.dto.user.GetUserProfileResponseDTO
+
+data class GetChattingCrewListResponseDTO(
+    val userInfoList: List<GetUserProfileResponseDTO>,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/GetChattingHistoryResponseDTO.kt

@@ -0,0 +1,9 @@
+package com.catchmate.data.dto.chatting
+
+data class GetChattingHistoryResponseDTO(
+    val chatMessageInfoList: List<ChatMessageInfoDTO>,
+    val totalPages: Int,
+    val totalElements: Int,
+    val isFirst: Boolean,
+    val isLast: Boolean,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/GetChattingRoomListResponseDTO.kt

@@ -0,0 +1,9 @@
+package com.catchmate.data.dto.chatting
+
+data class GetChattingRoomListResponseDTO(
+    val chatRoomInfoList: List<ChatRoomInfoDTO>,
+    val totalPages: Int,
+    val totalElements: Int,
+    val isFirst: Boolean,
+    val isLast: Boolean,
+)

CatchMate/data/src/main/java/com/catchmate/data/dto/chatting/PatchChattingRoomImageResponseDTO.kt

@@ -0,0 +1,5 @@
+package com.catchmate.data.dto.chatting
+
+data class PatchChattingRoomImageResponseDTO(
+    val state: Boolean,
+)

CatchMate/data/src/main/java/com/catchmate/data/mapper/BoardMapper.kt

@@ -147,7 +147,7 @@ object BoardMapper {
             isLast = responseDTO.isLast,
         )
 
-    private fun toBoard(dto: BoardDTO): Board =
+    fun toBoard(dto: BoardDTO): Board =
         Board(
             boardId = dto.boardId,
             title = dto.title,

CatchMate/data/src/main/java/com/catchmate/data/mapper/ChattingMapper.kt

@@ -0,0 +1,87 @@
+package com.catchmate.data.mapper
+
+import com.catchmate.data.dto.chatting.ChatMessageIdDTO
+import com.catchmate.data.dto.chatting.ChatMessageInfoDTO
+import com.catchmate.data.dto.chatting.ChatRoomInfoDTO
+import com.catchmate.data.dto.chatting.DeleteChattingCrewKickOutResponseDTO
+import com.catchmate.data.dto.chatting.DeleteChattingRoomResponseDTO
+import com.catchmate.data.dto.chatting.GetChattingCrewListResponseDTO
+import com.catchmate.data.dto.chatting.GetChattingHistoryResponseDTO
+import com.catchmate.data.dto.chatting.GetChattingRoomListResponseDTO
+import com.catchmate.data.dto.chatting.PatchChattingRoomImageResponseDTO
+import com.catchmate.data.mapper.BoardMapper.toBoard
+import com.catchmate.data.mapper.UserMapper.toGetUserProfileResponse
+import com.catchmate.domain.model.chatting.ChatMessageId
+import com.catchmate.domain.model.chatting.ChatMessageInfo
+import com.catchmate.domain.model.chatting.ChatRoomInfo
+import com.catchmate.domain.model.chatting.DeleteChattingCrewKickOutResponse
+import com.catchmate.domain.model.chatting.DeleteChattingRoomResponse
+import com.catchmate.domain.model.chatting.GetChattingCrewListResponse
+import com.catchmate.domain.model.chatting.GetChattingHistoryResponse
+import com.catchmate.domain.model.chatting.GetChattingRoomListResponse
+import com.catchmate.domain.model.chatting.PatchChattingRoomImageResponse
+
+object ChattingMapper {
+    fun toGetChattingRoomListResponse(dto: GetChattingRoomListResponseDTO): GetChattingRoomListResponse =
+        GetChattingRoomListResponse(
+            chatRoomInfoList = dto.chatRoomInfoList.map { toChatRoomInfo(it) },
+            totalPages = dto.totalPages,
+            totalElements = dto.totalElements,
+            isFirst = dto.isFirst,
+            isLast = dto.isLast,
+        )
+
+    fun toChatRoomInfo(dto: ChatRoomInfoDTO): ChatRoomInfo =
+        ChatRoomInfo(
+            chatRoomId = dto.chatRoomId,
+            boardInfo = toBoard(dto.boardInfo),
+            participantCount = dto.participantCount,
+            lastMessageAt = dto.lastMessageAt,
+            lastMessageContent = dto.lastMessageContent,
+            chatRoomImage = dto.chatRoomImage,
+        )
+
+    fun toGetChattingHistoryResponse(dto: GetChattingHistoryResponseDTO): GetChattingHistoryResponse =
+        GetChattingHistoryResponse(
+            chatMessageInfoList = dto.chatMessageInfoList.map { toChatMessageInfo(it) },
+            totalPages = dto.totalPages,
+            totalElements = dto.totalElements,
+            isFirst = dto.isFirst,
+            isLast = dto.isLast,
+        )
+
+    private fun toChatMessageInfo(dto: ChatMessageInfoDTO): ChatMessageInfo =
+        ChatMessageInfo(
+            id = toChatMessageId(dto.id),
+            roomId = dto.roomId,
+            content = dto.content,
+            senderId = dto.senderId,
+            messageType = dto.messageType,
+        )
+
+    private fun toChatMessageId(dto: ChatMessageIdDTO): ChatMessageId =
+        ChatMessageId(
+            timestamp = dto.timestamp,
+            date = dto.date,
+        )
+
+    fun toGetChattingCrewListResponse(dto: GetChattingCrewListResponseDTO): GetChattingCrewListResponse =
+        GetChattingCrewListResponse(
+            userInfoList = dto.userInfoList.map { toGetUserProfileResponse(it) },
+        )
+
+    fun toDeleteChattingRoomResponse(dto: DeleteChattingRoomResponseDTO): DeleteChattingRoomResponse =
+        DeleteChattingRoomResponse(
+            state = dto.state,
+        )
+
+    fun toDeleteChattingCrewKickOutResponse(dto: DeleteChattingCrewKickOutResponseDTO): DeleteChattingCrewKickOutResponse =
+        DeleteChattingCrewKickOutResponse(
+            state = dto.state,
+        )
+
+    fun toPatchChattingRoomImageResponse(dto: PatchChattingRoomImageResponseDTO): PatchChattingRoomImageResponse =
+        PatchChattingRoomImageResponse(
+            state = dto.state,
+        )
+}