package i8; import android.os.Bundle; import android.os.SystemClock; import android.util.Log; import com.vungle.warren.AdConfig; import com.vungle.warren.VungleApiClient; import com.vungle.warren.VungleLogger; import com.vungle.warren.c; import com.vungle.warren.model.n; import com.vungle.warren.r; import g8.d; import java.io.IOException; import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedList; import java.util.List; /* loaded from: classes2.dex */ public class b implements e { /* renamed from: d, reason: collision with root package name */ public static final String f10936d = "i8.b"; /* renamed from: e, reason: collision with root package name */ private static final String[] f10937e = new String[0]; /* renamed from: a, reason: collision with root package name */ private final VungleApiClient f10938a; /* renamed from: b, reason: collision with root package name */ private final g8.j f10939b; /* renamed from: c, reason: collision with root package name */ private final com.vungle.warren.c f10940c; public b(VungleApiClient vungleApiClient, g8.j jVar, com.vungle.warren.c cVar) { this.f10938a = vungleApiClient; this.f10939b = jVar; this.f10940c = cVar; } private void b(com.vungle.warren.model.c cVar, com.vungle.warren.model.h hVar) { try { Log.d(f10936d, "bustAd: deleting " + cVar.t()); this.f10940c.A(cVar.t()); this.f10939b.u(cVar.t()); g8.j jVar = this.f10939b; n nVar = (n) jVar.T(jVar.N(cVar), n.class).get(); if (nVar != null) { new AdConfig().c(nVar.b()); if (nVar.l()) { this.f10940c.W(nVar, nVar.b(), 0L, false); } else if (nVar.i()) { this.f10940c.T(new c.i(new com.vungle.warren.d(nVar.d(), false), nVar.b(), 0L, 2000L, 5, 1, 0, false, nVar.c(), new r[0])); } } hVar.j(System.currentTimeMillis()); this.f10939b.h0(hVar); } catch (d.a e10) { Log.e(f10936d, "bustAd: cannot drop cache or delete advertisement for " + cVar, e10); } } public static g c() { return new g(f10936d).l(0).o(true); } private void d(z4.k kVar, String str, int i10, String str2, List list, z4.e eVar) { if (kVar.x(str)) { Iterator it = kVar.v(str).iterator(); while (it.hasNext()) { com.vungle.warren.model.h hVar = (com.vungle.warren.model.h) eVar.k((z4.h) it.next(), com.vungle.warren.model.h.class); hVar.i(hVar.e() * 1000); hVar.h(i10); list.add(hVar); try { this.f10939b.h0(hVar); } catch (d.a unused) { VungleLogger.c(b.class.getSimpleName() + "#onRunJob", str2 + hVar); } } } } private void e(Iterable iterable) { Iterator it = iterable.iterator(); while (it.hasNext()) { com.vungle.warren.model.h hVar = (com.vungle.warren.model.h) it.next(); List G = hVar.d() == 1 ? this.f10939b.G(hVar.c()) : this.f10939b.I(hVar.c()); LinkedList linkedList = new LinkedList(); LinkedList linkedList2 = new LinkedList(); for (com.vungle.warren.model.c cVar : G) { if (cVar.y() < hVar.e() && g(cVar)) { linkedList.add(cVar.t()); linkedList2.add(cVar); } } if (linkedList.isEmpty()) { Log.d(f10936d, "processBust: bust has no relevant ads, deleting " + hVar); try { this.f10939b.s(hVar); } catch (d.a e10) { VungleLogger.c(b.class.getSimpleName() + "#processBust", "Cannot delete obsolete bust " + hVar + " because of " + e10); } } else { hVar.g((String[]) linkedList.toArray(f10937e)); Iterator it2 = linkedList2.iterator(); while (it2.hasNext()) { b((com.vungle.warren.model.c) it2.next(), hVar); } } } } private void f() { List list = (List) this.f10939b.V(com.vungle.warren.model.h.class).get(); if (list == null || list.size() == 0) { Log.d(f10936d, "sendAnalytics: no cachebusts in repository"); return; } LinkedList linkedList = new LinkedList(); for (com.vungle.warren.model.h hVar : list) { if (hVar.f() != 0) { linkedList.add(hVar); } } if (linkedList.isEmpty()) { Log.d(f10936d, "sendAnalytics: no cachebusts to send analytics"); return; } try { d8.e c10 = this.f10938a.E(linkedList).c(); if (!c10.e()) { Log.e(f10936d, "sendAnalytics: not successful, aborting, response is " + c10); return; } Iterator it = linkedList.iterator(); while (it.hasNext()) { try { this.f10939b.s((com.vungle.warren.model.h) it.next()); } catch (d.a unused) { VungleLogger.c(com.vungle.warren.j.class.getSimpleName() + "#sendAnalytics", "can't delete bust \" + cacheBust"); } } } catch (IOException e10) { Log.e(f10936d, "sendAnalytics: can't execute API call", e10); } } private boolean g(com.vungle.warren.model.c cVar) { return (cVar.A() == 2 || cVar.A() == 3) ? false : true; } @Override // i8.e public int a(Bundle bundle, h hVar) { g8.j jVar; String str = f10936d; Log.i(str, "CacheBustJob started"); if (this.f10938a == null || (jVar = this.f10939b) == null) { Log.e(str, "CacheBustJob finished - no client or repository"); return 1; } try { com.vungle.warren.model.j jVar2 = (com.vungle.warren.model.j) jVar.T("cacheBustSettings", com.vungle.warren.model.j.class).get(); if (jVar2 == null) { jVar2 = new com.vungle.warren.model.j("cacheBustSettings"); } com.vungle.warren.model.j jVar3 = jVar2; d8.e c10 = this.f10938a.h(jVar3.c("last_cache_bust").longValue()).c(); List arrayList = new ArrayList(); List O = this.f10939b.O(); if (O != null && !O.isEmpty()) { arrayList.addAll(O); } z4.e eVar = new z4.e(); if (c10.e()) { z4.k kVar = (z4.k) c10.a(); if (kVar != null && kVar.x("cache_bust")) { z4.k w10 = kVar.w("cache_bust"); if (w10.x("last_updated") && w10.u("last_updated").i() > 0) { jVar3.e("last_cache_bust", Long.valueOf(w10.u("last_updated").i())); this.f10939b.h0(jVar3); } d(w10, "campaign_ids", 1, "cannot save campaignBust=", arrayList, eVar); d(w10, "creative_ids", 2, "cannot save creativeBust=", arrayList, eVar); } Log.e(str, "CacheBustJob finished - no jsonObject or cache_bust in it"); return 1; } e(arrayList); h(bundle, jVar3); f(); Log.d(str, "CacheBustJob finished"); return 2; } catch (d.a e10) { Log.e(f10936d, "CacheBustJob failed - DBException", e10); return 2; } catch (IOException e11) { Log.e(f10936d, "CacheBustJob failed - IOException", e11); return 2; } } protected void h(Bundle bundle, com.vungle.warren.model.j jVar) { long j10 = bundle.getLong("cache_bust_interval"); if (j10 != 0) { jVar.e("next_cache_bust", Long.valueOf(SystemClock.elapsedRealtime() + j10)); } this.f10939b.h0(jVar); } }