add feature to delete all data from the remote database and refactor code

sakethpathike · sakethpathike · commit dbbd76229424 · 2025-02-02T14:21:37.000+05:30
diff --git a/src/main/kotlin/com/sakethh/linkora/data/Database.kt b/src/main/kotlin/com/sakethh/linkora/data/Database.kt
@@ -75,7 +75,7 @@ fun configureDatabase() {
 }
 
 private fun createRequiredTables() {
-    SchemaUtils.create(
-        FoldersTable, LinksTable, TombstoneTable, PanelsTable, PanelFoldersTable
-    )
-}
+    SchemaUtils.create(*linkoraTables())
+}
+
+fun linkoraTables() = arrayOf(FoldersTable, LinksTable, TombstoneTable, PanelsTable, PanelFoldersTable)
diff --git a/src/main/kotlin/com/sakethh/linkora/data/repository/FoldersImplementation.kt b/src/main/kotlin/com/sakethh/linkora/data/repository/FoldersImplementation.kt
@@ -1,6 +1,6 @@
 package com.sakethh.linkora.data.repository
 
-import com.sakethh.linkora.domain.Folder
+import com.sakethh.linkora.domain.model.Folder
 import com.sakethh.linkora.domain.dto.IDBasedDTO
 import com.sakethh.linkora.domain.dto.NewItemResponseDTO
 import com.sakethh.linkora.domain.dto.TimeStampBasedResponse
diff --git a/src/main/kotlin/com/sakethh/linkora/data/repository/SyncRepoImpl.kt b/src/main/kotlin/com/sakethh/linkora/data/repository/SyncRepoImpl.kt
@@ -1,14 +1,21 @@
 package com.sakethh.linkora.data.repository
 
-import com.sakethh.linkora.domain.*
+import com.sakethh.linkora.data.linkoraTables
+import com.sakethh.linkora.domain.LinkType
+import com.sakethh.linkora.domain.MediaType
 import com.sakethh.linkora.domain.dto.AllTablesDTO
 import com.sakethh.linkora.domain.dto.Tombstone
+import com.sakethh.linkora.domain.model.Folder
+import com.sakethh.linkora.domain.model.Link
+import com.sakethh.linkora.domain.model.Panel
+import com.sakethh.linkora.domain.model.PanelFolder
 import com.sakethh.linkora.domain.repository.SyncRepo
 import com.sakethh.linkora.domain.tables.*
 import kotlinx.coroutines.async
 import kotlinx.coroutines.awaitAll
 import kotlinx.coroutines.coroutineScope
 import kotlinx.serialization.json.Json
+import org.jetbrains.exposed.sql.SchemaUtils
 import org.jetbrains.exposed.sql.selectAll
 import org.jetbrains.exposed.sql.transactions.transaction
 
@@ -106,4 +113,16 @@ class SyncRepoImpl : SyncRepo {
             panelFolders = updatedPanelFolders.toList()
         )
     }
+
+    override suspend fun deleteEverything(): Result<Unit> {
+        return try {
+            transaction {
+                SchemaUtils.drop(*linkoraTables())
+            }
+            Result.success(Unit)
+        } catch (e: Exception) {
+            e.printStackTrace()
+            Result.failure(e)
+        }
+    }
 }
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/dto/AllTablesDTO.kt b/src/main/kotlin/com/sakethh/linkora/domain/dto/AllTablesDTO.kt
@@ -1,9 +1,9 @@
 package com.sakethh.linkora.domain.dto
 
-import com.sakethh.linkora.domain.Folder
-import com.sakethh.linkora.domain.Link
-import com.sakethh.linkora.domain.Panel
-import com.sakethh.linkora.domain.PanelFolder
+import com.sakethh.linkora.domain.model.Folder
+import com.sakethh.linkora.domain.model.Link
+import com.sakethh.linkora.domain.model.Panel
+import com.sakethh.linkora.domain.model.PanelFolder
 import kotlinx.serialization.Serializable
 
 @Serializable
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/model/Folder.kt b/src/main/kotlin/com/sakethh/linkora/domain/model/Folder.kt
@@ -1,4 +1,4 @@
-package com.sakethh.linkora.domain
+package com.sakethh.linkora.domain.model
 
 import kotlinx.serialization.Serializable
 
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/model/Link.kt b/src/main/kotlin/com/sakethh/linkora/domain/model/Link.kt
@@ -1,5 +1,7 @@
-package com.sakethh.linkora.domain
+package com.sakethh.linkora.domain.model
 
+import com.sakethh.linkora.domain.LinkType
+import com.sakethh.linkora.domain.MediaType
 import kotlinx.serialization.Serializable
 
 @Serializable
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/model/Panel.kt b/src/main/kotlin/com/sakethh/linkora/domain/model/Panel.kt
@@ -1,4 +1,4 @@
-package com.sakethh.linkora.domain
+package com.sakethh.linkora.domain.model
 
 import kotlinx.serialization.Serializable
 
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/model/PanelFolder.kt b/src/main/kotlin/com/sakethh/linkora/domain/model/PanelFolder.kt
@@ -1,4 +1,4 @@
-package com.sakethh.linkora.domain
+package com.sakethh.linkora.domain.model
 
 import kotlinx.serialization.Serializable
 
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/repository/FoldersRepository.kt b/src/main/kotlin/com/sakethh/linkora/domain/repository/FoldersRepository.kt
@@ -1,6 +1,6 @@
 package com.sakethh.linkora.domain.repository
 
-import com.sakethh.linkora.domain.Folder
+import com.sakethh.linkora.domain.model.Folder
 import com.sakethh.linkora.domain.dto.IDBasedDTO
 import com.sakethh.linkora.domain.dto.NewItemResponseDTO
 import com.sakethh.linkora.domain.dto.TimeStampBasedResponse
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/repository/SyncRepo.kt b/src/main/kotlin/com/sakethh/linkora/domain/repository/SyncRepo.kt
@@ -6,4 +6,5 @@ import com.sakethh.linkora.domain.dto.Tombstone
 interface SyncRepo {
     suspend fun getTombstonesAfter(eventTimestamp: Long): List<Tombstone>
     suspend fun getUpdatesAfter(eventTimestamp: Long): AllTablesDTO
+    suspend fun deleteEverything(): Result<Unit>
 }
diff --git a/src/main/kotlin/com/sakethh/linkora/domain/routes/SyncRoute.kt b/src/main/kotlin/com/sakethh/linkora/domain/routes/SyncRoute.kt
@@ -3,5 +3,6 @@ package com.sakethh.linkora.domain.routes
 enum class SyncRoute {
     TEST_BEARER,
     GET_UPDATES,
-    GET_TOMBSTONES
+    GET_TOMBSTONES,
+    DELETE_EVERYTHING
 }
diff --git a/src/main/kotlin/com/sakethh/linkora/presentation/routing/http/SyncRouting.kt b/src/main/kotlin/com/sakethh/linkora/presentation/routing/http/SyncRouting.kt
@@ -31,6 +31,18 @@ fun Application.syncRouting(syncRepo: SyncRepo) {
                     call.respond(e.message.toString())
                 }
             }
+
+            get(SyncRoute.DELETE_EVERYTHING.name) {
+                syncRepo.deleteEverything().onSuccess {
+                    call.respond(status = HttpStatusCode.OK, message = HttpStatusCode.OK.description)
+                }.onFailure {
+                    call.respond(
+                        status = HttpStatusCode.InternalServerError,
+                        message = HttpStatusCode.InternalServerError.description
+                    )
+                    it.printStackTrace()
+                }
+            }
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package com.sakethh.linkora.domain`
	`1`	`+package com.sakethh.linkora.domain.model`
`2`	`2`
`3`	`3`	`import kotlinx.serialization.Serializable`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -6,4 +6,5 @@ import com.sakethh.linkora.domain.dto.Tombstone`
`6`	`6`	`interface SyncRepo {`
`7`	`7`	`suspend fun getTombstonesAfter(eventTimestamp: Long): List<Tombstone>`
`8`	`8`	`suspend fun getUpdatesAfter(eventTimestamp: Long): AllTablesDTO`
	`9`	`+ suspend fun deleteEverything(): Result<Unit>`
`9`	`10`	`}`