package defpackage; import androidx.media3.container.NalUnitUtil; import defpackage.cc9; import defpackage.fx4; import defpackage.gj1; import java.util.Iterator; import java.util.List; import java.util.concurrent.CancellationException; import kotlin.Metadata; import kotlin.coroutines.jvm.internal.ContinuationImpl; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\u0018\u00002\u00020\u0001ยจ\u0006\u0002"}, d2 = {"Lj55;", "Lkd9;", "supabase-kt_release"}, k = 1, mv = {2, 1, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class j55 extends kd9 { public final long a; public final ta4 b; public j55(List list, long j, ab4 ab4Var) { ta4 ta4Var; cr4.g(list, "modifiers"); this.a = j; if (ab4Var != null) { za4 za4Var = new za4(); a(za4Var, list); ta4Var = new ta4(ab4Var, za4Var, false); } else { mb4 mb4Var = pb4.a; cr4.g(mb4Var, "engineFactory"); za4 za4Var2 = new za4(); a(za4Var2, list); ab4 ab4VarA = mb4Var.a(za4Var2.d); ta4Var = new ta4(ab4VarA, za4Var2, true); gj1.b bVarCb = ta4Var.d.cb(fx4.b.a); cr4.d(bVarCb); ((fx4) bVarCb).at(new co(ab4VarA, 14)); } this.b = ta4Var; } public final void a(za4 za4Var, List list) { za4Var.a(f12.b, new l24(this)); za4Var.a(te1.c, new l24(9)); za4Var.a(te4.b, new co(this, 19)); Iterator it = list.iterator(); while (it.hasNext()) { ((sq3) it.next()).invoke(za4Var); } } /* JADX WARN: Removed duplicated region for block: B:42:0x0117 */ /* JADX WARN: Removed duplicated region for block: B:45:0x013b */ /* JADX WARN: Removed duplicated region for block: B:50:0x0179 */ /* JADX WARN: Removed duplicated region for block: B:54:0x01a0 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object b(String str, sq3 sq3Var, ContinuationImpl continuationImpl) throws qd4, hd4 { i55 i55Var; fd4 fd4Var; Exception e; String str2; j55 j55Var; qd4 e2; CancellationException e3; vg5 vg5Var; String message; vg5 vg5Var2; vg5 vg5Var3; if (continuationImpl instanceof i55) { i55Var = (i55) continuationImpl; int i = i55Var.f; if ((i & Integer.MIN_VALUE) != 0) { i55Var.f = i - Integer.MIN_VALUE; } else { i55Var = new i55(this, continuationImpl); } } Object obj = i55Var.d; ck1 ck1Var = ck1.a; int i2 = i55Var.f; if (i2 == 0) { s38.b(obj); fd4 fd4Var2 = new fd4(); dx dxVar = kd4.a; cr4.g(str, "urlString"); v3a v3aVar = fd4Var2.a; a4a.b(v3aVar, str); sq3Var.invoke(fd4Var2); String strD = x3a.d(v3aVar); cc9.a.getClass(); u25 u25Var = cc9.a.c; vg5 vg5Var4 = vg5.a; u25Var.getClass(); if (vg5Var4.compareTo(cc9.a.b) >= 0) { u25Var.a(vg5Var4, null, n41.t(new StringBuilder("Starting "), fd4Var2.b.a, " request to endpoint ", strD)); } try { ta4 ta4Var = this.b; fd4 fd4Var3 = new fd4(); a4a.b(fd4Var3.a, str); sq3Var.invoke(fd4Var3); oe4 oe4Var = new oe4(fd4Var3, ta4Var); i55Var.a = this; i55Var.b = fd4Var2; i55Var.c = strD; i55Var.f = 1; Object objB = oe4Var.b(i55Var); if (objB == ck1Var) { return ck1Var; } j55Var = this; fd4Var = fd4Var2; obj = objB; str2 = strD; } catch (CancellationException e4) { fd4Var = fd4Var2; e3 = e4; str2 = strD; cc9.a.getClass(); u25 u25Var2 = cc9.a.c; vg5Var3 = vg5.c; u25Var2.getClass(); if (vg5Var3.compareTo(cc9.a.b) >= 0) { u25Var2.a(vg5Var3, null, n41.u(new StringBuilder(), fd4Var.b.a, " request to endpoint ", str2, " was cancelled")); } throw e3; } catch (qd4 e5) { j55Var = this; fd4Var = fd4Var2; e2 = e5; str2 = strD; cc9.a.getClass(); u25 u25Var3 = cc9.a.c; vg5Var2 = vg5.c; u25Var3.getClass(); if (vg5Var2.compareTo(cc9.a.b) >= 0) { StringBuilder sb = new StringBuilder(); vw2.aa(sb, fd4Var.b.a, " request to endpoint ", str2, " timed out after "); u25Var3.a(vg5Var2, null, n41.r(sb, j55Var.a, " ms")); } throw e2; } catch (Exception e6) { fd4Var = fd4Var2; e = e6; str2 = strD; cc9.a.getClass(); u25 u25Var4 = cc9.a.c; vg5Var = vg5.c; u25Var4.getClass(); if (vg5Var.compareTo(cc9.a.b) >= 0) { StringBuilder sb2 = new StringBuilder(); vw2.aa(sb2, fd4Var.b.a, " request to endpoint ", str2, " failed with exception "); sb2.append(e.getMessage()); u25Var4.a(vg5Var, e, sb2.toString()); } message = e.getMessage(); if (message == null) { message = ""; } cr4.g(fd4Var, "request"); StringBuilder sb3 = new StringBuilder("HTTP request to "); sb3.append(fd4Var.a.c()); sb3.append(" ("); throw new hd4(n41.t(sb3, fd4Var.b.a, ") failed with message: ", message)); } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } str2 = i55Var.c; fd4Var = i55Var.b; j55Var = i55Var.a; try { s38.b(obj); } catch (CancellationException e7) { e3 = e7; cc9.a.getClass(); u25 u25Var22 = cc9.a.c; vg5Var3 = vg5.c; u25Var22.getClass(); if (vg5Var3.compareTo(cc9.a.b) >= 0) { } throw e3; } catch (qd4 e8) { e2 = e8; cc9.a.getClass(); u25 u25Var32 = cc9.a.c; vg5Var2 = vg5.c; u25Var32.getClass(); if (vg5Var2.compareTo(cc9.a.b) >= 0) { } throw e2; } catch (Exception e9) { e = e9; cc9.a.getClass(); u25 u25Var42 = cc9.a.c; vg5Var = vg5.c; u25Var42.getClass(); if (vg5Var.compareTo(cc9.a.b) >= 0) { } message = e.getMessage(); if (message == null) { } cr4.g(fd4Var, "request"); StringBuilder sb32 = new StringBuilder("HTTP request to "); sb32.append(fd4Var.a.c()); sb32.append(" ("); throw new hd4(n41.t(sb32, fd4Var.b.a, ") failed with message: ", message)); } } rd4 rd4Var = (rd4) obj; int i3 = pg2.d; long jH = tg2.h(rd4Var.getD().k - rd4Var.getC().k, xg2.d); cc9.a.getClass(); u25 u25Var5 = cc9.a.c; vg5 vg5Var5 = vg5.a; u25Var5.getClass(); if (vg5Var5.compareTo(cc9.a.b) >= 0) { StringBuilder sb4 = new StringBuilder(); vw2.aa(sb4, fd4Var.b.a, " request to endpoint ", str2, " successfully finished in "); sb4.append((Object) pg2.i(jH)); u25Var5.a(vg5Var5, null, sb4.toString()); } return rd4Var; } }