[feat] #62 upload record

Author: lsakee

data/video/src/main/java/com/record/video/model/remote/request/RequestPostVideoDto.kt

@@ -12,7 +12,7 @@ data class RequestPostVideoDto(
     @SerialName("fileUrl")
     val fileUrl: FileUrl,
     @SerialName("keywords")
-    val keywords: List<String>,
+    val keywords: String,
     @SerialName("location")
     val location: String,
 )

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

@@ -40,7 +40,6 @@ class UploadRepositoryImpl @Inject constructor(
             is HttpException -> {
                 throw ApiError(exception.message())
             }
-
             else -> {
                 throw exception
             }

domain/upload/src/main/java/com/record/upload/model/VideoInfo.kt

@@ -3,7 +3,7 @@ package com.record.upload.model
 data class VideoInfo(
     val location: String,
     val content: String,
-    val keywords: List<String>,
+    val keywords: String,
     val videoUrl: String,
     val previewUrl: String,
 )

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

@@ -1,16 +1,19 @@
 package com.record.upload
 
 import android.content.Context
+import android.util.Base64
 import android.util.Log
 import androidx.lifecycle.viewModelScope
 import com.record.ui.base.BaseViewModel
 import com.record.upload.extension.GalleryVideo
 import com.record.upload.extension.uploadFileToS3PresignedUrl
 import com.record.upload.extension.uploadFileToS3ThumbnailPresignedUrl
+import com.record.upload.model.VideoInfo
 import com.record.upload.repository.UploadRepository
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.launch
 import java.io.File
+import java.net.URLDecoder
 import javax.inject.Inject
 
 @HiltViewModel
@@ -37,18 +40,48 @@ class UploadViewModel @Inject constructor(
         }
     }
 
+    private fun decodeBase64(encodedString: String): String? {
+        val decodedBytes = Base64.decode(encodedString, Base64.DEFAULT)
+        val decodedString = String(decodedBytes, Charsets.UTF_8)
+        return URLDecoder.decode(decodedString, "UTF-8")
+    }
+
     fun uploadVideoToS3Bucket(context: Context, file: File) =
         viewModelScope.launch {
             uploadFileToS3PresignedUrl(uiState.value.bucketUrl, file) { success, message ->
                 println(message)
                 Log.d("messageFile", "$message ")
             }
-            uploadFileToS3ThumbnailPresignedUrl(context, uiState.value.thumbnailUrl, file) { success, message ->
+            uploadFileToS3ThumbnailPresignedUrl(
+                context,
+                uiState.value.thumbnailUrl,
+                file,
+            ) { success, message ->
                 println(message)
                 Log.d("messageThumbnail", "$message ")
             }
+            uploadRecord()
         }
 
+    fun uploadRecord() =
+        viewModelScope.launch {
+            uploadRepository.uploadRecord(
+                videoInfo = VideoInfo(
+                    location = "test",
+                    content = "test",
+                    keywords = encodingString("감각적인,강렬한,귀여운").trim(),
+                    videoUrl = "https://recordy-bucket.s3.ap-northeast-2.amazonaws.com/videos/40683dd4-52a3-4bb1-9833-7fb2256285e9.mp4",
+                    previewUrl = "https://recordy-bucket.s3.ap-northeast-2.amazonaws.com/thumbnails/0ed9dfc0-8e41-491f-b4fb-2d7ea9a5d5e3.jpeg",
+                ),
+            )
+        }
+
+    private fun encodingString(contentValue: String): String {
+        val bytes = contentValue.toByteArray(Charsets.UTF_8)
+        val encodedString = Base64.encodeToString(bytes, Base64.DEFAULT)
+        return encodedString
+    }
+
     fun setVideo(video: GalleryVideo) = intent {
         copy(video = video)
     }

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

@@ -82,6 +82,7 @@ fun VideoPickerRoute(
     LaunchedEffectWithLifecycle {
         viewModel.getPresignedUrl()
         viewModel.sideEffect.collectLatest { }
+        viewModel.uploadRecord()
     }
 
     VideoPickerScreen(

feature/upload/src/main/java/com/record/upload/extension/UploadExtension.kt

@@ -175,25 +175,26 @@ fun uploadFileToS3PresignedUrl(presignedUrl: String, file: File, callback: (Bool
         .url(presignedUrl)
         .put(requestBody)
         .build()
+    client.newCall(request).enqueue(
+        object : okhttp3.Callback {
+            override fun onFailure(call: okhttp3.Call, e: IOException) {
+                callback(false, "Upload failed: ${e.message}")
+            }
 
-    client.newCall(request).enqueue(object : okhttp3.Callback {
-        override fun onFailure(call: okhttp3.Call, e: IOException) {
-            callback(false, "Upload failed: ${e.message}")
-        }
-
-        override fun onResponse(call: okhttp3.Call, response: okhttp3.Response) {
-            if (response.isSuccessful) {
-                callback(true, "Upload successful")
-            } else {
-                callback(false, "Upload failed: ${response.message}")
+            override fun onResponse(call: okhttp3.Call, response: okhttp3.Response) {
+                if (response.isSuccessful) {
+                    callback(true, "Upload successful")
+                } else {
+                    callback(false, "Upload failed: ${response.message}")
+                }
             }
-        }
-    },)
+        },
+    )
 }
 
 fun uploadFileToS3ThumbnailPresignedUrl(context: Context, presignedUrl: String, file: File, callback: (Boolean, String) -> Unit) {
     val videoPath = file.absolutePath
-    val outputImagePath = File(context.cacheDir, "${ file.name }.jpg")
+    val outputImagePath = File(context.cacheDir, file.name)
     getVideoFrameAt1Sec(videoPath, outputImagePath.absolutePath)
     val client = OkHttpClient()
     val mediaType = "application/octet-stream".toMediaTypeOrNull()
@@ -203,26 +204,27 @@ fun uploadFileToS3ThumbnailPresignedUrl(context: Context, presignedUrl: String,
         .url(presignedUrl)
         .put(requestBody)
         .build()
+    client.newCall(request).enqueue(
+        object : okhttp3.Callback {
+            override fun onFailure(call: okhttp3.Call, e: IOException) {
+                callback(false, "Upload failed: ${e.message}")
+            }
 
-    client.newCall(request).enqueue(object : okhttp3.Callback {
-        override fun onFailure(call: okhttp3.Call, e: IOException) {
-            callback(false, "Upload failed: ${e.message}")
-        }
-
-        override fun onResponse(call: okhttp3.Call, response: okhttp3.Response) {
-            if (response.isSuccessful) {
-                callback(true, "Upload successful")
-            } else {
-                callback(false, "Upload failed: ${response.message}")
+            override fun onResponse(call: okhttp3.Call, response: okhttp3.Response) {
+                if (response.isSuccessful) {
+                    callback(true, "Upload successful")
+                } else {
+                    callback(false, "Upload failed: ${response.message}")
+                }
             }
-        }
-    },)
+        },
+    )
 }
 fun getVideoFrameAt1Sec(videoPath: String, outputImagePath: String) {
     val retriever = MediaMetadataRetriever()
     try {
         retriever.setDataSource(videoPath)
-        val timeUs = 1 * 1000000 // 1초를 마이크로초로 변환
+        val timeUs = 1 * 1000000
         val bitmap: Bitmap? = retriever.getFrameAtTime(timeUs.toLong(), MediaMetadataRetriever.OPTION_CLOSEST_SYNC)
 
         if (bitmap != null) {