gronod/talk-android
1
0
Fork 1
mirror of https://github.com/nextcloud/talk-android synced 2025-06-19 11:39:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

uploading file works for first time users

Browse Source 
Signed-off-by: sowjanyakch <sowjanya.kch@gmail.com>
This commit is contained in:
sowjanyakch 2025-02-26 19:43:04 +01:00 committed by Marcel Hibbe
parent 2081a501a4
commit c0376c8eed
No known key found for this signature in database
GPG Key ID: C793F8B59F43CE7B
2 changed files with 34 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
app/src/main/java/com/nextcloud/talk/upload/normal/FileUploader.kt
View File

@ -41,7 +41,8 @@ class FileUploader(
) {
private var okHttpClientNoRedirects: OkHttpClient? = null
private var uploadFileUri:String = ""
private var okhttpClient:OkHttpClient = okHttpClient
init {
initHttpClient(okHttpClient, currentUser)
@ -54,39 +55,40 @@ class FileUploader(
createRequestBody(sourceFileUri)
)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()).map { response ->
.observeOn(AndroidSchedulers.mainThread())
.flatMap { response ->
if (response.isSuccessful) {
ShareOperationWorker.shareFile(
roomToken,
currentUser,
remotePath,
metaData
)
ShareOperationWorker.shareFile(roomToken, currentUser, remotePath, metaData)
FileUtils.copyFileToCache(context, sourceFileUri, fileName)
true
Observable.just(true)
} else {
if (response.code() == 404 || response.code() == 409) {
uploadFileUri = ApiUtils.getUrlForFile(
currentUser.baseUrl!!, currentUser.userId!!,
)
if (response.code() == HTTP_CODE_NOT_FOUND || response.code() == HTTP_CODE_CONFLICT) {
createDavResource(sourceFileUri, fileName, remotePath, metaData)
} else {
Observable.just(false)
}
}
}
}
val davResource =
DavResource(
okHttpClientNoRedirects!!,
uploadFileUri.toHttpUrlOrNull()!!
)
private fun createDavResource(sourceFileUri: Uri, fileName: String, remotePath: String, metaData: String?): Observable<Boolean> {
return Observable.fromCallable {
val userFileUploadPath = ApiUtils.userFileUploadPath(currentUser.baseUrl!!, currentUser.userId!!)
val userTalkAttachmentsUploadPath = ApiUtils.userTalkAttachmentsUploadPath(currentUser.baseUrl!!, currentUser.userId!!)
var davResource = DavResource(okHttpClientNoRedirects!!, userFileUploadPath.toHttpUrlOrNull()!!)
createFolder(davResource)
val value: Observable<Boolean> = upload(sourceFileUri, remotePath, fileName, metaData)
value.blockingFirst()
} else {
false
}
}
initHttpClient(okHttpClient = okhttpClient, currentUser)
davResource = DavResource(okHttpClientNoRedirects!!, userTalkAttachmentsUploadPath.toHttpUrlOrNull()!!)
createFolder(davResource)
true
}
.subscribeOn(Schedulers.io())
.flatMap { upload(sourceFileUri, fileName, remotePath, metaData) }
}
@Suppress("Detekt.TooGenericExceptionCaught")
private fun createRequestBody(sourceFileUri: Uri): RequestBody? {
var requestBody: RequestBody? = null
@ -146,5 +148,7 @@ class FileUploader(
companion object {
private val TAG = FileUploader::class.simpleName
private const val METHOD_NOT_ALLOWED_CODE: Int = 405
private const val HTTP_CODE_NOT_FOUND:Int = 404
private const val HTTP_CODE_CONFLICT : Int = 409
}
}

6
app/src/main/java/com/nextcloud/talk/utils/ApiUtils.kt
View File

@ -459,7 +459,11 @@ object ApiUtils {
return "$baseUrl/remote.php/dav/files/$user/$remotePath"
}
fun getUrlForFile(baseUrl: String, user: String): String {
fun userFileUploadPath(baseUrl: String, user: String): String {
return "$baseUrl/remote.php/dav/files/$user"
}
fun userTalkAttachmentsUploadPath(baseUrl: String, user: String): String {
return "$baseUrl/remote.php/dav/files/$user/Talk"
}