fix: improve push delivery for Android 14 and above

core/api/core.api

@@ -269,6 +269,38 @@ public final class io/customer/sdk/data/model/Region$US : io/customer/sdk/data/m
 	public static final field INSTANCE Lio/customer/sdk/data/model/Region$US;
 }
 
+public final class io/customer/sdk/data/model/Settings {
+	public static final field Companion Lio/customer/sdk/data/model/Settings$Companion;
+	public synthetic fun <init> (ILjava/lang/String;Ljava/lang/String;Lkotlinx/serialization/internal/SerializationConstructorMarker;)V
+	public fun <init> (Ljava/lang/String;Ljava/lang/String;)V
+	public final fun component1 ()Ljava/lang/String;
+	public final fun component2 ()Ljava/lang/String;
+	public final fun copy (Ljava/lang/String;Ljava/lang/String;)Lio/customer/sdk/data/model/Settings;
+	public static synthetic fun copy$default (Lio/customer/sdk/data/model/Settings;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)Lio/customer/sdk/data/model/Settings;
+	public fun equals (Ljava/lang/Object;)Z
+	public final fun getApiHost ()Ljava/lang/String;
+	public final fun getWriteKey ()Ljava/lang/String;
+	public fun hashCode ()I
+	public fun toString ()Ljava/lang/String;
+	public static final fun write$Self (Lio/customer/sdk/data/model/Settings;Lkotlinx/serialization/encoding/CompositeEncoder;Lkotlinx/serialization/descriptors/SerialDescriptor;)V
+}
+
+public final class io/customer/sdk/data/model/Settings$$serializer : kotlinx/serialization/internal/GeneratedSerializer {
+	public static final field INSTANCE Lio/customer/sdk/data/model/Settings$$serializer;
+	public static final synthetic field descriptor Lkotlinx/serialization/descriptors/SerialDescriptor;
+	public fun childSerializers ()[Lkotlinx/serialization/KSerializer;
+	public fun deserialize (Lkotlinx/serialization/encoding/Decoder;)Lio/customer/sdk/data/model/Settings;
+	public synthetic fun deserialize (Lkotlinx/serialization/encoding/Decoder;)Ljava/lang/Object;
+	public fun getDescriptor ()Lkotlinx/serialization/descriptors/SerialDescriptor;
+	public fun serialize (Lkotlinx/serialization/encoding/Encoder;Lio/customer/sdk/data/model/Settings;)V
+	public synthetic fun serialize (Lkotlinx/serialization/encoding/Encoder;Ljava/lang/Object;)V
+	public fun typeParametersSerializers ()[Lkotlinx/serialization/KSerializer;
+}
+
+public final class io/customer/sdk/data/model/Settings$Companion {
+	public final fun serializer ()Lkotlinx/serialization/KSerializer;
+}
+
 public final class io/customer/sdk/events/Metric : java/lang/Enum {
 	public static final field Clicked Lio/customer/sdk/events/Metric;
 	public static final field Converted Lio/customer/sdk/events/Metric;

core/build.gradle

@@ -5,6 +5,7 @@ plugins {
     id 'com.android.library'
     id 'kotlin-android'
     id 'com.twilio.apkscale'
+    id 'org.jetbrains.kotlin.plugin.serialization'
 }
 
 ext {
@@ -38,4 +39,7 @@ dependencies {
     api project(":base")
     api Dependencies.androidxCoreKtx
     implementation Dependencies.coroutinesAndroid
+    // Use this as API so customers can provide objects serializations without
+    // needing to add it as a dependency to their app
+    api(Dependencies.kotlinxSerializationJson)
 }

core/src/main/kotlin/io/customer/sdk/data/model/Settings.kt

@@ -0,0 +1,6 @@
+package io.customer.sdk.data.model
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class Settings(val writeKey: String, val apiHost: String)

core/src/main/kotlin/io/customer/sdk/data/store/GlobalPreferenceStore.kt

@@ -2,14 +2,18 @@
 
 import android.content.Context
 import androidx.core.content.edit
+import io.customer.sdk.data.model.Settings
+import kotlinx.serialization.json.Json
 
 /**
  * Store for global preferences that are not tied to a specific api key, user
  * or any other entity.
  */
 interface GlobalPreferenceStore {
     fun saveDeviceToken(token: String)
+    fun saveSettings(value: Settings)
     fun getDeviceToken(): String?
+    fun getSettings(): Settings?
     fun removeDeviceToken()
     fun clear(key: String)
     fun clearAll()
@@ -27,13 +31,27 @@
         putString(KEY_DEVICE_TOKEN, token)
     }
 
+    override fun saveSettings(value: Settings) = prefs.edit {
+        putString(KEY_CONFIG_SETTINGS, Json.encodeToString(Settings.serializer(), value))
+    }
+
     override fun getDeviceToken(): String? = prefs.read {
         getString(KEY_DEVICE_TOKEN, null)
     }
 
+    override fun getSettings(): Settings? = prefs.read {
+        runCatching {
+            Json.decodeFromString(
+                Settings.serializer(),
+                getString(KEY_CONFIG_SETTINGS, null) ?: return null
+            )
+        }.getOrNull()
+    }
+
     override fun removeDeviceToken() = clear(KEY_DEVICE_TOKEN)
 
     companion object {
         private const val KEY_DEVICE_TOKEN = "device_token"
+        private const val KEY_CONFIG_SETTINGS = "config_settings"
     }
 }

datapipelines/src/main/kotlin/io/customer/datapipelines/util/EventNames.kt → core/src/main/kotlin/io/customer/sdk/util/EventNames.kt

@@ -1,10 +1,10 @@
-package io.customer.datapipelines.util
+package io.customer.sdk.util
 
 /**
  * Event names to identify specific events in data pipelines so they can be
  * reflected on Journeys.
  */
-internal object EventNames {
+object EventNames {
     const val DEVICE_UPDATE = "Device Created or Updated"
     const val DEVICE_DELETE = "Device Deleted"
     const val METRIC_DELIVERY = "Report Delivery Event"

datapipelines/build.gradle

@@ -39,7 +39,4 @@ dependencies {
 
     implementation(Dependencies.segment)
     implementation Dependencies.androidxProcessLifecycle
-    // Use this as API so customers can provide objects serializations without
-    // needing to add it as a dependency to their app
-    api(Dependencies.kotlinxSerializationJson)
 }

datapipelines/src/main/kotlin/io/customer/datapipelines/migration/TrackingMigrationProcessor.kt

@@ -10,11 +10,11 @@ import com.segment.analytics.kotlin.core.platform.EnrichmentClosure
 import com.segment.analytics.kotlin.core.utilities.putAll
 import com.segment.analytics.kotlin.core.utilities.putInContextUnderKey
 import io.customer.datapipelines.extensions.toJsonObject
-import io.customer.datapipelines.util.EventNames
 import io.customer.datapipelines.util.SegmentInstantFormatter
 import io.customer.sdk.CustomerIO
 import io.customer.sdk.core.di.SDKComponent
 import io.customer.sdk.core.util.Logger
+import io.customer.sdk.util.EventNames
 import io.customer.tracking.migration.MigrationAssistant
 import io.customer.tracking.migration.MigrationProcessor
 import io.customer.tracking.migration.request.MigrationTask

datapipelines/src/main/kotlin/io/customer/datapipelines/plugins/AutoTrackDeviceAttributesPlugin.kt

@@ -5,7 +5,7 @@ import com.segment.analytics.kotlin.core.BaseEvent
 import com.segment.analytics.kotlin.core.TrackEvent
 import com.segment.analytics.kotlin.core.platform.Plugin
 import com.segment.analytics.kotlin.core.utilities.putAll
-import io.customer.datapipelines.util.EventNames
+import io.customer.sdk.util.EventNames
 import kotlinx.serialization.json.buildJsonObject
 import kotlinx.serialization.json.jsonObject
 

datapipelines/src/main/kotlin/io/customer/sdk/CustomerIO.kt

@@ -23,7 +23,6 @@ import io.customer.datapipelines.plugins.ContextPlugin
 import io.customer.datapipelines.plugins.CustomerIODestination
 import io.customer.datapipelines.plugins.DataPipelinePublishedEvents
 import io.customer.datapipelines.plugins.ScreenFilterPlugin
-import io.customer.datapipelines.util.EventNames
 import io.customer.sdk.communication.Event
 import io.customer.sdk.communication.subscribe
 import io.customer.sdk.core.di.AndroidSDKComponent
@@ -32,7 +31,9 @@ import io.customer.sdk.core.module.CustomerIOModule
 import io.customer.sdk.core.util.CioLogLevel
 import io.customer.sdk.core.util.Logger
 import io.customer.sdk.data.model.CustomAttributes
+import io.customer.sdk.data.model.Settings
 import io.customer.sdk.events.TrackMetric
+import io.customer.sdk.util.EventNames
 import io.customer.tracking.migration.MigrationProcessor
 import kotlinx.serialization.SerializationStrategy
 import kotlinx.serialization.serializer
@@ -173,6 +174,12 @@ class CustomerIO private constructor(
         logger.debug("CustomerIO SDK initialized with DataPipelines module.")
         // Migrate unsent events from previous version
         migrateTrackingEvents()
+
+        // save settings to storage
+        analytics.configuration.let { config ->
+            val settings = Settings(writeKey = config.writeKey, apiHost = config.apiHost)
+            globalPreferenceStore.saveSettings(settings)
+        }
     }
 
     override var profileAttributes: CustomAttributes

datapipelines/src/test/java/io/customer/datapipelines/DataPipelinesCompatibilityTests.kt

@@ -14,13 +14,13 @@ import io.customer.datapipelines.testutils.extensions.deviceToken
 import io.customer.datapipelines.testutils.extensions.encodeToJsonElement
 import io.customer.datapipelines.testutils.extensions.shouldMatchTo
 import io.customer.datapipelines.testutils.extensions.toJsonObject
-import io.customer.datapipelines.util.EventNames
 import io.customer.sdk.core.di.SDKComponent
 import io.customer.sdk.data.model.CustomAttributes
 import io.customer.sdk.data.store.DeviceStore
 import io.customer.sdk.data.store.GlobalPreferenceStore
 import io.customer.sdk.events.Metric
 import io.customer.sdk.events.TrackMetric
+import io.customer.sdk.util.EventNames
 import io.mockk.every
 import kotlinx.coroutines.test.runTest
 import kotlinx.serialization.json.JsonArray

datapipelines/src/test/java/io/customer/datapipelines/DataPipelinesInteractionTests.kt

@@ -13,11 +13,12 @@ import io.customer.datapipelines.testutils.utils.OutputReaderPlugin
 import io.customer.datapipelines.testutils.utils.identifyEvents
 import io.customer.datapipelines.testutils.utils.screenEvents
 import io.customer.datapipelines.testutils.utils.trackEvents
-import io.customer.datapipelines.util.EventNames
 import io.customer.sdk.core.di.SDKComponent
 import io.customer.sdk.data.model.CustomAttributes
+import io.customer.sdk.data.model.Settings
 import io.customer.sdk.data.store.DeviceStore
 import io.customer.sdk.data.store.GlobalPreferenceStore
+import io.customer.sdk.util.EventNames
 import io.mockk.every
 import kotlinx.serialization.json.buildJsonObject
 import kotlinx.serialization.json.put
@@ -593,6 +594,11 @@ class DataPipelinesInteractionTests : JUnitTest() {
         deviceRegisterEvent.context.deviceToken shouldBeEqualTo givenToken
     }
 
+    @Test
+    fun device_givenSDKInitialized_expectSettingsToBeStored() {
+        assertCalledOnce { globalPreferenceStore.saveSettings(Settings(writeKey = analytics.configuration.writeKey, apiHost = analytics.configuration.apiHost)) }
+    }
+
     @Test
     fun device_givenRegisterTokenWhenNoProfileIdentified_expectStoreAndRegisterDeviceForAnonymousProfile() {
         val givenToken = String.random

datapipelines/src/test/java/io/customer/datapipelines/DeviceAttributesTests.kt

@@ -12,9 +12,9 @@ import io.customer.datapipelines.testutils.extensions.deviceToken
 import io.customer.datapipelines.testutils.extensions.encodeToJsonValue
 import io.customer.datapipelines.testutils.utils.OutputReaderPlugin
 import io.customer.datapipelines.testutils.utils.trackEvents
-import io.customer.datapipelines.util.EventNames
 import io.customer.sdk.core.di.SDKComponent
 import io.customer.sdk.data.store.GlobalPreferenceStore
+import io.customer.sdk.util.EventNames
 import io.mockk.every
 import kotlinx.serialization.json.booleanOrNull
 import kotlinx.serialization.json.intOrNull

datapipelines/src/test/java/io/customer/datapipelines/migration/TrackingMigrationProcessorTest.kt

@@ -18,12 +18,12 @@ import io.customer.datapipelines.testutils.utils.OutputReaderPlugin
 import io.customer.datapipelines.testutils.utils.identifyEvents
 import io.customer.datapipelines.testutils.utils.screenEvents
 import io.customer.datapipelines.testutils.utils.trackEvents
-import io.customer.datapipelines.util.EventNames
 import io.customer.datapipelines.util.SegmentInstantFormatter
 import io.customer.sdk.core.di.SDKComponent
 import io.customer.sdk.data.store.GlobalPreferenceStore
 import io.customer.sdk.events.Metric
 import io.customer.sdk.events.serializedName
+import io.customer.sdk.util.EventNames
 import io.customer.tracking.migration.MigrationProcessor
 import io.customer.tracking.migration.request.MigrationTask
 import io.mockk.every

messagingpush/src/main/java/io/customer/messagingpush/PushDeliveryTracker.kt

@@ -0,0 +1,56 @@
+package io.customer.messagingpush
+
+import io.customer.messagingpush.di.httpClient
+import io.customer.messagingpush.network.HttpClient
+import io.customer.messagingpush.network.HttpRequestParams
+import io.customer.sdk.core.di.SDKComponent
+import io.customer.sdk.util.EventNames
+import org.json.JSONObject
+
+internal interface PushDeliveryTracker {
+    fun trackMetric(token: String, event: String, deliveryId: String, onComplete: ((Result<Unit>) -> Unit?)? = null)
+}
+
+internal class PushDeliveryTrackerImpl : PushDeliveryTracker {
+
+    private val httpClient: HttpClient
+        get() = SDKComponent.httpClient
+
+    /**
+     * Tracks a metric by performing a single POST request with JSON.
+     * Returns a `Result<Unit>`.
+     */
+    override fun trackMetric(
+        token: String,
+        event: String,
+        deliveryId: String,
+        onComplete: ((Result<Unit>) -> Unit?)?
+    ) {
+        val propertiesJson = JSONObject().apply {
+            put("recipient", token)
+            put("metric", event.lowercase())
+            put("deliveryId", deliveryId)
+        }
+        val topLevelJson = JSONObject().apply {
+            put("anonymousId", deliveryId)
+            put("properties", propertiesJson)
+            put("event", EventNames.METRIC_DELIVERY)
+        }
+
+        val params = HttpRequestParams(
+            path = "/track",
+            headers = mapOf(
+                "Content-Type" to "application/json; charset=utf-8"
+            ),
+            body = topLevelJson.toString()
+        )
+
+        // Perform request
+        httpClient.request(params) { result ->
+            val mappedResult = result.map { /* we only need success/failure */ }
+            if (onComplete != null) {
+                onComplete(mappedResult)
+            }
+        }
+    }
+}

messagingpush/src/main/java/io/customer/messagingpush/di/DiGraphMessagingPush.kt

@@ -5,6 +5,10 @@ package io.customer.messagingpush.di
 import io.customer.base.internal.InternalCustomerIOApi
 import io.customer.messagingpush.MessagingPushModuleConfig
 import io.customer.messagingpush.ModuleMessagingPushFCM
+import io.customer.messagingpush.PushDeliveryTracker
+import io.customer.messagingpush.PushDeliveryTrackerImpl
+import io.customer.messagingpush.network.HttpClient
+import io.customer.messagingpush.network.HttpClientImpl
 import io.customer.messagingpush.processor.PushMessageProcessor
 import io.customer.messagingpush.processor.PushMessageProcessorImpl
 import io.customer.messagingpush.provider.DeviceTokenProvider
@@ -45,3 +49,9 @@ internal val SDKComponent.pushMessageProcessor: PushMessageProcessor
             deepLinkUtil = deepLinkUtil
         )
     }
+
+internal val SDKComponent.httpClient: HttpClient
+    get() = singleton<HttpClient> { HttpClientImpl() }
+
+internal val SDKComponent.pushDeliveryTracker: PushDeliveryTracker
+    get() = singleton<PushDeliveryTracker> { PushDeliveryTrackerImpl() }