Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e498efc493 | ||
|
|
74bbc71741 | ||
|
|
502b4890e3 | ||
|
|
dfb60461e4 | ||
|
|
bd6bc418e6 | ||
|
|
a284143ce1 |
2
.idea/deploymentTargetDropDown.xml
generated
2
.idea/deploymentTargetDropDown.xml
generated
@@ -12,6 +12,6 @@
|
|||||||
</deviceKey>
|
</deviceKey>
|
||||||
</Target>
|
</Target>
|
||||||
</targetSelectedWithDropDown>
|
</targetSelectedWithDropDown>
|
||||||
<timeTargetWasSelectedWithDropDown value="2022-01-04T14:06:06.261345Z" />
|
<timeTargetWasSelectedWithDropDown value="2022-01-08T00:45:48.713777Z" />
|
||||||
</component>
|
</component>
|
||||||
</project>
|
</project>
|
||||||
@@ -2,7 +2,7 @@
|
|||||||
*Pupil, Hitomi.la viewer for Android*
|
*Pupil, Hitomi.la viewer for Android*
|
||||||
|
|
||||||

|

|
||||||
[](https://github.com/tom5079/Pupil/releases/download/5.2.6/Pupil-v5.2.6.apk)
|
[](https://github.com/tom5079/Pupil/releases/download/5.2.8/Pupil-v5.2.8.apk)
|
||||||
[](https://discord.gg/Stj4b5v)
|
[](https://discord.gg/Stj4b5v)
|
||||||
|
|
||||||
# Features
|
# Features
|
||||||
|
|||||||
@@ -38,7 +38,7 @@ android {
|
|||||||
minSdkVersion 16
|
minSdkVersion 16
|
||||||
targetSdkVersion 31
|
targetSdkVersion 31
|
||||||
versionCode 69
|
versionCode 69
|
||||||
versionName "5.2.6"
|
versionName "5.2.8"
|
||||||
testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
|
testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
|
||||||
vectorDrawables.useSupportLibrary = true
|
vectorDrawables.useSupportLibrary = true
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -12,7 +12,7 @@
|
|||||||
"filters": [],
|
"filters": [],
|
||||||
"attributes": [],
|
"attributes": [],
|
||||||
"versionCode": 69,
|
"versionCode": 69,
|
||||||
"versionName": "5.2.6",
|
"versionName": "5.2.8",
|
||||||
"outputFile": "app-release.apk"
|
"outputFile": "app-release.apk"
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
|
|||||||
@@ -39,7 +39,6 @@ import com.github.piasy.biv.loader.fresco.FrescoImageLoader
|
|||||||
import com.google.android.gms.common.GooglePlayServicesNotAvailableException
|
import com.google.android.gms.common.GooglePlayServicesNotAvailableException
|
||||||
import com.google.android.gms.common.GooglePlayServicesRepairableException
|
import com.google.android.gms.common.GooglePlayServicesRepairableException
|
||||||
import com.google.android.gms.security.ProviderInstaller
|
import com.google.android.gms.security.ProviderInstaller
|
||||||
import com.google.android.material.snackbar.Snackbar
|
|
||||||
import com.google.firebase.crashlytics.FirebaseCrashlytics
|
import com.google.firebase.crashlytics.FirebaseCrashlytics
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
import kotlinx.coroutines.channels.BufferOverflow
|
import kotlinx.coroutines.channels.BufferOverflow
|
||||||
@@ -47,13 +46,12 @@ import kotlinx.coroutines.flow.MutableSharedFlow
|
|||||||
import kotlinx.coroutines.flow.asSharedFlow
|
import kotlinx.coroutines.flow.asSharedFlow
|
||||||
import okhttp3.*
|
import okhttp3.*
|
||||||
import xyz.quaver.io.FileX
|
import xyz.quaver.io.FileX
|
||||||
import xyz.quaver.pupil.hitomi.evaluations
|
import xyz.quaver.pupil.hitomi.evaluationContext
|
||||||
import xyz.quaver.pupil.types.Tag
|
import xyz.quaver.pupil.types.Tag
|
||||||
import xyz.quaver.pupil.util.*
|
import xyz.quaver.pupil.util.*
|
||||||
import java.io.File
|
import java.io.File
|
||||||
import java.net.URL
|
import java.net.URL
|
||||||
import java.util.*
|
import java.util.*
|
||||||
import java.util.concurrent.ConcurrentHashMap
|
|
||||||
import java.util.concurrent.Executors
|
import java.util.concurrent.Executors
|
||||||
import java.util.concurrent.TimeUnit
|
import java.util.concurrent.TimeUnit
|
||||||
import kotlin.reflect.KClass
|
import kotlin.reflect.KClass
|
||||||
@@ -96,31 +94,29 @@ fun reloadWebView() {
|
|||||||
if (reloadJob?.isActive == true) return
|
if (reloadJob?.isActive == true) return
|
||||||
|
|
||||||
reloadJob = CoroutineScope(Dispatchers.IO).launch {
|
reloadJob = CoroutineScope(Dispatchers.IO).launch {
|
||||||
if (evaluations.isEmpty()) {
|
webViewReady = false
|
||||||
webViewReady = false
|
webViewFailed = false
|
||||||
webViewFailed = false
|
|
||||||
|
|
||||||
while (evaluations.isNotEmpty()) yield()
|
evaluationContext.cancelChildren()
|
||||||
|
|
||||||
runCatching {
|
runCatching {
|
||||||
URL(
|
URL(
|
||||||
if (isDebugBuild)
|
if (isDebugBuild)
|
||||||
"https://tom5079.github.io/Pupil/hitomi-dev.html"
|
"https://tom5079.github.io/Pupil/hitomi-dev.html"
|
||||||
else
|
else
|
||||||
"https://tom5079.github.io/Pupil/hitomi.html"
|
"https://tom5079.github.io/Pupil/hitomi.html"
|
||||||
).readText()
|
).readText()
|
||||||
}.onFailure {
|
}.onFailure {
|
||||||
webViewFailed = true
|
webViewFailed = true
|
||||||
}.getOrNull()?.let { html ->
|
}.getOrNull()?.let { html ->
|
||||||
launch(Dispatchers.Main) {
|
launch(Dispatchers.Main) {
|
||||||
webView.loadDataWithBaseURL(
|
webView.loadDataWithBaseURL(
|
||||||
"https://hitomi.la/",
|
"https://hitomi.la/",
|
||||||
html,
|
html,
|
||||||
"text/html",
|
"text/html",
|
||||||
null,
|
null,
|
||||||
null
|
null
|
||||||
)
|
)
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -152,7 +148,7 @@ fun reloadWhenFailedOrUpdate() = CoroutineScope(Dispatchers.Default).launch {
|
|||||||
}
|
}
|
||||||
|
|
||||||
var isDebugBuild: Boolean = false
|
var isDebugBuild: Boolean = false
|
||||||
private lateinit var userAgent: String
|
lateinit var userAgent: String
|
||||||
|
|
||||||
class Pupil : Application() {
|
class Pupil : Application() {
|
||||||
|
|
||||||
@@ -166,7 +162,7 @@ class Pupil : Application() {
|
|||||||
instance = this
|
instance = this
|
||||||
isDebugBuild = applicationInfo.flags and ApplicationInfo.FLAG_DEBUGGABLE != 0
|
isDebugBuild = applicationInfo.flags and ApplicationInfo.FLAG_DEBUGGABLE != 0
|
||||||
|
|
||||||
WebView.setWebContentsDebuggingEnabled(true)
|
if (isDebugBuild) WebView.setWebContentsDebuggingEnabled(true)
|
||||||
|
|
||||||
webView = WebView(this).apply {
|
webView = WebView(this).apply {
|
||||||
with (settings) {
|
with (settings) {
|
||||||
@@ -191,7 +187,6 @@ class Pupil : Application() {
|
|||||||
"onReceivedError: ${error?.description}"
|
"onReceivedError: ${error?.description}"
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
webViewFailed = true
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -257,7 +252,7 @@ class Pupil : Application() {
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
Preferences.get<String>("download_folder").also {
|
Preferences.get<String>("download_folder").also {
|
||||||
if (it.startsWith("content") && Build.VERSION.SDK_INT > 19)
|
if (it.startsWith("content://"))
|
||||||
contentResolver.takePersistableUriPermission(
|
contentResolver.takePersistableUriPermission(
|
||||||
Uri.parse(it),
|
Uri.parse(it),
|
||||||
Intent.FLAG_GRANT_READ_URI_PERMISSION or Intent.FLAG_GRANT_WRITE_URI_PERMISSION
|
Intent.FLAG_GRANT_READ_URI_PERMISSION or Intent.FLAG_GRANT_WRITE_URI_PERMISSION
|
||||||
|
|||||||
@@ -16,17 +16,15 @@
|
|||||||
|
|
||||||
package xyz.quaver.pupil.hitomi
|
package xyz.quaver.pupil.hitomi
|
||||||
|
|
||||||
|
import android.util.Log
|
||||||
import android.webkit.WebView
|
import android.webkit.WebView
|
||||||
import android.widget.Toast
|
import android.widget.Toast
|
||||||
import com.google.common.collect.ConcurrentHashMultiset
|
import com.google.common.collect.ConcurrentHashMultiset
|
||||||
import com.google.firebase.crashlytics.FirebaseCrashlytics
|
import com.google.firebase.crashlytics.FirebaseCrashlytics
|
||||||
import kotlinx.coroutines.Dispatchers
|
import kotlinx.coroutines.*
|
||||||
import kotlinx.coroutines.ExperimentalCoroutinesApi
|
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
import kotlinx.coroutines.flow.first
|
import kotlinx.coroutines.flow.first
|
||||||
import kotlinx.coroutines.flow.transformWhile
|
import kotlinx.coroutines.flow.transformWhile
|
||||||
import kotlinx.coroutines.withContext
|
|
||||||
import kotlinx.coroutines.yield
|
|
||||||
import kotlinx.serialization.ExperimentalSerializationApi
|
import kotlinx.serialization.ExperimentalSerializationApi
|
||||||
import kotlinx.serialization.decodeFromString
|
import kotlinx.serialization.decodeFromString
|
||||||
import kotlinx.serialization.encodeToString
|
import kotlinx.serialization.encodeToString
|
||||||
@@ -40,19 +38,25 @@ import kotlin.coroutines.suspendCoroutine
|
|||||||
|
|
||||||
const val protocol = "https:"
|
const val protocol = "https:"
|
||||||
|
|
||||||
val evaluations = Collections.newSetFromMap<String>(ConcurrentHashMap())
|
val evaluationContext = Dispatchers.Main + Job()
|
||||||
|
|
||||||
suspend fun WebView.evaluate(script: String): String = withContext(Dispatchers.Main) {
|
suspend fun WebView.evaluate(script: String): String = coroutineScope {
|
||||||
while (webViewFailed || !webViewReady) yield()
|
var result: String? = null
|
||||||
|
|
||||||
val uid = UUID.randomUUID().toString()
|
while (result == null) {
|
||||||
|
try {
|
||||||
|
result = withContext(evaluationContext) {
|
||||||
|
while (webViewFailed || !webViewReady) yield()
|
||||||
|
|
||||||
evaluations.add(uid)
|
suspendCoroutine { continuation ->
|
||||||
|
evaluateJavascript(script) {
|
||||||
|
continuation.resume(it)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
val result: String = suspendCoroutine { continuation ->
|
}
|
||||||
evaluateJavascript(script) {
|
} catch (e: CancellationException) {
|
||||||
evaluations.remove(uid)
|
continue
|
||||||
continuation.resume(it)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -60,24 +64,36 @@ suspend fun WebView.evaluate(script: String): String = withContext(Dispatchers.M
|
|||||||
}
|
}
|
||||||
|
|
||||||
@OptIn(ExperimentalCoroutinesApi::class)
|
@OptIn(ExperimentalCoroutinesApi::class)
|
||||||
suspend fun WebView.evaluatePromise(script: String, then: String = ".then(result => Callback.onResult(%uid, JSON.stringify(result))).catch(err => Callback.onError(%uid, JSON.stringify(error)))"): String? = withContext(Dispatchers.Main) {
|
suspend fun WebView.evaluatePromise(
|
||||||
while (webViewFailed || !webViewReady) yield()
|
script: String,
|
||||||
|
then: String = ".then(result => Callback.onResult(%uid, JSON.stringify(result))).catch(err => Callback.onError(%uid, JSON.stringify(error)))"
|
||||||
|
): String? = coroutineScope {
|
||||||
|
var result: String? = null
|
||||||
|
|
||||||
val uid = UUID.randomUUID().toString()
|
while (result == null) {
|
||||||
|
try {
|
||||||
|
result = withContext(evaluationContext) {
|
||||||
|
while (webViewFailed || !webViewReady) yield()
|
||||||
|
|
||||||
evaluations.add(uid)
|
val uid = UUID.randomUUID().toString()
|
||||||
|
|
||||||
evaluateJavascript((script+then).replace("%uid", "'$uid'"), null)
|
evaluateJavascript((script + then).replace("%uid", "'$uid'"), null)
|
||||||
|
|
||||||
val flow: Flow<Pair<String, String?>> = webViewFlow.transformWhile { (currentUid, result) ->
|
val flow: Flow<Pair<String, String?>> = webViewFlow.transformWhile { (currentUid, result) ->
|
||||||
if (currentUid == uid) {
|
if (currentUid == uid) {
|
||||||
evaluations.remove(uid)
|
emit(currentUid to result)
|
||||||
emit(currentUid to result)
|
}
|
||||||
|
currentUid != uid
|
||||||
|
}
|
||||||
|
|
||||||
|
flow.first().second
|
||||||
|
}
|
||||||
|
} catch (e: CancellationException) {
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
currentUid != uid
|
|
||||||
}
|
}
|
||||||
|
|
||||||
flow.first().second
|
result
|
||||||
}
|
}
|
||||||
|
|
||||||
@Suppress("EXPERIMENTAL_API_USAGE")
|
@Suppress("EXPERIMENTAL_API_USAGE")
|
||||||
@@ -107,16 +123,6 @@ suspend fun urlFromUrlFromHash(galleryID: Int, image: GalleryFiles, dir: String?
|
|||||||
""".trimIndent()
|
""".trimIndent()
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
FirebaseCrashlytics.getInstance().log(
|
|
||||||
"""
|
|
||||||
url_from_url_from_hash(
|
|
||||||
${galleryID.toString().js},
|
|
||||||
${Json.encodeToString(image)},
|
|
||||||
${dir.js}, ${ext.js}, ${base.js}
|
|
||||||
)
|
|
||||||
""".trimIndent()
|
|
||||||
)
|
|
||||||
return Json.decodeFromString(result)
|
return Json.decodeFromString(result)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -40,6 +40,7 @@ import xyz.quaver.pupil.hitomi.GalleryBlock
|
|||||||
import xyz.quaver.pupil.hitomi.GalleryInfo
|
import xyz.quaver.pupil.hitomi.GalleryInfo
|
||||||
import xyz.quaver.pupil.hitomi.getGalleryBlock
|
import xyz.quaver.pupil.hitomi.getGalleryBlock
|
||||||
import xyz.quaver.pupil.hitomi.getGalleryInfo
|
import xyz.quaver.pupil.hitomi.getGalleryInfo
|
||||||
|
import xyz.quaver.pupil.userAgent
|
||||||
import java.io.File
|
import java.io.File
|
||||||
import java.io.IOException
|
import java.io.IOException
|
||||||
import java.util.concurrent.ConcurrentHashMap
|
import java.util.concurrent.ConcurrentHashMap
|
||||||
@@ -172,6 +173,7 @@ class Cache private constructor(context: Context, val galleryID: Int) : ContextW
|
|||||||
kotlin.runCatching {
|
kotlin.runCatching {
|
||||||
val request = Request.Builder()
|
val request = Request.Builder()
|
||||||
.url(it)
|
.url(it)
|
||||||
|
.header("Referer", "https://hitomi.la/")
|
||||||
.build()
|
.build()
|
||||||
|
|
||||||
client.newCall(request).execute().also { if (it.code() != 200) throw IOException() }.body()?.use { it.bytes() }
|
client.newCall(request).execute().also { if (it.code() != 200) throw IOException() }.body()?.use { it.bytes() }
|
||||||
|
|||||||
Reference in New Issue
Block a user