Skip to content

Commit 6455427

Browse files
committed
feat: add tombstone logging for deleted duplicate links
1 parent b3b4e81 commit 6455427

1 file changed

Lines changed: 9 additions & 2 deletions

File tree

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

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,12 @@ import com.sakethh.linkora.utils.Result
1515
import kotlinx.serialization.encodeToString
1616
import kotlinx.serialization.json.Json
1717
import kotlinx.serialization.json.encodeToJsonElement
18-
import org.jetbrains.exposed.sql.*
1918
import org.jetbrains.exposed.sql.SqlExpressionBuilder.eq
20-
import org.jetbrains.exposed.sql.transactions.TransactionManager
19+
import org.jetbrains.exposed.sql.and
20+
import org.jetbrains.exposed.sql.deleteWhere
21+
import org.jetbrains.exposed.sql.insertAndGetId
2122
import org.jetbrains.exposed.sql.transactions.transaction
23+
import org.jetbrains.exposed.sql.update
2224
import java.time.Instant
2325

2426
class LinksImplementation : LinksRepository {
@@ -395,6 +397,11 @@ class LinksImplementation : LinksRepository {
395397
deleteDuplicateLinksDTO.linkIds.toString().substringBefore("]").substringAfter("[").trim()
396398
})"
397399
)
400+
TombStoneHelper.insert(
401+
payload = Json.encodeToString(deleteDuplicateLinksDTO),
402+
operation = LinkRoute.DELETE_DUPLICATE_LINKS.name,
403+
deletedAt = eventTimestamp
404+
)
398405
}
399406
Result.Success(
400407
response = TimeStampBasedResponse(

0 commit comments

Comments
 (0)