Skip to content

Commit 45c095f

Browse files
committed
fix: send eventTimestamp via socket when copying items
1 parent ab6dcc0 commit 45c095f

3 files changed

Lines changed: 17 additions & 5 deletions

File tree

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

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ class MultiActionRepoImpl(
168168
}
169169
}
170170

171-
override suspend fun copyMultipleItems(copyItemsDTO: CopyItemsDTO): Result<CopyItemsResponseDTO> {
171+
override suspend fun copyMultipleItems(copyItemsDTO: CopyItemsDTO): Result<CopyItemsHTTPResponseDTO> {
172172
return try {
173173
val eventTimestamp = Instant.now().epochSecond
174174
lateinit var linkIds: List<Long>
@@ -290,13 +290,20 @@ class MultiActionRepoImpl(
290290

291291
}.let {
292292
Result.Success(
293-
response = CopyItemsResponseDTO(
293+
response = CopyItemsHTTPResponseDTO(
294294
folders = copiedFolderResponse.toList(), linkIds = copyItemsDTO.linkIds.run {
295295
this.toList().mapIndexed { index, pair ->
296296
pair.first to linkIds[index]
297297
}.toMap()
298298
}, correlation = copyItemsDTO.correlation, eventTimestamp = eventTimestamp
299-
), webSocketEvent = null
299+
), webSocketEvent = WebSocketEvent(
300+
operation = Route.MultiAction.COPY_EXISTING_ITEMS.name, payload = Json.encodeToJsonElement(
301+
CopyItemsSocketResponseDTO(
302+
eventTimestamp = eventTimestamp,
303+
correlation = copyItemsDTO.correlation
304+
)
305+
)
306+
)
300307
)
301308
}
302309
} catch (e: Exception) {

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package com.sakethh.linkora.domain.dto
33
import kotlinx.serialization.Serializable
44

55
@Serializable
6-
data class CopyItemsResponseDTO(
6+
data class CopyItemsHTTPResponseDTO(
77
val folders: List<CopiedFolderResponse>,
88
val linkIds: Map<Long, Long>,
99
val correlation: Correlation,
@@ -13,4 +13,9 @@ data class CopyItemsResponseDTO(
1313
@Serializable
1414
data class CopiedFolderResponse(
1515
val currentFolder: CurrentFolder, val links: List<FolderLink>
16+
)
17+
18+
@Serializable
19+
data class CopyItemsSocketResponseDTO(
20+
val eventTimestamp: Long, val correlation: Correlation
1621
)

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,5 +10,5 @@ interface MultiActionRepo {
1010
suspend fun markItemsAsRegular(markItemsRegularDTO: MarkItemsRegularDTO): Result<TimeStampBasedResponse>
1111
suspend fun deleteMultipleItems(deleteMultipleItemsDTO: DeleteMultipleItemsDTO): Result<TimeStampBasedResponse>
1212
suspend fun moveMultipleItems(moveItemsDTO: MoveItemsDTO): Result<TimeStampBasedResponse>
13-
suspend fun copyMultipleItems(copyItemsDTO: CopyItemsDTO): Result<CopyItemsResponseDTO>
13+
suspend fun copyMultipleItems(copyItemsDTO: CopyItemsDTO): Result<CopyItemsHTTPResponseDTO>
1414
}

0 commit comments

Comments
 (0)