import 'dart:async'; import 'dart:convert'; import 'dart:developer'; import 'dart:io'; import 'dart:math' as math; import 'package:firebase_messaging/firebase_messaging.dart'; import 'package:flutter/cupertino.dart'; import 'package:flutter/material.dart'; import 'package:flutter_local_notifications/flutter_local_notifications.dart'; import 'package:hub/actions/actions.dart'; import 'package:hub/app_state.dart'; import 'package:hub/backend/api_requests/api_calls.dart'; import 'package:hub/backend/api_requests/api_manager.dart'; import 'package:hub/components/templates_components/access_notification_modal_template_component/access_notification_modal_template_component_widget.dart'; import 'package:hub/components/templates_components/message_notificaion_modal_template_component/message_notification_widget.dart'; import 'package:hub/components/templates_components/details_component/details_component_widget.dart'; import 'package:hub/flutter_flow/flutter_flow_icon_button.dart'; import 'package:hub/flutter_flow/flutter_flow_theme.dart'; import 'package:hub/flutter_flow/flutter_flow_util.dart'; import 'package:hub/flutter_flow/flutter_flow_widgets.dart'; import 'package:hub/flutter_flow/internationalization.dart'; import 'package:rxdart/rxdart.dart'; // class PushNotificationService { final FirebaseMessaging _firebaseMessaging = FirebaseMessaging.instance; final FlutterLocalNotificationsPlugin _flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin(); final Subject _onMessage = BehaviorSubject(); final BehaviorSubject _context = BehaviorSubject(); final BehaviorSubject> _notificationDetails = BehaviorSubject>(); PushNotificationService() { _initializeLocalNotifications(_context); _createNotificationChannels(); } Subject getOnMessage() { return _onMessage; } Future initialize(BuildContext context) async { _context.add(context); await _requestPermissions(); _listenToForegroundMessages(context); _listenToBackgroundMessages(); _listenToNotificationClicks(context); await updateDeviceToken(); } Future _requestPermissions() async { NotificationSettings settings = await _firebaseMessaging.requestPermission( alert: true, badge: true, sound: true, ); if (settings.authorizationStatus == AuthorizationStatus.authorized) { } else {} } Map validJsonFromString(String? jsonString) { if (jsonString == null || jsonString.isEmpty) { return {}; } // Passo 1 e 2: Adiciona aspas duplas em torno das chaves e valores que não estão corretamente delimitados String correctedJson = jsonString.replaceAllMapped( RegExp(r'([a-zA-Z0-9_]+)\s*:\s*([^",\}\]]+)'), (match) { var key = '"${match[1]!}"'; // Chaves sempre recebem aspas var value = match[2]!.trim(); // Verifica se o valor é uma string (não numérica, booleana, nula ou objeto JSON) bool isStringValue = !RegExp(r'^-?\d+(\.\d+)?$').hasMatch(value) && value != 'true' && value != 'false' && value != 'null' && !value.startsWith('{') && !value.endsWith('}'); // Adiciona aspas duplas em torno do valor se for uma string String quotedValue = isStringValue ? '"$value"' : value; return '$key: $quotedValue'; }); // Passo 3: Tratar corretamente strings JSON aninhadas correctedJson = correctedJson.replaceAllMapped(RegExp(r'"{([^"]+)}"'), (match) { // Remove as aspas duplas extras em torno de objetos JSON aninhados return '{${match[1]!}}'; }); try { // Passo 4: Decodificar o JSON corrigido return jsonDecode(correctedJson); } catch (e) { return {}; } } void _initializeLocalNotifications( BehaviorSubject context) async { while (context.valueOrNull == null) { await Future.delayed(Duration(milliseconds: 100)); } var initializationSettingsAndroid = AndroidInitializationSettings('mipmap/ic_fre_black'); var initializationSettingsIOS = DarwinInitializationSettings( requestAlertPermission: true, requestBadgePermission: true, requestSoundPermission: true, ); var initializationSettings = InitializationSettings( android: initializationSettingsAndroid, iOS: initializationSettingsIOS, ); _flutterLocalNotificationsPlugin.initialize( initializationSettings, onDidReceiveNotificationResponse: (NotificationResponse response) async { if (response.payload != null) { try { Map message = validJsonFromString(response.payload!); var data = _notificationDetails; // Assuming getOnMessage() now returns the latest RemoteMessage _handleNotificationClick(message, extra: data.value); } catch (e) {} } }, ); } void _createNotificationChannels() { List actions = [ 'visit_request', 'visit_response', 'access', 'mensagem', 'enroll_cond', 'miscellaneous' ]; for (String action in actions) { _createNotificationChannel(action, "Channel for $action"); } } void _createNotificationChannel(String channelId, String channelName) { _flutterLocalNotificationsPlugin .resolvePlatformSpecificImplementation< AndroidFlutterLocalNotificationsPlugin>() ?.createNotificationChannel( AndroidNotificationChannel( channelId, // Use o click_action como ID do canal channelName, // Nome descritivo baseado no click_action description: 'Channel for $channelName notifications', importance: Importance.max, ), ); } void _listenToForegroundMessages(BuildContext context) { FirebaseMessaging.onMessage.listen((RemoteMessage message) { _onMessage.add(message); _notificationDetails.add(message.toMap()['notification']); _showNotification(message); }); } void _listenToBackgroundMessages() { FirebaseMessaging.onBackgroundMessage(_firebaseMessagingBackgroundHandler); } void _listenToNotificationClicks(BuildContext context) { FirebaseMessaging.onMessageOpenedApp.listen((RemoteMessage message) { _onMessage.add(message); NotificationHandler().handleMessage(message.data, context); }); } void configureTokenRefresh() { _firebaseMessaging.onTokenRefresh .listen(_handleTokenUpdate) .onError((err) {}); } Future _updateToken(String token) async { FFAppState().token = token; final ApiCallResponse? response = await _updateTokenOnServer(token); if (_isTokenUpdateSuccessful(response)) { } else {} } Future _handleTokenUpdate(String newToken) async { await _updateToken(newToken); } Future updateDeviceToken() async { configureTokenRefresh(); final NotificationSettings settings = await _requestNotificationPermission(); if (Platform.isIOS) await _fetchAndLogApnsToken(settings); final String? deviceToken = await _firebaseMessaging.getToken(); if (deviceToken != null) { await _updateToken(deviceToken); } else {} } Future _requestNotificationPermission() async { final NotificationSettings settings = await _firebaseMessaging.requestPermission(); log(settings.authorizationStatus == AuthorizationStatus.authorized ? 'User granted permission' : 'User declined or has not accepted permission'); return settings; } Future _fetchAndLogApnsToken(NotificationSettings settings) async { if (settings.authorizationStatus == AuthorizationStatus.authorized) { final String? apnsToken = await _firebaseMessaging.getAPNSToken(); log(apnsToken != null ? 'APNS Token: $apnsToken' : 'Failed to get APNS token'); } } Future _updateTokenOnServer(String deviceToken) async { return await PhpGroup.updToken.call( token: deviceToken, devid: FFAppState().devUUID, useruuid: FFAppState().userUUID, ); } bool _isTokenUpdateSuccessful(ApiCallResponse? response) { return PhpGroup.updToken.error((response?.jsonBody ?? '')) == false; } String _getChannelIdBasedOnClickAction(String clickAction) { final baseId = clickAction.hashCode; return 'channel_$baseId'; } void _showNotification(RemoteMessage message) async { String channelId = _getChannelIdBasedOnClickAction(message.data['click_action']); var androidDetails = AndroidNotificationDetails( channelId, 'Channel Name for $channelId', channelDescription: 'Channel Description for $channelId', importance: Importance.max, priority: Priority.high, ); var iOSDetails = DarwinNotificationDetails(); var generalNotificationDetails = NotificationDetails(android: androidDetails, iOS: iOSDetails); await _flutterLocalNotificationsPlugin.show( // DateTime.now().millisecondsSinceEpoch % (1 << 31), math.Random().nextInt(1 << 30), message.notification?.title, message.notification?.body, generalNotificationDetails, payload: message.data.toString(), ); } _handleNotificationClick(Map payload, {Map extra = const {}}) { switch (payload.isNotEmpty) { case true: // Print the 'data' property // Handle the message data as needed NotificationHandler().handleMessage(payload, _context.value, extra: extra.isEmpty ? {} : extra); // Access the 'data' property of 'RemoteMessage' case false: // Handle the message notification as needed break; } } static Future _firebaseMessagingBackgroundHandler( RemoteMessage message) async {} } class NotificationHandler { void handleMessage(Map message, BuildContext context, {Map extra = const {}}) { message.forEach((key, value) {}); switch (message['click_action']) { case 'visit_request': _showVisitRequestDialog(message, context); break; case '': break; case 'access': _showAcessNotificationModal(message, context); break; case 'mensagem': _showMessageNotificationDialog(message, context, extra); break; case 'enroll_cond': break; default: } } String _getIdBasedOnUserType(Map message) { if (message['USR_TIPO'].toString() == 'O') { // Retorna USR_ID se não estiver vazio/nulo, caso contrário retorna '0' return message['USR_ID'].toString().isEmpty ? '0' : message['USR_ID'].toString(); } else { // Retorna USR_DOCUMENTO se não estiver vazio/nulo, caso contrário retorna '0' return message['USR_DOCUMENTO'].toString().isEmpty ? '0' : message['USR_DOCUMENTO'].toString(); } } void _showAcessNotificationModal( Map message, BuildContext context) { showDialog( context: context, builder: (BuildContext context) { _getIdBasedOnUserType(message); return Dialog( backgroundColor: Colors.transparent, child: AccessNotificationModalTemplateComponentWidget( datetime: message['ACE_DATAHORA'].toString(), drive: message['ACI_DESCRICAO'].toString(), id: message['USR_TIPO'].toString() == 'O' ? message['USR_ID'].toString() == '' ? '0' : message['USR_ID'].toString() : message['USR_DOCUMENTO'].toString() == '' ? '0' : message['USR_DOCUMENTO'].toString(), name: message['PES_NOME'].toString(), type: message['USR_TIPO'], )); }, ); } void _showMessageNotificationDialog(Map message, BuildContext context, Map extra) { showDialog( useSafeArea: true, barrierDismissible: true, context: context, builder: (BuildContext context) { return GestureDetector( onTap: () => Navigator.of(context).pop(), child: SizedBox( width: MediaQuery.of(context).size.width, height: MediaQuery.of(context).size.height, child: Dialog( backgroundColor: Colors.transparent, child: GestureDetector( onTap: () => Navigator.of(context).pop(), child: SizedBox( width: MediaQuery.of(context).size.width, height: MediaQuery.of(context).size.height, child: MessageNotificationModalTemplateComponentWidget( id: message['local']['CLI_ID'].toString(), from: message['remetente'].toString(), to: message['destinatario'].toString() == 'O' ? 'Morador' : 'Visitante', message: extra['body'].toString().isEmpty ? 'Unknown' : extra['body'].toString(), ), ), ), ), ), ); }, ); } void _showVisitRequestDialog( Map message, BuildContext context) { showDialog( context: context, barrierDismissible: true, // barrierColor: Colors.green, builder: (BuildContext context) { _getIdBasedOnUserType(message); return Dialog( backgroundColor: Colors.transparent, child: VisitRequestTemplateComponentWidget( buttons: [ FlutterFlowIconButton( icon: const Icon(Icons.done), onPressed: () async { showDialog( context: context, builder: (context) { return AlertDialog( title: Text( FFLocalizations.of(context).getVariableText( ptText: 'Aprovar Visita', enText: 'Approve Visit', ), ), content: Text( FFLocalizations.of(context).getVariableText( ptText: 'Você tem certeza que deseja aprovar essa visita?', enText: 'Are you sure you want to approve this visit?', ), ), backgroundColor: FlutterFlowTheme.of(context).primaryBackground, actions: [ FFButtonWidget( text: FFLocalizations.of(context).getVariableText( enText: 'No', ptText: 'Não', ), onPressed: () { Navigator.pop(context); }, options: FFButtonOptions( width: 100, height: 40, color: FlutterFlowTheme.of(context) .primaryBackground, textStyle: TextStyle( color: FlutterFlowTheme.of(context) .primaryText, ), borderSide: BorderSide( color: FlutterFlowTheme.of(context) .primaryBackground, width: 1, ), borderRadius: BorderRadius.circular(10)), ), FFButtonWidget( text: FFLocalizations.of(context).getVariableText( enText: 'Yes', ptText: 'Sim', ), onPressed: () async { await answersRequest.call( context, message['referencia'].toString(), 'L', 'Mensagem', message['idVisitante'].toString(), ); }, options: FFButtonOptions( width: 100, height: 40, color: FlutterFlowTheme.of(context) .primaryBackground, textStyle: TextStyle( color: FlutterFlowTheme.of(context).primaryText, ), borderSide: BorderSide( color: FlutterFlowTheme.of(context) .primaryBackground, width: 1, ), borderRadius: BorderRadius.circular(10), ), ), ], ); }); }, ), FlutterFlowIconButton( icon: const Icon(Icons.close), onPressed: () async { showDialog( context: context, builder: (context) { return AlertDialog( title: Text( FFLocalizations.of(context).getVariableText( ptText: 'Bloquear Visita', enText: 'Block Visit', ), ), content: Text( FFLocalizations.of(context).getVariableText( ptText: 'Você tem certeza que deseja bloquear essa visita?', enText: 'Are you sure you want to block this visit?', ), ), backgroundColor: FlutterFlowTheme.of(context).primaryBackground, actions: [ FFButtonWidget( text: FFLocalizations.of(context).getVariableText( enText: 'No', ptText: 'Não', ), onPressed: () { Navigator.pop(context); }, options: FFButtonOptions( width: 100, height: 40, color: FlutterFlowTheme.of(context) .primaryBackground, textStyle: TextStyle( color: FlutterFlowTheme.of(context) .primaryText, ), borderSide: BorderSide( color: FlutterFlowTheme.of(context) .primaryBackground, width: 1, ), borderRadius: BorderRadius.circular(10)), ), FFButtonWidget( text: FFLocalizations.of(context).getVariableText( enText: 'Yes', ptText: 'Sim', ), onPressed: () async { await answersRequest.call( context, message['referencia'].toString(), 'B', 'Mensagem', message['idVisitante'].toString(), ); }, options: FFButtonOptions( width: 100, height: 40, color: FlutterFlowTheme.of(context) .primaryBackground, textStyle: TextStyle( color: FlutterFlowTheme.of(context).primaryText, ), borderSide: BorderSide( color: FlutterFlowTheme.of(context) .primaryBackground, width: 1, ), borderRadius: BorderRadius.circular(10), ), ), ], ); }); }, ), ], labelsHashMap: Map.from({ FFLocalizations.of(context).getVariableText( enText: 'Visitor', ptText: 'Visitante', ): message['nomevisita'], FFLocalizations.of(context).getVariableText( enText: 'Reason', ptText: 'Motivo', ): message['motivo'], FFLocalizations.of(context).getVariableText( enText: 'Message', ptText: 'Mensagem', ): message['mensagem'], }), imagePath: 'https://freaccess.com.br/freaccess/getImage.php?cliID=${FFAppState().cliUUID}&atividade=getFoto&Documento=${message['documento'] ?? ''}&tipo=E', statusHashMap: [ { FFLocalizations.of(context).getVariableText( enText: 'Active', ptText: 'Ativo', ): FlutterFlowTheme.of(context).warning, }, ], // changeStatusAction: answersRequest, ), ); }, ); } } class PushNotificationManager { final StreamController _onMessageReceivedController = StreamController.broadcast(); Stream get onMessageReceived => _onMessageReceivedController.stream; PushNotificationManager() { FirebaseMessaging.onMessage.listen((RemoteMessage message) { _onMessageReceivedController.add(message); }); } void dispose() { _onMessageReceivedController.close(); } }