Customer Obsession Questions

// Kotlin (Android) — WorkManager Worker to batch-send analytics
class AnalyticsWorker(
    ctx: Context,
    params: WorkerParameters
): CoroutineWorker(ctx, params) {

    private val repo = AnalyticsRepository(ctx) // handles queue, storage, network

    override suspend fun doWork(): Result {
        val now = System.currentTimeMillis()
        val cutoff = now - TimeUnit.HOURS.toMillis(24)

        // 1) If there are events older than 24h, send them regardless of connectivity
        val stale = repo.peekOlderThan(cutoff)
        if (stale.isNotEmpty()) {
            repo.sendBatch(stale) // blocking suspend; handles retries/backoff
            repo.remove(stale)
            return Result.success()
        }

        // 2) Otherwise, if constraints satisfied (WorkManager ensures this task only runs when constraints met),
        // send a bounded-size batch to avoid large network ops.
        val batch = repo.peekRecentBatch(limit = 100)
        if (batch.isEmpty()) return Result.success()

        return try {
            repo.sendBatch(batch)
            repo.remove(batch)
            Result.success()
        } catch (e: Exception) {
            Result.retry()
        }
    }

    companion object {
        fun schedule(context: Context) {
            val constraints = Constraints.Builder()
                .setRequiredNetworkType(NetworkType.UNMETERED) // Wi‑Fi
                .setRequiresCharging(true)
                .build()

            val req = PeriodicWorkRequestBuilder<AnalyticsWorker>(15, TimeUnit.MINUTES)
                .setConstraints(constraints)
                .setBackoffCriteria(BackoffPolicy.EXPONENTIAL, 30, TimeUnit.SECONDS)
                .build()

            WorkManager.getInstance(context).enqueueUniquePeriodicWork(
                "analytics-sync",
                ExistingPeriodicWorkPolicy.KEEP,
                req
            )
        }
    }
}