Integrate 42 day confirmation pixel

Author: karlenDimla

pir/pir-impl/src/main/java/com/duckduckgo/pir/impl/pixels/OptOutConfirmationReporter.kt

@@ -52,9 +52,10 @@ class RealOptOutConfirmationReporter @Inject constructor(
             if (activeBrokers.isEmpty() || allValidRequestedOptOutJobs.isEmpty()) return@withContext
 
             allValidRequestedOptOutJobs.also {
+                // Fire 7 day pixel
                 it.attemptFirePixelForConfirmationDay(
                     activeBrokers,
-                    7,
+                    INTERVAL_DAY_7,
                     { jobRecord -> jobRecord.confirmation7dayReportSentDateMs == 0L },
                     { brokerUrl -> pixelSender.reportBrokerOptOutConfirmed7Days(brokerUrl) },
                     { brokerUrl -> pixelSender.reportBrokerOptOutUnconfirmed7Days(brokerUrl) },
@@ -63,9 +64,10 @@ class RealOptOutConfirmationReporter @Inject constructor(
                     },
                 )
 
+                // Fire 14 day pixel
                 it.attemptFirePixelForConfirmationDay(
                     activeBrokers,
-                    14,
+                    INTERVAL_DAY_14,
                     { jobRecord -> jobRecord.confirmation14dayReportSentDateMs == 0L },
                     { brokerUrl -> pixelSender.reportBrokerOptOutConfirmed14Days(brokerUrl) },
                     { brokerUrl -> pixelSender.reportBrokerOptOutUnconfirmed14Days(brokerUrl) },
@@ -74,16 +76,29 @@ class RealOptOutConfirmationReporter @Inject constructor(
                     },
                 )
 
+                // Fire 21 day pixel
                 it.attemptFirePixelForConfirmationDay(
                     activeBrokers,
-                    21,
+                    INTERVAL_DAY_21,
                     { jobRecord -> jobRecord.confirmation21dayReportSentDateMs == 0L },
                     { brokerUrl -> pixelSender.reportBrokerOptOutConfirmed21Days(brokerUrl) },
                     { brokerUrl -> pixelSender.reportBrokerOptOutUnconfirmed21Days(brokerUrl) },
                     { jobRecord, now ->
                         pirSchedulingRepository.markOptOutDay21ConfirmationPixelSent(jobRecord.extractedProfileId, now)
                     },
                 )
+
+                // Fire 42 day pixel
+                it.attemptFirePixelForConfirmationDay(
+                    activeBrokers,
+                    INTERVAL_DAY_42,
+                    { jobRecord -> jobRecord.confirmation42dayReportSentDateMs == 0L },
+                    { brokerUrl -> pixelSender.reportBrokerOptOutConfirmed42Days(brokerUrl) },
+                    { brokerUrl -> pixelSender.reportBrokerOptOutUnconfirmed42Days(brokerUrl) },
+                    { jobRecord, now ->
+                        pirSchedulingRepository.markOptOutDay42ConfirmationPixelSent(jobRecord.extractedProfileId, now)
+                    },
+                )
             }
         }
     }
@@ -120,4 +135,11 @@ class RealOptOutConfirmationReporter @Inject constructor(
     ): Boolean {
         return now >= this.optOutRequestedDateInMillis + TimeUnit.DAYS.toMillis(interval)
     }
+
+    companion object {
+        private const val INTERVAL_DAY_7 = 7L
+        private const val INTERVAL_DAY_14 = 14L
+        private const val INTERVAL_DAY_21 = 21L
+        private const val INTERVAL_DAY_42 = 42L
+    }
 }

pir/pir-impl/src/main/java/com/duckduckgo/pir/impl/store/PirSchedulingRepository.kt

@@ -140,6 +140,11 @@ interface PirSchedulingRepository {
         extractedProfileId: Long,
         timestampMs: Long,
     )
+
+    suspend fun markOptOutDay42ConfirmationPixelSent(
+        extractedProfileId: Long,
+        timestampMs: Long,
+    )
 }
 
 @ContributesBinding(
@@ -362,6 +367,15 @@ class RealPirSchedulingRepository @Inject constructor(
         }
     }
 
+    override suspend fun markOptOutDay42ConfirmationPixelSent(
+        extractedProfileId: Long,
+        timestampMs: Long,
+    ) {
+        withContext(dispatcherProvider.io()) {
+            jobSchedulingDao()?.update42DayConfirmationReportSentDate(extractedProfileId, timestampMs)
+        }
+    }
+
     private fun ScanJobRecordEntity.toRecord(): ScanJobRecord =
         ScanJobRecord(
             brokerName = this.brokerName,

pir/pir-impl/src/main/java/com/duckduckgo/pir/impl/store/db/JobSchedulingDao.kt

@@ -154,4 +154,16 @@ interface JobSchedulingDao {
         extractedProfileId: Long,
         newDate: Long,
     )
+
+    @Query(
+        """
+    UPDATE pir_optout_job_record
+    SET reporting_fortyTwoDayConfirmationReportSentDateMs = :newDate
+    WHERE extractedProfileId = :extractedProfileId
+    """,
+    )
+    fun update42DayConfirmationReportSentDate(
+        extractedProfileId: Long,
+        newDate: Long,
+    )
 }