CityMall v1.42.1 - AnalyticsRestAdapterImpl.java 源代码

package com.adster.sdk.mediation.analytics;

import K6.A;
import K6.i;
import K6.q;
import com.adster.sdk.mediation.adster.AdSterRestManagerKt;
import java.util.List;
import java.util.concurrent.TimeUnit;
import kotlin.Lazy;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.d;
import kotlin.coroutines.jvm.internal.j;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.k;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import p7.s;
import p7.x;
import retrofit2.Response;
import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;

@Metadata
public final class AnalyticsRestAdapterImpl implements AnalyticsRestAdapter {

    @NotNull
    private static final String BASE_URL = "https://logs.adster.tech/";

    @NotNull
    public static final AnalyticsRestAdapterImpl INSTANCE = new AnalyticsRestAdapterImpl();

    @NotNull
    private static final Lazy restApi$delegate = i.b(c.f10477a);

    @DebugMetadata(c = "com.adster.sdk.mediation.analytics.AnalyticsRestAdapterImpl$logEvent$2", f = "Network.kt", l = {62}, m = "invokeSuspend")
    public static final class a extends j implements Function1<Continuation<? super Response<x>>, Object> {

        public int f10472a;

        public final List<Event> f10473b;

        public a(List<Event> list, Continuation<? super a> continuation) {
            super(1, continuation);
            this.f10473b = list;
        }

        @NotNull
        public final Continuation<A> create(@NotNull Continuation<?> continuation) {
            return new a(this.f10473b, continuation);
        }

        public final Object invoke(Object obj) {
            return create((Continuation) obj).invokeSuspend(A.a);
        }

        @Nullable
        public final Object invokeSuspend(@NotNull Object obj) {
            Object c5 = P6.b.c();
            int i5 = this.f10472a;
            if (i5 == 0) {
                q.b(obj);
                AnalyticsApiService restApi = AnalyticsRestAdapterImpl.INSTANCE.getRestApi();
                List<Event> list = this.f10473b;
                this.f10472a = 1;
                obj = restApi.logEvent("msdfvisan231uiemfwrog2132323trvsidckvfergwoda21321ics123121vfregwfas", list, this);
                if (obj == c5) {
                    return c5;
                }
            } else {
                if (i5 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                q.b(obj);
            }
            return obj;
        }
    }

    @DebugMetadata(c = "com.adster.sdk.mediation.analytics.AnalyticsRestAdapterImpl", f = "Network.kt", l = {68}, m = "recordTrackers")
    public static final class b extends d {

        public Object f10474a;

        public int f10476c;

        public b(Continuation<? super b> continuation) {
            super(continuation);
        }

        @Nullable
        public final Object invokeSuspend(@NotNull Object obj) {
            this.f10474a = obj;
            this.f10476c |= Integer.MIN_VALUE;
            return AnalyticsRestAdapterImpl.this.recordTrackers(null, this);
        }
    }

    public static final class c extends k implements Function0<AnalyticsApiService> {

        public static final c f10477a = new c();

        public c() {
            super(0);
        }

        public final Object invoke() {
            s.a aVar = new s.a();
            TimeUnit timeUnit = TimeUnit.MILLISECONDS;
            return (AnalyticsApiService) new Retrofit.Builder().baseUrl(AnalyticsRestAdapterImpl.BASE_URL).client(aVar.f(3000L, timeUnit).S(3000L, timeUnit).W(3000L, timeUnit).T(false).c()).addConverterFactory(GsonConverterFactory.create()).build().create(AnalyticsApiService.class);
        }
    }

    private AnalyticsRestAdapterImpl() {
    }

    public final AnalyticsApiService getRestApi() {
        Object value = restApi$delegate.getValue();
        kotlin.jvm.internal.j.h(value, "<get-restApi>(...)");
        return (AnalyticsApiService) value;
    }

    @Override
    @Nullable
    public Object logEvent(@NotNull List<Event> list, @NotNull Continuation<? super Response<x>> continuation) {
        return AdSterRestManagerKt.suspendSafeExecute(new a(list, null), continuation);
    }

    @Override
    @org.jetbrains.annotations.Nullable
    public java.lang.Object recordTrackers(@org.jetbrains.annotations.NotNull java.lang.String r7, @org.jetbrains.annotations.NotNull kotlin.coroutines.Continuation<? super p7.x> r8) {
        throw new UnsupportedOperationException("Method not decompiled: com.adster.sdk.mediation.analytics.AnalyticsRestAdapterImpl.recordTrackers(java.lang.String, kotlin.coroutines.Continuation):java.lang.Object");
    }
}