Split events into chunks before sending

at-internet · Oct 19, 2023 · f5beab5 · f5beab5
1 parent 7abbf9b
commit f5beab5
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 6 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,10 @@
 # Piano Analytics SDK for Android
 
+## v3.3.4-SNAPSHOT
+* Updated dependencies:
+    - com.squareup.okhttp3:okhttp [4.11.0 -> 4.12.0]
+      https://square.github.io/okhttp/
+
 ## v3.3.3
 * Added `track` function to `MediaHelper` for tracking custom media events.
 * Changed behavior: `extraProps` in `MediaHelper` are added to all events, not only to "heartbeat" events.

diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -1,9 +1,9 @@
 [versions]
 # Plugins
 kotlin = "1.8.22"
-android = "8.1.1"
-versionUpdater = "0.47.0"
-ktlint = "11.5.1"
+android = "8.1.2"
+versionUpdater = "0.49.0"
+ktlint = "11.6.1"
 dokka = "1.8.20"
 mavenRelease = "0.25.3"
 moshiIR = "0.22.1"
@@ -18,7 +18,7 @@ materialLibrary = "1.9.0"
 googleAdsId = "18.0.1"
 huaweiAdsId = "3.4.26.303"
 retrofit = "2.6.4"
-okhttp = "4.11.0"
+okhttp = "4.12.0"
 moshi = "1.15.0"
 timber = "5.0.1"
 viewBindingProperty = "1.5.9"

diff --git a/piano-analytics/gradle.properties b/piano-analytics/gradle.properties
@@ -1,4 +1,4 @@
-VERSION_NAME=3.3.3
+VERSION_NAME=3.3.4-SNAPSHOT
 GROUP=io.piano.android
 POM_NAME=Analytics
 POM_ARTIFACT_ID=analytics

diff --git a/piano-analytics/src/main/java/io/piano/android/analytics/SendTask.kt b/piano-analytics/src/main/java/io/piano/android/analytics/SendTask.kt
@@ -28,7 +28,9 @@ internal class SendTask(
             Timber.w("Can't send events - no connection")
             return
         }
-        send(eventRepository.getNotSentEvents())
+        eventRepository.getNotSentEvents().chunked(CHUNK_SIZE).forEach {
+            send(it)
+        }
     }
 
     internal fun send(events: List<EventRecord>) {
@@ -58,5 +60,6 @@ internal class SendTask(
 
     companion object {
         internal val MEDIA_TYPE by lazy(LazyThreadSafetyMode.NONE) { "application/json; charset=UTF-8".toMediaType() }
+        private const val CHUNK_SIZE = 50
     }
 }