package defpackage;

import androidx.lifecycle.t;
import androidx.lifecycle.z;
import androidx.media3.container.NalUnitUtil;
import defpackage.cc9;
import defpackage.ew3;
import defpackage.hf1;
import defpackage.il8;
import defpackage.jl8;
import defpackage.mw7;
import defpackage.t11;
import defpackage.um5;
import defpackage.vx;
import java.io.Serializable;
import java.util.List;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0001\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lb00;", "Lvx;", "auth-kt_release"}, k = 1, mv = {2, 1, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
@wl7
public final class b00 implements vx {
    public final cc9 c;
    public final xx d;
    public final ig6 e;
    public final o29 f;
    public final ng1 g;
    public final do8 h;
    public final rn8 i;
    public final m00 j;
    public fx4 k;
    public final vd9 l;

    public b00(cc9 cc9Var, xx xxVar) {
        cr4.g(cc9Var, "supabaseClient");
        cr4.g(xxVar, "config");
        this.c = cc9Var;
        this.d = xxVar;
        ig6 ig6VarA = i49.a(jl8.b.a);
        this.e = ig6VarA;
        this.f = k63.b(ig6VarA);
        this.g = bk1.a(xxVar.e);
        int i = o87.a;
        this.h = new do8(ko8.b(cc9Var.g()) + "-session");
        this.i = new rn8(ko8.b(cc9Var.g()) + "-supabase_code_verifier");
        this.j = p00.a(cc9Var, this);
        this.l = cc9Var.f();
        if (cc9Var.a() != null) {
            throw new IllegalStateException("The Auth plugin is not available when using a custom access token provider. Please uninstall the Auth plugin.");
        }
    }

    @Override // defpackage.um5
    public final String a(String str) {
        cr4.g(str, "path");
        return um5.a.a(this, str);
    }

    @Override // defpackage.vx
    /* JADX INFO: renamed from: b, reason: from getter */
    public final o29 getF() {
        return this.f;
    }

    @Override // defpackage.vx
    public final Object c(Continuation continuation) {
        Object objL = k63.l(this.f, new fy(2, null), (ContinuationImpl) continuation);
        return objL == ck1.a ? objL : e6a.a;
    }

    @Override // defpackage.um5
    public final String d() {
        vx.a.getClass();
        return "auth";
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // defpackage.um5
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Serializable e(rd4 rd4Var, Continuation continuation) throws Throwable {
        yy yyVar;
        b00 b00Var;
        Object objC;
        Serializable g00Var;
        Serializable e7aVar;
        List list;
        if (continuation instanceof yy) {
            yyVar = (yy) continuation;
            int i = yyVar.e;
            if ((i & Integer.MIN_VALUE) != 0) {
                yyVar.e = i - Integer.MIN_VALUE;
            } else {
                yyVar = new yy(this, continuation);
            }
        }
        Object objA = yyVar.c;
        ck1 ck1Var = ck1.a;
        int i2 = yyVar.e;
        if (i2 == 0) {
            s38.b(objA);
            try {
                yyVar.a = this;
                yyVar.b = rd4Var;
                yyVar.e = 1;
                objA = yd4.a(rd4Var, bz0.a, yyVar);
                if (objA == ck1Var) {
                    return ck1Var;
                }
                b00Var = this;
            } catch (Exception unused) {
                b00Var = this;
                objC = null;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            rd4Var = yyVar.b;
            b00Var = yyVar.a;
            try {
                s38.b(objA);
            } catch (Exception unused2) {
                objC = null;
            }
        }
        dy4 dy4Var = gea.a;
        dy4Var.getClass();
        objC = dy4Var.c(ew3.INSTANCE.serializer(), (String) objA);
        ew3 ew3Var = (ew3) objC;
        if (ew3Var == null) {
            ew3Var = new ew3("Unknown error", "", null);
        }
        String str = ew3Var.b;
        String str2 = ew3Var.a;
        b00Var.getClass();
        if (cr4.b(str2, "weak_password")) {
            int i3 = rd4Var.getC().a;
            ew3.b bVar = ew3Var.c;
            if (bVar == null || (list = bVar.a) == null) {
                list = ik2.a;
            }
            g00Var = new j00(str, i3, list);
        } else if (cr4.b(str2, "session_not_found")) {
            wj0.c(b00Var.g, null, null, new gy(b00Var, null), 3);
            g00Var = new i00("session_not_found", "Session not found. This can happen if the user was logged out or deleted.", rd4Var.getC().a);
        } else {
            g00Var = str2 != null ? new g00(str2, str, rd4Var.getC().a) : null;
        }
        if (g00Var != null) {
            return g00Var;
        }
        pe4 a = rd4Var.getC();
        if (cr4.b(a, pe4.o)) {
            if (str2 == null) {
                str2 = "Unauthorized";
            }
            e7aVar = new z4a(str2, rd4Var, str);
        } else if (cr4.b(a, pe4.n)) {
            if (str2 == null) {
                str2 = "Bad Request";
            }
            e7aVar = new h60(str2, rd4Var, str);
        } else if (cr4.b(a, pe4.q)) {
            if (str2 == null) {
                str2 = "Unprocessable Entity";
            }
            e7aVar = new h60(str2, rd4Var, str);
        } else {
            if (str2 == null) {
                str2 = "Unknown Error";
            }
            e7aVar = new e7a(str2, rd4Var, null);
        }
        return e7aVar;
    }

    @Override // defpackage.td9
    public final Object f() {
        return this.d;
    }

    /* JADX WARN: Code restructure failed: missing block: B:44:0x00dd, code lost:
    
        if (r2.r(r0) == r1) goto L45;
     */
    /* JADX WARN: Removed duplicated region for block: B:30:0x0072  */
    /* JADX WARN: Removed duplicated region for block: B:35:0x00ab  */
    /* JADX WARN: Removed duplicated region for block: B:36:0x00b1  */
    /* JADX WARN: Removed duplicated region for block: B:43:0x00d3  */
    /* JADX WARN: Removed duplicated region for block: B:48:0x00f7  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // defpackage.vx
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object g(es8 es8Var, ContinuationImpl continuationImpl) throws j38 {
        sz szVar;
        b00 b00Var;
        m00 m00Var;
        rz rzVar;
        List list;
        int i;
        vg5 vg5Var;
        vg5 vg5Var2;
        if (continuationImpl instanceof sz) {
            szVar = (sz) continuationImpl;
            int i2 = szVar.e;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                szVar.e = i2 - Integer.MIN_VALUE;
            } else {
                szVar = new sz(this, continuationImpl);
            }
        }
        Object obj = szVar.c;
        ck1 ck1Var = ck1.a;
        int i3 = szVar.e;
        vx.a aVar = vx.a;
        if (i3 != 0) {
            if (i3 != 1) {
                if (i3 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                aVar.getClass();
                u25 u25Var = vx.a.b;
                vg5Var2 = vg5.a;
                u25Var.getClass();
                cc9.a.getClass();
                if (vg5Var2.compareTo(cc9.a.b) >= 0) {
                    u25Var.a(vg5Var2, null, "Successfully logged out");
                }
                return e6a.a;
            }
            es8Var = szVar.b;
            b00Var = szVar.a;
            try {
                s38.b(obj);
            } catch (j38 e) {
                e = e;
                list = c00.a;
                i = e.a;
                if (list.contains(Boxing.boxInt(i))) {
                    throw e;
                }
                aVar.getClass();
                u25 u25Var2 = vx.a.b;
                vg5 vg5Var3 = vg5.a;
                u25Var2.getClass();
                cc9.a.getClass();
                if (vg5Var3.compareTo(cc9.a.b) >= 0) {
                    u25Var2.a(vg5Var3, null, n41.i(i, "Received error code ", " while signing out user. This can happen if the user doesn't exist anymore or the JWT is invalid/expired. Proceeding to clean up local data..."));
                }
            }
            aVar.getClass();
            u25 u25Var3 = vx.a.b;
            vg5Var = vg5.a;
            u25Var3.getClass();
            cc9.a.getClass();
            if (vg5Var.compareTo(cc9.a.b) >= 0) {
                u25Var3.a(vg5Var, null, "Logged out session in Supabase");
            }
            if (es8Var != es8.b) {
                szVar.a = null;
                szVar.b = null;
                szVar.e = 2;
            }
            aVar.getClass();
            u25 u25Var4 = vx.a.b;
            vg5Var2 = vg5.a;
            u25Var4.getClass();
            cc9.a.getClass();
            if (vg5Var2.compareTo(cc9.a.b) >= 0) {
            }
            return e6a.a;
        }
        s38.b(obj);
        if (o() == null) {
            aVar.getClass();
            u25 u25Var5 = vx.a.b;
            vg5 vg5Var4 = vg5.b;
            u25Var5.getClass();
            cc9.a.getClass();
            if (vg5Var4.compareTo(cc9.a.b) >= 0) {
                u25Var5.a(vg5Var4, null, "Skipping session logout as there is no session available. Proceeding to clean up local data...");
            }
            b00Var = this;
            if (es8Var != es8.b) {
            }
            aVar.getClass();
            u25 u25Var42 = vx.a.b;
            vg5Var2 = vg5.a;
            u25Var42.getClass();
            cc9.a.getClass();
            if (vg5Var2.compareTo(cc9.a.b) >= 0) {
            }
            return e6a.a;
        }
        try {
            m00Var = this.j;
            rzVar = new rz(es8Var);
            szVar.a = this;
            szVar.b = es8Var;
            szVar.e = 1;
        } catch (j38 e2) {
            e = e2;
            b00Var = this;
            list = c00.a;
            i = e.a;
            if (list.contains(Boxing.boxInt(i))) {
            }
        }
        if (m00Var.c("logout", rzVar, szVar) != ck1Var) {
            b00Var = this;
            aVar.getClass();
            u25 u25Var32 = vx.a.b;
            vg5Var = vg5.a;
            u25Var32.getClass();
            cc9.a.getClass();
            if (vg5Var.compareTo(cc9.a.b) >= 0) {
            }
            if (es8Var != es8.b) {
            }
            aVar.getClass();
            u25 u25Var422 = vx.a.b;
            vg5Var2 = vg5.a;
            u25Var422.getClass();
            cc9.a.getClass();
            if (vg5Var2.compareTo(cc9.a.b) >= 0) {
            }
            return e6a.a;
        }
        return ck1Var;
    }

    @Override // defpackage.td9
    /* JADX INFO: renamed from: h, reason: from getter */
    public final cc9 getC() {
        return this.c;
    }

    /* JADX WARN: Code restructure failed: missing block: B:28:0x0076, code lost:
    
        if (r13.b(r10, r0) == r1) goto L43;
     */
    /* JADX WARN: Code restructure failed: missing block: B:42:0x00bc, code lost:
    
        if (r13.b(r10, r0) == r1) goto L43;
     */
    /* JADX WARN: Removed duplicated region for block: B:47:0x00ce  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // defpackage.vx
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object i(pba pbaVar, boolean z, il8 il8Var, ContinuationImpl continuationImpl) {
        ly lyVar;
        b00 b00Var;
        b00 b00Var2;
        fx4 fx4Var;
        if (continuationImpl instanceof ly) {
            lyVar = (ly) continuationImpl;
            int i = lyVar.f;
            if ((i & Integer.MIN_VALUE) != 0) {
                lyVar.f = i - Integer.MIN_VALUE;
            } else {
                lyVar = new ly(this, continuationImpl);
            }
        }
        Object obj = lyVar.d;
        ck1 ck1Var = ck1.a;
        int i2 = lyVar.f;
        e6a e6aVar = e6a.a;
        if (i2 != 0) {
            if (i2 == 1) {
                il8Var = lyVar.c;
                pbaVar = lyVar.b;
                b00Var2 = lyVar.a;
                s38.b(obj);
                b00Var2.e.setValue(new jl8.a(pbaVar, il8Var));
                return e6aVar;
            }
            if (i2 == 2) {
                s38.b(obj);
                return e6aVar;
            }
            if (i2 != 3) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            il8Var = lyVar.c;
            pbaVar = lyVar.b;
            b00Var = lyVar.a;
            s38.b(obj);
            b00Var.e.setValue(new jl8.a(pbaVar, il8Var));
            fx4Var = b00Var.k;
            if (fx4Var != null) {
                ((rx4) fx4Var).h(null);
            }
            b00Var.k = wj0.c(b00Var.g, null, null, new ry(b00Var, pbaVar, il8Var, null), 3);
            return e6aVar;
        }
        s38.b(obj);
        do8 do8Var = this.h;
        xx xxVar = this.d;
        if (!z) {
            if (!n89.ab(pbaVar.b) && pbaVar.e != 0 && xxVar.d) {
                lyVar.a = this;
                lyVar.b = pbaVar;
                lyVar.c = il8Var;
                lyVar.f = 1;
            }
            b00Var2 = this;
            b00Var2.e.setValue(new jl8.a(pbaVar, il8Var));
            return e6aVar;
        }
        xn4 xn4Var = pbaVar.i;
        xn4 xn4VarA = t11.b.a();
        xn4Var.getClass();
        if (xn4Var.a.compareTo(xn4VarA.a) > 0) {
            if (xxVar.d) {
                lyVar.a = this;
                lyVar.b = pbaVar;
                lyVar.c = il8Var;
                lyVar.f = 3;
            }
            b00Var = this;
            b00Var.e.setValue(new jl8.a(pbaVar, il8Var));
            fx4Var = b00Var.k;
            if (fx4Var != null) {
            }
            b00Var.k = wj0.c(b00Var.g, null, null, new ry(b00Var, pbaVar, il8Var, null), 3);
            return e6aVar;
        }
        my myVar = new my(this, pbaVar, null);
        ny nyVar = new ny(this, pbaVar, null);
        lyVar.f = 2;
        if (v(myVar, nyVar, lyVar) != ck1Var) {
            return e6aVar;
        }
        return ck1Var;
    }

    /* JADX WARN: Code restructure failed: missing block: B:28:0x006c, code lost:
    
        if (vx.b.a(r1, r8, false, r4, r5, 2) == r0) goto L29;
     */
    /* JADX WARN: Removed duplicated region for block: B:8:0x0014  */
    @Override // defpackage.vx
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object j(ContinuationImpl continuationImpl) throws Throwable {
        ez ezVar;
        String str;
        b00 b00Var;
        if (continuationImpl instanceof ez) {
            ezVar = (ez) continuationImpl;
            int i = ezVar.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                ezVar.d = i - Integer.MIN_VALUE;
            } else {
                ezVar = new ez(this, continuationImpl);
            }
        }
        ez ezVar2 = ezVar;
        Object objT = ezVar2.b;
        ck1 ck1Var = ck1.a;
        int i2 = ezVar2.d;
        if (i2 == 0) {
            s38.b(objT);
            pba pbaVarO = o();
            if (pbaVarO == null || (str = pbaVarO.b) == null) {
                throw new IllegalStateException("No refresh token found in current session");
            }
            ezVar2.a = this;
            ezVar2.d = 1;
            objT = t(str, ezVar2);
            if (objT != ck1Var) {
                b00Var = this;
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s38.b(objT);
            return e6a.a;
        }
        b00Var = ezVar2.a;
        s38.b(objT);
        pba pbaVar = (pba) objT;
        pba pbaVarO2 = b00Var.o();
        if (pbaVarO2 == null) {
            throw new IllegalStateException("No session found");
        }
        il8.c cVar = new il8.c(pbaVarO2);
        ezVar2.a = null;
        ezVar2.d = 2;
    }

    @Override // defpackage.jo1
    /* JADX INFO: renamed from: k, reason: from getter */
    public final vd9 getL() {
        return this.l;
    }

    @Override // defpackage.td9
    public final void m() {
        xx xxVar = this.d;
        boolean z = xxVar.f;
        ng1 ng1Var = this.g;
        if (z) {
            t tVar = z.k.f;
            m12 m12Var = sc2.a;
            wj0.c(ng1Var, sm5.a, null, new po8(tVar, this, ng1Var, null), 2);
        }
        if (xxVar.c) {
            wj0.c(ng1Var, null, null, new sy(this, null), 3);
        } else {
            this.e.setValue(new jl8.c(false));
        }
    }

    @Override // defpackage.vx
    /* JADX INFO: renamed from: n, reason: from getter */
    public final rn8 getI() {
        return this.i;
    }

    @Override // defpackage.vx
    public final pba o() {
        jl8 jl8Var = (jl8) getF().getValue();
        if (jl8Var instanceof jl8.a) {
            return ((jl8.a) jl8Var).a;
        }
        return null;
    }

    @Override // defpackage.vx
    public final String p() {
        pba pbaVarO = o();
        if (pbaVarO != null) {
            return pbaVarO.a;
        }
        return null;
    }

    /* JADX WARN: Removed duplicated region for block: B:29:0x0069  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // defpackage.vx
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object q(boolean z, ContinuationImpl continuationImpl) {
        xy xyVar;
        b00 b00Var;
        pba pbaVar;
        pba pbaVar2;
        if (continuationImpl instanceof xy) {
            xyVar = (xy) continuationImpl;
            int i = xyVar.e;
            if ((i & Integer.MIN_VALUE) != 0) {
                xyVar.e = i - Integer.MIN_VALUE;
            } else {
                xyVar = new xy(this, continuationImpl);
            }
        }
        Object objA = xyVar.c;
        ck1 ck1Var = ck1.a;
        int i2 = xyVar.e;
        if (i2 == 0) {
            s38.b(objA);
            xyVar.a = this;
            xyVar.b = z;
            xyVar.e = 1;
            objA = this.h.a(xyVar);
            if (objA != ck1Var) {
                b00Var = this;
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            pbaVar2 = (pba) xyVar.a;
            s38.b(objA);
            pbaVar = pbaVar2;
            return Boxing.boxBoolean(pbaVar != null);
        }
        z = xyVar.b;
        b00Var = (b00) xyVar.a;
        s38.b(objA);
        pbaVar = (pba) objA;
        if (pbaVar != null) {
            xyVar.a = pbaVar;
            xyVar.e = 2;
            if (b00Var.i(pbaVar, z, il8.f.a, xyVar) != ck1Var) {
                pbaVar2 = pbaVar;
                pbaVar = pbaVar2;
            }
            return ck1Var;
        }
        return Boxing.boxBoolean(pbaVar != null);
    }

    /* JADX WARN: Removed duplicated region for block: B:32:0x0070  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object r(ContinuationImpl continuationImpl) {
        hy hyVar;
        b00 b00Var;
        b00 b00Var2;
        fx4 fx4Var;
        if (continuationImpl instanceof hy) {
            hyVar = (hy) continuationImpl;
            int i = hyVar.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                hyVar.d = i - Integer.MIN_VALUE;
            } else {
                hyVar = new hy(this, continuationImpl);
            }
        }
        Object obj = hyVar.b;
        ck1 ck1Var = ck1.a;
        int i2 = hyVar.d;
        e6a e6aVar = e6a.a;
        if (i2 == 0) {
            s38.b(obj);
            hyVar.a = this;
            hyVar.d = 1;
            rn8 rn8Var = this.i;
            Object objA = rn8Var.c.a(rn8Var.b, hyVar);
            if (objA != ck1Var) {
                objA = e6aVar;
            }
            if (objA != ck1Var) {
                b00Var = this;
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            b00Var2 = hyVar.a;
            s38.b(obj);
            fx4Var = b00Var2.k;
            if (fx4Var != null) {
                ((rx4) fx4Var).h(null);
            }
            b00Var2.e.setValue(new jl8.c(true));
            b00Var2.k = null;
            return e6aVar;
        }
        b00Var = hyVar.a;
        s38.b(obj);
        do8 do8Var = b00Var.h;
        hyVar.a = b00Var;
        hyVar.d = 2;
        Object objA2 = do8Var.d.a(do8Var.b, hyVar);
        if (objA2 != ck1Var) {
            objA2 = e6aVar;
        }
        if (objA2 != ck1Var) {
            b00Var2 = b00Var;
            fx4Var = b00Var2.k;
            if (fx4Var != null) {
            }
            b00Var2.e.setValue(new jl8.c(true));
            b00Var2.k = null;
            return e6aVar;
        }
        return ck1Var;
    }

    /* JADX WARN: Code restructure failed: missing block: B:24:0x0081, code lost:
    
        if (r2.i((defpackage.pba) r10, r9, r4, r0) == r1) goto L25;
     */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object s(pba pbaVar, boolean z, ContinuationImpl continuationImpl) throws Throwable {
        ky kyVar;
        b00 b00Var;
        if (continuationImpl instanceof ky) {
            kyVar = (ky) continuationImpl;
            int i = kyVar.f;
            if ((i & Integer.MIN_VALUE) != 0) {
                kyVar.f = i - Integer.MIN_VALUE;
            } else {
                kyVar = new ky(this, continuationImpl);
            }
        }
        Object objT = kyVar.d;
        ck1 ck1Var = ck1.a;
        int i2 = kyVar.f;
        if (i2 == 0) {
            s38.b(objT);
            vx.a.getClass();
            u25 u25Var = vx.a.b;
            vg5 vg5Var = vg5.a;
            u25Var.getClass();
            cc9.a.getClass();
            if (vg5Var.compareTo(cc9.a.b) >= 0) {
                u25Var.a(vg5Var, null, "Session expired. Refreshing session...");
            }
            String str = pbaVar.b;
            kyVar.a = this;
            kyVar.b = pbaVar;
            kyVar.c = z;
            kyVar.f = 1;
            objT = t(str, kyVar);
            if (objT != ck1Var) {
                b00Var = this;
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s38.b(objT);
            return e6a.a;
        }
        z = kyVar.c;
        pbaVar = kyVar.b;
        b00Var = kyVar.a;
        s38.b(objT);
        il8.c cVar = new il8.c(pbaVar);
        kyVar.a = null;
        kyVar.b = null;
        kyVar.f = 2;
    }

    /* JADX WARN: Code restructure failed: missing block: B:23:0x008a, code lost:
    
        if (r9 == r1) goto L24;
     */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object t(String str, ContinuationImpl continuationImpl) throws Throwable {
        gz gzVar;
        String str2;
        if (continuationImpl instanceof gz) {
            gzVar = (gz) continuationImpl;
            int i = gzVar.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                gzVar.d = i - Integer.MIN_VALUE;
            } else {
                gzVar = new gz(this, continuationImpl);
            }
        }
        Object objC = gzVar.b;
        ck1 ck1Var = ck1.a;
        int i2 = gzVar.d;
        if (i2 == 0) {
            s38.b(objC);
            vx.a.getClass();
            u25 u25Var = vx.a.b;
            vg5 vg5Var = vg5.a;
            u25Var.getClass();
            cc9.a.getClass();
            if (vg5Var.compareTo(cc9.a.b) >= 0) {
                u25Var.a(vg5Var, null, "Refreshing session");
            }
            b05 b05Var = new b05();
            xy4.a(b05Var, "refresh_token", str);
            fz fzVar = new fz(hf1.a.a, b05Var.a());
            gzVar.d = 1;
            objC = this.j.c("token?grant_type=refresh_token", fzVar, gzVar);
            if (objC != ck1Var) {
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            str2 = gzVar.a;
            s38.b(objC);
            String str3 = (String) objC;
            String strConcat = str2 != null ? " in ".concat(str2) : "";
            try {
                dy4 dy4Var = gea.a;
                dy4Var.getClass();
                return dy4Var.c(pba.INSTANCE.serializer(), str3);
            } catch (ox5 unused) {
                StringBuilder sbS = vw2.s("Couldn't decode payload", strConcat, " as ");
                sbS.append(iw7.a.getOrCreateKotlinClass(pba.class).getSimpleName());
                sbS.append(". Input: ");
                sbS.append(n89.an(str3, "\n", ""));
                throw new ic9(sbS.toString());
            }
        }
        s38.b(objC);
        str2 = "Auth#refreshSession";
        gzVar.a = "Auth#refreshSession";
        gzVar.d = 2;
        objC = yd4.a((rd4) objC, bz0.a, gzVar);
    }

    /* JADX WARN: Code restructure failed: missing block: B:20:0x0055, code lost:
    
        if (r7 == r1) goto L21;
     */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object u(String str, ContinuationImpl continuationImpl) throws Throwable {
        mz mzVar;
        if (continuationImpl instanceof mz) {
            mzVar = (mz) continuationImpl;
            int i = mzVar.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                mzVar.c = i - Integer.MIN_VALUE;
            } else {
                mzVar = new mz(this, continuationImpl);
            }
        }
        Object objC = mzVar.a;
        ck1 ck1Var = ck1.a;
        int i2 = mzVar.c;
        if (i2 == 0) {
            s38.b(objC);
            lz lzVar = new lz(str);
            mzVar.c = 1;
            objC = this.j.c("user", lzVar, mzVar);
            if (objC != ck1Var) {
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s38.b(objC);
            dy4 dy4Var = gea.a;
            dy4Var.getClass();
            return dy4Var.c(kba.INSTANCE.serializer(), (String) objC);
        }
        s38.b(objC);
        mzVar.c = 2;
        objC = yd4.a((rd4) objC, bz0.a, mzVar);
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:33:0x0099  */
    /* JADX WARN: Removed duplicated region for block: B:34:0x00b5  */
    /* JADX WARN: Removed duplicated region for block: B:37:0x00d7  */
    /* JADX WARN: Removed duplicated region for block: B:38:0x00d9  */
    /* JADX WARN: Removed duplicated region for block: B:40:0x00dc  */
    /* JADX WARN: Removed duplicated region for block: B:41:0x00eb  */
    /* JADX WARN: Removed duplicated region for block: B:46:0x00f8  */
    /* JADX WARN: Removed duplicated region for block: B:49:0x00fd A[PHI: r4
      0x00fd: PHI (r4v13 ??) = (r4v4 ??), (r4v15 ??) binds: [B:47:0x00f9, B:13:0x003b] A[DONT_GENERATE, DONT_INLINE]] */
    /* JADX WARN: Removed duplicated region for block: B:58:0x011e  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    /* JADX WARN: Removed duplicated region for block: B:84:0x01ce  */
    /* JADX WARN: Removed duplicated region for block: B:87:0x01ef A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:88:0x01f0 A[RETURN] */
    /* JADX WARN: Type inference failed for: r19v0, types: [sq3] */
    /* JADX WARN: Type inference failed for: r20v0, types: [sq3] */
    /* JADX WARN: Type inference failed for: r4v1 */
    /* JADX WARN: Type inference failed for: r4v10, types: [sq3] */
    /* JADX WARN: Type inference failed for: r4v12, types: [sq3] */
    /* JADX WARN: Type inference failed for: r4v13, types: [sq3] */
    /* JADX WARN: Type inference failed for: r4v15, types: [sq3] */
    /* JADX WARN: Type inference failed for: r4v16 */
    /* JADX WARN: Type inference failed for: r4v2 */
    /* JADX WARN: Type inference failed for: r4v3 */
    /* JADX WARN: Type inference failed for: r4v4, types: [java.lang.Object] */
    /* JADX WARN: Type inference failed for: r4v5, types: [java.lang.Object] */
    /* JADX WARN: Type inference failed for: r4v7 */
    /* JADX WARN: Type inference failed for: r4v9, types: [sq3] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object v(sq3 sq3Var, sq3 sq3Var2, ContinuationImpl continuationImpl) {
        uz uzVar;
        ?? r4;
        b00 b00Var;
        long j;
        ?? r42;
        vg5 vg5Var;
        long j2;
        boolean z;
        long jD;
        Object objA;
        int i;
        vg5 vg5Var2;
        long jD2;
        if (continuationImpl instanceof uz) {
            uzVar = (uz) continuationImpl;
            int i2 = uzVar.e;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                uzVar.e = i2 - Integer.MIN_VALUE;
            } else {
                uzVar = new uz(this, continuationImpl);
            }
        }
        Object obj = uzVar.c;
        ck1 ck1Var = ck1.a;
        int i3 = uzVar.e;
        e6a e6aVar = e6a.a;
        vx.a aVar = vx.a;
        switch (i3) {
            case 0:
                s38.b(obj);
                try {
                    try {
                        uzVar.a = this;
                        try {
                            uzVar.b = (SuspendLambda) sq3Var2;
                            uzVar.e = 1;
                            break;
                        } catch (j38 e) {
                            e = e;
                            r4 = sq3Var2;
                            b00Var = this;
                            j = 0;
                            r42 = r4;
                            i = e.a;
                            if (500 <= i || i >= 600) {
                                aVar.getClass();
                                u25 u25Var = vx.a.b;
                                vg5Var2 = vg5.c;
                                u25Var.getClass();
                                cc9.a.getClass();
                                if (vg5Var2.compareTo(cc9.a.b) >= 0) {
                                    u25Var.a(vg5Var2, e, "Couldn't refresh session. The refresh token may have been revoked. Clearing session... (Status code " + i + ')');
                                }
                                uzVar.a = null;
                                uzVar.b = null;
                                uzVar.e = 4;
                                if (b00Var.r(uzVar) == ck1Var) {
                                }
                            } else {
                                aVar.getClass();
                                u25 u25Var2 = vx.a.b;
                                vg5 vg5Var3 = vg5.c;
                                u25Var2.getClass();
                                cc9.a.getClass();
                                if (vg5Var3.compareTo(cc9.a.b) >= 0) {
                                    u25Var2.a(vg5Var3, e, "Couldn't refresh session due to an internal server error. Retrying in " + ((Object) pg2.i(b00Var.d.a)) + " (Status code " + i + ')');
                                }
                                b00Var.e.setValue(new jl8.d(new mw7.a(e)));
                                long j3 = b00Var.d.a;
                                uzVar.a = r42;
                                uzVar.b = null;
                                uzVar.e = 2;
                                int i4 = pg2.d;
                                boolean z2 = j3 > j;
                                if (z2) {
                                    jD2 = pg2.d(pg2.g(j3, tg2.h(999999L, xg2.b)));
                                } else {
                                    if (z2) {
                                        throw new io6();
                                    }
                                    jD2 = j;
                                }
                                Object objA2 = h32.a(jD2, uzVar);
                                if (objA2 != ck1.a) {
                                    objA2 = e6aVar;
                                }
                                if (objA2 != ck1Var) {
                                    uzVar.a = null;
                                    uzVar.e = 3;
                                    if (r42.invoke(uzVar) != ck1Var) {
                                    }
                                }
                            }
                        }
                    } catch (j38 e2) {
                        e = e2;
                        j = 0;
                        r42 = sq3Var2;
                        b00Var = this;
                        i = e.a;
                        if (500 <= i) {
                        }
                        aVar.getClass();
                        u25 u25Var3 = vx.a.b;
                        vg5Var2 = vg5.c;
                        u25Var3.getClass();
                        cc9.a.getClass();
                        if (vg5Var2.compareTo(cc9.a.b) >= 0) {
                        }
                        uzVar.a = null;
                        uzVar.b = null;
                        uzVar.e = 4;
                        if (b00Var.r(uzVar) == ck1Var) {
                        }
                    }
                } catch (Exception e3) {
                    e = e3;
                    r4 = sq3Var2;
                    b00Var = this;
                    aVar.getClass();
                    u25 u25Var4 = vx.a.b;
                    vg5Var = vg5.c;
                    u25Var4.getClass();
                    cc9.a.getClass();
                    if (vg5Var.compareTo(cc9.a.b) < 0) {
                        j2 = 0;
                        u25Var4.a(vg5Var, e, "Couldn't reach Supabase. Either the address doesn't exist or the network might not be on. Retrying in " + ((Object) pg2.i(b00Var.d.a)));
                    } else {
                        j2 = 0;
                    }
                    b00Var.e.setValue(new jl8.d(new mw7.b(e)));
                    long j4 = b00Var.d.a;
                    uzVar.a = r4;
                    uzVar.b = null;
                    uzVar.e = 5;
                    int i5 = pg2.d;
                    z = j4 <= j2;
                    if (!z) {
                        jD = pg2.d(pg2.g(j4, tg2.h(999999L, xg2.b)));
                    } else {
                        if (z) {
                            throw new io6();
                        }
                        jD = j2;
                    }
                    objA = h32.a(jD, uzVar);
                    if (objA != ck1.a) {
                        objA = e6aVar;
                    }
                    if (objA != ck1Var) {
                        uzVar.a = null;
                        uzVar.e = 6;
                        if (r4.invoke(uzVar) != ck1Var) {
                        }
                    }
                }
                return sq3Var.invoke(uzVar) == ck1Var ? ck1Var : e6aVar;
            case 1:
                r4 = (sq3) uzVar.b;
                b00Var = (b00) uzVar.a;
                try {
                    s38.b(obj);
                    break;
                } catch (j38 e4) {
                    e = e4;
                    j = 0;
                    r42 = r4;
                    i = e.a;
                    if (500 <= i) {
                    }
                    aVar.getClass();
                    u25 u25Var32 = vx.a.b;
                    vg5Var2 = vg5.c;
                    u25Var32.getClass();
                    cc9.a.getClass();
                    if (vg5Var2.compareTo(cc9.a.b) >= 0) {
                    }
                    uzVar.a = null;
                    uzVar.b = null;
                    uzVar.e = 4;
                    if (b00Var.r(uzVar) == ck1Var) {
                    }
                } catch (Exception e5) {
                    e = e5;
                    aVar.getClass();
                    u25 u25Var42 = vx.a.b;
                    vg5Var = vg5.c;
                    u25Var42.getClass();
                    cc9.a.getClass();
                    if (vg5Var.compareTo(cc9.a.b) < 0) {
                    }
                    b00Var.e.setValue(new jl8.d(new mw7.b(e)));
                    long j42 = b00Var.d.a;
                    uzVar.a = r4;
                    uzVar.b = null;
                    uzVar.e = 5;
                    int i52 = pg2.d;
                    if (j42 <= j2) {
                    }
                    if (!z) {
                    }
                    objA = h32.a(jD, uzVar);
                    if (objA != ck1.a) {
                    }
                    if (objA != ck1Var) {
                    }
                }
            case 2:
                r42 = (sq3) uzVar.a;
                s38.b(obj);
                uzVar.a = null;
                uzVar.e = 3;
                if (r42.invoke(uzVar) != ck1Var) {
                }
                break;
            case 3:
            case 4:
            case 6:
                s38.b(obj);
            case 5:
                r4 = (sq3) uzVar.a;
                s38.b(obj);
                uzVar.a = null;
                uzVar.e = 6;
                if (r4.invoke(uzVar) != ck1Var) {
                }
                break;
            default:
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
    }
}