firebase 레파지토리 생성

Author: gunchimssak

app/build.gradle

@@ -26,6 +26,9 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
         }
     }
+    composeOptions {
+        kotlinCompilerExtensionVersion = "1.4.2"
+    }
     compileOptions {
         sourceCompatibility JavaVersion.VERSION_1_8
         targetCompatibility JavaVersion.VERSION_1_8
@@ -36,6 +39,9 @@ android {
     viewBinding{
         enabled = true
     }
+    buildFeatures {
+        compose true
+    }
 }
 
 dependencies {
@@ -66,5 +72,6 @@ dependencies {
     implementation 'androidx.activity:activity-compose:1.7.2'
 
     implementation "androidx.navigation:navigation-compose:2.6.0"
+    implementation "androidx.hilt:hilt-navigation-compose:1.0.0"
 
 }

app/src/main/AndroidManifest.xml

@@ -25,8 +25,9 @@
                 android:name="android.app.lib_name"
                 android:value="" />
         </activity>
+        <activity android:name=".MainActivity"/>
         <activity
-            android:name="com.example.webrtc.MainActivity"
+            android:name="com.example.webrtc.ComposeActivity"
             android:exported="true">
             <intent-filter>
                 <action android:name="android.intent.action.MAIN" />

data/src/main/java/com/example/data/di/RepositoryModule.kt

@@ -1,7 +1,9 @@
 package com.example.data.di
 
+import com.example.data.repository.FireStoreRepositoryImpl
 import com.example.data.repository.SignalRepositoryImpl
 import com.example.data.repository.WebRTCRepositoryImpl
+import com.example.domain.repository.FireStoreRepository
 import com.example.domain.repository.SignalRepository
 import com.example.domain.repository.WebRTCRepository
 import dagger.Binds
@@ -18,4 +20,7 @@ internal abstract class RepositoryModule {
 
     @Binds
     abstract fun bindsWebRTCRepository(webRTCRepositoryImpl: WebRTCRepositoryImpl): WebRTCRepository
+
+    @Binds
+    abstract fun bindsFireStoreRepository(fireStoreRepositoryImpl: FireStoreRepositoryImpl): FireStoreRepository
 }

data/src/main/java/com/example/data/repository/FireStoreRepositoryImpl.kt

@@ -0,0 +1,29 @@
+package com.example.data.repository
+
+import android.content.Intent
+import com.example.domain.repository.FireStoreRepository
+import com.google.firebase.firestore.DocumentSnapshot
+import com.google.firebase.firestore.FirebaseFirestore
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.callbackFlow
+import kotlinx.coroutines.launch
+import javax.inject.Inject
+
+class FireStoreRepositoryImpl @Inject constructor(
+    private val firestore: FirebaseFirestore
+) : FireStoreRepository {
+    override fun getRoomInfo(roomID: String): Flow<DocumentSnapshot> = callbackFlow {
+        firestore.collection("calls")
+            .document(roomID)
+            .get()
+            .addOnSuccessListener {
+                CoroutineScope(Dispatchers.IO).launch {
+                    send(it)
+                }
+            }
+        awaitClose {}
+    }
+}

domain/build.gradle

@@ -46,4 +46,7 @@ dependencies {
     kapt 'com.google.dagger:hilt-android-compiler:2.45'
 
     implementation 'org.webrtc:google-webrtc:1.0.32006'
+
+    implementation platform('com.google.firebase:firebase-bom:31.0.3')
+    implementation 'com.google.firebase:firebase-firestore-ktx'
 }

domain/src/main/java/com/example/domain/repository/FireStoreRepository.kt

@@ -0,0 +1,8 @@
+package com.example.domain.repository
+
+import com.google.firebase.firestore.DocumentSnapshot
+import kotlinx.coroutines.flow.Flow
+
+interface FireStoreRepository {
+    fun getRoomInfo(roomID: String): Flow<DocumentSnapshot>
+}

domain/src/main/java/com/example/domain/state/FireStoreState.kt

@@ -0,0 +1,7 @@
+package com.example.domain.state
+
+sealed class FireStoreState {
+    object Idle : FireStoreState()
+    data class EnterRoom(val isJoin: Boolean) : FireStoreState()
+    object RoomAlreadyEnded: FireStoreState()
+}

domain/src/main/java/com/example/usecase/GetRoomInfoUseCase.kt

@@ -0,0 +1,9 @@
+package com.example.usecase
+
+import com.example.domain.repository.FireStoreRepository
+import javax.inject.Inject
+
+class GetRoomInfoUseCase @Inject constructor(private val fireStoreRepository: FireStoreRepository) {
+
+    suspend operator fun invoke(roomId: String) = fireStoreRepository.getRoomInfo(roomId)
+}

presentaion/build.gradle

@@ -24,13 +24,25 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
         }
     }
+    composeOptions {
+        kotlinCompilerExtensionVersion = "1.4.2"
+    }
+    buildFeatures {
+        compose true
+    }
     compileOptions {
         sourceCompatibility JavaVersion.VERSION_1_8
         targetCompatibility JavaVersion.VERSION_1_8
     }
     kotlinOptions {
         jvmTarget = '1.8'
     }
+    viewBinding{
+        enabled = true
+    }
+    dataBinding {
+        enabled = true
+    }
 }
 
 dependencies {
@@ -49,6 +61,7 @@ dependencies {
     implementation 'androidx.lifecycle:lifecycle-viewmodel-ktx:2.6.1'
     implementation 'androidx.lifecycle:lifecycle-runtime-ktx:2.6.1'
     implementation 'androidx.activity:activity-ktx:1.7.2'
+    implementation 'androidx.fragment:fragment-ktx:1.6.0'
     implementation 'org.webrtc:google-webrtc:1.0.32006'
 
     implementation platform('com.google.firebase:firebase-bom:31.0.3')
@@ -59,4 +72,5 @@ dependencies {
     implementation 'androidx.compose.material:material:1.4.3'
     implementation 'androidx.compose.runtime:runtime:1.4.3'
     implementation 'androidx.activity:activity-compose:1.7.2'
+    implementation "androidx.navigation:navigation-compose:2.6.0"
 }

presentaion/src/main/java/com/example/presentaion/viewmodel/FireStoreViewModel.kt

@@ -0,0 +1,28 @@
+package com.example.presentaion.viewmodel
+
+import androidx.lifecycle.ViewModel
+import androidx.lifecycle.viewModelScope
+import com.example.domain.state.FireStoreState
+import com.example.usecase.GetRoomInfoUseCase
+import dagger.hilt.android.lifecycle.HiltViewModel
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.asStateFlow
+import kotlinx.coroutines.launch
+import javax.inject.Inject
+
+@HiltViewModel
+class FireStoreViewModel @Inject constructor(
+    private val getRoomInfoUseCase: GetRoomInfoUseCase
+) : ViewModel() {
+    private val _state = MutableStateFlow<FireStoreState>(FireStoreState.Idle)
+    val state = _state.asStateFlow()
+    fun getRoomInfo(roomId: String, isJoin: Boolean) = viewModelScope.launch {
+        getRoomInfoUseCase(roomId).collect { snapshot ->
+            if (snapshot["type"] == "OFFER" || snapshot["type"] == "ANSWER" || snapshot["type"] == "END_CALL") {
+                _state.emit(FireStoreState.RoomAlreadyEnded)
+            } else {
+                _state.emit(FireStoreState.EnterRoom(isJoin))
+            }
+        }
+    }
+}