package com.strmr.ps.data.remote;

import android.content.Context;
import android.net.ConnectivityManager;
import android.net.Network;
import android.net.NetworkCapabilities;
import android.net.NetworkRequest;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import dagger.hilt.android.qualifiers.ApplicationContext;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.dz5;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.hn2;
import defpackage.j43;
import defpackage.jn2;
import defpackage.k63;
import defpackage.kp6;
import defpackage.s38;
import defpackage.wi7;
import defpackage.xm6;
import defpackage.yi7;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0007\u0018\u00002\u00020\u0001:\u0001\u0006B\u0013\b\u0007\u0012\b\b\u0001\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005¨\u0006\u0007"}, d2 = {"Lcom/strmr/ps/data/remote/NetworkMonitor;", "", "Landroid/content/Context;", "context", "<init>", "(Landroid/content/Context;)V", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class NetworkMonitor {
    public final ConnectivityManager a;
    public final j43 b;

    /* JADX WARN: Failed to restore enum class, 'enum' modifier and super class removed */
    /* JADX WARN: Unknown enum class pattern. Please report as an issue! */
    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0010\n\u0000\b\u0086\u0081\u0002\u0018\u00002\b\u0012\u0004\u0012\u00020\u00000\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/remote/NetworkMonitor$a;", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class a {
        public static final /* synthetic */ a[] a;
        public static final /* synthetic */ hn2 b;

        static {
            a[] aVarArr = {new a("UNKNOWN", 0), new a("POOR", 1), new a("MODERATE", 2), new a("GOOD", 3), new a("EXCELLENT", 4)};
            a = aVarArr;
            b = jn2.a(aVarArr);
        }

        public static a valueOf(String str) {
            return (a) Enum.valueOf(a.class, str);
        }

        public static a[] values() {
            return (a[]) a.clone();
        }
    }

    @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\u00020\u0002*\b\u0012\u0004\u0012\u00020\u00010\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lyi7;", "", "Le6a;", "<anonymous>", "(Lyi7;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.remote.NetworkMonitor$isOnlineFlow$1", f = "NetworkMonitor.kt", i = {}, l = {104}, m = "invokeSuspend", n = {}, s = {})
    public static final class b extends SuspendLambda implements gr3<yi7<? super Boolean>, Continuation<? super e6a>, Object> {
        public int a;
        public /* synthetic */ Object b;

        public b(Continuation continuation) {
            super(2, continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation create(Object obj, Continuation continuation) {
            b bVar = NetworkMonitor.this.new b(continuation);
            bVar.b = obj;
            return bVar;
        }

        @Override // defpackage.gr3
        public final Object invoke(Object obj, Object obj2) {
            return ((b) create((yi7) obj, (Continuation) obj2)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.a;
            if (i == 0) {
                s38.b(obj);
                yi7 yi7Var = (yi7) this.b;
                xm6 xm6Var = new xm6(yi7Var);
                NetworkRequest networkRequestBuild = new NetworkRequest.Builder().addCapability(12).build();
                NetworkMonitor networkMonitor = NetworkMonitor.this;
                networkMonitor.a.registerNetworkCallback(networkRequestBuild, xm6Var);
                yi7Var.i(Boxing.boxBoolean(networkMonitor.a()));
                dz5 dz5Var = new dz5(networkMonitor, xm6Var, 13);
                this.a = 1;
                if (wi7.a(yi7Var, dz5Var, this) == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            return e6a.a;
        }
    }

    @Inject
    public NetworkMonitor(@ApplicationContext @kp6 Context context) {
        cr4.g(context, "context");
        Object systemService = context.getSystemService("connectivity");
        cr4.e(systemService, "null cannot be cast to non-null type android.net.ConnectivityManager");
        this.a = (ConnectivityManager) systemService;
        this.b = k63.h(k63.c(new b(null)));
    }

    public final boolean a() {
        NetworkCapabilities networkCapabilities;
        ConnectivityManager connectivityManager = this.a;
        Network activeNetwork = connectivityManager.getActiveNetwork();
        return activeNetwork != null && (networkCapabilities = connectivityManager.getNetworkCapabilities(activeNetwork)) != null && networkCapabilities.hasCapability(12) && networkCapabilities.hasCapability(16);
    }
}