feat: implement duplicate link deletion

Author: sakethpathike

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

@@ -15,12 +15,10 @@ import com.sakethh.linkora.utils.Result
 import kotlinx.serialization.encodeToString
 import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.encodeToJsonElement
+import org.jetbrains.exposed.sql.*
 import org.jetbrains.exposed.sql.SqlExpressionBuilder.eq
-import org.jetbrains.exposed.sql.and
-import org.jetbrains.exposed.sql.deleteWhere
-import org.jetbrains.exposed.sql.insertAndGetId
+import org.jetbrains.exposed.sql.transactions.TransactionManager
 import org.jetbrains.exposed.sql.transactions.transaction
-import org.jetbrains.exposed.sql.update
 import java.time.Instant
 
 class LinksImplementation : LinksRepository {
@@ -387,4 +385,27 @@ class LinksImplementation : LinksRepository {
             Result.Failure(e)
         }
     }
+
+    override suspend fun deleteDuplicateLinks(deleteDuplicateLinksDTO: DeleteDuplicateLinksDTO): Result<TimeStampBasedResponse> {
+        return try {
+            val eventTimestamp = Instant.now().epochSecond
+            transaction {
+                this.exec(
+                    "DELETE FROM links_table WHERE id IN (${
+                        deleteDuplicateLinksDTO.linkIds.toString().substringBefore("]").substringAfter("[").trim()
+                    })"
+                )
+            }
+            Result.Success(
+                response = TimeStampBasedResponse(
+                    eventTimestamp = eventTimestamp, message = "Deleted Duplicate links."
+                ), webSocketEvent = WebSocketEvent(
+                    operation = LinkRoute.DELETE_DUPLICATE_LINKS.name,
+                    payload = Json.encodeToJsonElement(deleteDuplicateLinksDTO.copy(eventTimestamp = eventTimestamp))
+                )
+            )
+        } catch (e: Exception) {
+            Result.Failure(e)
+        }
+    }
 }

src/main/kotlin/com/sakethh/linkora/domain/dto/link/DeleteDuplicateLinksDTO.kt

@@ -0,0 +1,9 @@
+package com.sakethh.linkora.domain.dto.link
+
+import com.sakethh.linkora.domain.dto.Correlation
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class DeleteDuplicateLinksDTO(
+    val linkIds: List<Long>, val correlation: Correlation, val eventTimestamp: Long
+)

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

@@ -18,4 +18,5 @@ interface LinksRepository {
     suspend fun markALinkAsImp(idBasedDTO: IDBasedDTO): Result<TimeStampBasedResponse>
     suspend fun markALinkAsNonImp(idBasedDTO: IDBasedDTO): Result<TimeStampBasedResponse>
     suspend fun updateLink(linkDTO: LinkDTO): Result<TimeStampBasedResponse>
+    suspend fun deleteDuplicateLinks(deleteDuplicateLinksDTO: DeleteDuplicateLinksDTO): Result<TimeStampBasedResponse>
 }

src/main/kotlin/com/sakethh/linkora/domain/routes/LinkRoute.kt

@@ -13,5 +13,6 @@ enum class LinkRoute {
     UNARCHIVE_LINK,
     MARK_AS_IMP,
     UNMARK_AS_IMP,
-    UPDATE_LINK
+    UPDATE_LINK,
+    DELETE_DUPLICATE_LINKS
 }

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

@@ -64,6 +64,10 @@ fun Application.linksRouting(linksRepository: LinksRepository) {
             post<LinkDTO>(LinkRoute.UPDATE_LINK.name) {
                 respondWithResult(linksRepository.updateLink(it))
             }
+
+            post<DeleteDuplicateLinksDTO>(LinkRoute.DELETE_DUPLICATE_LINKS.name) {
+                respondWithResult(linksRepository.deleteDuplicateLinks(it))
+            }
         }
     }
 }