Merge pull request #71 from Infomaniak/fix-track-upload

fix: Make track upload as suspend callback
Infomaniak · Oct 31, 2024 · 1f8aae0 · 1f8aae0
2 parents 8916777 + 6ada1d1
commit 1f8aae0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...rc/commonMain/kotlin/com/infomaniak/multiplatform_swisstransfer/managers/UploadManager.kt b/...rc/commonMain/kotlin/com/infomaniak/multiplatform_swisstransfer/managers/UploadManager.kt
@@ -181,7 +181,7 @@ class UploadManager(
         chunkIndex: Int,
         isLastChunk: Boolean,
         data: ByteArray,
-        onUpload: (bytesSentTotal: Long, chunkSize: Long) -> Unit,
+        onUpload: suspend (bytesSentTotal: Long, chunkSize: Long) -> Unit,
     ): Unit = withContext(Dispatchers.IO) {
         val uploadSession = uploadController.getUploadByUUID(uuid)
             ?: throw NotFoundException("${UploadSession::class.simpleName} not found in DB with uuid = $uuid")

diff --git a/...otlin/com/infomaniak/multiplatform_swisstransfer/network/repositories/UploadRepository.kt b/...otlin/com/infomaniak/multiplatform_swisstransfer/network/repositories/UploadRepository.kt
@@ -110,7 +110,7 @@ class UploadRepository internal constructor(private val uploadRequest: UploadReq
         chunkIndex: Int,
         isLastChunk: Boolean,
         data: ByteArray,
-        onUpload: (bytesSentTotal: Long, chunkSize: Long) -> Unit,
+        onUpload: suspend (bytesSentTotal: Long, chunkSize: Long) -> Unit,
     ): Boolean {
         return uploadRequest.uploadChunk(uploadHost, containerUUID, fileUUID, chunkIndex, isLastChunk, data, onUpload)
     }

diff --git a/...nMain/kotlin/com/infomaniak/multiplatform_swisstransfer/network/requests/UploadRequest.kt b/...nMain/kotlin/com/infomaniak/multiplatform_swisstransfer/network/requests/UploadRequest.kt
@@ -58,7 +58,7 @@ internal class UploadRequest(json: Json, httpClient: HttpClient) : BaseRequest(j
         chunkIndex: Int,
         isLastChunk: Boolean,
         data: ByteArray,
-        onUpload: (bytesSentTotal: Long, chunkSize: Long) -> Unit,
+        onUpload: suspend (bytesSentTotal: Long, chunkSize: Long) -> Unit,
     ): Boolean {
         val httpResponse = httpClient.post(
             urlString = SharedApiRoutes.uploadChunk(uploadHost, containerUUID, fileUUID, chunkIndex, isLastChunk)