86 lines
No EOL
3.3 KiB
Kotlin
86 lines
No EOL
3.3 KiB
Kotlin
package ani.dantotsu.notifications
|
|
|
|
import android.app.AlarmManager
|
|
import android.app.PendingIntent
|
|
import android.content.Context
|
|
import android.content.Intent
|
|
import android.os.Build
|
|
import ani.dantotsu.notifications.TaskScheduler.TaskType
|
|
import ani.dantotsu.notifications.anilist.AnilistNotificationReceiver
|
|
import ani.dantotsu.notifications.comment.CommentNotificationReceiver
|
|
import ani.dantotsu.notifications.subscription.SubscriptionNotificationReceiver
|
|
import ani.dantotsu.settings.saving.PrefManager
|
|
import ani.dantotsu.settings.saving.PrefName
|
|
import java.util.concurrent.TimeUnit
|
|
|
|
class AlarmManagerScheduler(private val context: Context) : TaskScheduler {
|
|
override fun scheduleRepeatingTask(taskType: TaskType, interval: Long) {
|
|
if (interval * 1000 < TimeUnit.MINUTES.toMillis(15)) {
|
|
cancelTask(taskType)
|
|
return
|
|
}
|
|
val alarmManager = context.getSystemService(Context.ALARM_SERVICE) as AlarmManager
|
|
|
|
val intent = when {
|
|
taskType == TaskType.COMMENT_NOTIFICATION && PrefManager.getVal<Int>(PrefName.CommentsEnabled) == 1 ->
|
|
Intent(context, CommentNotificationReceiver::class.java)
|
|
|
|
taskType == TaskType.ANILIST_NOTIFICATION ->
|
|
Intent(context, AnilistNotificationReceiver::class.java)
|
|
|
|
taskType == TaskType.SUBSCRIPTION_NOTIFICATION ->
|
|
Intent(context, SubscriptionNotificationReceiver::class.java)
|
|
|
|
else -> return
|
|
}
|
|
|
|
val pendingIntent = PendingIntent.getBroadcast(
|
|
context,
|
|
taskType.ordinal,
|
|
intent,
|
|
PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE
|
|
)
|
|
|
|
val triggerAtMillis = System.currentTimeMillis() + TimeUnit.MINUTES.toMillis(interval)
|
|
try {
|
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {
|
|
alarmManager.setExactAndAllowWhileIdle(
|
|
AlarmManager.RTC_WAKEUP,
|
|
triggerAtMillis,
|
|
pendingIntent
|
|
)
|
|
} else {
|
|
alarmManager.setExact(AlarmManager.RTC_WAKEUP, triggerAtMillis, pendingIntent)
|
|
}
|
|
} catch (e: SecurityException) {
|
|
PrefManager.setVal(PrefName.UseAlarmManager, false)
|
|
TaskScheduler.create(context, true).cancelAllTasks()
|
|
TaskScheduler.create(context, false).scheduleAllTasks(context)
|
|
}
|
|
}
|
|
|
|
override fun cancelTask(taskType: TaskType) {
|
|
val alarmManager = context.getSystemService(Context.ALARM_SERVICE) as AlarmManager
|
|
|
|
val intent = when {
|
|
taskType == TaskType.COMMENT_NOTIFICATION && PrefManager.getVal<Int>(PrefName.CommentsEnabled) == 1 ->
|
|
Intent(context, CommentNotificationReceiver::class.java)
|
|
|
|
taskType == TaskType.ANILIST_NOTIFICATION ->
|
|
Intent(context, AnilistNotificationReceiver::class.java)
|
|
|
|
taskType == TaskType.SUBSCRIPTION_NOTIFICATION ->
|
|
Intent(context, SubscriptionNotificationReceiver::class.java)
|
|
|
|
else -> return
|
|
}
|
|
|
|
val pendingIntent = PendingIntent.getBroadcast(
|
|
context,
|
|
taskType.ordinal,
|
|
intent,
|
|
PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE
|
|
)
|
|
alarmManager.cancel(pendingIntent)
|
|
}
|
|
} |