MD5 校验值：8df004f6dd2453bdf1d8ecd51cca1137
t0.java 文件包含反编译后的源代码，请注意，该内容仅供学习和参考使用，不得用于非法用途。
package bo.app;
import android.content.Context;
import android.content.SharedPreferences;
import bo.app.g2;
import bo.app.r3;
import bo.app.r5;
import bo.app.t0;
import bo.app.t5;
import bo.app.u0;
import com.braze.coroutine.BrazeCoroutineScope;
import com.braze.events.IEventSubscriber;
import com.braze.support.BrazeLogger;
import com.braze.support.StringUtils;
import java.util.concurrent.TimeUnit;
import vg.x1;
public final class t0 {
public static final f f9873f = new f(null);
private static final long f9874g = TimeUnit.SECONDS.toMillis(5);
private final l5 f9875a;
private final i2 f9876b;
private final SharedPreferences f9877c;
private final v0 f9878d;
private vg.x1 f9879e;
public static final class a extends kotlin.jvm.internal.q implements kg.a {
public static final a f9880b = new a();
a() {
super(0);
}
@Override
public final String invoke() {
return "Cancelling ending of DUST subscription on delay and resuming stream";
}
}
public static final class b extends kotlin.jvm.internal.q implements kg.a {
public static final b f9881b = new b();
b() {
super(0);
}
@Override
public final String invoke() {
return "Ending DUST subscription on delay";
}
}
public static final class c extends kotlin.coroutines.jvm.internal.l implements kg.l {
int f9882b;
public static final class a extends kotlin.jvm.internal.q implements kg.a {
public static final a f9884b = new a();
a() {
super(0);
}
@Override
public final String invoke() {
return "Ending subscription on a delay";
}
}
c(cg.d dVar) {
super(1, dVar);
}
@Override
public final Object invoke(cg.d dVar) {
return ((c) create(dVar)).invokeSuspend(yf.v.f33976a);
}
@Override
public final cg.d create(cg.d dVar) {
return new c(dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
dg.d.c();
if (this.f9882b == 0) {
yf.n.b(obj);
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, t0.this, (BrazeLogger.Priority) null, (Throwable) null, a.f9884b, 3, (Object) null);
t0.this.a();
return yf.v.f33976a;
}
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
}
public static final class d extends kotlin.jvm.internal.q implements kg.a {
final r3 f9885b;
d(r3 r3Var) {
super(0);
this.f9885b = r3Var;
}
@Override
public final String invoke() {
return "Got network change event: " + this.f9885b;
}
}
public static final class e extends kotlin.jvm.internal.q implements kg.a {
public static final e f9886b = new e();
e() {
super(0);
}
@Override
public final String invoke() {
return "Received MITE value. Starting/resuming a new subscription";
}
}
public static final class f {
public f(kotlin.jvm.internal.h hVar) {
this();
}
private f() {
}
}
public class g {
public static final int[] f9887a;
static {
int[] iArr = new int[g2.b.values().length];
try {
iArr[g2.b.CONTENT_CARD_REFRESH.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
f9887a = iArr;
}
}
public static final class h extends kotlin.jvm.internal.q implements kg.a {
public static final h f9888b = new h();
h() {
super(0);
}
@Override
public final String invoke() {
return "Ending DUST subscription";
}
}
public static final class i extends kotlin.jvm.internal.q implements kg.a {
final g2 f9889b;
i(g2 g2Var) {
super(0);
this.f9889b = g2Var;
}
@Override
public final String invoke() {
return "Ingesting DUST message\n" + this.f9889b;
}
}
public static final class j extends kotlin.jvm.internal.q implements kg.a {
final g2.b f9890b;
j(g2.b bVar) {
super(0);
this.f9890b = bVar;
}
@Override
public final String invoke() {
return "Lacked logic to ingest message! Type: " + this.f9890b;
}
}
public static final class k extends kotlin.jvm.internal.q implements kg.a {
final String f9891b;
k(String str) {
super(0);
this.f9891b = str;
}
@Override
public final String invoke() {
return "setting mite value to " + this.f9891b;
}
}
public static final class l extends kotlin.jvm.internal.q implements kg.a {
final String f9892b;
final t0 f9893c;
l(String str, t0 t0Var) {
super(0);
this.f9892b = str;
this.f9893c = t0Var;
}
@Override
public final String invoke() {
return "Cannot start a dust subscription with mite " + this.f9892b + " and enabled " + this.f9893c.c().y();
}
}
public static final class m extends kotlin.jvm.internal.q implements kg.a {
final boolean f9894b;
final String f9895c;
final String f9896d;
m(boolean z10, String str, String str2) {
super(0);
this.f9894b = z10;
this.f9895c = str;
this.f9896d = str2;
}
@Override
public final String invoke() {
return "Starting (resume = " + this.f9894b + ") DUST subscription for mite: " + this.f9895c + " to url: " + this.f9896d;
}
}
public class n extends kotlin.jvm.internal.m implements kg.l {
n(Object obj) {
super(1, obj, t0.class, "ingestDustMessages", "ingestDustMessages(Lcom/braze/models/dust/IDustMessage;)V", 0);
}
public final void a(g2 p02) {
kotlin.jvm.internal.p.g(p02, "p0");
((t0) this.receiver).a(p02);
}
@Override
public Object invoke(Object obj) {
a((g2) obj);
return yf.v.f33976a;
}
}
public t0(l5 serverConfigStorageProvider, i2 internalPublisher, Context context, String str, String str2) {
kotlin.jvm.internal.p.g(serverConfigStorageProvider, "serverConfigStorageProvider");
kotlin.jvm.internal.p.g(internalPublisher, "internalPublisher");
kotlin.jvm.internal.p.g(context, "context");
this.f9875a = serverConfigStorageProvider;
this.f9876b = internalPublisher;
SharedPreferences sharedPreferences = context.getSharedPreferences("com.braze.managers.dust.metadata" + StringUtils.getCacheFileSuffix(context, str, str2), 0);
kotlin.jvm.internal.p.f(sharedPreferences, "context.getSharedPrefere…xt.MODE_PRIVATE\n )");
this.f9877c = sharedPreferences;
this.f9878d = new v0();
internalPublisher.c(r5.class, new IEventSubscriber() {
@Override
public final void trigger(Object obj) {
t0.a(t0.this, (r5) obj);
}
});
internalPublisher.c(t5.class, new IEventSubscriber() {
@Override
public final void trigger(Object obj) {
t0.a(t0.this, (t5) obj);
}
});
internalPublisher.c(r3.class, new IEventSubscriber() {
@Override
public final void trigger(Object obj) {
t0.a(t0.this, (r3) obj);
}
});
internalPublisher.c(u0.class, new IEventSubscriber() {
@Override
public final void trigger(Object obj) {
t0.a(t0.this, (u0) obj);
}
});
}
public static final void a(t0 this$0, r5 it) {
kotlin.jvm.internal.p.g(this$0, "this$0");
kotlin.jvm.internal.p.g(it, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, a.f9880b, 3, (Object) null);
vg.x1 x1Var = this$0.f9879e;
if (x1Var != null) {
x1.a.a(x1Var, null, 1, null);
}
this$0.a(true);
}
private final String b() {
return this.f9877c.getString("mite", null);
}
public final l5 c() {
return this.f9875a;
}
public static final void a(t0 this$0, t5 it) {
kotlin.jvm.internal.p.g(this$0, "this$0");
kotlin.jvm.internal.p.g(it, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, b.f9881b, 3, (Object) null);
this$0.f9879e = BrazeCoroutineScope.launchDelayed$default(BrazeCoroutineScope.INSTANCE, Long.valueOf(f9874g), null, new c(null), 2, null);
}
public static final void a(t0 this$0, r3 it) {
kotlin.jvm.internal.p.g(this$0, "this$0");
kotlin.jvm.internal.p.g(it, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, new d(it), 3, (Object) null);
q3 a10 = it.a();
q3 q3Var = q3.NONE;
if (a10 == q3Var) {
this$0.a();
} else if (it.b() == q3Var) {
this$0.a(true);
}
}
public static final void a(t0 this$0, u0 it) {
kotlin.jvm.internal.p.g(this$0, "this$0");
kotlin.jvm.internal.p.g(it, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, e.f9886b, 3, (Object) null);
String b10 = this$0.b();
this$0.a(it.a());
this$0.a(kotlin.jvm.internal.p.b(b10, it.a()));
}
private final void a(String str) {
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new k(str), 3, (Object) null);
this.f9877c.edit().putString("mite", str).apply();
}
private final void a(boolean z10) {
String b10 = b();
if (b10 != null && this.f9875a.y()) {
String str = "https://dust.k8s.test-001.d-usw-2.braze.com/sse?mite=" + b10;
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new m(z10, b10, str), 3, (Object) null);
this.f9878d.a(str, new n(this), z10);
return;
}
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new l(b10, this), 3, (Object) null);
}
public final void a() {
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, h.f9888b, 3, (Object) null);
this.f9878d.b();
}
public final void a(g2 g2Var) {
BrazeLogger brazeLogger = BrazeLogger.INSTANCE;
BrazeLogger.brazelog$default(brazeLogger, this, (BrazeLogger.Priority) null, (Throwable) null, new i(g2Var), 3, (Object) null);
g2.b a10 = g2Var.a();
if (g.f9887a[a10.ordinal()] == 1) {
this.f9876b.a(new v(), v.class);
} else {
BrazeLogger.brazelog$default(brazeLogger, this, BrazeLogger.Priority.W, (Throwable) null, new j(a10), 2, (Object) null);
}
}
}