package com.strmr.ps.data.supabase;

import android.content.Context;
import android.os.Build;
import android.provider.Settings;
import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import dagger.hilt.android.qualifiers.ApplicationContext;
import defpackage.ae7;
import defpackage.aea;
import defpackage.bz0;
import defpackage.cc9;
import defpackage.ck1;
import defpackage.cp4;
import defpackage.cr4;
import defpackage.d82;
import defpackage.dp4;
import defpackage.dy4;
import defpackage.ey4;
import defpackage.fi7;
import defpackage.ie7;
import defpackage.iw7;
import defpackage.j43;
import defpackage.je7;
import defpackage.jn4;
import defpackage.k63;
import defpackage.ke7;
import defpackage.kn4;
import defpackage.kp6;
import defpackage.kr7;
import defpackage.l38;
import defpackage.n41;
import defpackage.n89;
import defpackage.qf8;
import defpackage.rf8;
import defpackage.s38;
import defpackage.to4;
import defpackage.vd9;
import defpackage.vw2;
import defpackage.vx8;
import defpackage.we7;
import defpackage.wy4;
import defpackage.y41;
import defpackage.yj7;
import defpackage.yy4;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Locale;
import java.util.UUID;
import java.util.concurrent.CancellationException;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.reflect.KTypeProjection;

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

    @Metadata(d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0007\b\u0086\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0006\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0006\u0010\u0007R\u0014\u0010\b\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\b\u0010\u0004R\u0014\u0010\n\u001a\u00020\t8\u0002X\u0082T¢\u0006\u0006\n\u0004\b\n\u0010\u000bR\u0014\u0010\f\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\f\u0010\u0007R\u0014\u0010\r\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\r\u0010\u0007R\u0014\u0010\u000e\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u000e\u0010\u0004R\u0014\u0010\u000f\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u000f\u0010\u0004¨\u0006\u0010"}, d2 = {"Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$a;", "", "", "TAG", "Ljava/lang/String;", "", "CODE_LENGTH", "I", "CODE_CHARS", "", "POLL_INTERVAL_MS", "J", "MAX_POLL_ATTEMPTS", "CODE_EXPIRY_MINUTES", "VERIFICATION_URL", "TABLE_NAME", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class a {
    }

    @Metadata(d1 = {"\u0000\u001e\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b6\u0018\u00002\u00020\u0001:\u0004\u0002\u0003\u0004\u0005\u0082\u0001\u0004\u0006\u0007\b\t¨\u0006\n"}, d2 = {"Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b;", "", "d", "c", "b", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$a;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$b;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$c;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$d;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static abstract class b {

        @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0086\b\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$a;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final /* data */ class a extends b {
            public final String a;

            public a(String str) {
                cr4.g(str, "message");
                this.a = str;
            }

            public final boolean equals(Object obj) {
                if (this == obj) {
                    return true;
                }
                return (obj instanceof a) && cr4.b(this.a, ((a) obj).a);
            }

            public final int hashCode() {
                return this.a.hashCode();
            }

            public final String toString() {
                return vw2.ab("Error(message=", this.a, ")");
            }
        }

        /* JADX INFO: renamed from: com.strmr.ps.data.supabase.DeviceCodeAuthManager$b$b, reason: collision with other inner class name */
        @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\bÆ\u0002\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$b;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final class C0104b extends b {
            public static final C0104b a = new C0104b();
        }

        @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\bÆ\u0002\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$c;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final class c extends b {
            public static final c a = new c();
        }

        @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0086\b\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b$d;", "Lcom/strmr/ps/data/supabase/DeviceCodeAuthManager$b;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
        public static final /* data */ class d extends b {
            public final String a;
            public final String b;
            public final String c;

            public d(String str, String str2, String str3) {
                cr4.g(str, "userId");
                cr4.g(str2, "accessToken");
                this.a = str;
                this.b = str2;
                this.c = str3;
            }

            public final boolean equals(Object obj) {
                if (this == obj) {
                    return true;
                }
                if (!(obj instanceof d)) {
                    return false;
                }
                d dVar = (d) obj;
                return cr4.b(this.a, dVar.a) && cr4.b(this.b, dVar.b) && cr4.b(this.c, dVar.c);
            }

            public final int hashCode() {
                return this.c.hashCode() + vw2.b(this.a.hashCode() * 31, 31, this.b);
            }

            public final String toString() {
                return n41.s(fi7.m("Success(userId=", this.a, ", accessToken=", this.b, ", refreshToken="), this.c, ")");
            }
        }
    }

    @Inject
    public DeviceCodeAuthManager(@kp6 cc9 cc9Var, @ApplicationContext @kp6 Context context) {
        cr4.g(cc9Var, "supabase");
        cr4.g(context, "context");
        this.a = cc9Var;
        this.b = context;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object a(DeviceCodeAuthManager deviceCodeAuthManager, String str, ContinuationImpl continuationImpl) {
        com.strmr.ps.data.supabase.a aVar;
        String message;
        String message2;
        String message3;
        String message4;
        String str2;
        if (continuationImpl instanceof com.strmr.ps.data.supabase.a) {
            aVar = (com.strmr.ps.data.supabase.a) continuationImpl;
            int i = aVar.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                aVar.c = i - Integer.MIN_VALUE;
            } else {
                aVar = new com.strmr.ps.data.supabase.a(deviceCodeAuthManager, continuationImpl);
            }
        }
        Object objA = aVar.a;
        ck1 ck1Var = ck1.a;
        int i2 = aVar.c;
        try {
            if (i2 == 0) {
                s38.b(objA);
                ke7 ke7VarA = je7.a(deviceCodeAuthManager.a, "device_auth_codes");
                ie7 ie7Var = ke7VarA.a;
                yj7 yj7Var = ie7Var.d.b;
                rf8 rf8Var = new rf8(yj7Var);
                LinkedHashMap linkedHashMap = rf8Var.b;
                ae7 ae7Var = new ae7(yj7Var, linkedHashMap);
                com.strmr.ps.data.supabase.b bVar = com.strmr.ps.data.supabase.b.a;
                String upperCase = str.toUpperCase(Locale.ROOT);
                cr4.f(upperCase, "toUpperCase(...)");
                ae7Var.a(bVar, upperCase);
                linkedHashMap.put("select", y41.am("*"));
                qf8 qf8Var = new qf8(aea.a(linkedHashMap), ke7VarA.c, rf8Var.c.m());
                l38 l38Var = l38.a;
                String str3 = ke7VarA.b;
                aVar.c = 1;
                objA = l38Var.a(ie7Var, str3, qf8Var, aVar);
                if (objA == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i2 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(objA);
            }
            we7 we7Var = (we7) objA;
            d82 d82Var = (d82) y41.ab((List) we7Var.c.getE().b(iw7.b(List.class, KTypeProjection.INSTANCE.invariant(iw7.a(d82.class))), we7Var.a));
            if (d82Var == null) {
                return new b.a("Code not found");
            }
            String str4 = d82Var.h;
            int iHashCode = str4.hashCode();
            if (iHashCode != -1402931637) {
                if (iHashCode != -1309235419) {
                    if (iHashCode == -682587753 && str4.equals("pending")) {
                        return b.c.a;
                    }
                } else if (str4.equals("expired")) {
                    return b.C0104b.a;
                }
            } else if (str4.equals("completed")) {
                String str5 = d82Var.e;
                String str6 = d82Var.f;
                String str7 = d82Var.g;
                if (str5 != null && !n89.ab(str5)) {
                    if (str6 != null && !n89.ab(str6)) {
                        if (str7 == null) {
                            str7 = "";
                        }
                        return new b.d(str5, str6, str7);
                    }
                    return new b.a("No access token in completed response");
                }
                return new b.a("No user ID in completed response");
            }
            return new b.a("Unknown status: ".concat(str4));
        } catch (CancellationException e) {
            throw e;
        } catch (Exception e2) {
            Log.e("DeviceCodeAuthManager", "Error checking code status", e2);
            String message5 = e2.getMessage();
            if ((message5 == null || !n89.l(message5, "Unable to resolve host", true)) && ((message = e2.getMessage()) == null || !n89.l(message, "UnresolvedAddressException", true))) {
                String message6 = e2.getMessage();
                if ((message6 == null || !n89.l(message6, "timeout", true)) && ((message2 = e2.getMessage()) == null || !n89.l(message2, "timed out", true))) {
                    String message7 = e2.getMessage();
                    if ((message7 == null || !n89.l(message7, "SSL", true)) && ((message3 = e2.getMessage()) == null || !n89.l(message3, "certificate", true))) {
                        String message8 = e2.getMessage();
                        str2 = ((message8 == null || !n89.l(message8, "Connection refused", true)) && ((message4 = e2.getMessage()) == null || !n89.l(message4, "ConnectException", true))) ? "Connection error. Please check your internet and try again." : "Could not connect to server. Please try again.";
                    } else {
                        str2 = "Secure connection failed. Please check your network settings.";
                    }
                } else {
                    str2 = "Connection timed out. Please try again.";
                }
            } else {
                str2 = "No internet connection. Please check your network.";
            }
            return new b.a(str2);
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Serializable b(ContinuationImpl continuationImpl) {
        c cVar;
        String message;
        String message2;
        String str;
        if (continuationImpl instanceof c) {
            cVar = (c) continuationImpl;
            int i = cVar.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                cVar.d = i - Integer.MIN_VALUE;
            } else {
                cVar = new c(this, continuationImpl);
            }
        }
        Object obj = cVar.b;
        ck1 ck1Var = ck1.a;
        int i2 = cVar.d;
        try {
            if (i2 != 0) {
                if (i2 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                String str2 = cVar.a;
                s38.b(obj);
                return str2;
            }
            s38.b(obj);
            dp4 dp4Var = new dp4(1, 6, 1);
            ArrayList arrayList = new ArrayList(y41.p(dp4Var, 10));
            Iterator<Integer> it = dp4Var.iterator();
            while (((cp4) it).c) {
                ((to4) it).nextInt();
                kr7 kr7Var = kr7.a;
                arrayList.add(Boxing.boxChar("ABCDEFGHJKMNPQRSTUVWXYZ23456789".charAt(kr7.a.e(31))));
            }
            String strAi = y41.ai(arrayList, "", null, null, null, 62);
            String str3 = Build.MANUFACTURER + " " + Build.MODEL;
            String strC = c();
            ke7 ke7VarA = je7.a(this.a, "device_auth_codes");
            List listAm = y41.am(new d82(strAi, strC, str3));
            ie7 ie7Var = ke7VarA.a;
            kn4 kn4Var = new kn4(ie7Var.d.b);
            LinkedHashMap linkedHashMap = kn4Var.b;
            vd9 vd9Var = ie7Var.e;
            dy4.a aVar = dy4.d;
            String strA = vd9Var.a(iw7.b(List.class, KTypeProjection.INSTANCE.invariant(iw7.a(d82.class))), listAm);
            aVar.getClass();
            ey4 ey4VarF = yy4.f((wy4) aVar.c(wy4.INSTANCE.serializer(), strA));
            ArrayList arrayList2 = new ArrayList(y41.p(ey4VarF, 10));
            Iterator it2 = ey4VarF.a.iterator();
            while (it2.hasNext()) {
                arrayList2.add(yy4.g((wy4) it2.next()).a.keySet());
            }
            List listT = y41.t(y41.ac(arrayList2));
            if (!listT.isEmpty()) {
                linkedHashMap.put("columns", y41.am(y41.ai(listT, ",", null, null, null, 62)));
            }
            jn4 jn4Var = new jn4(false, kn4Var.d, ey4VarF, aea.a(linkedHashMap), ke7VarA.c, kn4Var.c.m());
            l38 l38Var = l38.a;
            String str4 = ke7VarA.b;
            cVar.a = strAi;
            cVar.d = 1;
            return l38Var.a(ie7Var, str4, jn4Var, cVar) == ck1Var ? ck1Var : strAi;
        } catch (Exception e) {
            Log.e("DeviceCodeAuthManager", "Failed to generate code", e);
            String message3 = e.getMessage();
            if ((message3 == null || !n89.l(message3, "Unable to resolve host", true)) && ((message = e.getMessage()) == null || !n89.l(message, "UnresolvedAddressException", true))) {
                String message4 = e.getMessage();
                if (message4 == null || !n89.l(message4, "timeout", true)) {
                    String message5 = e.getMessage();
                    str = ((message5 == null || !n89.l(message5, "SSL", true)) && ((message2 = e.getMessage()) == null || !n89.l(message2, "certificate", true))) ? "Could not generate code. Please check your internet connection." : "Secure connection failed. Please check your network settings.";
                } else {
                    str = "Connection timed out. Please try again.";
                }
            } else {
                str = "No internet connection. Please check your network.";
            }
            return s38.a(new Exception(str, e));
        }
    }

    public final String c() {
        Context context = this.b;
        String string = Settings.Secure.getString(context.getContentResolver(), "android_id");
        if (string == null) {
            string = "unknown";
        }
        byte[] bytes = vw2.l(string, "_", context.getPackageName()).getBytes(bz0.a);
        cr4.f(bytes, "getBytes(...)");
        String string2 = UUID.nameUUIDFromBytes(bytes).toString();
        cr4.f(string2, "toString(...)");
        return string2;
    }

    public final j43 d(String str) {
        cr4.g(str, "code");
        return k63.n(new d(str, this, null));
    }
}