Merge branch 'coroutines' into coroutines-queue-manager

parsely/src/androidTest/java/com/parsely/parselyandroid/FunctionalTests.kt

@@ -18,6 +18,7 @@ import java.nio.file.Path
 import java.util.concurrent.TimeUnit
 import kotlin.io.path.Path
 import kotlin.time.Duration
+import kotlin.time.Duration.Companion.hours
 import kotlin.time.Duration.Companion.milliseconds
 import kotlin.time.Duration.Companion.seconds
 import kotlinx.coroutines.runBlocking
@@ -116,6 +117,43 @@ class FunctionalTests {
         }
     }
 
+    /**
+     * In this scenario, the consumer application:
+     * 1. Goes to the background
+     * 2. Is re-launched
+     * This pattern occurs twice, which allows us to confirm the following assertions:
+     * 1. The event request is triggered when the consumer application is moved to the background
+     * 2. If the consumer application is sent to the background again within a short interval,
+     * the request is not duplicated.
+     */
+    @Test
+    fun appSendsEventsWhenMovedToBackgroundAndDoesntSendDuplicatedRequestWhenItsMovedToBackgroundAgainQuickly() {
+        val device = UiDevice.getInstance(InstrumentationRegistry.getInstrumentation())
+        ActivityScenario.launch(SampleActivity::class.java).use { scenario ->
+            scenario.onActivity { activity: Activity ->
+                beforeEach(activity)
+                server.enqueue(MockResponse().setResponseCode(200))
+                server.enqueue(MockResponse().setResponseCode(200))
+                parselyTracker = initializeTracker(activity, flushInterval = 1.hours)
+
+                repeat(20) {
+                    parselyTracker.trackPageview("url", null, null, null)
+                }
+            }
+
+            device.pressHome()
+            device.pressRecentApps()
+            device.findObject(UiSelector().descriptionContains("com.parsely")).click()
+            device.pressHome()
+
+            val firstRequest = server.takeRequest(10000, TimeUnit.MILLISECONDS)?.toMap()
+            val secondRequest = server.takeRequest(10000, TimeUnit.MILLISECONDS)?.toMap()
+
+            assertThat(firstRequest!!["events"]).hasSize(20)
+            assertThat(secondRequest).isNull()
+        }
+    }
+
     /**
      * In this scenario we "stress test" the concurrency model to see if we have any conflict during
      *