Mastodon
/
nextpush-android
mirror of https://codeberg.org/NextPush/nextpush-android.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Restart once SSEListener on Failure

This commit is contained in:
S1m 2021-11-24 20:06:49 +01:00
parent c0022ddd09
commit 989fabdd33
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/src/main/java/org/unifiedpush/distributor/nextpush/services/SSEListener.kt
View File

@ -16,8 +16,11 @@ import org.unifiedpush.distributor.nextpush.distributor.sendUnregistered
private const val TAG = "SSEListener" private const val TAG = "SSEListener"
class SSEListener (val context: Context) : EventSourceListener() { class SSEListener (val context: Context) : EventSourceListener() {
private var failed = false
override fun onOpen(eventSource: EventSource, response: Response) { override fun onOpen(eventSource: EventSource, response: Response) {
deleteWarningNotification(context) deleteWarningNotification(context)
failed = false
try { try {
Log.d(TAG, "onOpen: " + response.code) Log.d(TAG, "onOpen: " + response.code)
} catch (e: Exception) { } catch (e: Exception) {
@ -59,8 +62,13 @@ class SSEListener (val context: Context) : EventSourceListener() {
} }
override fun onFailure(eventSource: EventSource, t: Throwable?, response: Response?) { override fun onFailure(eventSource: EventSource, t: Throwable?, response: Response?) {
Log.d(TAG, "onFailure")
isServiceStarted = false isServiceStarted = false
createWarningNotification(context) createWarningNotification(context)
if (!failed) {
failed = true
startListener(context)
}
t?.let { t?.let {
Log.d(TAG, "An error occurred: $t") Log.d(TAG, "An error occurred: $t")
return return