ibrahimsn98

import android.content.pm.PackageManager;
import android.graphics.Bitmap;
import android.graphics.Canvas;
import android.graphics.Path;
import android.graphics.drawable.AdaptiveIconDrawable;
import android.graphics.drawable.BitmapDrawable;
import android.graphics.drawable.Drawable;
import android.graphics.drawable.LayerDrawable;
import android.os.Build;

ibrahimsn98

First of all, please note that token expiration and revoking are two different things.

1. Expiration only happens for web apps, not for native mobile apps, because native apps never expire.
2. Revoking only happens when (1) uses click the logout button on the website or native Apps;(2) users reset their passwords; (3) users revoke their tokens explicitly in the administration panel.

1. How to hadle JWT expiration

A JWT token that never expires is dangerous if the token is stolen then someone can always access the user's data.

Quoted from JWT RFC:

ibrahimsn98

internal class BatchEventOperation : Operation {

    override suspend fun operate(demeter: Demeter) {
        val events = demeter.eventDataProvider.fetchAwaitingEvents(FETCH_EVENT_SIZE)
        
        ...

        demeter.eventDataProvider.updateEventStatus(
            events = events,
            eventStatus = EventStatus.PROCESSING,

ibrahimsn98

class MealDemeterEventDispatcher @Inject constructor(
    @MealDemeter private val demeter: Demeter,
) : EventDispatcher {

    override fun report(event: Event) {
        val eventData = event.getData().analyticsMap[MealEvent.DEMETER] ?: return
        
        ...

        when (eventGroup) {

ibrahimsn98

demeter.addEventResultReporter(DemeterResultReporter())

...

class DemeterResultReporter : EventResultReporter {

    override fun report(result: Result<String>) {
        if (result.isFailure) {
            // Report the result
        }

ibrahimsn98

{
    "session_id": "...",
    "platform": "...",
    "timestamp": "...",
    "os_version": "...",
    "app_version": "...",
    "domain": "...",
    "channel": "...",
    "parameters": {
        "event_param1": "...",

ibrahimsn98

 LifecycleAwareTimer.Builder()
        .interval(DISPATCHER_TIMER_INTERVAL)
        .scope(dispatcherScope)
        .lifecycleOwner(ProcessLifecycleOwner.get())
        .onInterval(this::onInterval)
        .build()

ibrahimsn98

internal class DemeterInitializer : Initializer {

    override suspend fun initialize(demeter: Demeter) {
        demeter.eventDataProvider.updateEventStatus(EventStatus.AWAITING)
    }
}

ibrahimsn98

internal class OperationQueue(demeter: Demeter, coroutineScope: CoroutineScope) {

    private val queue = Channel<Operation>(BUFFER_SIZE)

    init {
        queue.receiveAsFlow()
            .onEach { operation ->
                runCatching {
                    operation.operate(demeter)
                }.onFailure {

ibrahimsn98

class MealDemeterInterceptor @Inject constructor(
    private val buildConfigProvider: BuildConfigProvider,
    private val buildModelProvider: BuildModelProvider,
) : Demeter.Interceptor {
 
    override suspend fun intercept(parameters: Parameters): Parameters {
        val mutableParameters = parameters.toMutableMap()
        mutableParameters["os_version"] = buildModelProvider.getBuildVersion()
        mutableParameters["app_version"] = buildConfigProvider.getAppVersionName()
        mutableParameters["domain"] = DOMAIN