rider-pro-android-app/app/src/main/java/com/aiosman/ravenow/Messaging.kt

package com.aiosman.ravenow

import android.content.Context
import android.util.Log
import cn.jpush.android.api.JPushInterface
import com.aiosman.ravenow.data.AccountService
import com.aiosman.ravenow.data.AccountServiceImpl
import com.google.android.gms.tasks.OnCompleteListener
import com.google.firebase.messaging.FirebaseMessaging
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.launch

object Messaging {
    fun registerDevice(scope: CoroutineScope, context: Context) {

        registerJpush(scope, context)
//        registerFCM(scope)
    }

    suspend fun unregisterDevice(context: Context) {
        unregisterJpush(context)
    }


    fun registerJpush(scope: CoroutineScope, context: Context) {
        val accountService: AccountService = AccountServiceImpl()
        val regId = JPushInterface.getRegistrationID(context)
        scope.launch {
            accountService.registerMessageChannel(client = "jpush", identifier = regId)
        }
    }

    private suspend fun unregisterJpush(context: Context) {
        val accountService: AccountService = AccountServiceImpl()
        val regId = JPushInterface.getRegistrationID(context)
        accountService.unregisterMessageChannel(client = "jpush", identifier = regId)
    }

    fun registerFCM(scope: CoroutineScope) {
        val accountService: AccountService = AccountServiceImpl()
        FirebaseMessaging.getInstance().token.addOnCompleteListener(OnCompleteListener { task ->
            if (!task.isSuccessful) {
                Log.w("Pushing", "Fetching FCM registration token failed", task.exception)
                return@OnCompleteListener
            }

            // Get new FCM registration token
            val token = task.result

            // Log and toast
            Log.d("Pushing", token)
            scope.launch {
                accountService.registerMessageChannel(client = "fcm", token)
            }
        })
    }

}