Feat/push notification

personalization-sdk/src/main/AndroidManifest.xml

@@ -18,13 +18,14 @@
             </intent-filter>
         </service>
         <receiver
-            android:name=".notification.NotificationBroadcastReceiver"
+            android:name=".features.notification.data.broadcast.NotificationBroadcastReceiver"
             android:enabled="true"
             android:exported="false">
             <intent-filter>
                 <action android:name="ACTION_NEXT_IMAGE" />
                 <action android:name="ACTION_PREVIOUS_IMAGE" />
             </intent-filter>
         </receiver>
+
     </application>
 </manifest>

personalization-sdk/src/main/kotlin/com/personalization/SDK.kt

@@ -15,8 +15,8 @@ import com.personalization.api.managers.RecommendationManager
 import com.personalization.api.managers.SearchManager
 import com.personalization.api.managers.TrackEventManager
 import com.personalization.di.DaggerSdkComponent
-import com.personalization.notification.NotificationHandler
-import com.personalization.notification.NotificationHelper
+import com.personalization.features.notification.presentation.helpers.NotificationHelper
+import com.personalization.handlers.notifications.NotificationHandler
 import com.personalization.sdk.domain.usecases.network.AddTaskToQueueUseCase
 import com.personalization.sdk.domain.usecases.network.InitNetworkUseCase
 import com.personalization.sdk.domain.usecases.network.SendNetworkMethodUseCase
@@ -121,7 +121,6 @@ open class SDK {
 
         segment = getPreferencesValueUseCase.getSegment()
 
-        NotificationHelper.notificationType = notificationType
         NotificationHelper.notificationId = notificationId
 
         notificationHandler.initialize(context)
@@ -805,7 +804,7 @@ open class SDK {
         notificationReceived(remoteMessage.data)
 
         onMessageListener?.let { listener ->
-            val data = notificationHandler.prepareData(remoteMessage)
+            val data = notificationHandler.prepareData(remoteMessage = remoteMessage)
             listener.onMessage(data)
         }
     }

personalization-sdk/src/main/kotlin/com/personalization/errors/actions.error.kt

@@ -0,0 +1,18 @@
+package com.personalization.errors
+
+import android.util.Log
+
+class ActionsError(
+    private val tag: String,
+    private val functionName: String,
+    private val actionName: String,
+    private val message: String,
+) {
+
+    fun logError() {
+        Log.e(
+            /* tag = */ tag,
+            /* msg = */ "Error caught in $functionName : $message $actionName"
+        )
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/errors/emptyField.error.kt

@@ -0,0 +1,17 @@
+package com.personalization.errors
+
+import android.util.Log
+
+class EmptyFieldError(
+    private val tag: String,
+    private val functionName: String,
+    private val message: String,
+) {
+
+    fun logError() {
+        Log.e(
+            /* tag = */ tag,
+            /* msg = */ "Error caught in $functionName : $message"
+        )
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/errors/network.error.kt

@@ -0,0 +1,16 @@
+package com.personalization.errors
+
+import android.util.Log
+
+class NetworkError(
+    private val tag: String,
+    private val functionName: String
+) {
+
+    fun logError() {
+        Log.e(
+            /* tag = */ tag,
+            /* msg = */ "Error caught in $functionName : Network connection issue "
+        )
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/errors/parsing.error.kt

@@ -0,0 +1,17 @@
+package com.personalization.errors
+
+import android.util.Log
+
+class ParsingJsonError(
+    private val tag: String,
+    private val functionName: String,
+    private val message: String
+) {
+
+    fun logError() {
+        Log.e(
+            /* tag = */ tag,
+            /* msg = */ "Error caught in $functionName: $message"
+        )
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/errors/resourceLoading.error.kt

@@ -0,0 +1,17 @@
+package com.personalization.errors
+
+import android.util.Log
+
+class ResourceLoadError(
+    private val tag: String,
+    private val functionName: String,
+    private val message: String
+) {
+
+    fun logError() {
+        Log.e(
+            /* tag = */ tag,
+            /* msg = */ "Error caught in $functionName: $message"
+        )
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/features/notification/data/broadcast/NotificationBroadcastReceiver.kt

@@ -0,0 +1,81 @@
+package com.personalization.features.notification.data.broadcast
+
+import android.content.BroadcastReceiver
+import android.content.Context
+import android.content.Intent
+import androidx.work.Constraints
+import androidx.work.Data
+import androidx.work.ExistingWorkPolicy
+import androidx.work.NetworkType
+import androidx.work.OneTimeWorkRequestBuilder
+import androidx.work.WorkManager
+import com.personalization.errors.ActionsError
+import com.personalization.errors.EmptyFieldError
+import com.personalization.features.notification.data.worker.UpdateNotificationWorker
+import com.personalization.features.notification.domain.model.NotificationConstants.ACTION_NEXT_IMAGE
+import com.personalization.features.notification.domain.model.NotificationConstants.ACTION_PREVIOUS_IMAGE
+import com.personalization.features.notification.domain.model.NotificationConstants.CURRENT_IMAGE_INDEX
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_BODY
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_IMAGES
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_TITLE
+
+class NotificationBroadcastReceiver : BroadcastReceiver() {
+
+    override fun onReceive(context: Context, intent: Intent) {
+        val action = intent.action
+        val currentIndex = intent.getIntExtra(CURRENT_IMAGE_INDEX, 0)
+        val images = intent.getStringExtra(NOTIFICATION_IMAGES)
+        val title = intent.getStringExtra(NOTIFICATION_TITLE)
+        val body = intent.getStringExtra(NOTIFICATION_BODY)
+
+        when (action) {
+            ACTION_NEXT_IMAGE, ACTION_PREVIOUS_IMAGE -> {
+                when {
+                    !images.isNullOrEmpty() && !title.isNullOrEmpty() && !body.isNullOrEmpty() -> {
+                        val inputData = Data.Builder()
+                            .putString(NOTIFICATION_IMAGES, images)
+                            .putString(NOTIFICATION_TITLE, title)
+                            .putString(NOTIFICATION_BODY, body)
+                            .putInt(CURRENT_IMAGE_INDEX, currentIndex)
+                            .build()
+
+                        val updateNotificationWork =
+                            OneTimeWorkRequestBuilder<UpdateNotificationWorker>()
+                                .setInputData(inputData)
+                                .setConstraints(
+                                    Constraints.Builder().setRequiredNetworkType(
+                                        networkType = NetworkType.UNMETERED
+                                    ).build()
+                                )
+                                .build()
+
+                        WorkManager.getInstance(context).enqueueUniqueWork(
+                            /* uniqueWorkName = */ UPDATE_WORK,
+                            /* existingWorkPolicy = */ ExistingWorkPolicy.APPEND_OR_REPLACE,
+                            /* work = */ updateNotificationWork
+                        )
+                    }
+
+                    else -> EmptyFieldError(
+                        tag = TAG,
+                        functionName = FUNC_ON_RECEIVE,
+                        message = "One of the fields is empty or null"
+                    ).logError()
+                }
+            }
+
+            else -> ActionsError(
+                tag = TAG,
+                functionName = FUNC_ON_RECEIVE,
+                actionName = action.orEmpty(),
+                message = "Due to unknown action"
+            ).logError()
+        }
+    }
+
+    companion object {
+        private const val TAG = "NotificationBroadcastReceiver"
+        private const val FUNC_ON_RECEIVE = "OnReceive"
+        private const val UPDATE_WORK = "update_notification_work"
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/features/notification/data/helpers/NotificationChannelHelper.kt

@@ -0,0 +1,25 @@
+package com.personalization.features.notification.data.helpers
+
+import android.app.NotificationChannel
+import android.app.NotificationManager
+import android.content.Context
+import android.os.Build
+import com.personalization.R
+
+object NotificationChannelHelper {
+
+    fun createNotificationChannel(context: Context) {
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+            val channelId = context.getString(R.string.notification_channel_id)
+            val channelName = context.getString(R.string.notification_channel_name)
+            val notificationManager = context.getSystemService(NotificationManager::class.java)
+            notificationManager?.createNotificationChannel(
+                /* channel = */ NotificationChannel(
+                    /* id = */ channelId,
+                    /* name = */ channelName,
+                    /* importance = */ NotificationManager.IMPORTANCE_LOW
+                )
+            )
+        }
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/features/notification/data/mapper/NotificationDataMapper.kt

@@ -0,0 +1,34 @@
+package com.personalization.features.notification.data.mapper
+
+import com.google.firebase.messaging.RemoteMessage
+import com.personalization.features.notification.domain.model.NotificationConstants.ANALYTICS_LABEL_FIELD
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_BODY
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_IMAGES
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_TITLE
+
+object NotificationDataMapper {
+
+    fun mapRemoteMessageToData(remoteMessage: RemoteMessage): MutableMap<String, String> {
+        val data: MutableMap<String, String> = HashMap(remoteMessage.data)
+        remoteMessage.notification?.let { notification ->
+            addNotificationData(
+                notification = notification,
+                data = data
+            )
+        }
+        data[NOTIFICATION_IMAGES]?.takeIf { it.isNotEmpty() }
+            ?.let { data[NOTIFICATION_IMAGES] = it }
+        data[ANALYTICS_LABEL_FIELD]?.takeIf { it.isNotEmpty() }
+            ?.let { data[ANALYTICS_LABEL_FIELD] = it }
+        return data
+    }
+
+    private fun addNotificationData(
+        notification: RemoteMessage.Notification,
+        data: MutableMap<String, String>
+    ) {
+        notification.title?.takeIf { it.isNotEmpty() }?.let { data[NOTIFICATION_TITLE] = it }
+        notification.body?.takeIf { it.isNotEmpty() }?.let { data[NOTIFICATION_BODY] = it }
+        notification.imageUrl?.let { data[NOTIFICATION_IMAGES] = it.toString() }
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/features/notification/data/worker/UpdateNotificationWorker.kt

@@ -0,0 +1,68 @@
+package com.personalization.features.notification.data.worker
+
+import android.content.Context
+import androidx.work.CoroutineWorker
+import androidx.work.WorkerParameters
+import com.personalization.SDK
+import com.personalization.errors.NetworkError
+import com.personalization.features.notification.domain.model.NotificationConstants.CURRENT_IMAGE_INDEX
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_BODY
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_IMAGES
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_TITLE
+import com.personalization.features.notification.domain.model.NotificationData
+import com.personalization.features.notification.presentation.helpers.NotificationHelper
+import com.personalization.features.notification.presentation.helpers.NotificationImageHelper
+import java.io.IOException
+
+class UpdateNotificationWorker(
+    context: Context,
+    workerParams: WorkerParameters
+) : CoroutineWorker(context, workerParams) {
+
+    override suspend fun doWork(): Result {
+        val context = applicationContext
+
+        val newIndex = inputData.getInt(CURRENT_IMAGE_INDEX, 0)
+        val images = inputData.getString(NOTIFICATION_IMAGES)
+        val title = inputData.getString(NOTIFICATION_TITLE)
+        val body = inputData.getString(NOTIFICATION_BODY)
+
+        return if (images.isNullOrEmpty() || title.isNullOrEmpty() || body.isNullOrEmpty()) {
+            SDK.error("Invalid input data: images=$images, title=$title, body=$body")
+
+            Result.failure()
+        } else {
+
+            val data = NotificationData(
+                title = title,
+                body = body,
+                images = images
+            )
+
+            try {
+                val loadedImages = NotificationImageHelper.loadBitmaps(urls = images)
+
+                NotificationHelper.createNotification(
+                    context = context,
+                    notificationId = data.hashCode(),
+                    data = data,
+                    images = loadedImages,
+                    currentImageIndex = newIndex
+                )
+
+                Result.success()
+            } catch (ioException: IOException) {
+                NetworkError(
+                    tag = TAG,
+                    functionName = FUNC_DO_WORK
+                ).logError()
+                Result.failure()
+            }
+        }
+    }
+
+    companion object {
+        private const val TAG = "UpdateNotificationWorker"
+        private const val FUNC_DO_WORK = "DoWork"
+    }
+}

personalization-sdk/src/main/kotlin/com/personalization/features/notification/domain/helpers/NotificationClickHandler.kt

@@ -0,0 +1,44 @@
+package com.personalization.features.notification.domain.helpers
+
+import android.os.Bundle
+import com.personalization.errors.ParsingJsonError
+import com.personalization.features.notification.domain.model.NotificationConstants.CODE_PARAM
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_ID
+import com.personalization.features.notification.domain.model.NotificationConstants.NOTIFICATION_TYPE
+import com.personalization.features.notification.domain.model.NotificationConstants.TRACK_CLICKED
+import com.personalization.features.notification.domain.model.NotificationConstants.TYPE_PARAM
+import org.json.JSONException
+import org.json.JSONObject
+
+object NotificationClickHandler {
+
+    fun handleNotificationClick(
+        extras: Bundle?,
+        sendAsync: (String, JSONObject) -> Unit,
+        onResult: (type: String, code: String) -> Unit
+    ) {
+        if (extras == null) {
+            return
+        } else {
+            val type = extras.getString(NOTIFICATION_TYPE, null)
+            val code = extras.getString(NOTIFICATION_ID, null)
+
+            if (type != null && code != null) {
+                val params = JSONObject()
+                try {
+                    params.put(TYPE_PARAM, type)
+                    params.put(CODE_PARAM, code)
+                    sendAsync(TRACK_CLICKED, params)
+
+                    onResult(type, code)
+                } catch (jsonException: JSONException) {
+                    ParsingJsonError(
+                        tag = this@NotificationClickHandler.javaClass.name,
+                        functionName = "handleNotificationClick",
+                        message = jsonException.message.orEmpty()
+                    ).logError()
+                }
+            }
+        }
+    }
+}