Send push tokens in first wrapper start (#520)

Author: hborisoff

AndroidSDKCore/src/main/java/com/leanplum/migration/wrapper/CTWrapper.kt

@@ -23,9 +23,12 @@ package com.leanplum.migration.wrapper
 
 import android.app.Application
 import android.content.Context
+import android.text.TextUtils
 import com.clevertap.android.sdk.ActivityLifecycleCallback
 import com.clevertap.android.sdk.CleverTapAPI
 import com.clevertap.android.sdk.CleverTapInstanceConfig
+import com.clevertap.android.sdk.pushnotification.PushConstants
+import com.clevertap.android.sdk.pushnotification.PushNotificationHandler
 import com.leanplum.callbacks.CleverTapInstanceCallback
 import com.leanplum.internal.Constants
 import com.leanplum.internal.Log
@@ -34,6 +37,7 @@ import com.leanplum.migration.MigrationManager
 import com.leanplum.migration.push.FcmMigrationHandler
 import com.leanplum.migration.push.HmsMigrationHandler
 import com.leanplum.migration.push.MiPushMigrationHandler
+import com.leanplum.utils.SharedPreferencesUtil
 
 internal class CTWrapper(
   private val accountId: String,
@@ -50,6 +54,7 @@ internal class CTWrapper(
   private var cleverTapInstance: CleverTapAPI? = null
   private var instanceCallback: CleverTapInstanceCallback? = null
 
+  private var firstTimeStart = IdentityManager.isStateUndefined()
   private var identityManager = IdentityManager(deviceId, userId ?: deviceId)
 
   override fun launch(context: Context, callback: CleverTapInstanceCallback?) {
@@ -85,6 +90,10 @@ internal class CTWrapper(
       }
       Log.d("Wrapper: CleverTap instance created by Leanplum")
     }
+    if (firstTimeStart) {
+      // Send tokens in same session, because often a restart is needed for CT SDK to get them
+      sendPushTokens(context)
+    }
     triggerInstanceCallback()
   }
 
@@ -102,6 +111,35 @@ internal class CTWrapper(
     triggerInstanceCallback()
   }
 
+  private fun sendPushTokens(context: Context) {
+    // FCM
+    val fcmToken = SharedPreferencesUtil.getString(context,
+      Constants.Defaults.LEANPLUM_PUSH, Constants.Defaults.PROPERTY_FCM_TOKEN_ID)
+    if (!TextUtils.isEmpty(fcmToken)) {
+      val type = PushConstants.PushType.FCM.type
+      PushNotificationHandler.getPushNotificationHandler().onNewToken(context, fcmToken, type)
+      Log.d("Wrapper: fcm token sent")
+    }
+
+    // XPS
+    val miPushToken = SharedPreferencesUtil.getString(context,
+      Constants.Defaults.LEANPLUM_PUSH, Constants.Defaults.PROPERTY_MIPUSH_TOKEN_ID)
+    if (!TextUtils.isEmpty(miPushToken)) {
+      val type = PushConstants.PushType.XPS.type
+      PushNotificationHandler.getPushNotificationHandler().onNewToken(context, miPushToken, type)
+      Log.d("Wrapper: xps token sent")
+    }
+
+    // HMS
+    val hmsToken = SharedPreferencesUtil.getString(context,
+      Constants.Defaults.LEANPLUM_PUSH, Constants.Defaults.PROPERTY_HMS_TOKEN_ID)
+    if (!TextUtils.isEmpty(hmsToken)) {
+      val type = PushConstants.PushType.HPS.type
+      PushNotificationHandler.getPushNotificationHandler().onNewToken(context, hmsToken, type)
+      Log.d("Wrapper: hms token sent")
+    }
+  }
+
   override fun setUserId(userId: String?) {
     if (userId == null || userId.isEmpty()) return
     if (identityManager.getUserId() == userId) return

AndroidSDKCore/src/main/java/com/leanplum/migration/wrapper/IdentityManager.kt

@@ -65,6 +65,7 @@ internal class IdentityManager(
 
     private var anonymousMergeUserId: String? by StringPreferenceNullable("ct_anon_merge_userid")
     private var state: String by StringPreference("ct_login_state", UNDEFINED)
+    fun isStateUndefined() = state == UNDEFINED
   }
 
   init {