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

package com.olxgroup.panamera.app.application;

import android.content.Context;
import com.naspers.advertising.baxterandroid.data.entities.AdvertisingConfig;
import com.naspers.advertising.baxterandroid.data.entities.ClientConfig;
import com.olxgroup.panamera.app.common.infra.m2;
import java.util.HashMap;
import java.util.Map;
import kotlin.ResultKt;
import kotlin.Unit;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.coroutines.intrinsics.IntrinsicsKt;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.Intrinsics;
import kotlinx.coroutines.b1;
import kotlinx.coroutines.p0;
import kotlinx.coroutines.q0;
import kotlinx.coroutines.q2;
import kotlinx.coroutines.x1;
import olx.com.delorean.domain.service.ab.ABTestService;

public final class d {
    public static final d a = new d();
    private static final kotlinx.coroutines.o0 b = p0.a(b1.b().plus(q2.b((x1) null, 1, (Object) null)));
    public static final int c = 8;

    static final class a extends SuspendLambda implements Function2 {
        int a;
        final Context b;
        final ABTestService c;

        public static final class C0138a implements com.naspers.advertising.baxterandroid.i {
            C0138a() {
            }

            public void a(String str) {
            }

            public void b(AdvertisingConfig advertisingConfig) {
            }
        }

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

            b(ABTestService aBTestService, Continuation continuation) {
                super(2, continuation);
                this.c = aBTestService;
            }

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

            public final Object invoke(Boolean bool, Continuation continuation) {
                return create(bool, continuation).invokeSuspend(Unit.a);
            }

            public final Object invokeSuspend(Object obj) {
                IntrinsicsKt.g();
                if (this.a != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                ResultKt.b(obj);
                if (Intrinsics.d((Boolean) this.b, Boxing.a(true))) {
                    d.a.e(this.c);
                }
                return Unit.a;
            }
        }

        a(Context context, ABTestService aBTestService, Continuation continuation) {
            super(2, continuation);
            this.b = context;
            this.c = aBTestService;
        }

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

        public final Object invokeSuspend(Object obj) {
            String b2;
            Object g = IntrinsicsKt.g();
            int i = this.a;
            if (i == 0) {
                ResultKt.b(obj);
                m2 m2Var = m2.a;
                Map customHeadersKeyValueMap = m2Var.x1().getCustomHeadersKeyValueMap();
                com.olxgroup.panamera.domain.entities.c market = m2Var.E2().getMarket();
                if (market == null || market.c() == null) {
                    return Unit.a;
                }
                com.olxgroup.panamera.domain.entities.d c = market.c();
                String b3 = (c == null || (b2 = c.b()) == null || b2.length() <= 0) ? "https://api.olx.in" : market.c().b();
                String h = market.h();
                com.naspers.advertising.baxterandroid.g.a.w(this.b, new ClientConfig(b3, (h == null || h.length() <= 0) ? "olxin" : market.h(), customHeadersKeyValueMap, false), new C0138a(), m2Var.D1(), d.a.c(this.c));
                kotlinx.coroutines.flow.o0 onRemoteConfigStateFlow = this.c.onRemoteConfigStateFlow();
                if (onRemoteConfigStateFlow != null) {
                    b bVar = new b(this.c, null);
                    this.a = 1;
                    if (kotlinx.coroutines.flow.h.j(onRemoteConfigStateFlow, bVar, this) == g) {
                        return g;
                    }
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                ResultKt.b(obj);
            }
            return Unit.a;
        }

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

    private d() {
    }

    public final Map c(ABTestService aBTestService) {
        HashMap hashMap = new HashMap();
        hashMap.put("amazon", Boolean.valueOf(aBTestService.isAmazonAdsEnable()));
        hashMap.put("andBeyond", Boolean.valueOf(aBTestService.isAndBeyondAdsEnable()));
        hashMap.put("countDownTimer", Boolean.valueOf(aBTestService.isCountDownTimerEnable()));
        hashMap.put("criteo", Boolean.valueOf(aBTestService.isCriteoAdsEnable()));
        hashMap.put("adsenseSearch", Boolean.valueOf(aBTestService.isAadsenseSearchAdsEnable()));
        hashMap.put("adsenseShopping", Boolean.valueOf(aBTestService.isAdsenseShoppingAdsEnable()));
        hashMap.put("dfp", Boolean.valueOf(aBTestService.isDFPAdsEnable()));
        hashMap.put("jamboJar", Boolean.valueOf(aBTestService.isJamboJarAdsEnable()));
        hashMap.put("jio", Boolean.valueOf(aBTestService.isJioAdsEnable()));
        return hashMap;
    }

    public static final void d(Context context, ABTestService aBTestService) {
        kotlinx.coroutines.i.d(b, (CoroutineContext) null, (q0) null, new a(context, aBTestService, null), 3, (Object) null);
    }

    public final void e(ABTestService aBTestService) {
        com.naspers.advertising.baxterandroid.g.a.P(c(aBTestService));
    }
}