正在查看： Baubap v3.9.7 应用的 u0.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Baubap v3.9.7 - u0.java 源代码
package bo.app;
import android.content.Context;
import android.content.SharedPreferences;
import bo.app.i2;
import com.braze.coroutine.BrazeCoroutineScope;
import com.braze.events.IEventSubscriber;
import com.braze.support.BrazeLogger;
import com.braze.support.StringUtils;
import java.util.concurrent.CancellationException;
import java.util.concurrent.TimeUnit;
public final class u0 {
public static final f f6771f = new f(null);
private static final long f6772g = TimeUnit.SECONDS.toMillis(5);
private final r5 f6773a;
private final k2 f6774b;
private final SharedPreferences f6775c;
private final w0 f6776d;
private m40.m1 f6777e;
public static final class a extends kotlin.jvm.internal.l implements y30.a {
public static final a f6778b = new a();
public a() {
super(0);
}
public final String invoke() {
return "Cancelling ending of DUST subscription on delay and resuming stream";
}
}
public static final class b extends kotlin.jvm.internal.l implements y30.a {
public static final b f6779b = new b();
public b() {
super(0);
}
public final String invoke() {
return "Ending DUST subscription on delay";
}
}
public static final class c extends s30.i implements y30.c {
int f6780b;
public static final class a extends kotlin.jvm.internal.l implements y30.a {
public static final a f6782b = new a();
public a() {
super(0);
}
public final String invoke() {
return "Ending subscription on a delay";
}
}
public c(q30.e eVar) {
super(1, eVar);
}
public final Object invoke(q30.e eVar) {
return create(eVar).invokeSuspend(m30.x.a);
}
public final q30.e create(q30.e eVar) {
return u0.this.new c(eVar);
}
public final Object invokeSuspend(Object obj) {
r30.a aVar = r30.a.b;
if (this.f6780b != 0) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
lu.n.f0(obj);
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, u0.this, (BrazeLogger.Priority) null, (Throwable) null, a.f6782b, 3, (Object) null);
u0.this.a();
return m30.x.a;
}
}
public static final class d extends kotlin.jvm.internal.l implements y30.a {
final u3 f6783b;
public d(u3 u3Var) {
super(0);
this.f6783b = u3Var;
}
public final String invoke() {
return "Got network change event: " + this.f6783b;
}
}
public static final class e extends kotlin.jvm.internal.l implements y30.a {
public static final e f6784b = new e();
public e() {
super(0);
}
public final String invoke() {
return "Received MITE value. Starting/resuming a new subscription";
}
}
public static final class f {
public f(kotlin.jvm.internal.f fVar) {
this();
}
private f() {
}
}
public class g {
public static final int[] f6785a;
static {
int[] iArr = new int[i2.b.values().length];
try {
iArr[i2.b.CONTENT_CARD_REFRESH.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
f6785a = iArr;
}
}
public static final class h extends kotlin.jvm.internal.l implements y30.a {
public static final h f6786b = new h();
public h() {
super(0);
}
public final String invoke() {
return "Ending DUST subscription";
}
}
public static final class i extends kotlin.jvm.internal.l implements y30.a {
final i2 f6787b;
public i(i2 i2Var) {
super(0);
this.f6787b = i2Var;
}
public final String invoke() {
return "Ingesting DUST message\n" + this.f6787b;
}
}
public static final class j extends kotlin.jvm.internal.l implements y30.a {
final i2.b f6788b;
public j(i2.b bVar) {
super(0);
this.f6788b = bVar;
}
public final String invoke() {
return "Lacked logic to ingest message! Type: " + this.f6788b;
}
}
public static final class k extends kotlin.jvm.internal.l implements y30.a {
final String f6789b;
public k(String str) {
super(0);
this.f6789b = str;
}
public final String invoke() {
return "setting mite value to " + this.f6789b;
}
}
public static final class l extends kotlin.jvm.internal.l implements y30.a {
final String f6790b;
final u0 f6791c;
public l(String str, u0 u0Var) {
super(0);
this.f6790b = str;
this.f6791c = u0Var;
}
public final String invoke() {
return "Cannot start a dust subscription with mite " + this.f6790b + " and enabled " + this.f6791c.c().C();
}
}
public static final class m extends kotlin.jvm.internal.l implements y30.a {
final boolean f6792b;
final String f6793c;
final String f6794d;
public m(boolean z10, String str, String str2) {
super(0);
this.f6792b = z10;
this.f6793c = str;
this.f6794d = str2;
}
public final String invoke() {
return "Starting (resume = " + this.f6792b + ") DUST subscription for mite: " + this.f6793c + " to url: " + this.f6794d;
}
}
public class n extends kotlin.jvm.internal.j implements y30.c {
public n(Object obj) {
super(1, obj, u0.class, "ingestDustMessages", "ingestDustMessages(Lcom/braze/models/dust/IDustMessage;)V", 0);
}
public final void a(i2 i2Var) {
xu.b.y(i2Var, "p0");
((u0) ((kotlin.jvm.internal.c) this).receiver).a(i2Var);
}
public Object invoke(Object obj) {
a((i2) obj);
return m30.x.a;
}
}
public u0(r5 r5Var, k2 k2Var, Context context, String str, String str2) {
xu.b.y(r5Var, "serverConfigStorageProvider");
xu.b.y(k2Var, "internalPublisher");
xu.b.y(context, "context");
this.f6773a = r5Var;
this.f6774b = k2Var;
final int i10 = 0;
SharedPreferences sharedPreferences = context.getSharedPreferences("com.braze.managers.dust.metadata" + StringUtils.getCacheFileSuffix(context, str, str2), 0);
xu.b.x(sharedPreferences, "context.getSharedPrefere…xt.MODE_PRIVATE\n )");
this.f6775c = sharedPreferences;
this.f6776d = new w0();
k2Var.c(x5.class, new IEventSubscriber(this) {
public final u0 f6587c;
{
this.f6587c = this;
}
public final void trigger(Object obj) {
int i11 = i10;
u0 u0Var = this.f6587c;
switch (i11) {
case 0:
u0.a(u0Var, (x5) obj);
break;
case 1:
u0.a(u0Var, (z5) obj);
break;
case 2:
u0.a(u0Var, (u3) obj);
break;
default:
u0.a(u0Var, (v0) obj);
break;
}
}
});
final int i11 = 1;
k2Var.c(z5.class, new IEventSubscriber(this) {
public final u0 f6587c;
{
this.f6587c = this;
}
public final void trigger(Object obj) {
int i112 = i11;
u0 u0Var = this.f6587c;
switch (i112) {
case 0:
u0.a(u0Var, (x5) obj);
break;
case 1:
u0.a(u0Var, (z5) obj);
break;
case 2:
u0.a(u0Var, (u3) obj);
break;
default:
u0.a(u0Var, (v0) obj);
break;
}
}
});
final int i12 = 2;
k2Var.c(u3.class, new IEventSubscriber(this) {
public final u0 f6587c;
{
this.f6587c = this;
}
public final void trigger(Object obj) {
int i112 = i12;
u0 u0Var = this.f6587c;
switch (i112) {
case 0:
u0.a(u0Var, (x5) obj);
break;
case 1:
u0.a(u0Var, (z5) obj);
break;
case 2:
u0.a(u0Var, (u3) obj);
break;
default:
u0.a(u0Var, (v0) obj);
break;
}
}
});
final int i13 = 3;
k2Var.c(v0.class, new IEventSubscriber(this) {
public final u0 f6587c;
{
this.f6587c = this;
}
public final void trigger(Object obj) {
int i112 = i13;
u0 u0Var = this.f6587c;
switch (i112) {
case 0:
u0.a(u0Var, (x5) obj);
break;
case 1:
u0.a(u0Var, (z5) obj);
break;
case 2:
u0.a(u0Var, (u3) obj);
break;
default:
u0.a(u0Var, (v0) obj);
break;
}
}
});
}
public static final void a(u0 u0Var, x5 x5Var) {
xu.b.y(u0Var, "this$0");
xu.b.y(x5Var, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, u0Var, (BrazeLogger.Priority) null, (Throwable) null, a.f6778b, 3, (Object) null);
m40.m1 m1Var = u0Var.f6777e;
if (m1Var != null) {
m1Var.j((CancellationException) null);
}
u0Var.a(true);
}
private final String b() {
return this.f6775c.getString("mite", null);
}
public final r5 c() {
return this.f6773a;
}
public static final void a(u0 u0Var, z5 z5Var) {
xu.b.y(u0Var, "this$0");
xu.b.y(z5Var, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, u0Var, (BrazeLogger.Priority) null, (Throwable) null, b.f6779b, 3, (Object) null);
u0Var.f6777e = BrazeCoroutineScope.launchDelayed$default(BrazeCoroutineScope.INSTANCE, Long.valueOf(f6772g), (q30.j) null, u0Var.new c(null), 2, (Object) null);
}
public static final void a(u0 u0Var, u3 u3Var) {
xu.b.y(u0Var, "this$0");
xu.b.y(u3Var, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, u0Var, (BrazeLogger.Priority) null, (Throwable) null, new d(u3Var), 3, (Object) null);
t3 a10 = u3Var.a();
t3 t3Var = t3.NONE;
if (a10 == t3Var) {
u0Var.a();
} else if (u3Var.b() == t3Var) {
u0Var.a(true);
}
}
public static final void a(u0 u0Var, v0 v0Var) {
xu.b.y(u0Var, "this$0");
xu.b.y(v0Var, "it");
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, u0Var, (BrazeLogger.Priority) null, (Throwable) null, e.f6784b, 3, (Object) null);
String b6 = u0Var.b();
u0Var.a(v0Var.a());
u0Var.a(xu.b.n(b6, v0Var.a()));
}
private final void a(String str) {
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new k(str), 3, (Object) null);
iq.a.v(this.f6775c, "mite", str);
}
private final void a(boolean z10) {
String b6 = b();
if (b6 != null && this.f6773a.C()) {
String concat = "https://dust.k8s.test-001.d-usw-2.braze.com/sse?mite=".concat(b6);
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new m(z10, b6, concat), 3, (Object) null);
this.f6776d.a(concat, new n(this), z10);
return;
}
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new l(b6, this), 3, (Object) null);
}
public final void a() {
BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, h.f6786b, 3, (Object) null);
this.f6776d.b();
}
public final void a(i2 i2Var) {
BrazeLogger brazeLogger = BrazeLogger.INSTANCE;
BrazeLogger.brazelog$default(brazeLogger, this, (BrazeLogger.Priority) null, (Throwable) null, new i(i2Var), 3, (Object) null);
i2.b a10 = i2Var.a();
if (g.f6785a[a10.ordinal()] == 1) {
this.f6774b.a(new u(), u.class);
} else {
BrazeLogger.brazelog$default(brazeLogger, this, BrazeLogger.Priority.W, (Throwable) null, new j(a10), 2, (Object) null);
}
}
}