✨(feat) New message notification

TheAlphamerc · TheAlphamerc · commit 05ec7af22ce0 · 2020-04-14T23:55:22.000+05:30
1. If someone sends message then notificaion will appear in notification tray.
diff --git a/lib/helper/enum.dart b/lib/helper/enum.dart
@@ -16,4 +16,13 @@ enum SortUser{
   ByNewest,
   ByOldest,
   ByMaxFollower
+}
+
+enum NotificationType{
+  NOT_DETERMINED,
+  Message,
+  Tweet,
+  Reply,
+  Retweet,
+  Follow,
 }
diff --git a/lib/model/fcmNotificationModel.dart b/lib/model/fcmNotificationModel.dart
@@ -0,0 +1,63 @@
+import 'dart:convert';
+
+import 'package:flutter_twitter_clone/helper/enum.dart';
+
+class FcmNotificationModel {
+    String clickAction;
+    String id;
+    String status;
+    String type;
+    String userId;
+    String title;
+    String body;
+    String tweetId;
+
+    FcmNotificationModel({
+        this.clickAction,
+        this.id,
+        this.status,
+        this.type,
+        this.userId,
+        this.title,
+        this.body,
+        this.tweetId,
+    });
+
+    factory FcmNotificationModel.fromRawJson(String str) => FcmNotificationModel.fromJson(json.decode(str));
+
+    String toRawJson() => json.encode(toJson());
+
+    factory FcmNotificationModel.fromJson(Map<String, dynamic> json) {
+      print("dat jbj bkkn,");
+      return  FcmNotificationModel(
+        clickAction: json["click_action"] == null ? null : json["click_action"],
+        id: json["id"] == null ? null : json["id"],
+        status: json["status"] == null ? null : json["status"],
+        type: json["type"] == null ? null : json["type"],
+        userId: json["userId"] == null ? null : json["userId"],
+        title: json["title"] == null ? null : json["title"],
+        body: json["body"] == null ? null : json["body"],
+        tweetId: json["tweetId"] == null ? null : json["tweetId"],
+    );}
+
+    Map<String, dynamic> toJson() => {
+        "click_action": clickAction == null ? null : clickAction,
+        "id": id == null ? null : id,
+        "status": status == null ? null : status,
+        "type": type == null ? null : type,
+        "userId": userId == null ? null : userId,
+        "title": title == null ? null : title,
+        "body": body == null ? null : body,
+        "tweetId": tweetId == null ? null : tweetId,
+    };
+
+    NotificationType getNotificationType(){
+    switch (type) {
+      case 'NotificationType.Follow' : return NotificationType.Follow;
+      case 'NotificationType.Message' : return NotificationType.Message;
+      case 'NotificationType.NOT_DETERMINED' : return NotificationType.NOT_DETERMINED;
+      case 'NotificationType.Reply' : return NotificationType.Reply;
+      case 'NotificationType.Retweet' : return NotificationType.Retweet;
+      default: return  NotificationType.NOT_DETERMINED;
+    }}
+}
diff --git a/lib/page/homePage.dart b/lib/page/homePage.dart
@@ -1,4 +1,6 @@
 import 'package:flutter/material.dart';
+import 'package:flutter_twitter_clone/helper/enum.dart';
+import 'package:flutter_twitter_clone/helper/utility.dart';
 import 'package:flutter_twitter_clone/page/feed/feedPage.dart';
 import 'package:flutter_twitter_clone/page/message/chatListPage.dart';
 import 'package:flutter_twitter_clone/state/appState.dart';
@@ -27,10 +29,10 @@ class _HomePageState extends State<HomePage> {
       var state = Provider.of<AppState>(context, listen: false);
       state.setpageIndex = 0;
       initTweets();
+      initProfile();
       initSearch();
       initNotificaiton();
       initChat();
-      initProfile();
     });
 
     super.initState();
@@ -67,6 +69,20 @@ class _HomePageState extends State<HomePage> {
 
   Widget _body() {
     var state = Provider.of<AppState>(context);
+    WidgetsBinding.instance.addPostFrameCallback((_) {
+      var state = Provider.of<NotificationState>(context);
+      /// Check if user recieve chat notification from firebase
+      /// Redirect to chat screen
+      if (state.notificationType == NotificationType.Message) {
+        state.notificationType = NotificationType.NOT_DETERMINED;
+        state.getuserDetail(state.notificationSenderId).then((user) {
+          cprint("Opening user chat screen");
+          final chatState = Provider.of<ChatState>(context, listen: false);
+          chatState.setChatUser = user;
+          Navigator.pushNamed(context, '/ChatScreenPage');
+        });
+      }
+    });
     return SafeArea(child: Container(child: _getPage(state.pageIndex)));
   }
 
diff --git a/lib/state/authState.dart b/lib/state/authState.dart
@@ -190,11 +190,12 @@ class AuthState extends AppState {
 
       // Time at which user is created
       user.createdAt = DateTime.now().toUtc().toString();
-      
-       _firebaseMessaging.getToken().then((String token) {
-         assert(token != null);
-         user.fcmToken = token;
-       });
+      /// Get firebase token 
+      /// Helps to send notification
+      _firebaseMessaging.getToken().then((String token) {
+        assert(token != null);
+        user.fcmToken = token;
+      });
     }
     kDatabase.child('profile').child(user.userId).set(user.toJson());
     _userModel = user;
@@ -320,8 +321,7 @@ class AuthState extends AppState {
       cprint(error, errorIn: 'updateUserProfile');
     }
   }
- 
-  
+
   /// `Fetch` user `detail` whoose userId is passed
   Future<User> getuserDetail(String userId) async {
     User user;
@@ -360,7 +360,17 @@ class AuthState extends AppState {
                 // Check if user verified his email address
                 reloadUser();
               }
+              if (_userModel.fcmToken == null) {
+                /// if firebase  token not available in frofile
+                /// Then get token from firebase and save it to profile
+                _firebaseMessaging.getToken().then((String token) {
+                  assert(token != null);
+                  _userModel.fcmToken = token;
+                  createUser(_userModel);
+                });
+              }
             }
+
             logEvent('get_profile');
           }
         }
diff --git a/lib/state/chats/chatState.dart b/lib/state/chats/chatState.dart
@@ -2,6 +2,7 @@ import 'dart:async';
 import 'dart:convert';
 
 import 'package:firebase_analytics/firebase_analytics.dart';
+import 'package:flutter_twitter_clone/helper/enum.dart';
 import 'package:http/http.dart' as http;
 import 'package:firebase_database/firebase_database.dart';
 import 'package:firebase_messaging/firebase_messaging.dart';
@@ -13,7 +14,7 @@ import 'package:flutter_twitter_clone/state/appState.dart';
 class ChatState extends AppState {
   bool setIsChatScreenOpen;
   final FirebaseDatabase _database = FirebaseDatabase.instance;
-  
+
   List<ChatMessage> _messageList;
   List<User> _chatUserList;
   User _chatUser;
@@ -29,8 +30,9 @@ class ChatState extends AppState {
     if (_messageList == null) {
       return null;
     } else {
-      _messageList.sort((x, y) =>
-          DateTime.parse(x.createdAt).toLocal().compareTo(DateTime.parse(y.createdAt).toLocal()));
+      _messageList.sort((x, y) => DateTime.parse(x.createdAt)
+          .toLocal()
+          .compareTo(DateTime.parse(y.createdAt).toLocal()));
       _messageList.reversed;
       _messageList = _messageList.reversed.toList();
       return List.from(_messageList);
@@ -143,7 +145,7 @@ class ChatState extends AppState {
           .child(_channelName)
           .push()
           .set(message.toJson());
-      sendAndRetrieveMessage(secondUser.fcmToken);
+      sendAndRetrieveMessage(message);
       logEvent('send_message');
     } catch (error) {
       cprint(error);
@@ -229,38 +231,43 @@ class ChatState extends AppState {
     // _channelName = null;
   }
 
-final FirebaseMessaging firebaseMessaging = FirebaseMessaging();
-
-void sendAndRetrieveMessage(String message) async {
-  await firebaseMessaging.requestNotificationPermissions(
-    const IosNotificationSettings(sound: true, badge: true, alert: true, provisional: false),
-  );
-  final String serverToken = '';
-  String token = await firebaseMessaging.getToken();
-  var body = jsonEncode(
-     <String, dynamic>{
-       'notification': <String, dynamic>{
-         'body': 'this is a body',
-         'title': 'this is a title'
-       },
-       'priority': 'high',
-       'data': <String, dynamic>{
-         'click_action': 'FLUTTER_NOTIFICATION_CLICK',
-         'id': '1',
-         'status': 'done'
-       },
-       'to': token
-     });
-  print(token);
+  final FirebaseMessaging firebaseMessaging = FirebaseMessaging();
 
-  var response  =await http.post(
-    'https://fcm.googleapis.com/fcm/send',
-     headers: <String, String>{
-       'Content-Type': 'application/json',
-       'Authorization': 'key=$serverToken',
-     },
-     body:body
-  );
- print(response.body.toString());
-}
+  void sendAndRetrieveMessage(ChatMessage model) async {
+    /// on noti
+    await firebaseMessaging.requestNotificationPermissions(
+      const IosNotificationSettings(
+          sound: true, badge: true, alert: true, provisional: false),
+    );
+    if (chatUser.fcmToken == null) {
+      return;
+    }
+    final String serverToken = "ADD FIREBASE SERVER KEY HERE";
+        
+    var body = jsonEncode(<String, dynamic>{
+      'notification': <String, dynamic>{
+        'body': model.message,
+        'title': "Message from ${model.senderName}"
+      },
+      'priority': 'high',
+      'data': <String, dynamic>{
+        'click_action': 'FLUTTER_NOTIFICATION_CLICK',
+        'id': '1',
+        'status': 'done',
+        "type": NotificationType.Message.toString(),
+        "senderId": model.senderId,
+        "title": "title",
+        "body": model.message,
+        "tweetId": ""
+      },
+      '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);
+    print(response.body.toString());
+  }
 }
diff --git a/lib/state/notificationState.dart b/lib/state/notificationState.dart
@@ -1,5 +1,7 @@
 import 'dart:async';
 import 'dart:convert';
+import 'package:flutter_twitter_clone/helper/enum.dart';
+import 'package:flutter_twitter_clone/model/fcmNotificationModel.dart';
 import 'package:http/http.dart' as http;
 import 'package:firebase_database/firebase_database.dart';
 import 'package:firebase_messaging/firebase_messaging.dart';
@@ -13,6 +15,9 @@ import 'package:flutter_twitter_clone/state/appState.dart';
 
 class NotificationState extends AppState {
   String fcmToken;
+  NotificationType notificationType = NotificationType.NOT_DETERMINED;
+  // FcmNotificationModel notification;
+  String notificationSenderId;
   dabase.Query query;
   List<User> userList = [];
 
@@ -147,15 +152,24 @@ class NotificationState extends AppState {
     _firebaseMessaging.configure(
       onMessage: (Map<String, dynamic> message) async {
         print("onMessage: $message");
-        // _showItemDialog(message);
+        print(message['data']);
+        notifyListeners();
       },
       onLaunch: (Map<String, dynamic> message) async {
-        print("onLaunch: $message");
-        // _navigateToItemDetail(message);
+        cprint("Send to ",event: "UnBox");
+        var data = message['data'];
+        print(message['data']);
+        notificationSenderId = data["userId"];
+        notificationType = NotificationType.Message;
+        notifyListeners();
       },
       onResume: (Map<String, dynamic> message) async {
-        print("onResume: $message");
-        // _navigateToItemDetail(message);
+        cprint("Send to ",event: "UnBox");
+        var data = message['data'];
+        print(message['data']);
+        notificationSenderId = data["userId"];
+        notificationType = NotificationType.Message;
+        notifyListeners();
       },
     );
     _firebaseMessaging.requestNotificationPermissions(
@@ -172,5 +186,4 @@ class NotificationState extends AppState {
     });
   }
 
-
 }
