package com.strmr.ps.data.supabase;

import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import defpackage.e6a;
import defpackage.jl8;
import defpackage.l43;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
final class q<T> implements l43 {
    public final /* synthetic */ DeviceManager a;

    public q(DeviceManager deviceManager) {
        this.a = deviceManager;
    }

    @Override // defpackage.l43
    public final Object emit(Object obj, Continuation continuation) {
        jl8 jl8Var = (jl8) obj;
        boolean z = jl8Var instanceof jl8.a;
        e6a e6aVar = e6a.a;
        DeviceManager deviceManager = this.a;
        if (z) {
            deviceManager.c = 0;
            deviceManager.d = false;
            Boxing.boxInt(Log.d("DeviceManager", "Session authenticated (auto-refresh handled by SDK)"));
            return e6aVar;
        }
        if (jl8Var instanceof jl8.c) {
            if (((Boolean) deviceManager.e.getValue()).booleanValue()) {
                Log.w("DeviceManager", "Session became unauthenticated - user may need to re-link device");
                return e6aVar;
            }
        } else if ((jl8Var instanceof jl8.d) && !deviceManager.d) {
            int i = deviceManager.c + 1;
            deviceManager.c = i;
            Log.w("DeviceManager", "Session refresh failed (" + i + "/5 consecutive): " + ((jl8.d) jl8Var).a);
            if (deviceManager.c >= 5) {
                deviceManager.d = true;
                Log.e("DeviceManager", "Supabase auth circuit breaker tripped — suppressing further failure handling");
            }
        }
        return e6aVar;
    }
}