CallApp v2.226 - MediateEndpointRequester.java 源代码

package com.fyber.fairbid.mediation.config;

import android.content.Context;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fyber.fairbid.http.requests.IUrlParametersProvider;
import com.fyber.fairbid.http.requests.UrlParametersProvider;
import com.fyber.fairbid.internal.Constants;
import com.fyber.fairbid.internal.Utils;
import com.fyber.fairbid.internal.user.IUser;
import com.fyber.fairbid.io;
import com.fyber.fairbid.lt;
import com.fyber.fairbid.mi;
import com.fyber.fairbid.ni;
import com.fyber.fairbid.pi;
import com.fyber.fairbid.qr;
import com.fyber.fairbid.tq;
import com.fyber.fairbid.tr;
import com.fyber.fairbid.user.Gender;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.collections.k0;
import kotlin.jvm.internal.Intrinsics;
import org.jetbrains.annotations.NotNull;

@Metadata(d1 = {"\u0000P\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0000\u0018\u0000 \u001d2\u00020\u0001:\u0002\u001e\u001fR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0006\u001a\u00020\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0006\u0010\u0007R\u0014\u0010\t\u001a\u00020\b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\t\u0010\nR\u0014\u0010\f\u001a\u00020\u000b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\f\u0010\rR\u0014\u0010\u000f\u001a\u00020\u000e8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000f\u0010\u0010R\u0014\u0010\u0012\u001a\u00020\u00118\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0012\u0010\u0013R\u0014\u0010\u0015\u001a\u00020\u00148\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0015\u0010\u0016R\u0014\u0010\u0018\u001a\u00020\u00178\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0018\u0010\u0019R\u001a\u0010\u001b\u001a\b\u0012\u0004\u0012\u00020\u00170\u001a8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001b\u0010\u001c¨\u0006 "}, d2 = {"Lcom/fyber/fairbid/mediation/config/MediateEndpointRequester;", JsonProperty.USE_DEFAULT_NAME, "Landroid/content/Context;", "context", "Landroid/content/Context;", "Ljava/util/concurrent/ScheduledExecutorService;", "executorService", "Ljava/util/concurrent/ScheduledExecutorService;", "Lcom/fyber/fairbid/tq;", "postMediateActions", "Lcom/fyber/fairbid/tq;", "Lcom/fyber/fairbid/internal/Utils$ClockHelper;", "clockHelper", "Lcom/fyber/fairbid/internal/Utils$ClockHelper;", "Lcom/fyber/fairbid/http/requests/IUrlParametersProvider;", "urlParametersProvider", "Lcom/fyber/fairbid/http/requests/IUrlParametersProvider;", "Lcom/fyber/fairbid/lt;", "testSuiteUtils", "Lcom/fyber/fairbid/lt;", "Lcom/fyber/fairbid/internal/user/IUser;", "user", "Lcom/fyber/fairbid/internal/user/IUser;", JsonProperty.USE_DEFAULT_NAME, "requestUrl", "Ljava/lang/String;", "Ljava/util/concurrent/atomic/AtomicReference;", MediateEndpointRequester.RESPONSE_HASH_HEADER_KEY, "Ljava/util/concurrent/atomic/AtomicReference;", "Companion", "com/fyber/fairbid/mi", "com/fyber/fairbid/ni", "fairbid-sdk_release"}, k = 1, mv = {2, 1, 0}, xi = 48)
public final class MediateEndpointRequester {

    @NotNull
    private static final String HASH_HEADER_KEY = "hash";

    @NotNull
    private static final String MEDIATE_ENDPOINT = "https://mediation.fyber.com/mediate";

    @NotNull
    private static final String RESPONSE_HASH_HEADER_KEY = "responseHash";

    @NotNull
    private final Utils.ClockHelper clockHelper;

    @NotNull
    private final Context context;

    @NotNull
    private final ScheduledExecutorService executorService;

    @NotNull
    private final tq postMediateActions;

    @NotNull
    private final String requestUrl;

    @NotNull
    private final AtomicReference<String> responseHash;

    @NotNull
    private final lt testSuiteUtils;

    @NotNull
    private final IUrlParametersProvider urlParametersProvider;

    @NotNull
    private final IUser user;

    @NotNull
    public static final mi Companion = new mi();

    @NotNull
    private static final long[] retryIntervals = {10, 20, 40, 80, 160, 300};

    @NotNull
    private static final Map<String, String> ALL_VARIANTS = k0.b(new Pair("variants", "all"));

    public MediateEndpointRequester(Context context, ScheduledThreadPoolExecutor scheduledThreadPoolExecutor, tq tqVar, Utils.ClockHelper clockHelper, UrlParametersProvider urlParametersProvider, lt ltVar, IUser iUser) {
        Intrinsics.checkNotNullParameter(context, "context");
        Intrinsics.checkNotNullParameter(scheduledThreadPoolExecutor, "executorService");
        Intrinsics.checkNotNullParameter(tqVar, "postMediateActions");
        Intrinsics.checkNotNullParameter(clockHelper, "clockHelper");
        Intrinsics.checkNotNullParameter(urlParametersProvider, "urlParametersProvider");
        Intrinsics.checkNotNullParameter(ltVar, "testSuiteUtils");
        Intrinsics.checkNotNullParameter(iUser, "user");
        Intrinsics.checkNotNullParameter(MEDIATE_ENDPOINT, "requestUrl");
        this.context = context;
        this.executorService = scheduledThreadPoolExecutor;
        this.postMediateActions = tqVar;
        this.clockHelper = clockHelper;
        this.urlParametersProvider = urlParametersProvider;
        this.testSuiteUtils = ltVar;
        this.user = iUser;
        this.requestUrl = MEDIATE_ENDPOINT;
        this.responseHash = new AtomicReference<>();
    }

    public static final LinkedHashMap h(MediateEndpointRequester mediateEndpointRequester) {
        mediateEndpointRequester.getClass();
        LinkedHashMap linkedHashMap = new LinkedHashMap();
        linkedHashMap.put(Constants.HOURS_SINCE_INSTALL_KEY, String.valueOf((mediateEndpointRequester.clockHelper.getCurrentTimeMillis() - io.b(mediateEndpointRequester.context)) / 3600000));
        Date birthDate = mediateEndpointRequester.user.getBirthDate();
        if (birthDate != null) {
            linkedHashMap.put(Constants.BIRTH_DATE_KEY, String.valueOf(birthDate.getTime()));
        }
        Gender gender = mediateEndpointRequester.user.getGender();
        if (gender != null) {
            if (gender == Gender.UNKNOWN) {
                gender = null;
            }
            if (gender != null) {
                linkedHashMap.put("gender", gender.getCode());
            }
        }
        return linkedHashMap;
    }

    public final void a(ni niVar, boolean z) {
        Intrinsics.checkNotNullParameter(niVar, "callback");
        pi piVar = new pi(z, this, niVar);
        long[] jArr = retryIntervals;
        TimeUnit timeUnit = TimeUnit.SECONDS;
        tr trVar = new tr(piVar, new qr(jArr, timeUnit), this.executorService);
        synchronized (trVar) {
            trVar.a(0, timeUnit);
        }
    }
}