package io.flutter.plugins.firebase.messaging; import D.V; import L1.Q0; import P1.i; import P1.j; import P1.o; import android.app.Activity; import android.content.Intent; import android.os.Build; import androidx.fragment.app.RunnableC0268d; import androidx.lifecycle.C; import androidx.lifecycle.E; import com.google.android.gms.internal.measurement.C1; import com.google.firebase.messaging.FirebaseMessaging; import com.google.firebase.messaging.l; import com.google.firebase.messaging.m; import com.google.firebase.messaging.v; import io.flutter.embedding.engine.FlutterShellArgs; import io.flutter.embedding.engine.plugins.FlutterPlugin; import io.flutter.embedding.engine.plugins.activity.ActivityAware; import io.flutter.embedding.engine.plugins.activity.ActivityPluginBinding; import io.flutter.plugin.common.BinaryMessenger; import io.flutter.plugin.common.MethodCall; import io.flutter.plugin.common.MethodChannel; import io.flutter.plugin.common.PluginRegistry; import io.flutter.plugins.firebase.core.FlutterFirebasePlugin; import io.flutter.plugins.firebase.core.FlutterFirebasePluginRegistry; import java.util.HashMap; import java.util.Map; import java.util.Objects; import java.util.concurrent.Executors; import x1.ThreadFactoryC1100a; import y1.AbstractC1111a; /* JADX INFO: loaded from: classes.dex */ public class FlutterFirebaseMessagingPlugin implements FlutterFirebasePlugin, MethodChannel.MethodCallHandler, PluginRegistry.NewIntentListener, FlutterPlugin, ActivityAware { private MethodChannel channel; private v initialMessage; private Map initialMessageNotification; private Activity mainActivity; FlutterFirebasePermissionManager permissionManager; private E remoteMessageObserver; private E tokenObserver; private final HashMap consumedInitialMessages = new HashMap<>(); private final C liveDataRemoteMessage = FlutterFirebaseRemoteMessageLiveData.getInstance(); private final C liveDataToken = FlutterFirebaseTokenLiveData.getInstance(); private Boolean checkPermissions() { return Boolean.valueOf(ContextHolder.getApplicationContext().checkSelfPermission("android.permission.POST_NOTIFICATIONS") == 0); } private P1.h deleteToken() { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new f(1, iVar)); return iVar.f2505a; } private Map getExceptionDetails(Exception exc) { HashMap map = new HashMap(); map.put("code", "unknown"); if (exc != null) { map.put("message", exc.getMessage()); return map; } map.put("message", "An unknown error has occurred."); return map; } private P1.h getInitialMessage() { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new g(this, iVar, 3)); return iVar.f2505a; } private P1.h getPermissions() { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new g(this, iVar, 2)); return iVar.f2505a; } private P1.h getToken() { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new g(this, iVar, 1)); return iVar.f2505a; } private void initInstance(BinaryMessenger binaryMessenger) { MethodChannel methodChannel = new MethodChannel(binaryMessenger, "plugins.flutter.io/firebase_messaging"); this.channel = methodChannel; methodChannel.setMethodCallHandler(this); this.permissionManager = new FlutterFirebasePermissionManager(); final int i = 0; E e2 = new E(this) { // from class: io.flutter.plugins.firebase.messaging.h /* JADX INFO: renamed from: b, reason: collision with root package name */ public final /* synthetic */ FlutterFirebaseMessagingPlugin f6755b; { this.f6755b = this; } @Override // androidx.lifecycle.E public final void a(Object obj) { switch (i) { case 0: this.f6755b.lambda$initInstance$0((v) obj); break; default: this.f6755b.lambda$initInstance$1((String) obj); break; } } }; this.remoteMessageObserver = e2; final int i5 = 1; this.tokenObserver = new E(this) { // from class: io.flutter.plugins.firebase.messaging.h /* JADX INFO: renamed from: b, reason: collision with root package name */ public final /* synthetic */ FlutterFirebaseMessagingPlugin f6755b; { this.f6755b = this; } @Override // androidx.lifecycle.E public final void a(Object obj) { switch (i5) { case 0: this.f6755b.lambda$initInstance$0((v) obj); break; default: this.f6755b.lambda$initInstance$1((String) obj); break; } } }; this.liveDataRemoteMessage.observeForever(e2); this.liveDataToken.observeForever(this.tokenObserver); FlutterFirebasePluginRegistry.registerPlugin("plugins.flutter.io/firebase_messaging", this); } /* JADX INFO: Access modifiers changed from: private */ public static void lambda$deleteToken$2(i iVar) { o oVarL; try { FirebaseMessaging firebaseMessagingC = FirebaseMessaging.c(); if (firebaseMessagingC.f() == null) { oVarL = C1.l(null); } else { i iVar2 = new i(); Executors.newSingleThreadExecutor(new ThreadFactoryC1100a("Firebase-Messaging-Network-Io")).execute(new m(firebaseMessagingC, iVar2, 1)); oVarL = iVar2.f2505a; } C1.a(oVarL); iVar.b(null); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Removed duplicated region for block: B:35:0x007c A[PHI: r0 0x007c: PHI (r0v11 com.google.firebase.messaging.v) = (r0v8 com.google.firebase.messaging.v), (r0v13 com.google.firebase.messaging.v) binds: [B:31:0x0067, B:33:0x0071] A[DONT_GENERATE, DONT_INLINE]] */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct code enable 'Show inconsistent code' option in preferences */ public /* synthetic */ void lambda$getInitialMessage$9(P1.i r7) { /* r6 = this; com.google.firebase.messaging.v r0 = r6.initialMessage // Catch: java.lang.Exception -> L13 java.lang.String r1 = "notification" r2 = 0 if (r0 == 0) goto L1e java.util.Map r0 = io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingUtils.remoteMessageToMap(r0) // Catch: java.lang.Exception -> L13 java.util.Map r3 = r6.initialMessageNotification // Catch: java.lang.Exception -> L13 if (r3 == 0) goto L16 r0.put(r1, r3) // Catch: java.lang.Exception -> L13 goto L16 L13: r0 = move-exception goto Lae L16: r7.b(r0) // Catch: java.lang.Exception -> L13 r6.initialMessage = r2 // Catch: java.lang.Exception -> L13 r6.initialMessageNotification = r2 // Catch: java.lang.Exception -> L13 return L1e: android.app.Activity r0 = r6.mainActivity // Catch: java.lang.Exception -> L13 if (r0 != 0) goto L26 r7.b(r2) // Catch: java.lang.Exception -> L13 return L26: android.content.Intent r0 = r0.getIntent() // Catch: java.lang.Exception -> L13 if (r0 == 0) goto Laa android.os.Bundle r3 = r0.getExtras() // Catch: java.lang.Exception -> L13 if (r3 != 0) goto L34 goto Laa L34: android.os.Bundle r3 = r0.getExtras() // Catch: java.lang.Exception -> L13 java.lang.String r4 = "google.message_id" java.lang.String r3 = r3.getString(r4) // Catch: java.lang.Exception -> L13 if (r3 != 0) goto L4a android.os.Bundle r0 = r0.getExtras() // Catch: java.lang.Exception -> L13 java.lang.String r3 = "message_id" java.lang.String r3 = r0.getString(r3) // Catch: java.lang.Exception -> L13 L4a: if (r3 == 0) goto La6 java.util.HashMap r0 = r6.consumedInitialMessages // Catch: java.lang.Exception -> L13 java.lang.Object r0 = r0.get(r3) // Catch: java.lang.Exception -> L13 if (r0 == 0) goto L55 goto La6 L55: java.util.HashMap r0 = io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingReceiver.notifications // Catch: java.lang.Exception -> L13 java.lang.Object r0 = r0.get(r3) // Catch: java.lang.Exception -> L13 com.google.firebase.messaging.v r0 = (com.google.firebase.messaging.v) r0 // Catch: java.lang.Exception -> L13 if (r0 != 0) goto L85 io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingStore r4 = io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingStore.getInstance() // Catch: java.lang.Exception -> L13 java.util.Map r4 = r4.getFirebaseMessageMap(r3) // Catch: java.lang.Exception -> L13 if (r4 == 0) goto L7c com.google.firebase.messaging.v r0 = io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingUtils.getRemoteMessageForArguments(r4) // Catch: java.lang.Exception -> L13 java.lang.Object r5 = r4.get(r1) // Catch: java.lang.Exception -> L13 if (r5 == 0) goto L7c java.lang.Object r4 = r4.get(r1) // Catch: java.lang.Exception -> L13 java.util.Map r4 = r6.uncheckedCastToMap(r4) // Catch: java.lang.Exception -> L13 goto L7d L7c: r4 = r2 L7d: io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingStore r5 = io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingStore.getInstance() // Catch: java.lang.Exception -> L13 r5.removeFirebaseMessage(r3) // Catch: java.lang.Exception -> L13 goto L86 L85: r4 = r2 L86: if (r0 != 0) goto L8c r7.b(r2) // Catch: java.lang.Exception -> L13 return L8c: java.util.HashMap r2 = r6.consumedInitialMessages // Catch: java.lang.Exception -> L13 java.lang.Boolean r5 = java.lang.Boolean.TRUE // Catch: java.lang.Exception -> L13 r2.put(r3, r5) // Catch: java.lang.Exception -> L13 java.util.Map r2 = io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingUtils.remoteMessageToMap(r0) // Catch: java.lang.Exception -> L13 com.google.firebase.messaging.u r0 = r0.c() // Catch: java.lang.Exception -> L13 if (r0 != 0) goto La2 if (r4 == 0) goto La2 r2.put(r1, r4) // Catch: java.lang.Exception -> L13 La2: r7.b(r2) // Catch: java.lang.Exception -> L13 return La6: r7.b(r2) // Catch: java.lang.Exception -> L13 return Laa: r7.b(r2) // Catch: java.lang.Exception -> L13 return Lae: r7.a(r0) return */ throw new UnsupportedOperationException("Method not decompiled: io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingPlugin.lambda$getInitialMessage$9(P1.i):void"); } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Multi-variable type inference failed */ public void lambda$getPermissions$13(i iVar) { try { HashMap map = new HashMap(); map.put("authorizationStatus", Integer.valueOf(Build.VERSION.SDK_INT >= 33 ? checkPermissions().booleanValue() : new V(this.mainActivity).f347b.areNotificationsEnabled())); iVar.b(map); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public static void lambda$getPluginConstantsForFirebaseApp$15(I2.g gVar, i iVar) { try { HashMap map = new HashMap(); gVar.a(); if (gVar.f933b.equals("[DEFAULT]")) { map.put("AUTO_INIT_ENABLED", Boolean.valueOf(FirebaseMessaging.c().f5852e.b())); } iVar.b(map); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public void lambda$getToken$3(i iVar) { try { FirebaseMessaging firebaseMessagingC = FirebaseMessaging.c(); firebaseMessagingC.getClass(); i iVar2 = new i(); firebaseMessagingC.f5853f.execute(new m(firebaseMessagingC, iVar2, 0)); iVar.b(new HashMap((String) C1.a(iVar2.f2505a)) { // from class: io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingPlugin.1 final /* synthetic */ String val$token; { this.val$token = str; put("token", str); } }); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$initInstance$0(v vVar) { this.channel.invokeMethod("Messaging#onMessage", FlutterFirebaseMessagingUtils.remoteMessageToMap(vVar)); } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$initInstance$1(String str) { this.channel.invokeMethod("Messaging#onTokenRefresh", str); } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$onMethodCall$14(MethodChannel.Result result, P1.h hVar) { if (hVar.h()) { result.success(hVar.f()); } else { Exception excE = hVar.e(); result.error("firebase_messaging", excE != null ? excE.getMessage() : null, getExceptionDetails(excE)); } } /* JADX INFO: Access modifiers changed from: private */ public static /* synthetic */ void lambda$requestPermissions$10(Map map, i iVar, int i) { map.put("authorizationStatus", Integer.valueOf(i)); iVar.b(map); } /* JADX INFO: Access modifiers changed from: private */ public static /* synthetic */ void lambda$requestPermissions$11(i iVar, String str) { iVar.a(new Exception(str)); } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$requestPermissions$12(final i iVar) { HashMap map = new HashMap(); try { if (!checkPermissions().booleanValue()) { this.permissionManager.requestPermissions(this.mainActivity, new d(map, iVar), new ErrorCallback() { // from class: io.flutter.plugins.firebase.messaging.e @Override // io.flutter.plugins.firebase.messaging.ErrorCallback public final void onError(String str) { FlutterFirebaseMessagingPlugin.lambda$requestPermissions$11(iVar, str); } }); } else { map.put("authorizationStatus", 1); iVar.b(map); } } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public static /* synthetic */ void lambda$sendMessage$6(Map map, i iVar) { try { FlutterFirebaseMessagingUtils.getFirebaseMessagingForArguments(map).h(FlutterFirebaseMessagingUtils.getRemoteMessageForArguments(map)); iVar.b(null); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ void lambda$setAutoInitEnabled$7(Map map, i iVar) { try { FirebaseMessaging firebaseMessagingForArguments = FlutterFirebaseMessagingUtils.getFirebaseMessagingForArguments(map); Object obj = map.get("enabled"); Objects.requireNonNull(obj); firebaseMessagingForArguments.i(((Boolean) obj).booleanValue()); iVar.b(new HashMap(firebaseMessagingForArguments) { // from class: io.flutter.plugins.firebase.messaging.FlutterFirebaseMessagingPlugin.2 final /* synthetic */ FirebaseMessaging val$firebaseMessaging; { this.val$firebaseMessaging = firebaseMessagingForArguments; put("isAutoInitEnabled", Boolean.valueOf(firebaseMessagingForArguments.f5852e.b())); } }); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public static void lambda$setDeliveryMetricsExportToBigQuery$8(Map map, i iVar) { try { FirebaseMessaging firebaseMessagingForArguments = FlutterFirebaseMessagingUtils.getFirebaseMessagingForArguments(map); Object obj = map.get("enabled"); Objects.requireNonNull(obj); boolean zBooleanValue = ((Boolean) obj).booleanValue(); firebaseMessagingForArguments.getClass(); I2.g gVarD = I2.g.d(); gVarD.a(); gVarD.f932a.getSharedPreferences("com.google.firebase.messaging", 0).edit().putBoolean("export_to_big_query", zBooleanValue).apply(); AbstractC1111a.m(firebaseMessagingForArguments.f5849b, firebaseMessagingForArguments.f5850c, firebaseMessagingForArguments.j()); iVar.b(null); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public static void lambda$subscribeToTopic$4(Map map, i iVar) { try { FirebaseMessaging firebaseMessagingForArguments = FlutterFirebaseMessagingUtils.getFirebaseMessagingForArguments(map); Object obj = map.get("topic"); Objects.requireNonNull(obj); o oVar = firebaseMessagingForArguments.f5855h; l lVar = new l((String) obj, 0); oVar.getClass(); Q0 q02 = j.f2506a; o oVar2 = new o(); oVar.f2518b.i(new P1.m(q02, lVar, oVar2)); oVar.p(); C1.a(oVar2); iVar.b(null); } catch (Exception e2) { iVar.a(e2); } } /* JADX INFO: Access modifiers changed from: private */ public static void lambda$unsubscribeFromTopic$5(Map map, i iVar) { try { FirebaseMessaging firebaseMessagingForArguments = FlutterFirebaseMessagingUtils.getFirebaseMessagingForArguments(map); Object obj = map.get("topic"); Objects.requireNonNull(obj); o oVar = firebaseMessagingForArguments.f5855h; l lVar = new l((String) obj, 1); oVar.getClass(); Q0 q02 = j.f2506a; o oVar2 = new o(); oVar.f2518b.i(new P1.m(q02, lVar, oVar2)); oVar.p(); C1.a(oVar2); iVar.b(null); } catch (Exception e2) { iVar.a(e2); } } private P1.h requestPermissions() { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new g(this, iVar, 0)); return iVar.f2505a; } private P1.h sendMessage(Map map) { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new c(map, iVar, 3)); return iVar.f2505a; } private P1.h setAutoInitEnabled(Map map) { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new RunnableC0268d(this, map, iVar, 6)); return iVar.f2505a; } private P1.h setDeliveryMetricsExportToBigQuery(Map map) { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new c(map, iVar, 1)); return iVar.f2505a; } private P1.h subscribeToTopic(Map map) { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new c(map, iVar, 2)); return iVar.f2505a; } private Map uncheckedCastToMap(Object obj) { return (Map) obj; } private P1.h unsubscribeFromTopic(Map map) { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new c(map, iVar, 0)); return iVar.f2505a; } @Override // io.flutter.plugins.firebase.core.FlutterFirebasePlugin public P1.h didReinitializeFirebaseCore() { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new f(0, iVar)); return iVar.f2505a; } @Override // io.flutter.plugins.firebase.core.FlutterFirebasePlugin public P1.h getPluginConstantsForFirebaseApp(I2.g gVar) { i iVar = new i(); FlutterFirebasePlugin.cachedThreadPool.execute(new b(1, gVar, iVar)); return iVar.f2505a; } @Override // io.flutter.embedding.engine.plugins.activity.ActivityAware public void onAttachedToActivity(ActivityPluginBinding activityPluginBinding) { activityPluginBinding.addOnNewIntentListener(this); activityPluginBinding.addRequestPermissionsResultListener(this.permissionManager); Activity activity = activityPluginBinding.getActivity(); this.mainActivity = activity; if (activity.getIntent() == null || this.mainActivity.getIntent().getExtras() == null || (this.mainActivity.getIntent().getFlags() & 1048576) == 1048576) { return; } onNewIntent(this.mainActivity.getIntent()); } @Override // io.flutter.embedding.engine.plugins.FlutterPlugin public void onAttachedToEngine(FlutterPlugin.FlutterPluginBinding flutterPluginBinding) { ContextHolder.setApplicationContext(flutterPluginBinding.getApplicationContext()); initInstance(flutterPluginBinding.getBinaryMessenger()); } @Override // io.flutter.embedding.engine.plugins.activity.ActivityAware public void onDetachedFromActivity() { this.mainActivity = null; } @Override // io.flutter.embedding.engine.plugins.activity.ActivityAware public void onDetachedFromActivityForConfigChanges() { this.mainActivity = null; } @Override // io.flutter.embedding.engine.plugins.FlutterPlugin public void onDetachedFromEngine(FlutterPlugin.FlutterPluginBinding flutterPluginBinding) { this.liveDataToken.removeObserver(this.tokenObserver); this.liveDataRemoteMessage.removeObserver(this.remoteMessageObserver); } @Override // io.flutter.plugin.common.MethodChannel.MethodCallHandler public void onMethodCall(MethodCall methodCall, MethodChannel.Result result) { P1.h initialMessage; long jIntValue; long jIntValue2; String str = methodCall.method; str.getClass(); switch (str) { case "Messaging#getInitialMessage": initialMessage = getInitialMessage(); break; case "Messaging#setAutoInitEnabled": initialMessage = setAutoInitEnabled((Map) methodCall.arguments()); break; case "Messaging#deleteToken": initialMessage = deleteToken(); break; case "Messaging#unsubscribeFromTopic": initialMessage = unsubscribeFromTopic((Map) methodCall.arguments()); break; case "Messaging#subscribeToTopic": initialMessage = subscribeToTopic((Map) methodCall.arguments()); break; case "Messaging#setDeliveryMetricsExportToBigQuery": initialMessage = setDeliveryMetricsExportToBigQuery((Map) methodCall.arguments()); break; case "Messaging#startBackgroundIsolate": Map map = (Map) methodCall.arguments; Object obj = map.get("pluginCallbackHandle"); Object obj2 = map.get("userCallbackHandle"); if (obj instanceof Long) { jIntValue = ((Long) obj).longValue(); } else { if (!(obj instanceof Integer)) { throw new IllegalArgumentException("Expected 'Long' or 'Integer' type for 'pluginCallbackHandle'."); } jIntValue = ((Integer) obj).intValue(); } if (obj2 instanceof Long) { jIntValue2 = ((Long) obj2).longValue(); } else { if (!(obj2 instanceof Integer)) { throw new IllegalArgumentException("Expected 'Long' or 'Integer' type for 'userCallbackHandle'."); } jIntValue2 = ((Integer) obj2).intValue(); } Activity activity = this.mainActivity; FlutterShellArgs flutterShellArgsFromIntent = activity != null ? FlutterShellArgs.fromIntent(activity.getIntent()) : null; FlutterFirebaseMessagingBackgroundService.setCallbackDispatcher(jIntValue); FlutterFirebaseMessagingBackgroundService.setUserCallbackHandle(jIntValue2); FlutterFirebaseMessagingBackgroundService.startBackgroundIsolate(jIntValue, flutterShellArgsFromIntent); initialMessage = C1.l(null); break; case "Messaging#sendMessage": initialMessage = sendMessage((Map) methodCall.arguments()); break; case "Messaging#requestPermission": if (Build.VERSION.SDK_INT < 33) { initialMessage = getPermissions(); break; } else { initialMessage = requestPermissions(); break; } break; case "Messaging#getNotificationSettings": initialMessage = getPermissions(); break; case "Messaging#getToken": initialMessage = getToken(); break; default: result.notImplemented(); return; } initialMessage.a(new d(this, result)); } @Override // io.flutter.plugin.common.PluginRegistry.NewIntentListener public boolean onNewIntent(Intent intent) { Map remoteMessageNotificationForArguments; Map map; Map firebaseMessageMap; if (intent.getExtras() == null) { return false; } String string = intent.getExtras().getString("google.message_id"); if (string == null) { string = intent.getExtras().getString("message_id"); } if (string == null) { return false; } v remoteMessageForArguments = FlutterFirebaseMessagingReceiver.notifications.get(string); if (remoteMessageForArguments != null || (firebaseMessageMap = FlutterFirebaseMessagingStore.getInstance().getFirebaseMessageMap(string)) == null) { remoteMessageNotificationForArguments = null; } else { remoteMessageForArguments = FlutterFirebaseMessagingUtils.getRemoteMessageForArguments(firebaseMessageMap); remoteMessageNotificationForArguments = FlutterFirebaseMessagingUtils.getRemoteMessageNotificationForArguments(firebaseMessageMap); } if (remoteMessageForArguments == null) { return false; } this.initialMessage = remoteMessageForArguments; this.initialMessageNotification = remoteMessageNotificationForArguments; FlutterFirebaseMessagingReceiver.notifications.remove(string); Map mapRemoteMessageToMap = FlutterFirebaseMessagingUtils.remoteMessageToMap(remoteMessageForArguments); if (remoteMessageForArguments.c() == null && (map = this.initialMessageNotification) != null) { mapRemoteMessageToMap.put("notification", map); } this.channel.invokeMethod("Messaging#onMessageOpenedApp", mapRemoteMessageToMap); this.mainActivity.setIntent(intent); return true; } @Override // io.flutter.embedding.engine.plugins.activity.ActivityAware public void onReattachedToActivityForConfigChanges(ActivityPluginBinding activityPluginBinding) { activityPluginBinding.addOnNewIntentListener(this); this.mainActivity = activityPluginBinding.getActivity(); } }