MangaDex: remove MD@Home reporting (#10250)
This commit is contained in:
parent
8acd1707ae
commit
b57f7d72d4
@ -1,7 +1,7 @@
|
||||
ext {
|
||||
extName = 'MangaDex'
|
||||
extClass = '.MangaDexFactory'
|
||||
extVersionCode = 203
|
||||
extVersionCode = 204
|
||||
isNsfw = true
|
||||
}
|
||||
|
||||
|
@ -30,7 +30,6 @@ object MDConstants {
|
||||
const val apiMangaUrl = "$apiUrl/manga"
|
||||
const val apiChapterUrl = "$apiUrl/chapter"
|
||||
const val apiListUrl = "$apiUrl/list"
|
||||
const val atHomePostUrl = "https://api.mangadex.network/report"
|
||||
val whitespaceRegex = "\\s".toRegex()
|
||||
|
||||
val mdAtHomeTokenLifespan = 5.minutes.inWholeMilliseconds
|
||||
|
@ -73,7 +73,6 @@ abstract class MangaDex(final override val lang: String, private val dexLang: St
|
||||
|
||||
override val client = network.cloudflareClient.newBuilder()
|
||||
.rateLimit(3)
|
||||
.addInterceptor(MdAtHomeReportInterceptor(network.cloudflareClient, headers))
|
||||
.build()
|
||||
|
||||
// Popular manga section
|
||||
|
@ -1,109 +0,0 @@
|
||||
package eu.kanade.tachiyomi.extension.all.mangadex
|
||||
|
||||
import android.util.Log
|
||||
import eu.kanade.tachiyomi.extension.all.mangadex.dto.ImageReportDto
|
||||
import eu.kanade.tachiyomi.network.POST
|
||||
import kotlinx.serialization.encodeToString
|
||||
import kotlinx.serialization.json.Json
|
||||
import okhttp3.Call
|
||||
import okhttp3.Callback
|
||||
import okhttp3.Headers
|
||||
import okhttp3.HttpUrl.Companion.toHttpUrl
|
||||
import okhttp3.Interceptor
|
||||
import okhttp3.MediaType.Companion.toMediaType
|
||||
import okhttp3.OkHttpClient
|
||||
import okhttp3.Request
|
||||
import okhttp3.RequestBody.Companion.toRequestBody
|
||||
import okhttp3.Response
|
||||
import uy.kohesive.injekt.injectLazy
|
||||
|
||||
/**
|
||||
* Interceptor to post to MD@Home for MangaDex Stats
|
||||
*/
|
||||
class MdAtHomeReportInterceptor(
|
||||
private val client: OkHttpClient,
|
||||
private val headers: Headers,
|
||||
) : Interceptor {
|
||||
|
||||
private val json: Json by injectLazy()
|
||||
|
||||
override fun intercept(chain: Interceptor.Chain): Response {
|
||||
val originalRequest = chain.request()
|
||||
val response = chain.proceed(chain.request())
|
||||
val url = originalRequest.url.toString()
|
||||
|
||||
if (!url.contains(MD_AT_HOME_URL_REGEX)) {
|
||||
return response
|
||||
}
|
||||
|
||||
Log.e("MangaDex", "Connecting to MD@Home node at $url")
|
||||
|
||||
val reportRequest = mdAtHomeReportRequest(response)
|
||||
|
||||
// Execute the report endpoint network call asynchronously to avoid blocking
|
||||
// the reader from showing the image once it's fully loaded if the report call
|
||||
// gets stuck, as it tend to happens sometimes.
|
||||
client.newCall(reportRequest).enqueue(REPORT_CALLBACK)
|
||||
|
||||
if (response.isSuccessful) {
|
||||
return response
|
||||
}
|
||||
|
||||
response.close()
|
||||
|
||||
Log.e("MangaDex", "Error connecting to MD@Home node, fallback to uploads server")
|
||||
|
||||
val imagePath = originalRequest.url.pathSegments
|
||||
.dropWhile { it != "data" && it != "data-saver" }
|
||||
.joinToString("/")
|
||||
|
||||
val fallbackUrl = MDConstants.cdnUrl.toHttpUrl().newBuilder()
|
||||
.addPathSegments(imagePath)
|
||||
.build()
|
||||
|
||||
val fallbackRequest = originalRequest.newBuilder()
|
||||
.url(fallbackUrl)
|
||||
.headers(headers)
|
||||
.build()
|
||||
|
||||
return chain.proceed(fallbackRequest)
|
||||
}
|
||||
|
||||
private fun mdAtHomeReportRequest(response: Response): Request {
|
||||
val result = ImageReportDto(
|
||||
url = response.request.url.toString(),
|
||||
success = response.isSuccessful,
|
||||
bytes = response.peekBody(Long.MAX_VALUE).bytes().size,
|
||||
cached = response.headers["X-Cache"] == "HIT",
|
||||
duration = response.receivedResponseAtMillis - response.sentRequestAtMillis,
|
||||
)
|
||||
|
||||
val payload = json.encodeToString(result)
|
||||
|
||||
return POST(
|
||||
url = MDConstants.atHomePostUrl,
|
||||
headers = headers,
|
||||
body = payload.toRequestBody(JSON_MEDIA_TYPE),
|
||||
)
|
||||
}
|
||||
|
||||
companion object {
|
||||
private val JSON_MEDIA_TYPE = "application/json".toMediaType()
|
||||
private val MD_AT_HOME_URL_REGEX =
|
||||
"""^https://[\w\d]+\.[\w\d]+\.mangadex(\b-test\b)?\.network.*${'$'}""".toRegex()
|
||||
|
||||
private val REPORT_CALLBACK = object : Callback {
|
||||
override fun onFailure(call: Call, e: okio.IOException) {
|
||||
Log.e("MangaDex", "Error trying to POST report to MD@Home: ${e.message}")
|
||||
}
|
||||
|
||||
override fun onResponse(call: Call, response: Response) {
|
||||
if (!response.isSuccessful) {
|
||||
Log.e("MangaDex", "Error trying to POST report to MD@Home: HTTP error ${response.code}")
|
||||
}
|
||||
|
||||
response.close()
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user