import 'dart:convert'; import 'package:firebase_messaging/firebase_messaging.dart'; import 'package:flutter/cupertino.dart'; import 'package:flutter_callkit_incoming/entities/entities.dart'; import 'package:flutter_callkit_incoming/flutter_callkit_incoming.dart'; import 'package:mohem_flutter_app/app_state/app_state.dart'; import 'package:mohem_flutter_app/classes/consts.dart'; import 'package:mohem_flutter_app/classes/navigationService.dart'; import 'package:mohem_flutter_app/classes/notifications.dart'; import 'package:mohem_flutter_app/classes/utils.dart'; import 'package:mohem_flutter_app/config/routes.dart'; import 'package:mohem_flutter_app/main.dart'; import 'package:mohem_flutter_app/models/chat/call.dart'; import 'package:mohem_flutter_app/models/chat/get_single_user_chat_list_model.dart'; import 'package:mohem_flutter_app/models/chat/get_user_login_token_model.dart' as ALM; import 'package:mohem_flutter_app/models/chat/get_user_login_token_model.dart'; import 'package:mohem_flutter_app/models/chat/incoming_call_model.dart'; import 'package:mohem_flutter_app/provider/chat_call_provider.dart'; import 'package:mohem_flutter_app/provider/chat_provider_model.dart'; import 'package:mohem_flutter_app/ui/chat/call/chat_incoming_call_screen.dart'; import 'package:mohem_flutter_app/ui/landing/dashboard_screen.dart'; import 'package:provider/provider.dart'; import 'package:signalr_netcore/hub_connection.dart'; import 'package:signalr_netcore/signalr_client.dart'; class ChatVoipCall { static final ChatVoipCall _instance = ChatVoipCall._internal(); ChatVoipCall._internal(); factory ChatVoipCall() => _instance; late ChatProviderModel prov; late ChatCallProvider cProv; dynamic inCallData; bool isUserOnline = false; dynamic callData; late IncomingCallModel sessionData; Future showCallkitIncoming({required String uuid, RemoteMessage? data, CallDataModel? incomingCallData, bool background = false}) async { await ChatVoipCall().listenerEvent(); await FlutterCallkitIncoming.endAllCalls(); ALM.Response autoLoginData; SingleUserChatModel callerData; if (data!.data["user_token_response"] == null || data.data["user_token_response"].isEmpty) { // Online & App Logged In ALM.Response sharedDetails = ALM.Response.fromJson(jsonDecode(await Utils.getStringFromPrefs("userLoginChatDetails"))); autoLoginData = ALM.Response.fromJson(AppState().getchatUserDetails == null ? sharedDetails.toJson() : AppState().getchatUserDetails!.response!.toJson()); dynamic items = jsonDecode(data!.data["user_chat_history_response"]); callerData = SingleUserChatModel( targetUserId: items["CurrentUserId"], targetUserEmail: items["CurrentUserEmail"], targetUserName: items["CurrentUserName"].split("@").first, currentUserId: autoLoginData.id, currentUserEmail: autoLoginData.email, currentUserName: autoLoginData.userName, chatEventId: 3); isUserOnline = true; } else { // Offline or App in Background or App is At Verify Screen autoLoginData = ALM.Response.fromJson(jsonDecode(data.data["user_token_response"])); callerData = SingleUserChatModel.fromJson(json.decode(data!.data["user_chat_history_response"])); } CallKitParams params = CallKitParams( id: uuid, nameCaller: callerData.targetUserName, appName: 'Mohemm', handle: '', type: 0, duration: 20000, textAccept: 'Accept', textDecline: 'Decline', textMissedCall: 'Missed call', textCallback: 'Call back', extra: { "loginDetails": autoLoginData.toJson(), "callerDetails": callerData.toJson(), 'isIncomingCall': true, 'isUserOnline': isUserOnline, }, android: const AndroidParams( isCustomNotification: true, isShowLogo: false, isShowCallback: false, isShowMissedCallNotification: true, ringtonePath: 'system_ringtone_default', backgroundColor: '#0955fa', backgroundUrl: 'assets/test.png', actionColor: '#4CAF50', ), ios: IOSParams( iconName: 'Mohemm', handleType: '', supportsVideo: true, maximumCallGroups: 2, maximumCallsPerCallGroup: 1, audioSessionMode: 'default', audioSessionActive: true, audioSessionPreferredSampleRate: 38000.0, audioSessionPreferredIOBufferDuration: 0.005, supportsDTMF: true, supportsHolding: true, supportsGrouping: false, supportsUngrouping: false, ringtonePath: 'system_ringtone_default', ), ); sessionData = IncomingCallModel.fromJson(params.toJson()); if (callerData.chatEventId == 3) { await Utils.saveStringFromPrefs("isIncomingCall", "true"); await FlutterCallkitIncoming.showCallkitIncoming(params); } } Future getCurrentCall() async { var calls = await FlutterCallkitIncoming.activeCalls(); if (calls is List) { if (calls.isNotEmpty) { return calls[0]; } else { return null; } } } void checkAndNavigationCallingPage() async { dynamic currentCall = await getCurrentCall(); if (currentCall != null) { Future.delayed(const Duration(seconds: 1)).whenComplete(() { Navigator.pushNamed(AppRoutes.navigatorKey.currentContext!, AppRoutes.chatStartCall); }); } } Future isCall() async { dynamic calls = await FlutterCallkitIncoming.activeCalls(); if (calls is List) { if (calls.isNotEmpty) { NavigationService.navigateToPage(StartCallPage()); } } } //Function(CallEvent) callback Future listenerEvent() async { try { FlutterCallkitIncoming.onEvent.listen((CallEvent? event) async { switch (event!.event) { case Event.ACTION_CALL_INCOMING: break; case Event.ACTION_CALL_START: break; case Event.ACTION_CALL_ACCEPT: if (isUserOnline) { checkAndNavigationCallingPage(); } else { isCall(); } break; case Event.ACTION_CALL_DECLINE: Utils.saveStringFromPrefs("isIncomingCall", "false"); Utils.saveStringFromPrefs("inComingCallData", "null"); declineCall(); break; case Event.ACTION_CALL_ENDED: Utils.saveStringFromPrefs("isIncomingCall", "false"); Utils.saveStringFromPrefs("inComingCallData", "null"); FlutterCallkitIncoming.endAllCalls(); break; case Event.ACTION_CALL_TIMEOUT: Utils.saveStringFromPrefs("isIncomingCall", "false"); Utils.saveStringFromPrefs("inComingCallData", "null"); FlutterCallkitIncoming.endAllCalls(); break; } }); } on Exception {} } Future declineCall() async { if (isUserOnline) { if (chatHubConnection.state == HubConnectionState.Connected) { if (sessionData?.extra != null) { chatHubConnection.invoke("HangUpAsync", args: [ int.parse(sessionData.extra!.callerDetails!.currentUserId.toString()), int.parse(sessionData.extra!.callerDetails!.targetUserId.toString()), ]); chatHubConnection.invoke("UpdateUserStatusAsync", args: [ int.parse(sessionData.extra!.callerDetails!.currentUserId.toString()), 1, ]); FlutterCallkitIncoming.endCall(sessionData.id!); } } } else { HttpConnectionOptions httpOp = HttpConnectionOptions(skipNegotiation: false, logMessageContent: true); HubConnection hc = HubConnectionBuilder() .withUrl(ApiConsts.chatHubConnectionUrl + "?UserId=${sessionData.extra!.loginDetails!.id}&source=Desktop&access_token=${sessionData.extra?.loginDetails!.token}", options: httpOp) .withAutomaticReconnect(retryDelays: [2000, 5000, 10000, 20000]).build(); await hc.start(); await hc.invoke( "HangUpAsync", args: [ int.parse(sessionData.extra!.callerDetails!.currentUserId.toString()), int.parse(sessionData.extra!.callerDetails!.targetUserId.toString()), ], ); FlutterCallkitIncoming.endCall(sessionData.id!); hc.stop(); } } }