SagerNet/sing-box-for-android
1
0
Fork 0
mirror of https://github.com/SagerNet/sing-box-for-android.git synced 2025-04-05 12:57:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix profile auto update

Browse source
This commit is contained in:
世界 2023-11-09 13:39:47 +08:00
parent d45e2af1c2
commit 71acd29526
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 14 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

22
app/src/main/java/io/nekohasekai/sfa/bg/UpdateProfileWork.kt
View file

@ -21,29 +21,30 @@ class UpdateProfileWork {
companion object { companion object {
private const val WORK_NAME = "UpdateProfile" private const val WORK_NAME = "UpdateProfile"
private const val TAG = "UpdateProfileWork"
suspend fun reconfigureUpdater() { suspend fun reconfigureUpdater() {
runCatching { runCatching {
reconfigureUpdater0() reconfigureUpdater0()
}.onFailure { }.onFailure {
Log.e("UpdateProfileWork", "reconfigureUpdater", it) Log.e(TAG, "reconfigureUpdater", it)
} }
} }
private suspend fun reconfigureUpdater0() { private suspend fun reconfigureUpdater0() {
WorkManager.getInstance(Application.application).cancelUniqueWork(WORK_NAME)
val remoteProfiles = ProfileManager.list() val remoteProfiles = ProfileManager.list()
.filter { it.typed.type == TypedProfile.Type.Remote && it.typed.autoUpdate } .filter { it.typed.type == TypedProfile.Type.Remote && it.typed.autoUpdate }
if (remoteProfiles.isEmpty()) return if (remoteProfiles.isEmpty()) {
WorkManager.getInstance(Application.application).cancelUniqueWork(WORK_NAME)
return
}
var minDelay = var minDelay =
remoteProfiles.minByOrNull { it.typed.autoUpdateInterval }!!.typed.autoUpdateInterval.toLong() remoteProfiles.minByOrNull { it.typed.autoUpdateInterval }!!.typed.autoUpdateInterval.toLong()
val now = System.currentTimeMillis() / 1000L val nowSeconds = System.currentTimeMillis() / 1000L
val minInitDelay = val minInitDelay =
remoteProfiles.minOf { now - (it.typed.lastUpdated.time / 1000L) - (minDelay * 60) } remoteProfiles.minOf { (it.typed.autoUpdateInterval * 60) - (nowSeconds - (it.typed.lastUpdated.time / 1000L)) }
if (minDelay < 15) minDelay = 15 if (minDelay < 15) minDelay = 15
WorkManager.getInstance(Application.application).enqueueUniquePeriodicWork( WorkManager.getInstance(Application.application).enqueueUniquePeriodicWork(
WORK_NAME, WORK_NAME,
ExistingPeriodicWorkPolicy.UPDATE, ExistingPeriodicWorkPolicy.UPDATE,
@ -67,6 +68,11 @@ class UpdateProfileWork {
if (remoteProfiles.isEmpty()) return Result.success() if (remoteProfiles.isEmpty()) return Result.success()
var success = true var success = true
for (profile in remoteProfiles) { for (profile in remoteProfiles) {
val lastSeconds =
(System.currentTimeMillis() - profile.typed.lastUpdated.time) / 1000L
if (lastSeconds < profile.typed.autoUpdateInterval * 60) {
continue
}
try { try {
val content = HTTPClient().use { it.getString(profile.typed.remoteURL) } val content = HTTPClient().use { it.getString(profile.typed.remoteURL) }
Libbox.checkConfig(content) Libbox.checkConfig(content)
@ -74,7 +80,7 @@ class UpdateProfileWork {
profile.typed.lastUpdated = Date() profile.typed.lastUpdated = Date()
ProfileManager.update(profile) ProfileManager.update(profile)
} catch (e: Exception) { } catch (e: Exception) {
Log.e("UpdateProfileWork", "error when updating profile ${profile.name}", e) Log.e(TAG, "update profile ${profile.name}", e)
success = false success = false
} }
} }