import 'dart:convert'; import 'dart:io'; import 'package:firebase_messaging/firebase_messaging.dart'; import 'package:flutter/material.dart'; import 'package:get/get.dart'; import 'package:http/http.dart' as http; import '../../constant/api_key.dart'; import '../../constant/box_name.dart'; import '../../constant/colors.dart'; import '../../constant/links.dart'; import '../../constant/style.dart'; import '../../main.dart'; import '../../views/home/profile/promos_passenger_page.dart'; import '../../views/home/Captin/orderCaptin/order_request_page.dart'; class FirebaseMessagesController extends GetxController { final fcmToken = FirebaseMessaging.instance; List tokens = []; List dataTokens = []; late String driverID; late String driverToken; NotificationSettings? notificationSettings; Future getNotificationSettings() async { // Get the current notification settings NotificationSettings? notificationSettings = await FirebaseMessaging.instance.getNotificationSettings(); print( 'Notification authorization status: ${notificationSettings.authorizationStatus}'); // Call the update function if needed update(); } Future requestFirebaseMessagingPermission() async { FirebaseMessaging messaging = FirebaseMessaging.instance; // Check if the platform is Android if (Platform.isAndroid) { // Request permission for Android await messaging.requestPermission(); } else if (Platform.isIOS) { // Request permission for iOS NotificationSettings settings = await messaging.requestPermission( alert: true, announcement: true, badge: true, carPlay: true, criticalAlert: true, provisional: false, sound: true, ); print('User granted permission: ${settings.authorizationStatus}'); messaging.setForegroundNotificationPresentationOptions( alert: true, badge: true, sound: true); } } Future getTokens() async { String? basicAuthCredentials = await storage.read(key: BoxName.basicAuthCredentials); var res = await http.post( Uri.parse(AppLink.getTokens), headers: { 'Authorization': 'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}', }, body: {}, ); // print(res.body); var jsonResponse = jsonDecode(res.body); // print(jsonResponse); if (jsonResponse['status'] == 'success') { dataTokens = jsonResponse['data']; for (var i = 0; i < dataTokens.length; i++) { tokens.add(jsonResponse['data'][i]['token']); } box.write(BoxName.tokens, tokens); print(box.read(BoxName.tokens)); } else { Get.defaultDialog(title: "Warning", middleText: "Server Error"); } } Future getToken() async { fcmToken.getToken().then((token) { if (box.read(BoxName.email) == null) { box.write(BoxName.tokenDriver, token); } else { box.write(BoxName.tokenFCM, token); } print(token); }); FirebaseMessaging.onMessage.listen((RemoteMessage message) { if (message.data.isNotEmpty) { firebasetitles(message); } // If the app is in the background or terminated, show a system tray message RemoteNotification? notification = message.notification; AndroidNotification? android = notification?.android; // if (notification != null && android != null) { if (notification != null && android != null) { // print('onMessageOpenedApp: ${notification.title} ${notification.body}'); if (message.data.isNotEmpty) { firebasetitles(message); } } }); FirebaseMessaging.onMessageOpenedApp.listen((RemoteMessage message) { // print( // 'onMessageOpenedApp: ${message.notification!.title} ${message.notification!.body}'); RemoteNotification? notification = message.notification; firebasetitles(message); }); } void firebasetitles(RemoteMessage message) { if (message.notification!.title!.contains('Order')) { var myListString = message.data['DriverList']; print(myListString); print('9999999999999myListString999999999999999'); var myList = jsonDecode(myListString) as List; driverToken = myList[14].toString(); update(); print('driverToken==============$driverToken'); Get.to(() => OrderRequestPage(), arguments: { 'myListString': myListString, 'DriverList': myList, 'body': message.notification!.body }); } else if (message.notification!.title!.contains('Apply Ride')) { var passengerList = message.data['passengerList']; print(passengerList); print('9999999999999my Apply Ride 999999999999999'); var myList = jsonDecode(passengerList) as List; driverID = myList[2].toString(); Get.snackbar( 'Captain Applied the Ride for You'.tr, 'message', colorText: AppColor.greenColor, duration: const Duration(seconds: 11), snackPosition: SnackPosition.TOP, titleText: Text( 'Applied'.tr, style: const TextStyle(color: AppColor.redColor), ), messageText: Text( 'Captain Applied the Ride for You'.tr, style: AppStyle.title, ), icon: const Icon(Icons.approval), shouldIconPulse: true, margin: const EdgeInsets.all(16), padding: const EdgeInsets.all(16), ); } else if (message.notification!.title!.contains('Promo')) { Get.to(const PromosPassengerPage()); } else if (message.notification!.title! .contains('DriverIsGoingToPassenger')) { Get.snackbar('Driver is Going To Passenger', '', backgroundColor: AppColor.greenColor); } else if (message.notification!.title!.contains('RideIsBegin')) { // MapPassengerController mapController = Get.put(MapPassengerController()); Get.snackbar('RideIsBegin', '', backgroundColor: AppColor.greenColor); // mapController.driverArrivePassenger(); update(); } else if (message.notification!.title!.contains('Captain Finish Trip')) { // MapPassengerController mapController = // Get.find(); Get.snackbar('Ride Finished'.tr, '', backgroundColor: AppColor.greenColor); // mapController.isRideFinished = true;//todo fix that for dfinish ride in passenger app update(); } } void sendNotificationAll(String title, body) async { // Get the token you want to subtract. String token = box.read(BoxName.tokenFCM); tokens = box.read(BoxName.tokens); // Subtract the token from the list of tokens. tokens.remove(token); // Save the list of tokens back to the box. // box.write(BoxName.tokens, tokens); tokens = box.read(BoxName.tokens); // print(tokens); for (var i = 0; i < tokens.length; i++) { http .post(Uri.parse('https://fcm.googleapis.com/fcm/send'), headers: { 'Content-Type': 'application/json', 'Authorization': 'key=${AK.serverAPI}' }, body: jsonEncode({ 'notification': { 'title': title, 'body': body, 'sound': 'assets/notify.mp3' }, 'priority': 'high', 'data': { 'click_action': 'FLUTTER_NOTIFICATION_CLICK', 'id': '1', 'status': 'done' }, 'to': tokens[i], })) .whenComplete(() {}) .catchError((e) { print('sendNotification() error: $e'); }); } } // for (var i = 0; i < tokens.length; i++) { // http // .post(Uri.parse('https://fcm.googleapis.com/fcm/send'), // headers: { // 'Content-Type': 'application/json', // 'Authorization': 'key=${storage.read(key: BoxName.serverAPI}' // }, // body: jsonEncode({ // 'notification': { // 'title': title, // 'body': body, // 'sound': 'true' // }, // 'priority': 'high', // 'data': { // 'click_action': 'FLUTTER_NOTIFICATION_CLICK', // 'id': '1', // 'status': 'done' // }, // 'to': tokens[i], // })) // .whenComplete(() {}) // .catchError((e) { // print('sendNotification() error: $e'); // }); // } // } void sendNotificationToPassengerToken( String title, body, token, List map) async { try { final response = await http.post( Uri.parse('https://fcm.googleapis.com/fcm/send'), headers: { 'Content-Type': 'application/json', 'Authorization': 'key=${AK.serverAPI}' }, body: jsonEncode({ 'notification': { 'title': title, 'body': body, 'sound': 'assets/notify.mp3' }, 'data': { 'passengerList': map, }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully print('Notification sent successfully'); } else { // Handle error response print( 'Failed to send notification. Status code: ${response.statusCode}'); } } catch (e) { // Handle other exceptions print('sendNotification() error: $e'); } } void sendNotificationToAnyWithoutData( String title, String body, String token) async { try { final response = await http.post( Uri.parse('https://fcm.googleapis.com/fcm/send'), headers: { 'Content-Type': 'application/json', 'Authorization': 'key=${AK.serverAPI}' }, body: jsonEncode({ 'notification': { 'title': title, 'body': body, 'sound': 'assets/notify.mp3' }, 'data': { 'click_action': 'FLUTTER_NOTIFICATION_CLICK', 'id': '1', 'status': 'done' }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully print('Notification sent successfully'); } else { // Handle error response print( 'Failed to send notification. Status code: ${response.statusCode}'); } } catch (e) { // Handle other exceptions print('sendNotification() error: $e'); } } void sendNotificationToDriverMAP( String title, String body, String token, List data) async { try { final response = await http.post( Uri.parse('https://fcm.googleapis.com/fcm/send'), headers: { 'Content-Type': 'application/json', 'Authorization': 'key=${AK.serverAPI}' }, body: jsonEncode({ 'notification': { 'title': title, 'body': body, 'sound': 'assets/notify.mp3' }, 'data': { 'DriverList': data, }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully print('Notification sent successfully'); } else { // Handle error response print( 'Failed to send notification. Status code: ${response.statusCode}'); } } catch (e) { // Handle other exceptions print('sendNotification() error: $e'); } } }