kuring-38 [수정] 서버에서 학과 이름이 바뀌었을 때 로컬 DB에도 반영하도록 수정

app/src/main/java/com/ku_stacks/ku_ring/data/db/DepartmentDao.kt

@@ -20,6 +20,12 @@ interface DepartmentDao {
     @Query("SELECT * FROM departments WHERE koreanName LIKE '%' || :koreanName || '%'")
     suspend fun getDepartmentsByKoreanName(koreanName: String): List<DepartmentEntity>
 
+    @Query("SELECT COUNT(*) FROM departments")
+    suspend fun getDepartmentsSize(): Int
+
+    @Query("UPDATE departments SET shortName = :shortName, koreanName = :koreanName WHERE name = :name")
+    suspend fun updateDepartment(name: String, shortName: String, koreanName: String)
+
     @Query("SELECT * FROM departments WHERE isSubscribed = :isSubscribed")
     suspend fun getDepartmentsBySubscribed(isSubscribed: Boolean): List<DepartmentEntity>
 

app/src/main/java/com/ku_stacks/ku_ring/repository/DepartmentRepository.kt

@@ -4,8 +4,8 @@ import com.ku_stacks.ku_ring.data.model.Department
 import kotlinx.coroutines.flow.Flow
 
 interface DepartmentRepository {
-    suspend fun insertAllDepartmentsFromRemote()
-    suspend fun fetchAllDepartmentsFromRemote(): List<Department>?
+    suspend fun updateDepartmentsFromRemote()
+    suspend fun fetchDepartmentsFromRemote(): List<Department>?
     suspend fun insertDepartment(department: Department)
     suspend fun insertDepartments(departments: List<Department>)
     suspend fun getAllDepartments(): List<Department>

app/src/main/java/com/ku_stacks/ku_ring/repository/DepartmentRepositoryImpl.kt

@@ -23,19 +23,32 @@ class DepartmentRepositoryImpl @Inject constructor(
     // null: 데이터가 업데이트되어 새 데이터를 가져와야 함
     private var departments: List<Department>? = null
 
-    override suspend fun insertAllDepartmentsFromRemote() {
-        val departments = fetchAllDepartmentsFromRemote()
+    override suspend fun updateDepartmentsFromRemote() {
+        val departments = fetchDepartmentsFromRemote()
         departments?.let {
-            departmentDao.insertDepartments(departments.map { it.toEntity() })
+            if (departmentDao.getDepartmentsSize() == 0) {
+                departmentDao.insertDepartments(departments.toEntityList())
+            } else {
+                updateDepartmentsName(it)
+            }
         }
     }
 
-    override suspend fun fetchAllDepartmentsFromRemote(): List<Department>? {
+    override suspend fun fetchDepartmentsFromRemote(): List<Department>? {
         return runCatching {
             departmentClient.fetchDepartmentList().data?.map { it.toDepartment() } ?: emptyList()
         }.getOrNull()
     }
 
+    private suspend fun updateDepartmentsName(departments: List<Department>) {
+        withContext(ioDispatcher) {
+            departments.forEach { (name, shortName, koreanName, _) ->
+                departmentDao.updateDepartment(name, shortName, koreanName)
+            }
+        }
+        this.departments = null
+    }
+
     override suspend fun insertDepartment(department: Department) {
         withContext(ioDispatcher) {
             departmentDao.insertDepartment(department.toEntity())

app/src/main/java/com/ku_stacks/ku_ring/ui/edit_subscription/EditSubscriptionViewModel.kt

@@ -100,7 +100,7 @@ class EditSubscriptionViewModel @Inject constructor(
         }
 
         viewModelScope.launch {
-            departmentRepository.insertAllDepartmentsFromRemote()
+            departmentRepository.updateDepartmentsFromRemote()
             val subscribedDepartments = departmentRepository.getSubscribedDepartments()
             addDepartmentsToMap(subscribedDepartments)
             val notificationEnabledDepartments = repository.fetchSubscribedDepartments()

app/src/main/java/com/ku_stacks/ku_ring/ui/main/notice/department/fragment_subscribe/DepartmentSubscribeViewModel.kt

@@ -27,7 +27,7 @@ class DepartmentSubscribeViewModel @Inject constructor(
 
     init {
         viewModelScope.launch {
-            departmentRepository.insertAllDepartmentsFromRemote()
+            departmentRepository.updateDepartmentsFromRemote()
         }
 
         searchKeyword.onEach { loadFilteredDepartment(it) }

app/src/test/java/com/ku_stacks/ku_ring/persistence/LocalDbAbstract.kt → app/src/test/java/com/ku_stacks/ku_ring/LocalDbAbstract.kt

@@ -1,4 +1,4 @@
-package com.ku_stacks.ku_ring.persistence
+package com.ku_stacks.ku_ring
 
 import androidx.room.Room
 import androidx.test.core.app.ApplicationProvider.getApplicationContext

app/src/test/java/com/ku_stacks/ku_ring/MockUtil.kt

@@ -10,6 +10,7 @@ import com.ku_stacks.ku_ring.data.api.response.NoticeResponse
 import com.ku_stacks.ku_ring.data.api.response.SubscribeListResponse
 import com.ku_stacks.ku_ring.data.api.response.UserListResponse
 import com.ku_stacks.ku_ring.data.api.response.UserResponse
+import com.ku_stacks.ku_ring.data.db.DepartmentEntity
 import com.ku_stacks.ku_ring.data.db.NoticeEntity
 import com.ku_stacks.ku_ring.data.db.PushEntity
 import com.ku_stacks.ku_ring.data.model.Notice
@@ -58,6 +59,13 @@ object MockUtil {
         isReadOnStorage = false,
     )
 
+    fun mockDepartmentEntity() = DepartmentEntity(
+        name = "smart_ict_convergence",
+        shortName = "sicte",
+        koreanName = "스마트ICT융합공학과",
+        isSubscribed = false,
+    )
+
     fun mockNotice() = Notice(
         postedDate = "20220203",
         subject = "2022학년도 1학기 재입학 합격자 유의사항 안내",

app/src/test/java/com/ku_stacks/ku_ring/paging_source/DepartmentNoticeMediatorTest.kt

@@ -13,7 +13,7 @@ import com.ku_stacks.ku_ring.data.api.NoticeClient
 import com.ku_stacks.ku_ring.data.db.NoticeDao
 import com.ku_stacks.ku_ring.data.db.NoticeEntity
 import com.ku_stacks.ku_ring.data.source.DepartmentNoticeMediator
-import com.ku_stacks.ku_ring.persistence.LocalDbAbstract
+import com.ku_stacks.ku_ring.LocalDbAbstract
 import com.ku_stacks.ku_ring.util.PreferenceUtil
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.test.runTest

app/src/test/java/com/ku_stacks/ku_ring/persistence/DepartmentDaoTest.kt

@@ -0,0 +1,45 @@
+package com.ku_stacks.ku_ring.persistence
+
+import com.ku_stacks.ku_ring.LocalDbAbstract
+import com.ku_stacks.ku_ring.MockUtil
+import com.ku_stacks.ku_ring.data.db.DepartmentDao
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.test.runTest
+import org.junit.Assert.assertEquals
+import org.junit.Before
+import org.junit.Test
+import org.junit.runner.RunWith
+import org.robolectric.RobolectricTestRunner
+
+@OptIn(ExperimentalCoroutinesApi::class)
+@RunWith(RobolectricTestRunner::class)
+class DepartmentDaoTest : LocalDbAbstract() {
+    private lateinit var departmentDao: DepartmentDao
+
+    @Before
+    fun setup() {
+        departmentDao = db.departmentDao()
+    }
+
+    @Test
+    fun `insertDepartment and updateDepartment test`() = runTest {
+        // given
+        val entity = MockUtil.mockDepartmentEntity()
+        departmentDao.insertDepartment(entity)
+
+        // when
+        val newShortName = "ict"
+        val newKoreanName = "스융공"
+        departmentDao.updateDepartment(
+            name = entity.name,
+            shortName = newShortName,
+            koreanName = newKoreanName
+        )
+
+        // then
+        val result = departmentDao.getDepartmentsByName(entity.name)
+        assert(result.isNotEmpty())
+        assertEquals(1, result.size)
+        assertEquals(result[0], entity.copy(shortName = newShortName, koreanName = newKoreanName))
+    }
+}

app/src/test/java/com/ku_stacks/ku_ring/persistence/NoticeDaoTest.kt

@@ -1,6 +1,7 @@
 package com.ku_stacks.ku_ring.persistence
 
 import androidx.paging.PagingSource
+import com.ku_stacks.ku_ring.LocalDbAbstract
 import com.ku_stacks.ku_ring.data.db.NoticeDao
 import com.ku_stacks.ku_ring.data.db.NoticeEntity
 import kotlinx.coroutines.ExperimentalCoroutinesApi

app/src/test/java/com/ku_stacks/ku_ring/persistence/PushDaoTest.kt

@@ -1,5 +1,6 @@
 package com.ku_stacks.ku_ring.persistence
 
+import com.ku_stacks.ku_ring.LocalDbAbstract
 import com.ku_stacks.ku_ring.data.db.PushDao
 import com.ku_stacks.ku_ring.data.db.PushEntity
 import kotlinx.coroutines.runBlocking