PhotoRoom v4.8.2版本的 MD5 值为：c40a01bb3380c0f75c0cb6ac6760f295
以下内容为反编译后的 f.java 源代码，内容仅作参考
package o8;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import kotlin.collections.q0;
import kotlin.collections.r0;
import kotlin.collections.z0;
import kotlin.jvm.internal.o0;
import m20.f;
import org.json.JSONObject;
import px.c0;
import px.f1;
import s8.h;
import w10.b0;
import w10.d0;
import w10.e0;
import w10.z;
public final class f implements k {
private final String f61788a;
private final l f61789b;
private final z f61790c;
private final ScheduledExecutorService f61791d;
private m f61792e;
private final q8.j f61793f;
private final r8.b f61794g;
private final r8.b f61795h;
private final Object f61796i;
private s8.d f61797j;
private final long f61798k;
private final s8.e f61799l;
private final s8.m f61800m;
private final w10.v f61801n;
private final w10.v f61802o;
private final t f61803p;
private n f61804q;
private final s8.n f61805r;
private final s8.p f61806s;
private final Object f61807t;
public class a {
public static final int[] f61808a;
static {
int[] iArr = new int[v.values().length];
iArr[v.LOCAL_STORAGE.ordinal()] = 1;
iArr[v.INITIAL_VARIANTS.ordinal()] = 2;
f61808a = iArr;
}
}
public static final class b implements w10.f {
final s8.b f61810c;
b(s8.b bVar) {
this.f61810c = bVar;
}
@Override
public void onFailure(w10.e call, IOException e11) {
kotlin.jvm.internal.t.i(call, "call");
kotlin.jvm.internal.t.i(e11, "e");
this.f61810c.b(e11);
}
@Override
public void onResponse(w10.e call, d0 response) {
kotlin.jvm.internal.t.i(call, "call");
kotlin.jvm.internal.t.i(response, "response");
try {
s8.l lVar = s8.l.f70265a;
lVar.d("Received fetch variants response: " + response);
this.f61810c.a(f.this.y(response));
} catch (Exception e11) {
this.f61810c.b(e11);
}
}
}
public static final class c extends kotlin.jvm.internal.v implements hy.l {
c() {
super(1);
}
@Override
public Object invoke(Object obj) {
invoke((Map) obj);
return f1.f64673a;
}
public final void invoke(Map flags) {
kotlin.jvm.internal.t.i(flags, "flags");
r8.b bVar = f.this.f61795h;
f fVar = f.this;
synchronized (bVar) {
fVar.f61795h.a();
fVar.f61795h.f(flags);
r8.b.i(fVar.f61795h, null, 1, null);
fVar.x();
f1 f1Var = f1.f64673a;
}
}
}
class d extends kotlin.jvm.internal.a implements hy.a {
d(Object obj) {
super(0, obj, f.class, "doFlags", "doFlags()Ljava/util/concurrent/Future;", 8);
}
public final void b() {
((f) this.receiver).k();
}
@Override
public Object invoke() {
b();
return f1.f64673a;
}
}
public static final class e extends kotlin.jvm.internal.v implements hy.a {
final m f61813h;
e(m mVar, q qVar) {
super(0);
this.f61813h = mVar;
}
@Override
public Object invoke() {
m14983invoke();
return f1.f64673a;
}
public final void m14983invoke() {
f fVar = f.this;
fVar.p(this.f61813h, fVar.f61798k, false, null);
}
}
public f(String apiKey, l config, z httpClient, r8.d storage, ScheduledExecutorService executorService) {
kotlin.jvm.internal.t.i(apiKey, "apiKey");
kotlin.jvm.internal.t.i(config, "config");
kotlin.jvm.internal.t.i(httpClient, "httpClient");
kotlin.jvm.internal.t.i(storage, "storage");
kotlin.jvm.internal.t.i(executorService, "executorService");
this.f61788a = apiKey;
this.f61789b = config;
this.f61790c = httpClient;
this.f61791d = executorService;
this.f61793f = new q8.j(null, 1, null);
r8.b f11 = r8.a.f(apiKey, config.f61832b, storage);
this.f61794g = f11;
r8.b e11 = r8.a.e(apiKey, config.f61832b, storage);
this.f61795h = e11;
f11.d();
e11.d();
x();
this.f61796i = new Object();
this.f61798k = 10000L;
this.f61799l = new s8.e(8L, 500L, 10000L, 1.5f);
this.f61800m = new s8.m(executorService, new d(this), 60000L);
this.f61801n = (kotlin.jvm.internal.t.d(config.f61837g, "https://api.lab.amplitude.com/") && kotlin.jvm.internal.t.d(config.f61838h, "https://flag.lab.amplitude.com/") && config.f61839i == u.EU) ? w10.v.f78341k.d("https://api.lab.eu.amplitude.com/") : w10.v.f78341k.d(config.f61837g);
w10.v d11 = (kotlin.jvm.internal.t.d(config.f61837g, "https://api.lab.amplitude.com/") && kotlin.jvm.internal.t.d(config.f61838h, "https://flag.lab.amplitude.com/") && config.f61839i == u.EU) ? w10.v.f78341k.d("https://flag.lab.eu.amplitude.com/") : w10.v.f78341k.d(config.f61838h);
this.f61802o = d11;
this.f61803p = new t(apiKey, d11, httpClient);
this.f61804q = config.f61846p;
p8.b bVar = config.f61847q;
this.f61805r = bVar != null ? new s8.n(bVar) : null;
p pVar = config.f61848r;
this.f61806s = pVar != null ? new s8.p(pVar) : null;
this.f61807t = new Object();
}
private final void A(m mVar, q qVar) {
synchronized (this.f61796i) {
s8.d dVar = this.f61797j;
if (dVar != null) {
dVar.d();
}
this.f61797j = s8.f.a(this.f61791d, this.f61799l, new e(mVar, qVar));
f1 f1Var = f1.f64673a;
}
}
private final f1 B() {
f1 f1Var;
synchronized (this.f61796i) {
s8.d dVar = this.f61797j;
if (dVar != null) {
dVar.d();
f1Var = f1.f64673a;
} else {
f1Var = null;
}
}
return f1Var;
}
private final void C(Map map, q qVar) {
ArrayList<String> arrayList = new ArrayList();
synchronized (this.f61794g) {
this.f61794g.a();
for (Map.Entry entry : map.entrySet()) {
this.f61794g.e((String) entry.getKey(), entry.getValue());
arrayList.remove(entry.getKey());
}
for (String str : arrayList) {
this.f61794g.g(str);
}
r8.b.i(this.f61794g, null, 1, null);
s8.l lVar = s8.l.f70265a;
lVar.d("Stored variants: " + map);
f1 f1Var = f1.f64673a;
}
}
private final Future j(m mVar, long j11, q qVar) {
if (mVar.f61877a == null && mVar.f61878b == null) {
h.a.b(s8.l.f70265a, "user id and device id are null; amplitude may not resolve identity", null, 2, null);
}
s8.l lVar = s8.l.f70265a;
lVar.d("Fetch variants for user: " + mVar);
f.a aVar = m20.f.f58272e;
byte[] bytes = s8.o.g(mVar).getBytes(kotlin.text.d.f56128b);
kotlin.jvm.internal.t.h(bytes, "this as java.lang.String).getBytes(charset)");
String c11 = f.a.g(aVar, bytes, 0, 0, 3, null).c();
b0.a v11 = new b0.a().f().v(this.f61801n.k().b("sdk/v2/vardata").e());
w10.e b11 = this.f61790c.b(v11.a("Authorization", "Api-Key " + this.f61788a).a("X-Amp-Exp-User", c11).b());
b11.timeout().g(j11, TimeUnit.MILLISECONDS);
s8.b bVar = new s8.b(b11, null, 2, null);
b11.o0(new b(bVar));
return bVar;
}
public final Future k() {
return this.f61803p.a(new s("experiment-js-client", "1.12.0", null, this.f61789b.f61840j, 4, null), new c());
}
private final Map l(Set set) {
Map i11;
Map c11;
int e11;
m q11 = q();
try {
synchronized (this.f61795h) {
c11 = this.f61795h.c();
}
List c12 = q8.u.c(c11, set);
Map g11 = this.f61793f.g(s8.o.f(q11), c12);
e11 = q0.e(g11.size());
LinkedHashMap linkedHashMap = new LinkedHashMap(e11);
for (Map.Entry entry : g11.entrySet()) {
linkedHashMap.put(entry.getKey(), s8.r.a((q8.n) entry.getValue()));
}
return linkedHashMap;
} catch (Exception e12) {
s8.l.f70265a.a("Error during topological sort of flags", e12);
i11 = r0.i();
return i11;
}
}
private final void m(String str, x xVar) {
String str2;
u(str, xVar.c(), xVar.b());
boolean t11 = t(xVar.b());
if (!t11 || xVar.a()) {
String str3 = xVar.c().f61933c;
Map map = xVar.c().f61935e;
if (t11 || xVar.c().a()) {
str2 = null;
} else {
str2 = xVar.c().f61934d;
if (str2 == null) {
str2 = xVar.c().f61931a;
}
}
o oVar = new o(str, str2, str3, map);
s8.p pVar = this.f61806s;
if (pVar != null) {
s8.p.b(pVar, oVar, null, 2, null);
}
}
}
public static final k o(f this$0, q qVar) {
kotlin.jvm.internal.t.i(this$0, "this$0");
m r11 = this$0.r(10000L);
l lVar = this$0.f61789b;
this$0.p(r11, lVar.f61840j, lVar.f61841k, qVar);
return this$0;
}
private final m q() {
m mVar = this.f61792e;
if (mVar == null) {
mVar = new m();
}
m a11 = mVar.a().m("experiment-android-client/1.12.0").a();
n nVar = this.f61789b.f61846p;
return s8.o.c(a11, nVar != null ? nVar.j() : null);
}
private final m r(long j11) {
m a11;
n nVar = this.f61804q;
if (nVar instanceof o8.c) {
try {
a11 = ((o8.c) nVar).a(j11);
} catch (TimeoutException e11) {
throw new IllegalStateException(e11);
}
} else {
a11 = nVar != null ? nVar.j() : null;
}
m mVar = this.f61792e;
if (mVar == null) {
mVar = new m();
}
return s8.o.c(mVar.a().m("experiment-android-client/1.12.0").a(), a11);
}
private final x s(String str, w wVar) {
w wVar2;
Map map;
x xVar = new x(null, null, false, 7, null);
w wVar3 = (w) this.f61789b.f61835e.get(str);
if (wVar3 != null) {
return new x(wVar3, y.INITIAL_VARIANTS, false);
}
synchronized (this.f61794g) {
wVar2 = (w) this.f61794g.c().get(str);
}
Object obj = (wVar2 == null || (map = wVar2.f61935e) == null) ? null : map.get("default");
Boolean bool = obj instanceof Boolean ? (Boolean) obj : null;
if (wVar2 == null || kotlin.jvm.internal.t.d(bool, Boolean.TRUE)) {
if (kotlin.jvm.internal.t.d(bool, Boolean.TRUE)) {
xVar = new x(wVar2, y.LOCAL_STORAGE, true);
}
if (wVar != null) {
return new x(wVar, y.FALLBACK_INLINE, xVar.a());
}
w wVar4 = this.f61789b.f61833c;
return !wVar4.b() ? new x(wVar4, y.FALLBACK_CONFIG, xVar.a()) : xVar;
}
return new x(wVar2, y.LOCAL_STORAGE, false);
}
private final boolean t(y yVar) {
return yVar == null || yVar.c();
}
private final void u(String str, w wVar, y yVar) {
p8.c cVar = new p8.c(q(), str, wVar, yVar);
if (yVar.c() || wVar.f61934d == null) {
s8.n nVar = this.f61805r;
if (nVar != null) {
nVar.c(cVar);
return;
}
return;
}
s8.n nVar2 = this.f61805r;
if (nVar2 != null) {
nVar2.a(cVar);
}
s8.n nVar3 = this.f61805r;
if (nVar3 != null) {
nVar3.b(cVar);
}
}
private final x v(String str, q8.k kVar, w wVar) {
Set d11;
Map map;
x xVar = new x(null, null, false, 7, null);
d11 = z0.d(kVar.b());
w wVar2 = (w) l(d11).get(str);
y yVar = y.LOCAL_EVALUATION;
Object obj = (wVar2 == null || (map = wVar2.f61935e) == null) ? null : map.get("default");
Boolean bool = obj instanceof Boolean ? (Boolean) obj : null;
if (wVar2 == null || kotlin.jvm.internal.t.d(bool, Boolean.TRUE)) {
if (kotlin.jvm.internal.t.d(bool, Boolean.TRUE)) {
xVar = new x(wVar2, yVar, true);
}
if (wVar != null) {
return new x(wVar, y.FALLBACK_INLINE, xVar.a());
}
w wVar3 = (w) this.f61789b.f61835e.get(str);
if (wVar3 != null) {
return new x(wVar3, y.SECONDARY_INITIAL_VARIANTS, xVar.a());
}
w wVar4 = this.f61789b.f61833c;
return !wVar4.b() ? new x(wVar4, y.FALLBACK_CONFIG, xVar.a()) : xVar;
}
return new x(wVar2, yVar, false);
}
private final x w(String str, w wVar) {
w wVar2;
Map map;
x xVar = new x(null, null, false, 7, null);
synchronized (this.f61794g) {
wVar2 = (w) this.f61794g.c().get(str);
}
Object obj = (wVar2 == null || (map = wVar2.f61935e) == null) ? null : map.get("default");
Boolean bool = obj instanceof Boolean ? (Boolean) obj : null;
if (wVar2 == null || kotlin.jvm.internal.t.d(bool, Boolean.TRUE)) {
if (kotlin.jvm.internal.t.d(bool, Boolean.TRUE)) {
xVar = new x(wVar2, y.LOCAL_STORAGE, true);
}
if (wVar != null) {
return new x(wVar, y.FALLBACK_INLINE, xVar.a());
}
w wVar3 = (w) this.f61789b.f61835e.get(str);
if (wVar3 != null) {
return new x(wVar3, y.SECONDARY_INITIAL_VARIANTS, xVar.a());
}
w wVar4 = this.f61789b.f61833c;
return !wVar4.b() ? new x(wVar4, y.FALLBACK_CONFIG, xVar.a()) : xVar;
}
return new x(wVar2, y.LOCAL_STORAGE, false);
}
public final void x() {
String str = this.f61789b.f61834d;
if (str != null) {
t10.a aVar = q8.m.f66100a;
for (q8.k kVar : (List) aVar.b(o10.w.d(aVar.a(), o0.m(List.class, kotlin.reflect.s.f56100c.d(o0.l(q8.k.class)))), str)) {
if (this.f61795h.b(kVar.b()) == null) {
this.f61795h.e(kVar.b(), kVar);
}
}
}
}
public final Map y(d0 d0Var) {
try {
if (!d0Var.A0()) {
throw new IOException("fetch error response: " + d0Var);
}
e0 a11 = d0Var.a();
JSONObject jSONObject = new JSONObject((a11 == null || (r0 = a11.n()) == null) ? "" : "");
LinkedHashMap linkedHashMap = new LinkedHashMap();
Iterator<String> keys = jSONObject.keys();
kotlin.jvm.internal.t.h(keys, "json.keys()");
while (keys.hasNext()) {
String key = keys.next();
w d11 = s8.r.d(jSONObject.getJSONObject(key));
if (d11 != null) {
kotlin.jvm.internal.t.h(key, "key");
linkedHashMap.put(key, d11);
}
}
cy.c.a(d0Var, null);
return linkedHashMap;
} catch (Throwable th2) {
try {
throw th2;
} catch (Throwable th3) {
cy.c.a(d0Var, th2);
throw th3;
}
}
}
private final x z(String str, w wVar) {
x w11;
q8.k kVar;
int i11 = a.f61808a[this.f61789b.f61836f.ordinal()];
if (i11 == 1) {
w11 = w(str, wVar);
} else if (i11 != 2) {
throw new c0();
} else {
w11 = s(str, wVar);
}
synchronized (this.f61795h) {
kVar = (q8.k) this.f61795h.b(str);
}
return kVar != null ? (s8.g.a(kVar) || w11.c().b()) ? v(str, kVar, wVar) : w11 : w11;
}
public w D(String key, w wVar) {
kotlin.jvm.internal.t.i(key, "key");
x z11 = z(key, wVar);
if (this.f61789b.f61842l) {
m(key, z11);
}
return z11.c();
}
@Override
public w a(String key) {
kotlin.jvm.internal.t.i(key, "key");
return D(key, null);
}
@Override
public void b(m user) {
kotlin.jvm.internal.t.i(user, "user");
this.f61792e = user;
}
@Override
public Future c(m mVar) {
return n(mVar, null);
}
public Future n(m mVar, final q qVar) {
if (mVar == null) {
mVar = this.f61792e;
}
this.f61792e = mVar;
Future submit = this.f61791d.submit(new Callable(qVar) {
@Override
public final Object call() {
k o11;
o11 = f.o(f.this, null);
return o11;
}
});
kotlin.jvm.internal.t.h(submit, "executorService.submit(\n…s\n }\n )");
return submit;
}
public final void p(m user, long j11, boolean z11, q qVar) {
kotlin.jvm.internal.t.i(user, "user");
if (z11) {
B();
}
try {
Map variants = (Map) j(user, j11, qVar).get();
kotlin.jvm.internal.t.h(variants, "variants");
C(variants, qVar);
} catch (Exception e11) {
if (z11) {
A(user, qVar);
}
throw e11;
}
}
}