package com.bykv.vk.openvk.preload.geckox;

import android.os.SystemClock;
import android.text.TextUtils;
import com.bykv.vk.openvk.preload.a.d;
import com.bykv.vk.openvk.preload.geckox.model.CheckRequestBodyModel;
import java.io.File;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;
import org.json.JSONObject;

/* JADX INFO: loaded from: classes.dex */
public final class a {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private com.bykv.vk.openvk.preload.falconx.a.a f5977a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private Queue<String> f5978b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private b f5979c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private File f5980d;

    private a(b bVar) {
        new ArrayList();
        this.f5977a = new com.bykv.vk.openvk.preload.falconx.a.a();
        this.f5978b = new LinkedBlockingQueue();
        this.f5979c = bVar;
        File fileN = bVar.n();
        this.f5980d = fileN;
        fileN.mkdirs();
        com.bykv.vk.openvk.preload.geckox.statistic.b.a(this, this.f5979c);
    }

    public static /* synthetic */ void d(a aVar) {
        ArrayList arrayList = new ArrayList();
        arrayList.addAll(aVar.f5979c.e());
        try {
            String strA = new com.bykv.vk.openvk.preload.geckox.a.a(arrayList).a();
            if (aVar.f5979c.p() != null && aVar.f5979c.p().a()) {
                aVar.f5979c.p();
            } else if (aVar.f5978b.size() < 10) {
                aVar.f5978b.add(strA);
            }
        } catch (Throwable unused) {
        }
    }

    public static a a(b bVar) {
        List<String> listE = bVar.e();
        if (listE == null || listE.isEmpty()) {
            throw new IllegalArgumentException("access key empty");
        }
        bVar.a();
        return new a(bVar);
    }

    private boolean b(Map<String, List<CheckRequestBodyModel.TargetChannel>> map) {
        if (map != null && !map.isEmpty()) {
            List<String> listE = this.f5979c.e();
            for (Map.Entry<String, List<CheckRequestBodyModel.TargetChannel>> entry : map.entrySet()) {
                Iterator<String> it = listE.iterator();
                boolean z10 = false;
                while (it.hasNext()) {
                    if (TextUtils.equals(it.next(), entry.getKey())) {
                        z10 = true;
                    }
                }
                if (!z10) {
                    return false;
                }
            }
        }
        return true;
    }

    private boolean a() {
        List<String> listD = this.f5979c.d();
        List<String> listE = this.f5979c.e();
        if (listD == null || listD.isEmpty() || listE == null || listE.isEmpty()) {
            return false;
        }
        for (String str : listE) {
            Iterator<String> it = listD.iterator();
            boolean z10 = false;
            while (it.hasNext()) {
                if (TextUtils.equals(str, it.next())) {
                    z10 = true;
                }
            }
            if (!z10) {
                return false;
            }
        }
        return true;
    }

    public final void a(Class<? extends d<?, ?>> cls, com.bykv.vk.openvk.preload.a.b.a aVar) {
        this.f5977a.a(cls, aVar);
    }

    public final void a(final Map<String, List<CheckRequestBodyModel.TargetChannel>> map) {
        final String str = "default";
        final Map map2 = null;
        final com.bykv.vk.openvk.preload.geckox.d.a aVar = null;
        if (!TextUtils.isEmpty("default")) {
            if (a()) {
                if (b(map)) {
                    b.h().execute(new Runnable() { // from class: com.bykv.vk.openvk.preload.geckox.a.1
                        /* JADX WARN: Multi-variable type inference failed */
                        /* JADX WARN: Type inference failed for: r1v6, types: [com.bykv.vk.openvk.preload.geckox.statistic.IStatisticMonitor] */
                        /* JADX WARN: Type inference failed for: r2v15 */
                        /* JADX WARN: Type inference failed for: r2v16, types: [org.json.JSONObject] */
                        /* JADX WARN: Type inference failed for: r2v17, types: [org.json.JSONObject] */
                        /* JADX WARN: Type inference failed for: r2v27 */
                        /* JADX WARN: Type inference failed for: r2v3 */
                        /* JADX WARN: Type inference failed for: r2v30 */
                        /* JADX WARN: Type inference failed for: r2v31 */
                        /* JADX WARN: Type inference failed for: r2v4, types: [com.bykv.vk.openvk.preload.geckox.a.a.b] */
                        @Override // java.lang.Runnable
                        public final void run() {
                            ?? r22;
                            long jElapsedRealtime;
                            long jS;
                            if (a.this.f5979c.b() != null) {
                                com.bykv.vk.openvk.preload.geckox.a.a.b bVarA = a.this.f5979c.b().a();
                                bVarA.a(a.this.f5979c.b(), a.this.f5979c.n(), a.this.f5979c.e());
                                r22 = bVarA;
                            } else {
                                r22 = 0;
                            }
                            try {
                                try {
                                    a.this.f5979c.a(new JSONObject());
                                    com.bykv.vk.openvk.preload.geckox.g.a.a(aVar, a.this.f5980d, a.this.f5979c, a.this.f5977a, map2, map, str).a(str);
                                    if (r22 != 0) {
                                        r22.a();
                                    }
                                    JSONObject jSONObjectF = a.this.f5979c.f();
                                    JSONObject jSONObject = jSONObjectF;
                                    if (jSONObjectF == null) {
                                        jSONObject = new JSONObject();
                                    }
                                    jElapsedRealtime = SystemClock.elapsedRealtime();
                                    jS = a.this.f5979c.s();
                                    r22 = jSONObject;
                                } catch (Exception e10) {
                                    try {
                                        JSONObject jSONObject2 = new JSONObject();
                                        jSONObject2.put("success", false);
                                        jSONObject2.put("msg", e10.toString());
                                        jSONObject2.put("code", 2);
                                        a.this.f5979c.a(jSONObject2);
                                    } catch (Throwable unused) {
                                    }
                                    if (r22 != 0) {
                                        r22.a();
                                    }
                                    JSONObject jSONObjectF2 = a.this.f5979c.f();
                                    JSONObject jSONObject3 = jSONObjectF2;
                                    if (jSONObjectF2 == null) {
                                        jSONObject3 = new JSONObject();
                                    }
                                    jElapsedRealtime = SystemClock.elapsedRealtime();
                                    jS = a.this.f5979c.s();
                                    r22 = jSONObject3;
                                } catch (Throwable th) {
                                    if (r22 != 0) {
                                        r22.a();
                                    }
                                    JSONObject jSONObjectF3 = a.this.f5979c.f();
                                    if (jSONObjectF3 == null) {
                                        jSONObjectF3 = new JSONObject();
                                    }
                                    try {
                                        jSONObjectF3.put("download_duration", SystemClock.elapsedRealtime() - a.this.f5979c.s());
                                    } catch (Throwable unused2) {
                                    }
                                    a.this.f5979c.q().upload("download_gecko_end", jSONObjectF3);
                                    throw th;
                                }
                                r22.put("download_duration", jElapsedRealtime - jS);
                            } catch (Throwable unused3) {
                            }
                            a.this.f5979c.q().upload("download_gecko_end", r22);
                            a.d(a.this);
                        }
                    });
                    return;
                }
                throw new IllegalArgumentException("target keys not in deployments keys");
            }
            throw new IllegalArgumentException("deployments keys not in local keys");
        }
        throw new IllegalArgumentException("groupType == null");
    }
}
