OLX India v19.42.007 - c.java 源代码

package india.olx.pulse.utils;

import com.google.firebase.perf.network.FirebasePerfUrlConnection;
import java.net.URL;
import java.net.URLConnection;
import kotlin.ResultKt;
import kotlin.Unit;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.functions.Function2;
import kotlin.text.Charsets;
import kotlin.text.StringsKt__StringsKt;
import kotlinx.coroutines.b1;
import kotlinx.coroutines.i;
import kotlinx.coroutines.o0;
import kotlinx.coroutines.p0;
import kotlinx.coroutines.q0;
import kotlinx.coroutines.u0;

public final class c {
    public static final c a = new c();
    private static String b;

    static final class a extends SuspendLambda implements Function2 {
        int a;
        final String b;

        a(String str, Continuation continuation) {
            super(2, continuation);
            this.b = str;
        }

        @Override
        public final Continuation create(Object obj, Continuation continuation) {
            return new a(this.b, continuation);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            kotlin.coroutines.intrinsics.a.g();
            if (this.a != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ResultKt.b(obj);
            try {
                byte[] bArr = new byte[1024];
                return new String(bArr, 0, ((URLConnection) FirebasePerfUrlConnection.instrument(new URL(this.b).openConnection())).getInputStream().read(bArr), Charsets.b);
            } catch (Exception unused) {
                return "";
            }
        }

        @Override
        public final Object invoke(o0 o0Var, Continuation continuation) {
            return ((a) create(o0Var, continuation)).invokeSuspend(Unit.a);
        }
    }

    static final class b extends SuspendLambda implements Function2 {
        int a;
        private Object b;
        final Function1 c;

        b(Function1 function1, Continuation continuation) {
            super(2, continuation);
            this.c = function1;
        }

        @Override
        public final Continuation create(Object obj, Continuation continuation) {
            b bVar = new b(this.c, continuation);
            bVar.b = obj;
            return bVar;
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            Object g;
            g = kotlin.coroutines.intrinsics.a.g();
            int i = this.a;
            if (i == 0) {
                ResultKt.b(obj);
                u0 e = c.a.e((o0) this.b);
                this.a = 1;
                obj = e.v(this);
                if (obj == g) {
                    return g;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                ResultKt.b(obj);
            }
            String str = (String) obj;
            c cVar = c.a;
            cVar.f(str);
            d.a.o("DEBUG_PULSE_LOGS-CleverTap -Ip Address", cVar.d());
            this.c.invoke(str);
            return Unit.a;
        }

        @Override
        public final Object invoke(o0 o0Var, Continuation continuation) {
            return ((b) create(o0Var, continuation)).invokeSuspend(Unit.a);
        }
    }

    static final class C0133c extends SuspendLambda implements Function2 {
        int a;

        C0133c(Continuation continuation) {
            super(2, continuation);
        }

        @Override
        public final Continuation create(Object obj, Continuation continuation) {
            return new C0133c(continuation);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            Object g;
            boolean T;
            g = kotlin.coroutines.intrinsics.a.g();
            int i = this.a;
            if (i == 0) {
                ResultKt.b(obj);
                c cVar = c.a;
                this.a = 1;
                obj = cVar.b("https://api.ipify.org", this);
                if (obj == g) {
                    return g;
                }
            } else {
                if (i != 1) {
                    if (i != 2) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    ResultKt.b(obj);
                    return (String) obj;
                }
                ResultKt.b(obj);
            }
            String str = (String) obj;
            if (!StringsKt__StringsKt.i0(str)) {
                T = StringsKt__StringsKt.T(str, "error", false, 2, null);
                if (!T) {
                    return str;
                }
            }
            c cVar2 = c.a;
            this.a = 2;
            obj = cVar2.b("https://api.seeip.org/", this);
            if (obj == g) {
                return g;
            }
            return (String) obj;
        }

        @Override
        public final Object invoke(o0 o0Var, Continuation continuation) {
            return ((C0133c) create(o0Var, continuation)).invokeSuspend(Unit.a);
        }
    }

    private c() {
    }

    public final u0 e(o0 o0Var) {
        return i.b(o0Var, (CoroutineContext) null, (q0) null, new C0133c(null), 3, (Object) null);
    }

    public final Object b(String str, Continuation continuation) {
        return i.g(b1.b(), new a(str, null), continuation);
    }

    public final void c(Function1 function1) {
        String str = b;
        if (str == null || StringsKt__StringsKt.i0(str)) {
            i.d(p0.a(b1.c()), (CoroutineContext) null, (q0) null, new b(function1, null), 3, (Object) null);
        } else {
            function1.invoke(b);
        }
    }

    public final String d() {
        return b;
    }

    public final void f(String str) {
        b = str;
    }
}