[feat] #62 separate s3 thumbnail upload with architecture

Author: lsakee

data/video/src/main/java/com/record/video/repository/UploadRepositoryImpl.kt

@@ -57,4 +57,18 @@ class UploadRepositoryImpl @Inject constructor(
                 }
             }
         }
+
+    override suspend fun uploadThumbnailToS3Bucket(url: String, file: File): Result<String> =
+    runCatching {
+        remoteUploadDataSource.uploadThumbnailToS3Bucket(url, file)
+    }.recoverCatching { exception ->
+        when (exception) {
+            is HttpException -> {
+                throw ApiError(exception.message())
+            }
+            else -> {
+                throw exception
+            }
+        }
+    }
 }

data/video/src/main/java/com/record/video/source/remote/RemoteUploadDataSource.kt

@@ -9,4 +9,5 @@ interface RemoteUploadDataSource {
     suspend fun getUploadUrl(): ResponseGetPresignedUrlDto
     suspend fun uploadRecord(requestPostVideoDto: RequestPostVideoDto)
     suspend fun uploadVideoToS3Bucket(url: String, file: File):String
+    suspend fun uploadThumbnailToS3Bucket(url: String, file: File):String
 }

domain/upload/src/main/java/com/record/upload/repository/UploadRepository.kt

@@ -8,5 +8,5 @@ interface UploadRepository {
     suspend fun getPresignedUrl(): Result<UploadInfo>
     suspend fun uploadRecord(videoInfo: VideoInfo): Result<Unit>
     suspend fun uploadVideoToS3Bucket(url: String, file: File): Result<String>
-
+    suspend fun uploadThumbnailToS3Bucket(url: String, file: File): Result<String>
 }

feature/upload/src/main/java/com/record/upload/UploadViewModel.kt

@@ -52,12 +52,11 @@ class UploadViewModel @Inject constructor(
             ).onSuccess {
                 a = removeQueryParameters(it)
                 Log.d("testUpload", "$a")
-                uploadFileToS3ThumbnailPresignedUrl(
-                    context,
+                uploadRepository.uploadThumbnailToS3Bucket(
                     uiState.value.thumbnailUrl,
                     file,
-                ) { success, message ->
-                    b = removeQueryParameters(message)
+                ) .onSuccess{
+                    b = removeQueryParameters(it)
                     Log.d("testUploadthumbnailUrl", "$b")
                     uploadRecord(a, b)
                 }

remote/video/build.gradle.kts

@@ -8,4 +8,5 @@ android {
 
 dependencies {
     implementation(projects.data.video)
+    implementation(projects.core.common)
 }

remote/video/src/main/java/com/record/video/datasource/RemoteUploadDataSourceImpl.kt

@@ -2,23 +2,23 @@ package com.record.video.datasource
 
 import android.content.Context
 import android.util.Log
+import com.record.common.util.getVideoFrameAt1Sec
 import com.record.video.api.BucketApi
 import com.record.video.api.UploadApi
 import com.record.video.model.remote.request.RequestPostVideoDto
 import com.record.video.model.remote.response.ResponseGetPresignedUrlDto
 import com.record.video.source.remote.RemoteUploadDataSource
+import dagger.hilt.android.qualifiers.ApplicationContext
 import okhttp3.MediaType.Companion.toMediaTypeOrNull
-import okhttp3.MultipartBody
 import okhttp3.RequestBody
-import okhttp3.RequestBody.Companion.toRequestBody
-import okhttp3.ResponseBody.Companion.toResponseBody
 import java.io.File
 import java.net.URL
 import javax.inject.Inject
 
 class RemoteUploadDataSourceImpl @Inject constructor(
     private val uploadApi: UploadApi,
     private val bucketApi: BucketApi,
+    @ApplicationContext private val context: Context
 ) : RemoteUploadDataSource {
     override suspend fun getUploadUrl(): ResponseGetPresignedUrlDto =
         uploadApi.getPresignedUploadUrl()
@@ -35,4 +35,16 @@ class RemoteUploadDataSourceImpl @Inject constructor(
         Log.d("testUrl","$url")
        return URL(url.protocol, url.host, url.port, url.path).toString()
     }
+
+    override suspend fun uploadThumbnailToS3Bucket(url: String, file: File): String {
+        val videoPath = file.absolutePath
+        val outputImagePath = File(context.cacheDir, file.name)
+        getVideoFrameAt1Sec(videoPath, outputImagePath.absolutePath)
+        val mediaType = "application/octet-stream".toMediaTypeOrNull()
+        val requestBody = RequestBody.create(mediaType, outputImagePath)
+        val url = URL(bucketApi.uploadVideoWithS3Video(url, requestBody).raw().request.url.toString())
+        Log.d("testUrl2","$url")
+        return URL(url.protocol, url.host, url.port, url.path).toString()
+
+    }
 }