From 706cf4028d84334c8566cf59bc3730cdb482ae04 Mon Sep 17 00:00:00 2001
From: Jaissica <jaissica.hora@rokt.com>
Date: Tue, 26 May 2026 11:40:35 -0400
Subject: [PATCH] feat: add BatchListener to forward mParticle batches to Rokt
 SDK

- Implement KitIntegration.BatchListener interface
- Forward full mParticle batch JSON via Rokt.receiveMParticleBatch()
- Enables Transactions API to receive mParticle event stream alongside native Rokt events
---
 src/main/kotlin/com/mparticle/kits/RoktKit.kt | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/main/kotlin/com/mparticle/kits/RoktKit.kt b/src/main/kotlin/com/mparticle/kits/RoktKit.kt
index 81d5566..9815e7b 100644
--- a/src/main/kotlin/com/mparticle/kits/RoktKit.kt
+++ b/src/main/kotlin/com/mparticle/kits/RoktKit.kt
@@ -57,6 +57,7 @@ class RoktKit :
     CommerceListener,
     IdentityListener,
     RoktListener,
+    KitIntegration.BatchListener,
     Rokt.RoktCallback {
     private var applicationContext: Context? = null
     private var mpRoktEventCallback: MpRoktEventCallback? = null
@@ -135,6 +136,18 @@ class RoktKit :
 
     override fun logEvent(commerceEvent: CommerceEvent): List<ReportingMessage> = emptyList()
 
+    /*
+     * Overrides for BatchListener
+     */
+    override fun logBatch(jsonObject: org.json.JSONObject): List<ReportingMessage> {
+        try {
+            Rokt.receiveMParticleBatch(jsonObject.toString())
+        } catch (e: Exception) {
+            Logger.warning("RoktKit: Failed to forward batch to Rokt: ${e.message}")
+        }
+        return emptyList()
+    }
+
     /*
      * Overrides for IdentityListener
      */