package com.flurry.sdk;
import android.os.Handler;
import android.os.Looper;
import android.text.TextUtils;
import android.util.Pair;
import com.flurry.android.FlurryConfigListener;
import com.flurry.sdk.bw;
import com.flurry.sdk.cb;
import com.flurry.sdk.ew;
import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public final class by extends f {
private static volatile by b;
private static final Object k = new Object();
private static ck p;
public bz a;
private bv d;
private cd e;
private cj f;
private cp g;
private Handler h;
private final Map<FlurryConfigListener, Pair<cf, WeakReference<Handler>>> i;
private final Map<cf, Pair<Boolean, Boolean>> j;
private volatile boolean l;
private volatile boolean m;
private volatile boolean n;
private a o;
/* access modifiers changed from: package-private */
public enum a {
Complete("Complete", 3),
CompleteNoChange("No Change", 2),
Fail("Fail", 1),
None("None", 0);
int e;
private String f;
private a(String str, int i) {
this.f = str;
this.e = i;
}
public final String toString() {
return this.f;
}
}
public static synchronized by a() {
by f2;
synchronized (by.class) {
f2 = f();
}
return f2;
}
private static synchronized by f() {
by byVar;
synchronized (by.class) {
if (b == null) {
b = new by((byte) 0);
}
byVar = b;
}
return byVar;
}
private by() {
this((byte) 0);
}
private by(byte b2) {
super("ConfigManager", ew.a(ew.a.CONFIG));
this.i = new ConcurrentHashMap();
this.j = new HashMap();
this.l = false;
this.m = false;
this.n = false;
this.o = a.None;
p = null;
for (cf cfVar : cf.b()) {
Map<cf, Pair<Boolean, Boolean>> map = this.j;
Boolean bool = Boolean.FALSE;
map.put(cfVar, new Pair<>(bool, bool));
}
this.e = new cd();
this.f = new cj();
this.a = new bz();
this.g = new cp();
this.h = new Handler(Looper.getMainLooper());
runAsync(new ea() {
/* class com.flurry.sdk.by.AnonymousClass1 */
/* JADX ERROR: StackOverflowError in pass: MarkFinallyVisitor
java.lang.StackOverflowError
at jadx.core.dex.instructions.InvokeNode.isSame(InvokeNode.java:77)
at jadx.core.dex.visitors.MarkFinallyVisitor.sameInsns(MarkFinallyVisitor.java:451)
at jadx.core.dex.visitors.MarkFinallyVisitor.compareBlocks(MarkFinallyVisitor.java:436)
at jadx.core.dex.visitors.MarkFinallyVisitor.checkBlocksTree(MarkFinallyVisitor.java:408)
at jadx.core.dex.visitors.MarkFinallyVisitor.checkBlocksTree(MarkFinallyVisitor.java:411)
*/
@Override // com.flurry.sdk.ea
public final void a() throws java.lang.Exception {
/*
// Method dump skipped, instructions count: 336
*/
throw new UnsupportedOperationException("Method not decompiled: com.flurry.sdk.by.AnonymousClass1.a():void");
}
});
}
public static ck b() {
return p;
}
public final bv c() {
if (this.d == null) {
g();
this.d = new bv(this.e, this.f);
}
return this.d;
}
private void g() {
synchronized (k) {
while (!this.l) {
try {
k.wait();
} catch (InterruptedException e2) {
cx.b("ConfigManager", "Interrupted Exception!", e2);
}
}
}
}
public final void d() {
if (this.m) {
cx.a(3, "ConfigManager", "Preventing re-entry...");
return;
}
this.m = true;
cx.a(3, "ConfigManager", "Fetch started");
for (bw bwVar : cc.a(cp.a(b.a(), "https://cfg.flurry.com/sdk/v1/config"), new bw.a() {
/* class com.flurry.sdk.by.AnonymousClass2 */
@Override // com.flurry.sdk.bw.a
public final void a(cb cbVar, boolean z) {
a aVar;
if (!z) {
by.this.m = false;
}
if (cbVar.d == cb.a.SUCCEED) {
cx.a("ConfigManager", "Fetch succeeded.");
aVar = a.Complete;
by.this.n = true;
for (cf cfVar : cf.b()) {
boolean z2 = false;
if (by.this.j.containsKey(cfVar)) {
z2 = ((Boolean) ((Pair) by.this.j.get(cfVar)).first).booleanValue();
}
by.this.j.put(cfVar, new Pair(Boolean.valueOf(z2), Boolean.FALSE));
}
} else if (cbVar.d == cb.a.NO_CHANGE) {
cx.a("ConfigManager", "Fetch finished.");
aVar = a.CompleteNoChange;
} else {
cx.a("ConfigManager", "Error occured while fetching: ".concat(String.valueOf(cbVar)));
aVar = a.Fail;
}
if (by.this.o.e <= aVar.e) {
by.this.o = aVar;
}
by.b(by.this, aVar);
}
}, this.a, this.f)) {
bwVar.a();
}
}
public final void a(FlurryConfigListener flurryConfigListener, cf cfVar, Handler handler) {
if (flurryConfigListener != null) {
synchronized (this.i) {
if (this.i.containsKey(flurryConfigListener)) {
cx.a(5, "ConfigManager", "The listener is already registered");
return;
}
this.i.put(flurryConfigListener, new Pair<>(cfVar, new WeakReference(handler)));
int i2 = AnonymousClass6.a[this.o.ordinal()];
if (i2 == 2) {
flurryConfigListener.onFetchSuccess();
} else if (i2 == 3) {
flurryConfigListener.onFetchNoChange();
} else if (i2 == 4) {
flurryConfigListener.onFetchError(this.m);
}
if (this.j.containsKey(cfVar)) {
Pair<Boolean, Boolean> pair = this.j.get(cfVar);
if (((Boolean) pair.first).booleanValue() || ((Boolean) pair.second).booleanValue()) {
flurryConfigListener.onActivateComplete(!((Boolean) pair.second).booleanValue());
}
} else {
Map<cf, Pair<Boolean, Boolean>> map = this.j;
Boolean bool = Boolean.FALSE;
map.put(cfVar, new Pair<>(bool, bool));
}
}
}
}
/* renamed from: com.flurry.sdk.by$6 reason: invalid class name */
static /* synthetic */ class AnonymousClass6 {
static final /* synthetic */ int[] a;
/* JADX WARNING: Can't wrap try/catch for region: R(8:0|1|2|3|4|5|6|(3:7|8|10)) */
/* JADX WARNING: Failed to process nested try/catch */
/* JADX WARNING: Missing exception handler attribute for start block: B:3:0x0012 */
/* JADX WARNING: Missing exception handler attribute for start block: B:5:0x001d */
/* JADX WARNING: Missing exception handler attribute for start block: B:7:0x0028 */
static {
int[] iArr = new int[a.values().length];
a = iArr;
iArr[a.None.ordinal()] = 1;
a[a.Complete.ordinal()] = 2;
a[a.CompleteNoChange.ordinal()] = 3;
try {
a[a.Fail.ordinal()] = 4;
} catch (NoSuchFieldError unused) {
}
}
}
public final void a(FlurryConfigListener flurryConfigListener) {
if (flurryConfigListener != null) {
synchronized (this.i) {
this.i.remove(flurryConfigListener);
}
}
}
public final void a(cf cfVar, final boolean z) {
synchronized (this.i) {
for (Map.Entry<FlurryConfigListener, Pair<cf, WeakReference<Handler>>> entry : this.i.entrySet()) {
if (cfVar == null || cfVar == entry.getValue().first) {
final FlurryConfigListener key = entry.getKey();
Handler handler = (Handler) ((WeakReference) entry.getValue().second).get();
AnonymousClass4 r4 = new ea() {
/* class com.flurry.sdk.by.AnonymousClass4 */
@Override // com.flurry.sdk.ea
public final void a() {
key.onActivateComplete(z);
}
};
if (handler == null) {
this.h.post(r4);
} else {
handler.post(r4);
}
}
}
}
}
public final List<ci> e() {
cj cjVar = this.f;
if (cjVar != null) {
return cjVar.b();
}
return null;
}
public final boolean a(cf cfVar) {
boolean z;
if (!this.n) {
return false;
}
boolean z2 = true;
if (cfVar == null) {
boolean z3 = false;
for (Map.Entry<cf, Pair<Boolean, Boolean>> entry : this.j.entrySet()) {
Pair<Boolean, Boolean> value = entry.getValue();
if (!((Boolean) value.second).booleanValue()) {
entry.setValue(new Pair<>(value.first, Boolean.TRUE));
z3 = true;
}
}
z2 = z3;
} else {
Pair<Boolean, Boolean> pair = this.j.get(cfVar);
if (pair == null || !((Boolean) pair.second).booleanValue()) {
Map<cf, Pair<Boolean, Boolean>> map = this.j;
if (pair == null) {
z = false;
} else {
z = ((Boolean) pair.first).booleanValue();
}
map.put(cfVar, new Pair<>(Boolean.valueOf(z), Boolean.TRUE));
} else {
z2 = false;
}
}
if (z2) {
this.f.a(cfVar);
a(cfVar, false);
}
return z2;
}
public final String toString() {
g();
ArrayList arrayList = new ArrayList();
List<ci> e2 = e();
if (e2 == null || e2.isEmpty()) {
return "No variants were found!";
}
for (ci ciVar : e2) {
arrayList.add(ciVar.toString());
}
return TextUtils.join(",", arrayList);
}
static /* synthetic */ void c(by byVar) {
Object obj = k;
synchronized (obj) {
byVar.l = true;
obj.notifyAll();
}
}
static /* synthetic */ void b(by byVar, final a aVar) {
synchronized (byVar.i) {
for (Map.Entry<FlurryConfigListener, Pair<cf, WeakReference<Handler>>> entry : byVar.i.entrySet()) {
final FlurryConfigListener key = entry.getKey();
Handler handler = (Handler) ((WeakReference) entry.getValue().second).get();
AnonymousClass3 r4 = new ea() {
/* class com.flurry.sdk.by.AnonymousClass3 */
@Override // com.flurry.sdk.ea
public final void a() {
int i = AnonymousClass6.a[aVar.ordinal()];
if (i == 2) {
key.onFetchSuccess();
} else if (i == 3) {
key.onFetchNoChange();
} else if (i == 4) {
key.onFetchError(by.this.m);
}
}
};
if (handler == null) {
byVar.h.post(r4);
} else {
handler.post(r4);
}
}
}
}
}