正在查看： Dostt v1.0.89 应用的 C2048b.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Dostt v1.0.89 - C2048b.java 源代码
package vh;
import Dg.k;
import Dg.m;
import Lg.C0712a;
import Lg.C0714c;
import Lg.K;
import Sh.J;
import android.os.Bundle;
import com.google.android.gms.tasks.OnCompleteListener;
import com.google.android.gms.tasks.Task;
import com.google.firebase.messaging.FirebaseMessaging;
import gi.l;
import gi.p;
import java.util.Map;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.jvm.internal.AbstractC1735t;
import kotlin.jvm.internal.M;
import kotlin.jvm.internal.r;
import wg.n;
@Metadata(d1 = {"\u0000D\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\u0018\u00002\u00020\u00012\u00020\u0002B\u0007¢\u0006\u0004\b\u0003\u0010\u0004J\u0019\u0010\b\u001a\u0004\u0018\u00010\u00072\u0006\u0010\u0006\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\b\u0010\tJ\u000f\u0010\u000b\u001a\u00020\nH\u0016¢\u0006\u0004\b\u000b\u0010\fJ\u0017\u0010\u0010\u001a\u00020\u000f2\u0006\u0010\u000e\u001a\u00020\rH\u0016¢\u0006\u0004\b\u0010\u0010\u0011R\u0018\u0010\u0015\u001a\u0004\u0018\u00010\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014R\u0016\u0010\u0019\u001a\u0004\u0018\u00010\u00168BX\u0082\u0004¢\u0006\u0006\u001a\u0004\b\u0017\u0010\u0018¨\u0006\u001a"}, d2 = {"Lvh/b;", "LFg/a;", "Lwh/b;", "<init>", "()V", "Lwg/n;", "promise", "Lcom/google/firebase/messaging/FirebaseMessaging;", "r", "(Lwg/n;)Lcom/google/firebase/messaging/FirebaseMessaging;", "LFg/c;", "g", "()LFg/c;", "", "token", "LSh/J;", "a", "(Ljava/lang/String;)V", "LPf/a;", "d", "LPf/a;", "eventEmitter", "Lwh/c;", "s", "()Lwh/c;", "tokenManager", "expo-notifications_release"}, k = 1, mv = {1, 9, 0}, xi = 48)
public final class C2048b extends Fg.a implements wh.b {
private Pf.a eventEmitter;
static final class a implements OnCompleteListener {
final n a;
final Fg.b b;
final C2048b c;
a(n nVar, Fg.b bVar, C2048b c2048b) {
this.a = nVar;
this.b = bVar;
this.c = c2048b;
}
public final void onComplete(Task task) {
String str;
r.f(task, "task");
if (task.isSuccessful()) {
String str2 = (String) task.getResult();
if (str2 == null) {
this.a.reject("E_REGISTRATION_FAILED", "Fetching the token failed. Invalid token.", null);
return;
} else {
this.a.g(str2);
this.c.a(str2);
return;
}
}
Exception exception = task.getException();
n nVar = this.a;
if (exception == null || (str = exception.getMessage()) == null) {
str = "unknown";
}
nVar.reject("E_REGISTRATION_FAILED", "Fetching the token failed: " + str, exception);
}
}
static final class C0292b implements OnCompleteListener {
final n a;
C0292b(n nVar) {
this.a = nVar;
}
public final void onComplete(Task task) {
String str;
r.f(task, "task");
if (task.isSuccessful()) {
this.a.resolve(null);
return;
}
Exception exception = task.getException();
n nVar = this.a;
if (exception == null || (str = exception.getMessage()) == null) {
str = "unknown";
}
nVar.reject("E_UNREGISTER_FOR_NOTIFICATIONS_FAILED", "Unregistering for notifications failed: " + str, exception);
}
}
public static final class c extends AbstractC1735t implements p {
final Fg.b b;
public c(Fg.b bVar) {
super(2);
this.b = bVar;
}
public final void a(Object[] objArr, n promise) {
r.f(objArr, "<anonymous parameter 0>");
r.f(promise, "promise");
FirebaseMessaging r = C2048b.this.r(promise);
if (r == null) {
return;
}
r.w().addOnCompleteListener(new a(promise, this.b, C2048b.this));
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (n) obj2);
return J.a;
}
}
public static final class d extends AbstractC1735t implements gi.a {
public static final d a = new d();
public d() {
super(0);
}
@Override
public final ni.p invoke() {
return M.p(n.class);
}
}
public static final class e extends AbstractC1735t implements l {
final Fg.b b;
public e(Fg.b bVar) {
super(1);
this.b = bVar;
}
@Override
public final Object invoke(Object[] objArr) {
r.f(objArr, "<name for destructuring parameter 0>");
n nVar = (n) objArr[0];
FirebaseMessaging r = C2048b.this.r(nVar);
if (r != null) {
r.w().addOnCompleteListener(new a(nVar, this.b, C2048b.this));
}
return J.a;
}
}
public static final class f extends AbstractC1735t implements p {
public f() {
super(2);
}
public final void a(Object[] objArr, n promise) {
r.f(objArr, "<anonymous parameter 0>");
r.f(promise, "promise");
FirebaseMessaging r = C2048b.this.r(promise);
if (r == null) {
return;
}
r.p().addOnCompleteListener(new C0292b(promise));
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (n) obj2);
return J.a;
}
}
public static final class g extends AbstractC1735t implements gi.a {
public static final g a = new g();
public g() {
super(0);
}
@Override
public final ni.p invoke() {
return M.p(n.class);
}
}
public static final class h extends AbstractC1735t implements l {
public h() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
r.f(objArr, "<name for destructuring parameter 0>");
n nVar = (n) objArr[0];
FirebaseMessaging r = C2048b.this.r(nVar);
if (r != null) {
r.p().addOnCompleteListener(new C0292b(nVar));
}
return J.a;
}
}
public static final class i extends AbstractC1735t implements gi.a {
public i() {
super(0);
}
public final void a() {
Object obj;
C2048b c2048b = C2048b.this;
try {
obj = c2048b.f().t().b(Pf.a.class);
} catch (Exception unused) {
obj = null;
}
Pf.a aVar = (Pf.a) obj;
if (aVar == null) {
throw new Yg.a(M.b(Pf.a.class));
}
c2048b.eventEmitter = aVar;
wh.c s = C2048b.this.s();
if (s != null) {
s.k(C2048b.this);
}
}
@Override
public Object invoke() {
a();
return J.a;
}
}
public static final class j extends AbstractC1735t implements gi.a {
public j() {
super(0);
}
public final void a() {
wh.c s = C2048b.this.s();
if (s != null) {
s.g(C2048b.this);
}
}
@Override
public Object invoke() {
a();
return J.a;
}
}
public final FirebaseMessaging r(n promise) {
try {
return FirebaseMessaging.t();
} catch (IllegalStateException e2) {
promise.reject("E_REGISTRATION_FAILED", "Make sure to complete the guide at https://docs.expo.dev/push-notifications/fcm-credentials/ : " + e2.getMessage(), e2);
return null;
}
}
public final wh.c s() {
return (wh.c) f().t().c("PushTokenManager", wh.c.class);
}
@Override
public void a(String token) {
r.f(token, "token");
Pf.a aVar = this.eventEmitter;
if (aVar != null) {
Bundle bundle = new Bundle();
bundle.putString("devicePushToken", token);
aVar.a("onDevicePushToken", bundle);
}
}
@Override
public Fg.c g() {
Dg.a kVar;
Dg.a kVar2;
w1.a.c("[ExpoModulesCore] " + (getClass() + ".ModuleDefinition"));
try {
Fg.b bVar = new Fg.b(this);
bVar.n("ExpoPushTokenManager");
bVar.d("onDevicePushToken");
Map r = bVar.r();
Cg.e eVar = Cg.e.a;
r.put(eVar, new Cg.a(eVar, new i()));
Map r2 = bVar.r();
Cg.e eVar2 = Cg.e.b;
r2.put(eVar2, new Cg.a(eVar2, new j()));
if (r.b(n.class, n.class)) {
kVar = new Dg.f("getDevicePushTokenAsync", new C0712a[0], new c(bVar));
} else {
C0712a c0712a = (C0712a) C0714c.a.a().get(new Pair(M.b(n.class), Boolean.FALSE));
if (c0712a == null) {
c0712a = new C0712a(new K(M.b(n.class), false, d.a));
}
C0712a[] c0712aArr = {c0712a};
e eVar3 = new e(bVar);
kVar = r.b(J.class, Integer.TYPE) ? new k("getDevicePushTokenAsync", c0712aArr, eVar3) : r.b(J.class, Boolean.TYPE) ? new Dg.h("getDevicePushTokenAsync", c0712aArr, eVar3) : r.b(J.class, Double.TYPE) ? new Dg.i("getDevicePushTokenAsync", c0712aArr, eVar3) : r.b(J.class, Float.TYPE) ? new Dg.j("getDevicePushTokenAsync", c0712aArr, eVar3) : r.b(J.class, String.class) ? new m("getDevicePushTokenAsync", c0712aArr, eVar3) : new Dg.e("getDevicePushTokenAsync", c0712aArr, eVar3);
}
bVar.j().put("getDevicePushTokenAsync", kVar);
if (r.b(n.class, n.class)) {
kVar2 = new Dg.f("unregisterForNotificationsAsync", new C0712a[0], new f());
} else {
C0712a c0712a2 = (C0712a) C0714c.a.a().get(new Pair(M.b(n.class), Boolean.FALSE));
if (c0712a2 == null) {
c0712a2 = new C0712a(new K(M.b(n.class), false, g.a));
}
C0712a[] c0712aArr2 = {c0712a2};
h hVar = new h();
kVar2 = r.b(J.class, Integer.TYPE) ? new k("unregisterForNotificationsAsync", c0712aArr2, hVar) : r.b(J.class, Boolean.TYPE) ? new Dg.h("unregisterForNotificationsAsync", c0712aArr2, hVar) : r.b(J.class, Double.TYPE) ? new Dg.i("unregisterForNotificationsAsync", c0712aArr2, hVar) : r.b(J.class, Float.TYPE) ? new Dg.j("unregisterForNotificationsAsync", c0712aArr2, hVar) : r.b(J.class, String.class) ? new m("unregisterForNotificationsAsync", c0712aArr2, hVar) : new Dg.e("unregisterForNotificationsAsync", c0712aArr2, hVar);
}
bVar.j().put("unregisterForNotificationsAsync", kVar2);
Fg.c p = bVar.p();
w1.a.f();
return p;
} catch (Throwable th2) {
w1.a.f();
throw th2;
}
}
}