|
|
|
@ -2,36 +2,43 @@ package io.legado.app.ui.book.remote |
|
|
|
|
|
|
|
|
|
import android.app.Application |
|
|
|
|
import android.util.Log |
|
|
|
|
import android.widget.Toast |
|
|
|
|
import io.legado.app.base.BaseViewModel |
|
|
|
|
import io.legado.app.utils.FileDoc |
|
|
|
|
import kotlinx.coroutines.Dispatchers |
|
|
|
|
import io.legado.app.constant.PreferKey |
|
|
|
|
import io.legado.app.lib.webdav.Authorization |
|
|
|
|
import io.legado.app.lib.webdav.WebDav |
|
|
|
|
import io.legado.app.utils.FileUtils |
|
|
|
|
import io.legado.app.utils.exists |
|
|
|
|
import io.legado.app.utils.externalFiles |
|
|
|
|
import io.legado.app.utils.getPrefString |
|
|
|
|
import kotlinx.coroutines.* |
|
|
|
|
import kotlinx.coroutines.channels.awaitClose |
|
|
|
|
import kotlinx.coroutines.flow.callbackFlow |
|
|
|
|
import kotlinx.coroutines.flow.flowOn |
|
|
|
|
import kotlinx.coroutines.flow.map |
|
|
|
|
import kotlinx.coroutines.withContext |
|
|
|
|
import splitties.init.appCtx |
|
|
|
|
import java.io.File |
|
|
|
|
import java.nio.charset.Charset |
|
|
|
|
import java.util.* |
|
|
|
|
import kotlin.reflect.typeOf |
|
|
|
|
|
|
|
|
|
class RemoteBookViewModel(application: Application): BaseViewModel(application){ |
|
|
|
|
|
|
|
|
|
private val remoteBookFolderName = "book_remote" |
|
|
|
|
private var dataCallback : DataCallback? = null |
|
|
|
|
var dataFlowStart: (() -> Unit)? = null |
|
|
|
|
val dataFlow = callbackFlow<List<String>> { |
|
|
|
|
private var authorization: Authorization? = null |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
val dataFlow = callbackFlow<List<RemoteBook>> { |
|
|
|
|
|
|
|
|
|
val list = Collections.synchronizedList(ArrayList<String>()) |
|
|
|
|
val list = Collections.synchronizedList(ArrayList<RemoteBook>()) |
|
|
|
|
|
|
|
|
|
dataCallback = object : DataCallback { |
|
|
|
|
|
|
|
|
|
override fun setItems(remoteFiles: List<String>) { |
|
|
|
|
override fun setItems(remoteFiles: List<RemoteBook>) { |
|
|
|
|
list.clear() |
|
|
|
|
list.addAll(remoteFiles) |
|
|
|
|
Log.e("TAG", ": 1", ) |
|
|
|
|
trySend(list) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
override fun addItems(remoteFiles: List<String>) { |
|
|
|
|
override fun addItems(remoteFiles: List<RemoteBook>) { |
|
|
|
|
list.addAll(remoteFiles) |
|
|
|
|
trySend(list) |
|
|
|
|
} |
|
|
|
@ -41,28 +48,88 @@ class RemoteBookViewModel(application: Application): BaseViewModel(application){ |
|
|
|
|
trySend(emptyList()) |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// withContext(Dispatchers.Main) { |
|
|
|
|
// dataFlowStart?.invoke() |
|
|
|
|
// } |
|
|
|
|
|
|
|
|
|
awaitClose { |
|
|
|
|
dataCallback = null |
|
|
|
|
// dataCallback = null |
|
|
|
|
} |
|
|
|
|
}.flowOn(Dispatchers.Main) |
|
|
|
|
}.flowOn(Dispatchers.IO) |
|
|
|
|
|
|
|
|
|
fun loadRemoteBookList() { |
|
|
|
|
Log.e("TAG", dataCallback.toString(), ) |
|
|
|
|
dataCallback?.setItems(listOf("1", "2", "3")) |
|
|
|
|
execute { |
|
|
|
|
dataCallback?.clear() |
|
|
|
|
kotlin.runCatching { |
|
|
|
|
authorization = null |
|
|
|
|
val account = appCtx.getPrefString(PreferKey.webDavAccount) |
|
|
|
|
val password = appCtx.getPrefString(PreferKey.webDavPassword) |
|
|
|
|
if (!account.isNullOrBlank() && !password.isNullOrBlank()) { |
|
|
|
|
val mAuthorization = Authorization(account, password) |
|
|
|
|
authorization = mAuthorization |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
authorization?.let { it -> |
|
|
|
|
val remoteWebDavFileList = WebDav("http://txc.qianfanguojin.top/",it).listFiles() |
|
|
|
|
val remoteList = remoteWebDavFileList.map { |
|
|
|
|
RemoteBook(it.displayName,it.urlName,it.size,"epub",it.lastModify) |
|
|
|
|
} |
|
|
|
|
dataCallback?.setItems(remoteList) |
|
|
|
|
} |
|
|
|
|
// dataCallback?.setItems() |
|
|
|
|
} |
|
|
|
|
// dataCallback?.setItems(listOf("1", "2", "3")) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
fun downloadRemoteBook(urlName: String) { |
|
|
|
|
execute { |
|
|
|
|
// kotlin.runCatching { |
|
|
|
|
// val remoteWebDavFile = WebDav("http://txc.qianfanguojin.top/",authorization!!).getFile(url) |
|
|
|
|
// val remoteBook = RemoteBook(remoteWebDavFile.displayName,remoteWebDavFile.urlName,remoteWebDavFile.size,"epub",remoteWebDavFile.lastModify) |
|
|
|
|
// dataCallback?.addItems(listOf(remoteBook)) |
|
|
|
|
// } |
|
|
|
|
|
|
|
|
|
kotlin.runCatching { |
|
|
|
|
authorization = null |
|
|
|
|
val account = appCtx.getPrefString(PreferKey.webDavAccount) |
|
|
|
|
val password = appCtx.getPrefString(PreferKey.webDavPassword) |
|
|
|
|
if (!account.isNullOrBlank() && !password.isNullOrBlank()) { |
|
|
|
|
val mAuthorization = Authorization(account, password) |
|
|
|
|
authorization = mAuthorization |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
authorization?.let { it -> |
|
|
|
|
Log.e("TAG", "downloadRemoteBook: 1", ) |
|
|
|
|
val saveFolder = "${appCtx.externalFiles.absolutePath}${File.separator}${remoteBookFolderName}" |
|
|
|
|
FileUtils.createFolderIfNotExist(saveFolder).run{ |
|
|
|
|
|
|
|
|
|
// Log.e("TAG", "downloadRemoteBook: 2 ${appCtx.externalFiles.absoluteFile}", ) |
|
|
|
|
val trueCodeURLName = String(urlName.toByteArray(Charset.forName("GBK")), Charset.forName("UTF-8")) |
|
|
|
|
withTimeout(15000L) { |
|
|
|
|
val webdav = WebDav("http://txc.qianfanguojin.top${trueCodeURLName}", it) |
|
|
|
|
webdav.downloadTo("${saveFolder}${trueCodeURLName}", true).apply { |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
interface DataCallback { |
|
|
|
|
|
|
|
|
|
fun setItems(remoteFiles: List<String>) |
|
|
|
|
fun setItems(remoteFiles: List<RemoteBook>) |
|
|
|
|
|
|
|
|
|
fun addItems(remoteFiles: List<String>) |
|
|
|
|
fun addItems(remoteFiles: List<RemoteBook>) |
|
|
|
|
|
|
|
|
|
fun clear() |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
data class RemoteBook( |
|
|
|
|
val name: String, |
|
|
|
|
val url: String, |
|
|
|
|
val size: Long, |
|
|
|
|
val contentType: String, |
|
|
|
|
val lastModify: Long |
|
|
|
|
) |