package com.vungle.warren;

import android.util.Log;
import com.vungle.warren.model.r;
import com.vungle.warren.utility.a;
import g8.d;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicInteger;

/* loaded from: classes2.dex */
public class c0 {

    /* renamed from: o, reason: collision with root package name */
    private static final String f8056o = "c0";

    /* renamed from: p, reason: collision with root package name */
    private static c0 f8057p;

    /* renamed from: q, reason: collision with root package name */
    private static long f8058q;

    /* renamed from: a, reason: collision with root package name */
    private com.vungle.warren.utility.y f8059a;

    /* renamed from: b, reason: collision with root package name */
    private ExecutorService f8060b;

    /* renamed from: d, reason: collision with root package name */
    private long f8062d;

    /* renamed from: e, reason: collision with root package name */
    private d f8063e;

    /* renamed from: i, reason: collision with root package name */
    private VungleApiClient f8067i;

    /* renamed from: l, reason: collision with root package name */
    private int f8070l;

    /* renamed from: m, reason: collision with root package name */
    private g8.j f8071m;

    /* renamed from: c, reason: collision with root package name */
    private boolean f8061c = false;

    /* renamed from: f, reason: collision with root package name */
    private final List f8064f = Collections.synchronizedList(new ArrayList());

    /* renamed from: g, reason: collision with root package name */
    private final List f8065g = new ArrayList();

    /* renamed from: h, reason: collision with root package name */
    private final Map f8066h = new HashMap();

    /* renamed from: j, reason: collision with root package name */
    private int f8068j = 40;

    /* renamed from: k, reason: collision with root package name */
    private AtomicInteger f8069k = new AtomicInteger();

    /* renamed from: n, reason: collision with root package name */
    public a.g f8072n = new c();

    class a implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ boolean f8073a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ g8.j f8074b;

        a(boolean z10, g8.j jVar) {
            this.f8073a = z10;
            this.f8074b = jVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (!c0.this.f8064f.isEmpty() && this.f8073a) {
                Iterator it = c0.this.f8064f.iterator();
                while (it.hasNext()) {
                    c0.this.w((com.vungle.warren.model.r) it.next());
                }
            }
            c0.this.f8064f.clear();
            for (List list : com.vungle.warren.utility.m.a((List) this.f8074b.V(com.vungle.warren.model.r.class).get(), c0.this.f8068j)) {
                if (list.size() >= c0.this.f8068j) {
                    try {
                        c0.this.q(list);
                    } catch (d.a e10) {
                        Log.e(c0.f8056o, "Unable to retrieve data to send " + e10.getLocalizedMessage());
                    }
                } else {
                    c0.this.f8069k.set(list.size());
                }
            }
        }
    }

    class b implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ com.vungle.warren.model.r f8076a;

        b(com.vungle.warren.model.r rVar) {
            this.f8076a = rVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                if (c0.this.f8071m != null && this.f8076a != null) {
                    c0.this.f8071m.h0(this.f8076a);
                    c0.this.f8069k.incrementAndGet();
                    Log.d(c0.f8056o, "Session Count: " + c0.this.f8069k + " " + this.f8076a.f8429a);
                    if (c0.this.f8069k.get() >= c0.this.f8068j) {
                        c0 c0Var = c0.this;
                        c0Var.q((List) c0Var.f8071m.V(com.vungle.warren.model.r.class).get());
                        Log.d(c0.f8056o, "SendData " + c0.this.f8069k);
                    }
                }
            } catch (d.a unused) {
                VungleLogger.c(c0.f8056o, "Could not save event to DB");
            }
        }
    }

    class c extends a.g {

        /* renamed from: a, reason: collision with root package name */
        private long f8078a;

        c() {
        }

        @Override // com.vungle.warren.utility.a.g
        public void c() {
            if (this.f8078a <= 0) {
                return;
            }
            long a10 = c0.this.f8059a.a() - this.f8078a;
            if (c0.this.j() > -1 && a10 > 0 && a10 >= c0.this.j() * 1000 && c0.this.f8063e != null) {
                c0.this.f8063e.a();
            }
            c0.this.w(new r.b().d(h8.c.APP_FOREGROUND).c());
        }

        @Override // com.vungle.warren.utility.a.g
        public void d() {
            c0.this.w(new r.b().d(h8.c.APP_BACKGROUND).c());
            this.f8078a = c0.this.f8059a.a();
        }
    }

    public interface d {
        void a();
    }

    private c0() {
    }

    public static c0 l() {
        if (f8057p == null) {
            f8057p = new c0();
        }
        return f8057p;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public synchronized void q(List list) {
        if (this.f8061c && !list.isEmpty()) {
            z4.g gVar = new z4.g();
            Iterator it = list.iterator();
            while (it.hasNext()) {
                z4.h c10 = z4.m.c(((com.vungle.warren.model.r) it.next()).b());
                if (c10 != null && c10.m()) {
                    gVar.p(c10.g());
                }
            }
            try {
                d8.e c11 = this.f8067i.G(gVar).c();
                Iterator it2 = list.iterator();
                while (it2.hasNext()) {
                    com.vungle.warren.model.r rVar = (com.vungle.warren.model.r) it2.next();
                    if (!c11.e() && rVar.d() < this.f8068j) {
                        rVar.f();
                        this.f8071m.h0(rVar);
                    }
                    this.f8071m.s(rVar);
                }
            } catch (IOException e10) {
                Log.e(f8056o, "Sending session analytics failed " + e10.getLocalizedMessage());
            }
            this.f8069k.set(0);
        }
    }

    private synchronized void t(com.vungle.warren.model.r rVar) {
        ExecutorService executorService = this.f8060b;
        if (executorService == null) {
            return;
        }
        executorService.submit(new b(rVar));
    }

    protected void i() {
        this.f8064f.clear();
    }

    public long j() {
        return this.f8062d;
    }

    public long k() {
        return f8058q;
    }

    public String m(int i10) {
        return i10 != 0 ? i10 != 1 ? i10 != 2 ? i10 != 3 ? "none" : "match_video" : "auto_rotate" : "landscape" : "portrait";
    }

    protected synchronized boolean n(com.vungle.warren.model.r rVar) {
        h8.c cVar = h8.c.INIT;
        h8.c cVar2 = rVar.f8429a;
        if (cVar == cVar2) {
            this.f8070l++;
            return false;
        }
        if (h8.c.INIT_END == cVar2) {
            int i10 = this.f8070l;
            if (i10 <= 0) {
                return true;
            }
            this.f8070l = i10 - 1;
            return false;
        }
        if (h8.c.LOAD_AD == cVar2) {
            this.f8065g.add(rVar.e(h8.a.PLACEMENT_ID));
            return false;
        }
        if (h8.c.LOAD_AD_END == cVar2) {
            List list = this.f8065g;
            h8.a aVar = h8.a.PLACEMENT_ID;
            if (!list.contains(rVar.e(aVar))) {
                return true;
            }
            this.f8065g.remove(rVar.e(aVar));
            return false;
        }
        if (h8.c.ADS_CACHED != cVar2) {
            return false;
        }
        if (rVar.e(h8.a.VIDEO_CACHED) == null) {
            this.f8066h.put(rVar.e(h8.a.URL), rVar);
            return true;
        }
        Map map = this.f8066h;
        h8.a aVar2 = h8.a.URL;
        com.vungle.warren.model.r rVar2 = (com.vungle.warren.model.r) map.get(rVar.e(aVar2));
        if (rVar2 == null) {
            return !rVar.e(r0).equals(h8.b.f10570a);
        }
        this.f8066h.remove(rVar.e(aVar2));
        rVar.g(aVar2);
        h8.a aVar3 = h8.a.EVENT_ID;
        rVar.a(aVar3, rVar2.e(aVar3));
        return false;
    }

    protected void o(d dVar, com.vungle.warren.utility.y yVar, g8.j jVar, ExecutorService executorService, VungleApiClient vungleApiClient, boolean z10, int i10) {
        this.f8063e = dVar;
        this.f8059a = yVar;
        this.f8060b = executorService;
        this.f8071m = jVar;
        this.f8061c = z10;
        this.f8067i = vungleApiClient;
        if (i10 <= 0) {
            i10 = 40;
        }
        this.f8068j = i10;
        if (z10) {
            executorService.submit(new a(z10, jVar));
        } else {
            i();
        }
    }

    public void p() {
        com.vungle.warren.utility.a.p().n(this.f8072n);
    }

    public void r(long j10) {
        this.f8062d = j10;
    }

    public void s(long j10) {
        f8058q = j10;
    }

    public void u(AdConfig adConfig) {
        if (adConfig != null && adConfig.f8221c) {
            w(new r.b().d(h8.c.MUTE).b(h8.a.MUTED, (adConfig.b() & 1) == 1).c());
        }
        if (adConfig == null || !adConfig.f7838f) {
            return;
        }
        w(new r.b().d(h8.c.ORIENTATION).a(h8.a.ORIENTATION, m(adConfig.e())).c());
    }

    public void v(f fVar) {
        if (fVar == null || !fVar.f8221c) {
            return;
        }
        w(new r.b().d(h8.c.MUTE).b(h8.a.MUTED, (fVar.b() & 1) == 1).c());
    }

    public synchronized void w(com.vungle.warren.model.r rVar) {
        if (rVar == null) {
            return;
        }
        if (!this.f8061c) {
            this.f8064f.add(rVar);
        } else {
            if (!n(rVar)) {
                t(rVar);
            }
        }
    }
}