refactor: change DELETE_EVERYTHING to a POST request and push the event via socket

Author: sakethpathike

src/main/kotlin/com/sakethh/linkora/data/repository/SyncRepoImpl.kt

@@ -3,21 +3,23 @@ package com.sakethh.linkora.data.repository
 import com.sakethh.linkora.data.linkoraTables
 import com.sakethh.linkora.domain.LinkType
 import com.sakethh.linkora.domain.MediaType
+import com.sakethh.linkora.domain.Result
+import com.sakethh.linkora.domain.Route
 import com.sakethh.linkora.domain.dto.AllTablesDTO
+import com.sakethh.linkora.domain.dto.DeleteEverythingDTO
 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.model.*
 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 kotlinx.serialization.json.encodeToJsonElement
 import org.jetbrains.exposed.sql.deleteAll
 import org.jetbrains.exposed.sql.selectAll
 import org.jetbrains.exposed.sql.transactions.transaction
+import java.time.Instant
 
 class SyncRepoImpl : SyncRepo {
     override suspend fun getTombstonesAfter(eventTimestamp: Long): List<Tombstone> {
@@ -121,17 +123,23 @@ class SyncRepoImpl : SyncRepo {
         )
     }
 
-    override suspend fun deleteEverything(): Result<Unit> {
+    override suspend fun deleteEverything(deleteEverythingDTO: DeleteEverythingDTO): Result<Unit> {
         return try {
+            val eventTimestamp = Instant.now().epochSecond
             transaction {
                 linkoraTables().forEach {
                     it.deleteAll()
                 }
             }
-            Result.success(Unit)
+            Result.Success(
+                response = Unit, webSocketEvent = WebSocketEvent(
+                    operation = Route.Sync.DELETE_EVERYTHING.name,
+                    payload = Json.encodeToJsonElement(deleteEverythingDTO.copy(eventTimestamp = eventTimestamp))
+                )
+            )
         } catch (e: Exception) {
             e.printStackTrace()
-            Result.failure(e)
+            Result.Failure(e)
         }
     }
 }

src/main/kotlin/com/sakethh/linkora/domain/dto/DeleteEverythingDTO.kt

@@ -0,0 +1,8 @@
+package com.sakethh.linkora.domain.dto
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class DeleteEverythingDTO(
+    val eventTimestamp: Long, val correlation: Correlation
+)

src/main/kotlin/com/sakethh/linkora/domain/repository/SyncRepo.kt

@@ -1,10 +1,12 @@
 package com.sakethh.linkora.domain.repository
 
+import com.sakethh.linkora.domain.Result
 import com.sakethh.linkora.domain.dto.AllTablesDTO
+import com.sakethh.linkora.domain.dto.DeleteEverythingDTO
 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>
+    suspend fun deleteEverything(deleteEverythingDTO: DeleteEverythingDTO): Result<Unit>
 }

src/main/kotlin/com/sakethh/linkora/presentation/routing/http/SyncRouting.kt

@@ -1,8 +1,10 @@
 package com.sakethh.linkora.presentation.routing.http
 
 import com.sakethh.linkora.Security
-import com.sakethh.linkora.domain.repository.SyncRepo
 import com.sakethh.linkora.domain.Route
+import com.sakethh.linkora.domain.dto.DeleteEverythingDTO
+import com.sakethh.linkora.domain.repository.SyncRepo
+import com.sakethh.linkora.utils.respondWithResult
 import io.ktor.http.*
 import io.ktor.server.application.*
 import io.ktor.server.auth.*
@@ -32,16 +34,8 @@ fun Application.syncRouting(syncRepo: SyncRepo) {
                 }
             }
 
-            get(Route.Sync.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()
-                }
+            post<DeleteEverythingDTO>(Route.Sync.DELETE_EVERYTHING.name) {
+                respondWithResult(syncRepo.deleteEverything(it))
             }
         }
     }