kiosk-ops-sdk/com.sarastarquant.kioskops.sdk.queue/QueueRepository

QueueRepository

@RestrictTo(value = [RestrictTo.Scope.LIBRARY])

class QueueRepository(context: Context, logs: RingLog, crypto: CryptoProvider, openHelperFactory: SupportSQLiteOpenHelper.Factory? = null)

Constructors

QueueRepository

constructor(context: Context, logs: RingLog, crypto: CryptoProvider, openHelperFactory: SupportSQLiteOpenHelper.Factory? = null)

Functions

applyRetention

suspend fun applyRetention(cfg: KioskOpsConfig)

Retention: delete SENT and FAILED events older than the configured window. This supports minimization requirements and prevents unbounded local storage growth.

countActive

suspend fun countActive(): Long

countActiveFlow

fun countActiveFlow(): Flow<Long>

Reactive queue depth: emits on every DB change that affects the non-SENT count.

decodePayloadJson

fun decodePayloadJson(e: QueueEventEntity): String

delete

suspend fun delete(id: String)

deleteByUserId

suspend fun deleteByUserId(userId: String): Int

enqueue

suspend fun enqueue(type: String, payloadJson: String, cfg: KioskOpsConfig, stableEventId: String? = null, idempotencyKeyOverride: String? = null, userId: String? = null, dataClassification: String? = null, anomalyScore: Float? = null): EnqueueResult

getAnomalous

suspend fun getAnomalous(threshold: Float): List<QueueEventEntity>

getByUserId

suspend fun getByUserId(userId: String): List<QueueEventEntity>

markBatchFailureNoAttemptBump

suspend fun markBatchFailureNoAttemptBump(id: String, err: String, nextAttemptAtMs: Long)

Record a batch-level failure for an event without incrementing its attempts counter. See QueueDao.markBatchFailureNoAttemptBump.

markFailed

suspend fun markFailed(id: String, err: String, nextAttemptAtMs: Long, permanentFailure: Int, quarantineReason: String? = null)

markSending

suspend fun markSending(id: String)

markSent

suspend fun markSent(id: String)

nextBatch

suspend fun nextBatch(nowMs: Long, limit: Int = 25): List<QueueEventEntity>

quarantinedSummaries

suspend fun quarantinedSummaries(limit: Int = 50): List<QuarantinedEventSummary>

reconcileStaleSending

suspend fun reconcileStaleSending(staleBeforeEpochMs: Long): Int

Reset SENDING rows older than staleBeforeEpochMs back to PENDING. Called on SDK init so crash-abandoned events don't rot forever. Returns number of rows rescued.