diff --git a/app/src/main/java/io/legado/app/App.kt b/app/src/main/java/io/legado/app/App.kt index 7fdab716d..6b48a7499 100644 --- a/app/src/main/java/io/legado/app/App.kt +++ b/app/src/main/java/io/legado/app/App.kt @@ -9,6 +9,7 @@ import android.provider.Settings import androidx.appcompat.app.AppCompatDelegate import androidx.multidex.MultiDexApplication import com.jeremyliao.liveeventbus.LiveEventBus +import io.legado.app.constant.AppConst import io.legado.app.constant.AppConst.channelIdDownload import io.legado.app.constant.AppConst.channelIdReadAloud import io.legado.app.constant.AppConst.channelIdWeb @@ -47,6 +48,9 @@ class App : MultiDexApplication() { LanguageUtils.setConfiguration(this) db = AppDatabase.createDatabase(INSTANCE) RxHttp.init(HttpHelper.client, BuildConfig.DEBUG) + RxHttp.setOnParamAssembly { + it.addHeader(AppConst.UA_NAME, AppConfig.userAgent) + } packageManager.getPackageInfo(packageName, 0)?.let { versionCode = it.versionCode versionName = it.versionName diff --git a/app/src/main/java/io/legado/app/help/BookHelp.kt b/app/src/main/java/io/legado/app/help/BookHelp.kt index febf55a12..6ae431662 100644 --- a/app/src/main/java/io/legado/app/help/BookHelp.kt +++ b/app/src/main/java/io/legado/app/help/BookHelp.kt @@ -112,7 +112,7 @@ object BookHelp { downloadImages.add(src) val analyzeUrl = AnalyzeUrl(src) try { - analyzeUrl.getResponseBytes(book.origin)?.let { + analyzeUrl.getByteArray(book.origin).let { FileUtils.createFileIfNotExist( downloadDir, cacheFolderName, diff --git a/app/src/main/java/io/legado/app/help/JsExtensions.kt b/app/src/main/java/io/legado/app/help/JsExtensions.kt index 9810228fe..9629e3efe 100644 --- a/app/src/main/java/io/legado/app/help/JsExtensions.kt +++ b/app/src/main/java/io/legado/app/help/JsExtensions.kt @@ -6,7 +6,6 @@ import androidx.annotation.Keep import io.legado.app.App import io.legado.app.constant.AppConst.dateFormat import io.legado.app.help.http.CookieStore -import io.legado.app.help.http.HttpHelper import io.legado.app.help.http.SSLHelper import io.legado.app.model.Debug import io.legado.app.model.analyzeRule.AnalyzeUrl @@ -15,6 +14,8 @@ import io.legado.app.utils.* import kotlinx.coroutines.runBlocking import org.jsoup.Connection import org.jsoup.Jsoup +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toByteArray import java.io.File import java.net.URLEncoder import java.nio.charset.Charset @@ -250,8 +251,8 @@ interface JsExtensions { str.isAbsUrl() -> runBlocking { var x = CacheManager.getByteArray(key) if (x == null) { - x = HttpHelper.simpleGetBytesAsync(str) - x?.let { + x = RxHttp.get(str).toByteArray().await() + x.let { CacheManager.put(key, it) } } diff --git a/app/src/main/java/io/legado/app/help/http/ByteParser.kt b/app/src/main/java/io/legado/app/help/http/ByteParser.kt new file mode 100644 index 000000000..3d466214b --- /dev/null +++ b/app/src/main/java/io/legado/app/help/http/ByteParser.kt @@ -0,0 +1,13 @@ +package io.legado.app.help.http + +import okhttp3.Response +import rxhttp.wrapper.annotation.Parser + +@Parser(name = "ByteArray") +class ByteParser : rxhttp.wrapper.parse.Parser { + + override fun onParse(response: Response): ByteArray { + return response.body()!!.bytes() + } + +} \ No newline at end of file diff --git a/app/src/main/java/io/legado/app/help/http/HttpHelper.kt b/app/src/main/java/io/legado/app/help/http/HttpHelper.kt index a355b6f13..49bb0d52f 100644 --- a/app/src/main/java/io/legado/app/help/http/HttpHelper.kt +++ b/app/src/main/java/io/legado/app/help/http/HttpHelper.kt @@ -1,14 +1,8 @@ package io.legado.app.help.http -import io.legado.app.constant.AppConst -import io.legado.app.help.AppConfig -import io.legado.app.help.http.api.HttpGetApi -import io.legado.app.utils.NetworkUtils import kotlinx.coroutines.suspendCancellableCoroutine import okhttp3.* import retrofit2.Retrofit -import rxhttp.wrapper.param.RxHttp -import rxhttp.wrapper.param.toText import java.net.InetSocketAddress import java.net.Proxy import java.util.concurrent.TimeUnit @@ -41,72 +35,48 @@ object HttpHelper { builder.build() } - suspend fun simpleGetAsync(url: String): String { - val str = RxHttp.get(url) - .addHeader(AppConst.UA_NAME, AppConfig.userAgent) - .toText() - return str.await() - } - - suspend fun simpleGetBytesAsync(url: String): ByteArray? { - NetworkUtils.getBaseUrl(url)?.let { baseUrl -> - return getByteRetrofit(baseUrl) - .create(HttpGetApi::class.java) - .getMapByteAsync(url, mapOf(), mapOf(Pair(AppConst.UA_NAME, AppConfig.userAgent))) - .body() - } - return null - } - inline fun getApiService( baseUrl: String, encode: String? = null, proxy: String? = null ): T { - return if (proxy.isNullOrEmpty()) { - getRetrofit(baseUrl, encode).create(T::class.java) - } else { - getRetrofitWithProxy(baseUrl, encode, proxy).create(T::class.java) - } - } - - inline fun getBytesApiService(baseUrl: String): T { - return getByteRetrofit(baseUrl).create(T::class.java) + return getRetrofit(baseUrl, encode, proxy).create(T::class.java) } - fun getRetrofit(baseUrl: String, encode: String? = null): Retrofit { + fun getRetrofit( + baseUrl: String, + encode: String? = null, + proxy: String? = null + ): Retrofit { return Retrofit.Builder().baseUrl(baseUrl) //增加返回值为字符串的支持(以实体类返回) .addConverterFactory(EncodeConverter(encode)) - .client(client) + .client(getProxyClient(proxy)) .build() } - fun getRetrofitWithProxy( - baseUrl: String, - encode: String? = null, - proxy: String? = null - ): Retrofit { + fun getProxyClient(proxy: String? = null): OkHttpClient { + if (proxy.isNullOrBlank()) { + return client + } val r = Regex("(http|socks4|socks5)://(.*):(\\d{2,5})(@.*@.*)?") - val ms = proxy?.let { r.findAll(it) } - val group = ms?.first() - var type = "direct" //直接连接 - var host = "127.0.0.1" //代理服务器hostname - var port = 1080 //代理服务器port + val ms = r.findAll(proxy) + val group = ms.first() + val type: String //直接连接 + val host: String //代理服务器hostname + val port: Int //代理服务器port var username = "" //代理服务器验证用户名 var password = "" //代理服务器验证密码 - if (group != null) { - type = if (group.groupValues[1] == "http") { - "http" - } else { - "socks" - } - host = group.groupValues[2] - port = group.groupValues[3].toInt() - if (group.groupValues[4] != "") { - username = group.groupValues[4].split("@")[1] - password = group.groupValues[4].split("@")[2] - } + type = if (group.groupValues[1] == "http") { + "http" + } else { + "socks" + } + host = group.groupValues[2] + port = group.groupValues[3].toInt() + if (group.groupValues[4] != "") { + username = group.groupValues[4].split("@")[1] + password = group.groupValues[4].split("@")[2] } val builder = client.newBuilder() if (type != "direct" && host != "") { @@ -125,18 +95,7 @@ object HttpHelper { } } - return Retrofit.Builder().baseUrl(baseUrl) - //增加返回值为字符串的支持(以实体类返回) - .addConverterFactory(EncodeConverter(encode)) - .client(builder.build()) - .build() - } - - fun getByteRetrofit(baseUrl: String): Retrofit { - return Retrofit.Builder().baseUrl(baseUrl) - .addConverterFactory(ByteConverter()) - .client(client) - .build() + return builder.build() } private fun getHeaderInterceptor(): Interceptor { diff --git a/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt b/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt index 338b8386e..86910724a 100644 --- a/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt +++ b/app/src/main/java/io/legado/app/model/analyzeRule/AnalyzeUrl.kt @@ -22,6 +22,8 @@ import okhttp3.FormBody import okhttp3.MediaType import okhttp3.RequestBody import retrofit2.Call +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toByteArray import java.net.URLEncoder import java.util.* import java.util.regex.Pattern @@ -315,13 +317,13 @@ class AnalyzeUrl( } } - suspend fun getResponseAwait( + suspend fun getRes( tag: String, jsStr: String? = null, sourceRegex: String? = null, ): Res { if (type != null) { - return Res(url, StringUtils.byteToHexString(getResponseBytes(tag))) + return Res(url, StringUtils.byteToHexString(getByteArray(tag))) } val cookie = CookieStore.getCookie(tag) if (cookie.isNotEmpty()) { @@ -369,7 +371,7 @@ class AnalyzeUrl( return Res(NetworkUtils.getUrl(res), res.body()) } - suspend fun getResponseBytes(tag: String? = null): ByteArray? { + suspend fun getByteArray(tag: String? = null): ByteArray { if (tag != null) { val cookie = CookieStore.getCookie(tag) if (cookie.isNotEmpty()) { @@ -382,26 +384,24 @@ class AnalyzeUrl( } } } - val response = when { - method == RequestMethod.POST -> { + return when (method) { + RequestMethod.POST -> { if (fieldMap.isNotEmpty()) { - HttpHelper - .getBytesApiService(baseUrl) - .postMapByteAsync(url, fieldMap, headerMap) + RxHttp.postForm(url) + .addAll(fieldMap) + .addAllHeader(headerMap) + .toByteArray().await() } else { - HttpHelper - .getBytesApiService(baseUrl) - .postBodyByteAsync(url, requestBody!!, headerMap) + RxHttp.postJson(url) + .addAll(body) + .addAllHeader(headerMap) + .toByteArray().await() } } - fieldMap.isEmpty() -> HttpHelper - .getBytesApiService(baseUrl) - .getByteAsync(url, headerMap) - else -> HttpHelper - .getBytesApiService(baseUrl) - .getMapByteAsync(url, fieldMap, headerMap) + else -> RxHttp.get(url) + .addAll(fieldMap) + .toByteArray().await() } - return response.body() } fun getGlideUrl(): GlideUrl { diff --git a/app/src/main/java/io/legado/app/model/rss/Rss.kt b/app/src/main/java/io/legado/app/model/rss/Rss.kt index 6dee8a9d0..979d2e308 100644 --- a/app/src/main/java/io/legado/app/model/rss/Rss.kt +++ b/app/src/main/java/io/legado/app/model/rss/Rss.kt @@ -26,7 +26,7 @@ object Rss { page = page, headerMapF = rssSource.getHeaderMap() ) - val body = analyzeUrl.getResponseAwait(rssSource.sourceUrl).body + val body = analyzeUrl.getRes(rssSource.sourceUrl).body RssParserByRule.parseXML(sortName, sortUrl, body, rssSource) } } @@ -42,7 +42,7 @@ object Rss { val body = AnalyzeUrl( rssArticle.link, baseUrl = rssArticle.origin, headerMapF = rssSource?.getHeaderMap() - ).getResponseAwait(rssArticle.origin) + ).getRes(rssArticle.origin) .body val analyzeRule = AnalyzeRule() analyzeRule.setContent(body) diff --git a/app/src/main/java/io/legado/app/model/webBook/BookChapterList.kt b/app/src/main/java/io/legado/app/model/webBook/BookChapterList.kt index 35f07b8cf..fb51b4802 100644 --- a/app/src/main/java/io/legado/app/model/webBook/BookChapterList.kt +++ b/app/src/main/java/io/legado/app/model/webBook/BookChapterList.kt @@ -63,7 +63,7 @@ object BookChapterList { ruleUrl = nextUrl, book = book, headerMapF = bookSource.getHeaderMap() - ).getResponseAwait(bookSource.bookSourceUrl) + ).getRes(bookSource.bookSourceUrl) .body?.let { nextBody -> chapterData = analyzeChapterList( book, nextUrl, nextBody, tocRule, listRule, bookSource @@ -132,7 +132,7 @@ object BookChapterList { ruleUrl = chapterData.nextUrl, book = book, headerMapF = bookSource.getHeaderMap() - ).getResponseAwait(bookSource.bookSourceUrl).body + ).getRes(bookSource.bookSourceUrl).body ?: throw Exception("${chapterData.nextUrl}, 下载失败") val nextChapterData = analyzeChapterList( book, chapterData.nextUrl, nextBody, tocRule, listRule, bookSource, diff --git a/app/src/main/java/io/legado/app/model/webBook/BookContent.kt b/app/src/main/java/io/legado/app/model/webBook/BookContent.kt index 4c0a7a6af..d3d055ffa 100644 --- a/app/src/main/java/io/legado/app/model/webBook/BookContent.kt +++ b/app/src/main/java/io/legado/app/model/webBook/BookContent.kt @@ -56,7 +56,7 @@ object BookContent { ruleUrl = nextUrl, book = book, headerMapF = bookSource.getHeaderMap() - ).getResponseAwait(bookSource.bookSourceUrl).body?.let { nextBody -> + ).getRes(bookSource.bookSourceUrl).body?.let { nextBody -> contentData = analyzeContent( book, nextUrl, nextBody, contentRule, bookChapter, bookSource, false ) @@ -78,7 +78,7 @@ object BookContent { ruleUrl = item.nextUrl, book = book, headerMapF = bookSource.getHeaderMap() - ).getResponseAwait(bookSource.bookSourceUrl).body?.let { + ).getRes(bookSource.bookSourceUrl).body?.let { contentData = analyzeContent( book, item.nextUrl, it, contentRule, bookChapter, bookSource, false ) diff --git a/app/src/main/java/io/legado/app/model/webBook/WebBook.kt b/app/src/main/java/io/legado/app/model/webBook/WebBook.kt index a2d487113..b7057ee61 100644 --- a/app/src/main/java/io/legado/app/model/webBook/WebBook.kt +++ b/app/src/main/java/io/legado/app/model/webBook/WebBook.kt @@ -46,7 +46,7 @@ class WebBook(val bookSource: BookSource) { headerMapF = bookSource.getHeaderMap(), book = variableBook ) - val res = analyzeUrl.getResponseAwait(bookSource.bookSourceUrl) + val res = analyzeUrl.getRes(bookSource.bookSourceUrl) return BookList.analyzeBookList( scope, res.body, @@ -77,7 +77,7 @@ class WebBook(val bookSource: BookSource) { baseUrl = sourceUrl, headerMapF = bookSource.getHeaderMap() ) - val res = analyzeUrl.getResponseAwait(bookSource.bookSourceUrl) + val res = analyzeUrl.getRes(bookSource.bookSourceUrl) BookList.analyzeBookList( scope, res.body, @@ -110,7 +110,7 @@ class WebBook(val bookSource: BookSource) { baseUrl = sourceUrl, headerMapF = bookSource.getHeaderMap(), book = book - ).getResponseAwait(bookSource.bookSourceUrl) + ).getRes(bookSource.bookSourceUrl) BookInfo.analyzeBookInfo(book, res.body, bookSource, book.bookUrl, canReName) } book @@ -141,7 +141,7 @@ class WebBook(val bookSource: BookSource) { ruleUrl = book.tocUrl, baseUrl = book.bookUrl, headerMapF = bookSource.getHeaderMap() - ).getResponseAwait(bookSource.bookSourceUrl) + ).getRes(bookSource.bookSourceUrl) BookChapterList.analyzeChapterList( this, book, @@ -201,7 +201,7 @@ class WebBook(val bookSource: BookSource) { headerMapF = bookSource.getHeaderMap(), book = book, chapter = bookChapter - ).getResponseAwait( + ).getRes( bookSource.bookSourceUrl, jsStr = bookSource.getContentRule().webJs, sourceRegex = bookSource.getContentRule().sourceRegex diff --git a/app/src/main/java/io/legado/app/service/HttpReadAloudService.kt b/app/src/main/java/io/legado/app/service/HttpReadAloudService.kt index 4fe576dcf..2851173ed 100644 --- a/app/src/main/java/io/legado/app/service/HttpReadAloudService.kt +++ b/app/src/main/java/io/legado/app/service/HttpReadAloudService.kt @@ -76,7 +76,7 @@ class HttpReadAloudService : BaseReadAloudService(), it.url, speakText = contentList[index], speakSpeed = AppConfig.ttsSpeechRate - ).getResponseBytes()?.let { bytes -> + ).getByteArray().let { bytes -> if (isActive) { val file = getSpeakFile(index) file.writeBytes(bytes) diff --git a/app/src/main/java/io/legado/app/ui/association/ImportBookSourceViewModel.kt b/app/src/main/java/io/legado/app/ui/association/ImportBookSourceViewModel.kt index 2b57d7c06..8b3397a0c 100644 --- a/app/src/main/java/io/legado/app/ui/association/ImportBookSourceViewModel.kt +++ b/app/src/main/java/io/legado/app/ui/association/ImportBookSourceViewModel.kt @@ -11,10 +11,11 @@ import io.legado.app.base.BaseViewModel import io.legado.app.data.entities.BookSource import io.legado.app.help.AppConfig import io.legado.app.help.SourceHelp -import io.legado.app.help.http.HttpHelper import io.legado.app.help.storage.OldRule import io.legado.app.help.storage.Restore import io.legado.app.utils.* +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toText import java.io.File class ImportBookSourceViewModel(app: Application) : BaseViewModel(app) { @@ -119,7 +120,7 @@ class ImportBookSourceViewModel(app: Application) : BaseViewModel(app) { } private suspend fun importSourceUrl(url: String) { - HttpHelper.simpleGetAsync(url).let { body -> + RxHttp.get(url).toText("utf-8").await().let { body -> val items: List> = Restore.jsonPath.parse(body).read("$") for (item in items) { val jsonItem = Restore.jsonPath.parse(item) diff --git a/app/src/main/java/io/legado/app/ui/association/ImportReplaceRuleViewModel.kt b/app/src/main/java/io/legado/app/ui/association/ImportReplaceRuleViewModel.kt index 28f90e553..e5e29392f 100644 --- a/app/src/main/java/io/legado/app/ui/association/ImportReplaceRuleViewModel.kt +++ b/app/src/main/java/io/legado/app/ui/association/ImportReplaceRuleViewModel.kt @@ -7,11 +7,12 @@ import androidx.lifecycle.MutableLiveData import io.legado.app.R import io.legado.app.base.BaseViewModel import io.legado.app.data.entities.ReplaceRule -import io.legado.app.help.http.HttpHelper import io.legado.app.help.storage.OldReplace import io.legado.app.utils.isAbsUrl import io.legado.app.utils.isContentScheme import io.legado.app.utils.readText +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toText import java.io.File class ImportReplaceRuleViewModel(app: Application) : BaseViewModel(app) { @@ -48,7 +49,7 @@ class ImportReplaceRuleViewModel(app: Application) : BaseViewModel(app) { fun import(text: String) { execute { if (text.isAbsUrl()) { - HttpHelper.simpleGetAsync(text).let { + RxHttp.get(text).toText("utf-8").await().let { val rules = OldReplace.jsonToReplaceRules(it) allRules.addAll(rules) } diff --git a/app/src/main/java/io/legado/app/ui/association/ImportRssSourceViewModel.kt b/app/src/main/java/io/legado/app/ui/association/ImportRssSourceViewModel.kt index 8de7a33af..35aad7c27 100644 --- a/app/src/main/java/io/legado/app/ui/association/ImportRssSourceViewModel.kt +++ b/app/src/main/java/io/legado/app/ui/association/ImportRssSourceViewModel.kt @@ -11,9 +11,10 @@ import io.legado.app.base.BaseViewModel import io.legado.app.data.entities.RssSource import io.legado.app.help.AppConfig import io.legado.app.help.SourceHelp -import io.legado.app.help.http.HttpHelper import io.legado.app.help.storage.Restore import io.legado.app.utils.* +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toText import java.io.File class ImportRssSourceViewModel(app: Application) : BaseViewModel(app) { @@ -114,7 +115,7 @@ class ImportRssSourceViewModel(app: Application) : BaseViewModel(app) { } private suspend fun importSourceUrl(url: String) { - HttpHelper.simpleGetAsync(url).let { body -> + RxHttp.get(url).toText("utf-8").await().let { body -> val items: List> = Restore.jsonPath.parse(body).read("$") for (item in items) { val jsonItem = Restore.jsonPath.parse(item) diff --git a/app/src/main/java/io/legado/app/ui/book/read/config/BgTextConfigDialog.kt b/app/src/main/java/io/legado/app/ui/book/read/config/BgTextConfigDialog.kt index 9e0c9cd1c..4a808df44 100644 --- a/app/src/main/java/io/legado/app/ui/book/read/config/BgTextConfigDialog.kt +++ b/app/src/main/java/io/legado/app/ui/book/read/config/BgTextConfigDialog.kt @@ -17,7 +17,6 @@ import io.legado.app.databinding.DialogEditTextBinding import io.legado.app.databinding.DialogReadBgTextBinding import io.legado.app.databinding.ItemBgImageBinding import io.legado.app.help.ReadBookConfig -import io.legado.app.help.http.HttpHelper import io.legado.app.help.permission.Permissions import io.legado.app.help.permission.PermissionsCompat import io.legado.app.lib.dialogs.alert @@ -31,6 +30,8 @@ import io.legado.app.utils.* import io.legado.app.utils.viewbindingdelegate.viewBinding import org.jetbrains.anko.sdk27.listeners.onCheckedChange import org.jetbrains.anko.sdk27.listeners.onClick +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toByteArray import java.io.File class BgTextConfigDialog : BaseDialogFragment(), FilePickerDialog.CallBack { @@ -286,9 +287,9 @@ class BgTextConfigDialog : BaseDialogFragment(), FilePickerDialog.CallBack { private fun importNetConfig(url: String) { execute { - HttpHelper.simpleGetBytesAsync(url)?.let { + RxHttp.get(url).toByteArray().await()?.let { importConfig(it) - } ?: throw Exception("获取失败") + } }.onError { longToast(it.msg) } diff --git a/app/src/main/java/io/legado/app/ui/book/read/config/SpeakEngineViewModel.kt b/app/src/main/java/io/legado/app/ui/book/read/config/SpeakEngineViewModel.kt index e79ad4730..b72f65343 100644 --- a/app/src/main/java/io/legado/app/ui/book/read/config/SpeakEngineViewModel.kt +++ b/app/src/main/java/io/legado/app/ui/book/read/config/SpeakEngineViewModel.kt @@ -5,9 +5,10 @@ import io.legado.app.App import io.legado.app.base.BaseViewModel import io.legado.app.data.entities.HttpTTS import io.legado.app.help.DefaultData -import io.legado.app.help.http.HttpHelper import io.legado.app.utils.GSON import io.legado.app.utils.fromJsonArray +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toText class SpeakEngineViewModel(application: Application) : BaseViewModel(application) { @@ -21,7 +22,7 @@ class SpeakEngineViewModel(application: Application) : BaseViewModel(application fun importOnLine(url: String, finally: (msg: String) -> Unit) { execute { - HttpHelper.simpleGetAsync(url).let { json -> + RxHttp.get(url).toText("utf-8").await().let { json -> GSON.fromJsonArray(json)?.let { App.db.httpTTSDao.insert(*it.toTypedArray()) } diff --git a/app/src/main/java/io/legado/app/ui/book/read/config/TocRegexViewModel.kt b/app/src/main/java/io/legado/app/ui/book/read/config/TocRegexViewModel.kt index ae9ad00cb..aa8ee25fb 100644 --- a/app/src/main/java/io/legado/app/ui/book/read/config/TocRegexViewModel.kt +++ b/app/src/main/java/io/legado/app/ui/book/read/config/TocRegexViewModel.kt @@ -5,9 +5,10 @@ import io.legado.app.App import io.legado.app.base.BaseViewModel import io.legado.app.data.entities.TxtTocRule import io.legado.app.help.DefaultData -import io.legado.app.help.http.HttpHelper import io.legado.app.utils.GSON import io.legado.app.utils.fromJsonArray +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toText class TocRegexViewModel(application: Application) : BaseViewModel(application) { @@ -28,7 +29,7 @@ class TocRegexViewModel(application: Application) : BaseViewModel(application) { fun importOnLine(url: String, finally: (msg: String) -> Unit) { execute { - HttpHelper.simpleGetAsync(url).let { json -> + RxHttp.get(url).toText("utf-8").await().let { json -> GSON.fromJsonArray(json)?.let { App.db.txtTocRule.insert(*it.toTypedArray()) } diff --git a/app/src/main/java/io/legado/app/ui/rss/read/ReadRssViewModel.kt b/app/src/main/java/io/legado/app/ui/rss/read/ReadRssViewModel.kt index ce16916e0..a9daa6654 100644 --- a/app/src/main/java/io/legado/app/ui/rss/read/ReadRssViewModel.kt +++ b/app/src/main/java/io/legado/app/ui/rss/read/ReadRssViewModel.kt @@ -16,7 +16,6 @@ import io.legado.app.constant.AppConst import io.legado.app.data.entities.RssArticle import io.legado.app.data.entities.RssSource import io.legado.app.data.entities.RssStar -import io.legado.app.help.http.HttpHelper import io.legado.app.model.analyzeRule.AnalyzeUrl import io.legado.app.model.rss.Rss import io.legado.app.utils.DocumentUtils @@ -25,6 +24,8 @@ import io.legado.app.utils.isContentScheme import io.legado.app.utils.writeBytes import kotlinx.coroutines.Dispatchers.IO import kotlinx.coroutines.launch +import rxhttp.wrapper.param.RxHttp +import rxhttp.wrapper.param.toByteArray import java.io.File import java.util.* @@ -131,7 +132,7 @@ class ReadRssViewModel(application: Application) : BaseViewModel(application), private suspend fun webData2bitmap(data: String): ByteArray? { return if (URLUtil.isValidUrl(data)) { - HttpHelper.simpleGetBytesAsync(data) + RxHttp.get(data).toByteArray().await() } else { Base64.decode(data.split(",").toTypedArray()[1], Base64.DEFAULT) }