[MOBILE-4653] Fix resuming display not displaying IAX (#1491)

* [MOBILE-4653] Fix resuming display not displaying IAX

* Release 18.1.6

Author: rlepinski

CHANGELOG.md

@@ -2,6 +2,13 @@
 
 [Migration Guides](https://github.com/urbanairship/android-library/tree/main/documentation/migration)
 
+
+## Version 18.1.6 August 9, 2024
+Patch release that fixes in-app experience displays when resuming from a paused state. Apps that use in-app experiences are encouraged to update.
+
+### Changes
+- Fixed Automation Engine updates when pause state changes.
+
 ## Version 18.1.5, August 06, 2024
 Patch release that fixes test devices audience check and holdout group experiments displays.
 

build.gradle

@@ -1,7 +1,7 @@
 buildscript {
     ext {
         // Airship Version - major.minor.patch
-        airshipVersion = '18.1.5'
+        airshipVersion = '18.1.6'
 
         // Airship Version Qualifier beta, release, etc...
         // airshipVersionQualifier = "alpha"

urbanairship-automation/src/main/java/com/urbanairship/automation/engine/AutomationEngine.kt

@@ -22,7 +22,11 @@ import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.async
 import kotlinx.coroutines.cancelChildren
 import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.combine
+import kotlinx.coroutines.flow.distinctUntilChanged
+import kotlinx.coroutines.flow.drop
 import kotlinx.coroutines.flow.first
+import kotlinx.coroutines.flow.skip
 import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
@@ -122,6 +126,16 @@ internal class AutomationEngine(
                     }
                 }
             }
+
+            launch {
+                combine(isPaused, isExecutionPaused) { enginePaused, executionPaused ->
+                    enginePaused || executionPaused
+                }.distinctUntilChanged().collect { paused ->
+                    if (isActive && !paused) {
+                        scheduleConditionsChangedNotifier.notifyChanged()
+                    }
+                }
+            }
         }
     }
 

urbanairship-automation/src/test/java/com/urbanairship/automation/AutomationEngineTest.kt

@@ -30,6 +30,7 @@ import io.mockk.coVerifyOrder
 import io.mockk.coVerifySequence
 import io.mockk.every
 import io.mockk.mockk
+import io.mockk.verify
 import junit.framework.TestCase.assertFalse
 import junit.framework.TestCase.assertNotNull
 import junit.framework.TestCase.assertNull
@@ -95,6 +96,8 @@ public class AutomationEngineTest {
 
     private val delayProcessor: AutomationDelayProcessor = mockk(relaxed = true)
 
+    private val scheduleConditionsChangedNotifier: ScheduleConditionsChangedNotifier = mockk(relaxed = true)
+
     private val sleeper = TestTaskSleeper(clock) { sleep ->
         clock.currentTimeMillis += sleep.inWholeMilliseconds
     }
@@ -103,7 +106,7 @@ public class AutomationEngineTest {
         store = store,
         executor = executor,
         preparer = preparer,
-        scheduleConditionsChangedNotifier = ScheduleConditionsChangedNotifier(),
+        scheduleConditionsChangedNotifier = scheduleConditionsChangedNotifier,
         eventsFeed = eventsFeed,
         triggerProcessor = triggerProcessor,
         delayProcessor = delayProcessor,
@@ -196,6 +199,32 @@ public class AutomationEngineTest {
         assertFalse(engine.isPaused())
     }
 
+    @Test
+    public fun testResumeNotifiesScheduleConditionsChanged(): TestResult = runTest {
+        engine.setExecutionPaused(true)
+        engine.setEnginePaused(true)
+        engine.start()
+        advanceUntilIdle()
+
+        verify(exactly = 0) {
+            scheduleConditionsChangedNotifier.notifyChanged()
+        }
+
+        engine.setExecutionPaused(false)
+        advanceUntilIdle()
+
+        verify(exactly = 0) {
+            scheduleConditionsChangedNotifier.notifyChanged()
+        }
+
+        engine.setEnginePaused(false)
+        advanceUntilIdle()
+
+        verify(exactly = 1) {
+            scheduleConditionsChangedNotifier.notifyChanged()
+        }
+    }
+
     @Test
     public fun testSetExecutionPaused(): TestResult = runTest {
         coEvery { store.updateSchedule(eq("test"), any()) } answers { scheduleData }