Introduce PushDistributorHandler and wire up PushMessageReceiver and PushNotificationUtils.

app/src/fdroid/java/com/vitorpamplona/amethyst/service/notifications/PushDistributorHandler.kt

@@ -0,0 +1,43 @@
+package com.vitorpamplona.amethyst.service.notifications
+
+import com.vitorpamplona.amethyst.Amethyst
+import org.unifiedpush.android.connector.UnifiedPush
+
+interface PushDistributorActions {
+    fun getSavedDistributor(): String
+    fun getInstalledDistributors(): List<String>
+    fun saveDistributor(distributor: String)
+    fun removeSavedDistributor()
+}
+class PushDistributorHandler() : PushDistributorActions {
+    private val appContext = Amethyst.instance.applicationContext
+    private val unifiedPush: UnifiedPush = UnifiedPush()
+
+    private var endpointInternal = ""
+    val endpoint = endpointInternal
+
+    fun getEndpoint() = endpoint
+    fun setEndpoint(newEndpoint: String) {
+        endpointInternal = newEndpoint
+    }
+
+    override fun getSavedDistributor(): String {
+        return unifiedPush.getDistributor(appContext)
+    }
+
+    fun savedDistributorExists(): Boolean = getSavedDistributor().isNotEmpty()
+
+    override fun getInstalledDistributors(): List<String> {
+        return unifiedPush.getDistributors(appContext)
+    }
+
+    override fun saveDistributor(distributor: String) {
+        unifiedPush.saveDistributor(appContext, distributor)
+    }
+
+    override fun removeSavedDistributor() {
+        unifiedPush.safeRemoveDistributor(appContext)
+    }
+}
+
+fun UnifiedPush() = UnifiedPush

app/src/fdroid/java/com/vitorpamplona/amethyst/service/notifications/PushMessageReceiver.kt

@@ -1,27 +1,81 @@
 package com.vitorpamplona.amethyst.service.notifications
 
+import android.app.NotificationManager
 import android.content.Context
 import android.content.Intent
+import android.util.Log
+import android.util.LruCache
+import androidx.core.content.ContextCompat
+import com.vitorpamplona.amethyst.Amethyst
+import com.vitorpamplona.amethyst.LocalPreferences
+import com.vitorpamplona.amethyst.service.notifications.NotificationUtils.getOrCreateDMChannel
+import com.vitorpamplona.amethyst.service.notifications.NotificationUtils.getOrCreateZapChannel
+import com.vitorpamplona.quartz.events.Event
+import com.vitorpamplona.quartz.events.GiftWrapEvent
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.cancel
+import kotlinx.coroutines.launch
 import org.unifiedpush.android.connector.MessagingReceiver
 
-class PushMessageReceiver: MessagingReceiver() {
+class PushMessageReceiver : MessagingReceiver() {
+    private val appContext = Amethyst.instance.applicationContext
+    private val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
+    private val eventCache = LruCache<String, String>(100)
+    private val pushHandler = PushDistributorHandler()
+
     override fun onMessage(context: Context, message: ByteArray, instance: String) {
-        super.onMessage(context, message, instance)
+        val messageStr = String(message)
+        Log.d("Amethyst-OSSPush", "New message ${message.decodeToString()} for Instance: $instance")
+        scope.launch {
+            parseMessage(messageStr)?.let {
+                receiveIfNew(it)
+            }
+        }
+    }
+
+    private suspend fun parseMessage(message: String): GiftWrapEvent? {
+        (Event.fromJson(message) as? GiftWrapEvent)?.let {
+            return it
+        }
+        return null
+    }
+
+    private suspend fun receiveIfNew(event: GiftWrapEvent) {
+        if (eventCache.get(event.id) == null) {
+            eventCache.put(event.id, event.id)
+            EventNotificationConsumer(appContext).consume(event)
+        }
     }
 
     override fun onNewEndpoint(context: Context, endpoint: String, instance: String) {
-        super.onNewEndpoint(context, endpoint, instance)
+        Log.d("Amethyst-OSSPush", "New endpoint provided:- $endpoint for Instance: $instance")
+        pushHandler.setEndpoint(endpoint)
+        scope.launch(Dispatchers.IO) {
+            RegisterAccounts(LocalPreferences.allSavedAccounts()).go(endpoint)
+            notificationManager().getOrCreateZapChannel(appContext)
+            notificationManager().getOrCreateDMChannel(appContext)
+        }
     }
 
     override fun onReceive(context: Context, intent: Intent) {
+        val intentData = intent.dataString
+        val intentAction = intent.action.toString()
+        Log.d("Amethyst-OSSPush", "Intent Data:- $intentData Intent Action: $intentAction")
         super.onReceive(context, intent)
     }
 
     override fun onRegistrationFailed(context: Context, instance: String) {
+        scope.cancel()
         super.onRegistrationFailed(context, instance)
     }
 
     override fun onUnregistered(context: Context, instance: String) {
         super.onUnregistered(context, instance)
     }
+
+    fun notificationManager(): NotificationManager {
+        return ContextCompat.getSystemService(appContext, NotificationManager::class.java) as NotificationManager
+    }
 }

app/src/fdroid/java/com/vitorpamplona/amethyst/service/notifications/PushNotificationUtils.kt

@@ -1,9 +1,20 @@
 package com.vitorpamplona.amethyst.service.notifications
 
+import android.util.Log
 import com.vitorpamplona.amethyst.AccountInfo
+import kotlinx.coroutines.Dispatchers
 
 object PushNotificationUtils {
-    var hasInit: Boolean = true
+    var hasInit: Boolean = false
-    suspend fun init(accounts: List<AccountInfo>) {
+    private val pushHandler = PushDistributorHandler()
+    suspend fun init(accounts: List<AccountInfo>) = with(Dispatchers.IO) {
+        if (hasInit || pushHandler.savedDistributorExists()) {
+            return@with
+        }
+        try {
+            RegisterAccounts(accounts).go(pushHandler.getEndpoint())
+        } catch (e: Exception) {
+            Log.d("Amethyst-OSSPushUtils", "Failed to get endpoint.")
+        }
     }
 }