Zepto v25.1.4 - ImpressionsAPI.java 源代码

package com.zeptoconsumerapp.ImpressionsLogger;

import android.content.ContentValues;
import android.content.Context;
import com.chuckerteam.chucker.api.ChuckerCollector;
import com.chuckerteam.chucker.api.ChuckerInterceptor;
import com.chuckerteam.chucker.api.RetentionManager;
import com.google.firebase.perf.network.FirebasePerfOkHttpClient;
import com.inmobi.media.df;
import com.zeptoconsumerapp.Utils;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.regex.Pattern;
import kotlin.jvm.internal.Intrinsics;
import okhttp3.Headers;
import okhttp3.Interceptor;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

public class ImpressionsAPI {
    public final OkHttpClient a;
    public final ImpressionsDbAdapter b;
    public HashMap c;

    public final ExecutorService f2883d;

    public final Context f2884e;

    public ImpressionsAPI(Context context) {
        this.f2884e = context;
        String str = Utils.a;
        if ("true".equals(context.getSharedPreferences("Zepto", 0).getString("isChuckEnabled", "false"))) {
            ChuckerCollector collector = new ChuckerCollector(context, true, RetentionManager.Period.b);
            ChuckerInterceptor.Builder builder = new ChuckerInterceptor.Builder(context);
            Intrinsics.checkNotNullParameter(collector, "collector");
            builder.b = collector;
            builder.c = true;
            Interceptor a = builder.a();
            OkHttpClient.Builder builder2 = new OkHttpClient.Builder();
            long intValue = ImpressionsConfig.b.intValue();
            TimeUnit timeUnit = TimeUnit.MILLISECONDS;
            builder2.c(intValue, timeUnit);
            builder2.a(a);
            builder2.f(r3.intValue(), timeUnit);
            this.a = new OkHttpClient(builder2);
        } else {
            OkHttpClient.Builder builder3 = new OkHttpClient.Builder();
            long intValue2 = ImpressionsConfig.b.intValue();
            TimeUnit timeUnit2 = TimeUnit.MILLISECONDS;
            builder3.c(intValue2, timeUnit2);
            builder3.f(r2.intValue(), timeUnit2);
            this.a = new OkHttpClient(builder3);
        }
        this.b = new ImpressionsDbAdapter(context);
        HashMap a2 = ImpressionsConfig.a(context);
        this.c = a2;
        if (a2 != null) {
            a2.put("sentFromNative", "true");
        }
        this.f2883d = Executors.newFixedThreadPool(ImpressionsConfig.c.intValue());
    }

    public final synchronized void a(ContentValues contentValues) {
        try {
            Pattern pattern = MediaType.f6622d;
            MediaType b = MediaType.Companion.b("application/json; charset=utf-8");
            String asString = contentValues.getAsString("event");
            Integer asInteger = contentValues.getAsInteger("retry_count");
            RequestBody body = RequestBody.create(b, asString);
            if (this.c == null) {
                this.c = ImpressionsConfig.a(this.f2884e);
            }
            Request.Builder builder = new Request.Builder();
            Integer num = ImpressionsConfig.a;
            builder.i("https://events.zepto.co.in/api/v1/publish-events");
            builder.e(Headers.f(this.c));
            Intrinsics.checkNotNullParameter(body, "body");
            builder.f("POST", body);
            try {
                Response execute = FirebasePerfOkHttpClient.execute(this.a.a(builder.b()));
                try {
                    if (!execute.d()) {
                        try {
                            this.b.a(asString, asInteger);
                        } catch (Exception e2) {
                            Utils.d(e2);
                        }
                    }
                    execute.close();
                } catch (Throwable th) {
                    if (execute != null) {
                        try {
                            execute.close();
                        } catch (Throwable th2) {
                            th.addSuppressed(th2);
                        }
                    }
                    throw th;
                }
            } catch (IOException e3) {
                Utils.d(e3);
                try {
                    this.b.a(asString, asInteger);
                } catch (Exception e4) {
                    Utils.d(e4);
                }
            }
        } catch (Throwable th3) {
            throw th3;
        }
    }

    public final void b(ArrayList arrayList) {
        Iterator it = arrayList.iterator();
        while (it.hasNext()) {
            this.f2883d.submit(new df(9, this, (ContentValues) it.next()));
        }
    }
}