PIR Android: fix confirmation/maintenance scan for requested/removed opt outs (#6960)

Task/Issue URL:
https://app.asana.com/1/137249556945/project/488551667048375/task/1211207086563708?focus=true

### Description
See attached task description

### Steps to test this PR
https://app.asana.com/1/137249556945/task/1211672394316847?focus=true

Author: karlenDimla

pir/pir-impl/src/main/java/com/duckduckgo/pir/impl/scheduling/EligibleScanJobProvider.kt

@@ -71,16 +71,38 @@ class RealEligibleScanJobProvider @Inject constructor(
         }.sortedBy {
             it.attemptCount
         }.mapNotNull {
-            pirSchedulingRepository.getValidScanJobRecord(it.brokerName, it.userProfileId)
+            val schedulingConfig =
+                schedulingConfigs.find { config -> config.brokerName == it.brokerName }!!
+
+            val expectedScanDate = when (it.status) {
+                OptOutJobStatus.REQUESTED -> it.getRequestConfirmationScanDate(schedulingConfig)
+                OptOutJobStatus.REMOVED -> it.getRemovedMaintenanceScanDate(schedulingConfig)
+                else -> return@mapNotNull null
+            }
+            val scanJobRecord = pirSchedulingRepository.getValidScanJobRecord(it.brokerName, it.userProfileId)
+
+            // If the last scan happened more recently that the expected scan date from opt outs, it means we have already performed the
+            // maintenance scan / confirmation scan needed for this opt-out.
+            // More info on https://app.asana.com/1/137249556945/project/488551667048375/task/1211207086563708?focus=true
+            return@mapNotNull if (scanJobRecord != null && scanJobRecord.lastScanDateInMillis <= expectedScanDate) {
+                scanJobRecord
+            } else {
+                null
+            }
         }
     }
 
     private fun OptOutJobRecord.isRequestedAndShouldBeConfirmedNow(
         schedulingConfig: BrokerSchedulingConfig,
         timeInMillis: Long,
     ): Boolean {
-        return this.status == OptOutJobStatus.REQUESTED &&
-            (this.optOutRequestedDateInMillis + schedulingConfig.confirmOptOutScanInMillis) <= timeInMillis
+        return this.status == OptOutJobStatus.REQUESTED && this.getRequestConfirmationScanDate(schedulingConfig) <= timeInMillis
+    }
+
+    private fun OptOutJobRecord.getRequestConfirmationScanDate(
+        schedulingConfig: BrokerSchedulingConfig,
+    ): Long {
+        return this.optOutRequestedDateInMillis + schedulingConfig.confirmOptOutScanInMillis
     }
 
     private fun OptOutJobRecord.isRemovedAndShouldBeMaintainedNow(
@@ -90,7 +112,13 @@ class RealEligibleScanJobProvider @Inject constructor(
         return this.status == OptOutJobStatus.REMOVED &&
             // do not pick-up deprecated opt-out jobs for maintenance scans as they belong to invalid/removed profiles
             !this.deprecated &&
-            (this.optOutRemovedDateInMillis + schedulingConfig.maintenanceScanInMillis) <= timeInMillis
+            this.getRemovedMaintenanceScanDate(schedulingConfig) <= timeInMillis
+    }
+
+    private fun OptOutJobRecord.getRemovedMaintenanceScanDate(
+        schedulingConfig: BrokerSchedulingConfig,
+    ): Long {
+        return this.optOutRemovedDateInMillis + schedulingConfig.maintenanceScanInMillis
     }
 
     private suspend fun getValidScanJobsFromScanJobRecords(

pir/pir-impl/src/test/kotlin/com/duckduckgo/pir/impl/scheduling/RealEligibleScanJobProviderTest.kt

@@ -30,6 +30,7 @@ import org.junit.Assert.assertTrue
 import org.junit.Before
 import org.junit.Rule
 import org.junit.Test
+import org.mockito.kotlin.any
 import org.mockito.kotlin.mock
 import org.mockito.kotlin.whenever
 import java.util.concurrent.TimeUnit
@@ -208,7 +209,7 @@ class RealEligibleScanJobProviderTest {
 
     @Test
     fun whenGetAllEligibleScanJobsWithOptOutRequestedAndDueForConfirmThenReturnScanRecord() = runTest {
-        val expectedScanRecord = scanJobRecordNotExecuted
+        val expectedScanRecord = scanJobRecordMatchFound
         whenever(mockPirRepository.getAllBrokerSchedulingConfigs()).thenReturn(listOf(brokerSchedulingConfig))
         whenever(mockPirSchedulingRepository.getAllValidOptOutJobRecords()).thenReturn(listOf(optOutJobRecordRequested))
         whenever(mockPirSchedulingRepository.getAllValidScanJobRecords()).thenReturn(emptyList())
@@ -404,9 +405,19 @@ class RealEligibleScanJobProviderTest {
         )
 
         // Create corresponding scan records for opt-out records
-        val scanFromOptOut1 = scanJobRecordNotExecuted.copy(userProfileId = 1001L)
-        val scanFromOptOut2 = scanJobRecordNotExecuted.copy(userProfileId = 1002L)
-        val scanFromOptOut3 = scanJobRecordNotExecuted.copy(userProfileId = 1003L)
+        val scanFromOptOut1 = scanJobRecordNotExecuted.copy(
+            userProfileId = 1001L,
+            lastScanDateInMillis = currentTimeMillis - TimeUnit.HOURS.toMillis(25),
+        )
+        val scanFromOptOut2 = scanJobRecordNotExecuted.copy(
+            userProfileId = 1002L,
+            lastScanDateInMillis = currentTimeMillis - TimeUnit.HOURS.toMillis(25),
+        )
+        val scanFromOptOut3 = scanJobRecordNotExecuted.copy(
+            userProfileId = 1003L,
+
+            lastScanDateInMillis = currentTimeMillis - TimeUnit.HOURS.toMillis(25),
+        )
 
         // Add a duplicate scan record that should be deduplicated
         val duplicateScanRecord = scanFromOptOut3.copy() // Same as scanRecord1
@@ -542,7 +553,7 @@ class RealEligibleScanJobProviderTest {
         // Deprecated flag only affects REMOVED opt-out records for maintenance scans,
         // REQUESTED opt-out records should still trigger confirmation scans
         val deprecatedOptOutRequested = optOutJobRecordRequested.copy(deprecated = true)
-        val expectedScanRecord = scanJobRecordNotExecuted
+        val expectedScanRecord = scanJobRecordMatchFound
 
         whenever(mockPirRepository.getAllBrokerSchedulingConfigs()).thenReturn(listOf(brokerSchedulingConfig))
         whenever(mockPirSchedulingRepository.getAllValidOptOutJobRecords()).thenReturn(listOf(deprecatedOptOutRequested))
@@ -602,8 +613,11 @@ class RealEligibleScanJobProviderTest {
         )
 
         val scanForDeprecatedRemoved = scanJobRecordNotExecuted.copy(userProfileId = 2001L)
-        val scanForNonDeprecatedRemoved = scanJobRecordNotExecuted.copy(userProfileId = 2002L)
-        val scanForRequested = scanJobRecordNotExecuted.copy(userProfileId = 3001L)
+        val scanForNonDeprecatedRemoved = scanJobRecordNotExecuted.copy(
+            userProfileId = 2002L,
+            lastScanDateInMillis = currentTimeMillis - DAYS.toMillis(1),
+        )
+        val scanForRequested = scanJobRecordNotExecuted.copy(userProfileId = 3001L, lastScanDateInMillis = currentTimeMillis - DAYS.toMillis(1))
 
         whenever(mockPirRepository.getAllBrokerSchedulingConfigs()).thenReturn(listOf(brokerSchedulingConfig))
         whenever(mockPirSchedulingRepository.getAllValidOptOutJobRecords()).thenReturn(
@@ -632,4 +646,54 @@ class RealEligibleScanJobProviderTest {
         assertTrue(result.none { it.userProfileId == 1001L }) // deprecated scan record filtered
         assertTrue(result.none { it.userProfileId == 2001L }) // deprecated removed opt-out filtered
     }
+
+    @Test
+    fun whenOptOutJobRecordIsRequestedButAlreadyScannedThenRecordIsNotEligible() = runTest {
+        // Confirmation scan should have happened 6 hours ago confirmation scan after 24 hours)
+        val requestedJobRecord = optOutJobRecordRequested.copy(
+            userProfileId = 125L,
+            optOutRequestedDateInMillis = currentTimeMillis - HOURS.toMillis(30),
+        )
+
+        // Scan just happened an hour ago
+        val scanJobRecord = scanJobRecordMatchFound.copy(
+            lastScanDateInMillis = currentTimeMillis - HOURS.toMillis(1),
+        )
+        whenever(mockPirRepository.getAllBrokerSchedulingConfigs()).thenReturn(listOf(brokerSchedulingConfig))
+        whenever(mockPirSchedulingRepository.getAllValidOptOutJobRecords()).thenReturn(listOf(requestedJobRecord))
+        whenever(mockPirSchedulingRepository.getValidScanJobRecord("test-broker", 2001L)).thenReturn(scanJobRecord)
+        whenever(mockPirSchedulingRepository.getAllValidScanJobRecords()).thenReturn(
+            listOf(scanJobRecord),
+        )
+
+        val result = testee.getAllEligibleScanJobs(currentTimeMillis)
+
+        // Opt-out not eligible as a scan already happened for the confirmation
+        assertTrue(result.isEmpty())
+    }
+
+    @Test
+    fun whenOptOutJobRecordIsRemovedButAlreadyScannedThenRecordIsNotEligible() = runTest {
+        // Maintenance scan should have happened 3 days ago. Maintenance scan after 7 days of removal)
+        val requestedJobRecord = optOutJobRecordRemoved.copy(
+            userProfileId = 125L,
+            optOutRemovedDateInMillis = currentTimeMillis - DAYS.toMillis(10),
+        )
+
+        // Scan just happened an hour ago
+        val scanJobRecord = scanJobRecordMatchFound.copy(
+            lastScanDateInMillis = currentTimeMillis - HOURS.toMillis(1),
+        )
+        whenever(mockPirRepository.getAllBrokerSchedulingConfigs()).thenReturn(listOf(brokerSchedulingConfig))
+        whenever(mockPirSchedulingRepository.getAllValidOptOutJobRecords()).thenReturn(listOf(requestedJobRecord))
+        whenever(mockPirSchedulingRepository.getValidScanJobRecord("test-broker", 2001L)).thenReturn(scanJobRecord)
+        whenever(mockPirSchedulingRepository.getAllValidScanJobRecords()).thenReturn(
+            listOf(scanJobRecord),
+        )
+
+        val result = testee.getAllEligibleScanJobs(currentTimeMillis)
+
+        // Opt-out not eligible as a scan already happened for the confirmation
+        assertTrue(result.isEmpty())
+    }
 }