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/widgets/elevated_btn.dart'; import 'local_notification.dart'; class FirebaseMessagesController extends GetxController { final fcmToken = FirebaseMessaging.instance; List tokens = []; List tokensPassengers = []; List dataTokens = []; late String driverID; late String driverToken; NotificationSettings? notificationSettings; Future getNotificationSettings() async { // Get the current notification settings NotificationSettings? notificationSettings = await FirebaseMessaging.instance.getNotificationSettings(); '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, ); messaging.setForegroundNotificationPresentationOptions( alert: true, badge: true, sound: true); } } Future getTokens() async { var res = await http.post( Uri.parse(AppLink.getTokens), headers: { 'Authorization': 'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}', }, body: {}, ); var jsonResponse = jsonDecode(res.body); 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); } else { Get.defaultDialog(title: "Warning", middleText: "Server Error"); } } Future getAllTokenDrivers() async { var res = await http.post( Uri.parse(AppLink.getAllTokenDrivers), headers: { 'Authorization': 'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}', }, body: {}, ); var jsonResponse = jsonDecode(res.body); if (jsonResponse['status'] == 'success') { dataTokens = jsonResponse['data']; for (var i = 0; i < dataTokens.length; i++) { tokens.add(jsonResponse['data'][i]['token']); } box.write(BoxName.tokensDrivers, tokens); } else { Get.defaultDialog(title: "Warning", middleText: "Server Error"); } } Future getAllTokenPassengers() async { var res = await http.post( Uri.parse(AppLink.getAllTokenPassengers), headers: { 'Authorization': 'Basic ${base64Encode(utf8.encode(AK.basicAuthCredentials))}', }, body: {}, ); var jsonResponse = jsonDecode(res.body); if (jsonResponse['status'] == 'success') { dataTokens = jsonResponse['data']; for (var i = 0; i < dataTokens.length; i++) { tokensPassengers.add(jsonResponse['data'][i]['token']); } box.write(BoxName.tokensPassengers, tokensPassengers); } 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); } }); FirebaseMessaging.onMessage.listen((RemoteMessage 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 (message.data.isNotEmpty && message.notification != null) { fireBaseTitles(message); } }); } void fireBaseTitles(RemoteMessage message) { if (message.notification!.title! == 'Order') { if (Platform.isAndroid) { // NotificationController().showNotification('Order', '', 'order'); } var myListString = message.data['DriverList']; // var points = message.data['PolylineJson']; var myList = jsonDecode(myListString) as List; // var myPoints = jsonDecode(points) as List; driverToken = myList[14].toString(); // This is for location using and uploading status update(); } } SnackbarController driverAppliedTripSnakBar() { return Get.snackbar( 'Driver Applied the Ride for You'.tr, '', colorText: AppColor.greenColor, duration: const Duration(seconds: 3), snackPosition: SnackPosition.TOP, titleText: Text( 'Applied'.tr, style: const TextStyle(color: AppColor.redColor), ), messageText: Text( 'Driver 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), ); } Future passengerDialog(String message) { return Get.defaultDialog( barrierDismissible: false, title: 'message From passenger'.tr, titleStyle: AppStyle.title, middleTextStyle: AppStyle.title, middleText: message.tr, confirm: MyElevatedButton( title: 'Ok'.tr, onPressed: () { // FirebaseMessagesController().sendNotificationToPassengerToken( // 'Hi ,I will go now'.tr, // 'I will go now'.tr, // Get.find().driverToken, []); // Get.find() // .startTimerDriverWaitPassenger5Minute(); Get.back(); })); } // Future driverFinishTripDialoge(List driverList) { // return Get.defaultDialog( // title: 'Driver Finish Trip'.tr, // content: const DriverTipWidget(), // confirm: MyElevatedButton( // title: 'Yes'.tr, // onPressed: () async { // var tip = (Get.find().totalPassenger) * // (double.parse(box.read(BoxName.tipPercentage.toString()))); // var res = await CRUD().post(link: AppLink.addTips, payload: { // 'passengerID': box.read(BoxName.passengerID), // 'driverID': driverList[0].toString(), // 'rideID': driverList[1].toString(), // 'tipAmount': tip.toString(), // }); // await CRUD().post(link: AppLink.addPassengersWallet, payload: { // 'passenger_id': box.read(BoxName.passengerID).toString(), // 'balance': ((-1) * tip).toString() // }); // await CRUD().post(link: AppLink.addDriversWalletPoints, payload: { // 'driverID': driverList[0].toString(), // 'paymentID': '${Get.find().rideId}tip', // 'amount': (tip * 100).toString(), // 'paymentMethod': 'visa-tip', // }); // if (res != 'failure') { // FirebaseMessagesController().sendNotificationToAnyWithoutData( // 'You Have Tips', // '${'${tip.toString()}\$${' tips\nTotal is'.tr}'} ${tip + (Get.find().totalPassenger)}', // driverList[2].toString(), // ); // } // Get.to(() => RateDriverFromPassenger(), arguments: { // 'driverId': driverList[0].toString(), // 'rideId': driverList[1].toString(), // 'price': driverList[3].toString() // }); // }, // kolor: AppColor.greenColor, // ), // cancel: MyElevatedButton( // title: 'No,I want'.tr, // onPressed: () { // Get.to(() => RateDriverFromPassenger(), arguments: { // 'driverId': driverList[0].toString(), // 'rideId': driverList[1].toString(), // 'price': driverList[3].toString() // }); // }, // kolor: AppColor.redColor, // )); // } void sendNotificationAll(String title, body) async { // Get the token you want to subtract. String token = box.read(BoxName.tokenFCM); tokens = box.read(BoxName.tokensDrivers); // 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); 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': 'start.wav' }, 'priority': 'high', 'data': { 'click_action': 'FLUTTER_NOTIFICATION_CLICK', 'id': '1', 'status': 'done' }, 'to': tokens[i], })) .whenComplete(() {}) .catchError((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) { // }); // } // } 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': 'tone2.wav' }, 'data': { 'passengerList': map, }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully } else { // Handle error response 'Failed to send notification. Status code: ${response.statusCode}'; } } catch (e) { // Handle other exceptions } } 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': 'notify.wav' }, 'data': { 'click_action': 'FLUTTER_NOTIFICATION_CLICK', 'id': '1', 'status': 'done' }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully } else { // Handle error response 'Failed to send notification. Status code: ${response.statusCode}'; } } catch (e) { // Handle other exceptions } } 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': 'tone2.wav', 'sound': 'order.wav' }, 'data': { 'DriverList': data, }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully } else { // Handle error response 'Failed to send notification. Status code: ${response.statusCode}'; } } catch (e) { // Handle other exceptions } } void sendNotificationToDriverMapPolyline(String title, String body, String token, List data, String polylineJson) 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': 'tone2.wav', 'sound': 'order.wav' }, 'data': { 'DriverList': data, 'PolylineJson': polylineJson, }, 'priority': 'high', 'to': token, }), ); if (response.statusCode == 200) { // Notification sent successfully } else { // Handle error response 'Failed to send notification. Status code: ${response.statusCode}'; } } catch (e) { // Handle other exceptions } } }