✨ Open tweet detail when clicked on push notification if user tag available.

⬆️ update packages.

Author: TheAlphamerc

ios/Flutter/Flutter.podspec

@@ -16,7 +16,8 @@ import '../widgets/newWidget/customLoader.dart';
 final kAnalytics = FirebaseAnalytics();
 final DatabaseReference kDatabase = FirebaseDatabase.instance.reference();
 final kScreenloader = CustomLoader();
-void cprint(dynamic data, {String errorIn, String event}) {
+void cprint(dynamic data,
+    {String errorIn, String event, String label = 'Log'}) {
   /// Print logs only in development mode
   if (kDebugMode) {
     if (errorIn != null) {
@@ -27,7 +28,7 @@ void cprint(dynamic data, {String errorIn, String event}) {
       print(
           '****************************** error ******************************');
     } else if (data != null) {
-      developer.log(data, time: DateTime.now());
+      developer.log(data, time: DateTime.now(), name: label);
     }
     if (event != null) {
       Utility.logEvent(event);

lib/helper/utility.dart

@@ -36,7 +36,7 @@ class MyApp extends StatelessWidget {
       child: MaterialApp(
         title: 'Fwitter',
         theme: AppTheme.apptheme.copyWith(
-          textTheme: GoogleFonts.muliTextTheme(
+          textTheme: GoogleFonts.mulishTextTheme(
             Theme.of(context).textTheme,
           ),
         ),

lib/main.dart

@@ -2,32 +2,6 @@ import 'dart:convert';
 
 class PushNotificationModel {
   PushNotificationModel({
-    this.notification,
-    this.data,
-  });
-
-  final Notification notification;
-  final Data data;
-
-  factory PushNotificationModel.fromRawJson(String str) =>
-      PushNotificationModel.fromJson(json.decode(str));
-
-  String toRawJson() => json.encode(toJson());
-
-  factory PushNotificationModel.fromJson(Map<dynamic, dynamic> json) =>
-      PushNotificationModel(
-        notification: Notification.fromJson(json["notification"]),
-        data: Data.fromJson(json["data"]),
-      );
-
-  Map<String, dynamic> toJson() => {
-        "notification": notification.toJson(),
-        "data": data.toJson(),
-      };
-}
-
-class Data {
-  Data({
     this.id,
     this.type,
     this.receiverId,
@@ -45,11 +19,13 @@ class Data {
   final String body;
   final String tweetId;
 
-  factory Data.fromRawJson(String str) => Data.fromJson(json.decode(str));
+  factory PushNotificationModel.fromRawJson(String str) =>
+      PushNotificationModel.fromJson(json.decode(str));
 
   String toRawJson() => json.encode(toJson());
 
-  factory Data.fromJson(Map<dynamic, dynamic> json) => Data(
+  factory PushNotificationModel.fromJson(Map<dynamic, dynamic> json) =>
+      PushNotificationModel(
         id: json["id"],
         type: json["type"],
         receiverId: json["receiverId"],

lib/model/push_notification_model.dart

@@ -1,8 +1,16 @@
+import 'dart:async';
+
 import 'package:firebase_messaging/firebase_messaging.dart';
 import 'package:flutter_twitter_clone/helper/utility.dart';
 import 'package:flutter_twitter_clone/model/push_notification_model.dart';
 import 'package:rxdart/rxdart.dart';
 
+Future<void> _firebaseMessagingBackgroundHandler(RemoteMessage message) async {
+  // If you're going to use other Firebase services in the background, such as Firestore,
+  // make sure you call `initializeApp` before using other Firebase services.
+  cprint("Handling a background message: ${message.messageId}");
+}
+
 class PushNotificationService {
   final FirebaseMessaging _firebaseMessaging;
 
@@ -15,23 +23,54 @@ class PushNotificationService {
   Stream<PushNotificationModel> get pushNotificationResponseStream =>
       _pushNotificationSubject.stream;
 
+  StreamSubscription<RemoteMessage> _backgroundMessageSubscription;
+
   void initializeMessages() {
-    _firebaseMessaging.requestNotificationPermissions(
-        const IosNotificationSettings(sound: true, badge: true, alert: true));
+    // _firebaseMessaging.requestNotificationPermissions(
+    //     const IosNotificationSettings(sound: true, badge: true, alert: true));
     configure();
   }
 
-  /// Configure the firebase messaging handler
-  void configure() {
-    _firebaseMessaging.configure(
-        onMessage: (Map<String, dynamic> message) async {
-      myBackgroundMessageHandler(message, onMessage: true);
-    }, onLaunch: (Map<String, dynamic> message) async {
-      myBackgroundMessageHandler(message, onLaunch: true);
-    }, onResume: (Map<String, dynamic> message) async {
-      myBackgroundMessageHandler(message, onResume: true);
-    });
+  /// Configured from Home page
+  void configure() async {
     _pushNotificationSubject = PublishSubject<PushNotificationModel>();
+    FirebaseMessaging.onMessage.listen((RemoteMessage message) {
+      cprint('Got a message whilst in the foreground!');
+
+      try {
+        // var data = json.decode(message.data.toString()) as Map<String, dynamic>;
+        myBackgroundMessageHandler(message.data, onMessage: true);
+      } catch (e) {
+        cprint(e, errorIn: "On Message");
+      }
+    });
+
+    FirebaseMessaging.onBackgroundMessage(_firebaseMessagingBackgroundHandler);
+
+    /// Get message when the app is in the Terminated form
+    FirebaseMessaging.instance.getInitialMessage().then((event) {
+      if (event != null && event.data != null) {
+        try {
+          myBackgroundMessageHandler(event.data, onLaunch: true);
+        } catch (e) {
+          cprint(e, errorIn: "On getInitialMessage");
+        }
+      }
+    });
+
+    /// Returns a [Stream] that is called when a user presses a notification message displayed via FCM.
+    _backgroundMessageSubscription =
+        FirebaseMessaging.onMessageOpenedApp.listen((event) {
+      if (event != null && event.data != null) {
+        if (event != null && event.data != null) {
+          try {
+            myBackgroundMessageHandler(event.data, onLaunch: true);
+          } catch (e) {
+            cprint(e, errorIn: "On onMessageOpenedApp");
+          }
+        }
+      }
+    });
   }
 
   /// Return FCM token
@@ -41,15 +80,13 @@ class PushNotificationService {
   }
 
   /// Callback triger everytime a push notification is received
-  Future<dynamic> myBackgroundMessageHandler(Map<String, dynamic> message,
+  void myBackgroundMessageHandler(Map<String, dynamic> message,
       {bool onBackGround = false,
       bool onLaunch = false,
       bool onMessage = false,
       bool onResume = false}) async {
     try {
-      if (!onMessage &&
-          message["data"] != null &&
-          message["notification"] != null) {
+      if (!onMessage) {
         PushNotificationModel model = PushNotificationModel.fromJson(message);
         _pushNotificationSubject.add(model);
       }

lib/resource/push_notification_service.dart

@@ -22,7 +22,7 @@ class AuthState extends AppState {
   bool isSignInWithGoogle = false;
   User user;
   String userId;
-  final FirebaseMessaging _firebaseMessaging = FirebaseMessaging();
+  final FirebaseMessaging _firebaseMessaging = FirebaseMessaging.instance;
   final FirebaseAuth _firebaseAuth = FirebaseAuth.instance;
   final GoogleSignIn _googleSignIn = GoogleSignIn();
   final FirebaseStorage _firebaseStorage = FirebaseStorage.instance;

lib/state/authState.dart

@@ -11,7 +11,7 @@ import 'package:flutter_twitter_clone/state/appState.dart';
 
 class ChatState extends AppState {
   bool setIsChatScreenOpen;
-  final FirebaseMessaging firebaseMessaging = FirebaseMessaging();
+  final FirebaseMessaging firebaseMessaging = FirebaseMessaging.instance;
 
   List<ChatMessage> _messageList;
   List<ChatMessage> _chatUserList;
@@ -83,8 +83,8 @@ class ChatState extends AppState {
   /// For package detail check:-  https://pub.dev/packages/firebase_remote_config#-readme-tab-
   void getFCMServerKey() async {
     final RemoteConfig remoteConfig = await RemoteConfig.instance;
-    await remoteConfig.fetch(expiration: const Duration(days: 5));
-    await remoteConfig.activateFetched();
+    await remoteConfig.fetchAndActivate();
+    // await remoteConfig.
     var data = remoteConfig.getString('FcmServerKey');
     if (data != null && data.isNotEmpty) {
       serverToken = jsonDecode(data)["key"];
@@ -284,10 +284,10 @@ class ChatState extends AppState {
   /// Push notification will be sent to other user when you send him a message in chat.
   /// To send push notification make sure you have FCM `serverToken`
   void sendAndRetrieveMessage(ChatMessage model) async {
-    await firebaseMessaging.requestNotificationPermissions(
-      const IosNotificationSettings(
-          sound: true, badge: true, alert: true, provisional: false),
-    );
+    // await firebaseMessaging.requestNotificationPermissions(
+    //   const IosNotificationSettings(
+    //       sound: true, badge: true, alert: true, provisional: false),
+    // );
     if (chatUser.fcmToken == null) {
       return;
     }
@@ -310,16 +310,20 @@ class ChatState extends AppState {
       },
       'to': chatUser.fcmToken
     });
-    var response = await http.post('https://fcm.googleapis.com/fcm/send',
-        headers: <String, String>{
-          'Content-Type': 'application/json',
-          'Authorization': 'key=$serverToken',
-        },
-        body: body);
+    var response =
+        await http.post(Uri.parse('https://fcm.googleapis.com/fcm/send'),
+            headers: <String, String>{
+              'Content-Type': 'application/json',
+              'Authorization': 'key=$serverToken',
+            },
+            body: body);
     if (response.reasonPhrase.contains("INVALID_KEY")) {
-      cprint("You are using Invalid FCM key");
+      cprint(
+        "You are using Invalid FCM key",
+        errorIn: "sendAndRetrieveMessage",
+      );
       return;
     }
-    print(response.body.toString());
+    cprint(response.body.toString());
   }
 }

lib/state/chats/chatState.dart

@@ -286,9 +286,10 @@ class FeedState extends AppState {
     notifyListeners();
     String tweetKey;
     try {
-      DatabaseReference dbReference = kDatabase.child('tweet');
+      DatabaseReference dbReference = kDatabase.child('tweet').push();
+
+      await dbReference.set(model.toJson());
 
-      await dbReference.push().set(model.toJson());
       tweetKey = dbReference.key;
     } catch (error) {
       cprint(error, errorIn: 'createTweet');

lib/state/feedState.dart

@@ -168,7 +168,7 @@ class NotificationState extends AppState {
   void initfirebaseService() {
     if (!getIt.isRegistered<PushNotificationService>()) {
       getIt.registerSingleton<PushNotificationService>(
-          PushNotificationService(FirebaseMessaging()));
+          PushNotificationService(FirebaseMessaging.instance));
     }
   }
 

lib/state/notificationState.dart

@@ -91,8 +91,8 @@ class _SplashPageState extends State<SplashPage> {
   /// For package detail check:-  https://pub.dev/packages/firebase_remote_config#-readme-tab-
   Future<String> _getAppVersionFromFirebaseConfig() async {
     final RemoteConfig remoteConfig = await RemoteConfig.instance;
-    await remoteConfig.fetch(expiration: const Duration(minutes: 1));
-    await remoteConfig.activateFetched();
+    await remoteConfig.fetchAndActivate();
+    // await remoteConfig.activateFetched();
     var data = remoteConfig.getString('appVersion');
     if (data != null && data.isNotEmpty) {
       return jsonDecode(data)["key"];