From a677def7f3cc081395fe2a3c14d302bf41819d21 Mon Sep 17 00:00:00 2001 From: liyi Date: Thu, 5 Dec 2024 13:50:57 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E5=A2=9E=E5=8A=A0=E9=93=83=E5=A3=B0?= =?UTF-8?q?=E3=80=81=E9=80=9A=E8=AF=9D=E4=BF=9D=E6=8C=81=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../talk_ping_overtime_timer_manger.dart | 53 +++++++++++ .../handle/scp_message_base_handle.dart | 29 ++++++ lib/talk/startChart/start_chart_manage.dart | 95 +++++++++++++++++-- 3 files changed, 168 insertions(+), 9 deletions(-) create mode 100644 lib/talk/startChart/handle/other/talk_ping_overtime_timer_manger.dart diff --git a/lib/talk/startChart/handle/other/talk_ping_overtime_timer_manger.dart b/lib/talk/startChart/handle/other/talk_ping_overtime_timer_manger.dart new file mode 100644 index 00000000..96eb263b --- /dev/null +++ b/lib/talk/startChart/handle/other/talk_ping_overtime_timer_manger.dart @@ -0,0 +1,53 @@ +import 'dart:async'; + +typedef TimeoutCallback = void Function(); + +class TalkPingOverTimeTimerManager { + // 构造函数，接受超时时间 + TalkPingOverTimeTimerManager({required this.timeoutInSeconds}); + + // 定义一个可取消的 Timer + Timer? _timer; + + // 超时时间（以秒为单位），是 final 的，因此必须在构造函数中初始化 + final int timeoutInSeconds; + + // 默认超时时间（以秒为单位） + static const int defaultTimeoutInSeconds = 5; + + // 超时回调函数 + TimeoutCallback? _onTimeout; + + // 启动计时器 + void startTimer() { + _cancelTimer(); // 取消任何已存在的计时器 + _timer = Timer(Duration(seconds: timeoutInSeconds), () { + // 超时回调方法 + _onTimeout?.call(); + // 清楚定时器 + _cancelTimer(); + }); + } + + // 接收到消息时调用此方法 + void receiveMessage() { + print("Received a message, resetting the timer."); + startTimer(); + } + + // 设置超时回调函数 + void setOnTimeout(TimeoutCallback? callback) { + _onTimeout = callback; + } + + // 取消计时器 + void _cancelTimer() { + _timer?.cancel(); + _timer = null; + } + + // 清理资源 + void dispose() { + _cancelTimer(); + } +} diff --git a/lib/talk/startChart/handle/scp_message_base_handle.dart b/lib/talk/startChart/handle/scp_message_base_handle.dart index acf1b8a7..416b1f8a 100644 --- a/lib/talk/startChart/handle/scp_message_base_handle.dart +++ b/lib/talk/startChart/handle/scp_message_base_handle.dart @@ -1,8 +1,27 @@ +import 'package:audioplayers/audioplayers.dart'; +import 'package:flutter_local_notifications/flutter_local_notifications.dart'; + import 'package:star_lock/app_settings/app_settings.dart'; +import 'package:star_lock/talk/other/audio_player_manager.dart'; import 'package:star_lock/talk/startChart/constant/udp_constant.dart'; +import 'package:star_lock/talk/startChart/handle/other/talk_ping_overtime_timer_manger.dart'; + import 'package:star_lock/talk/startChart/proto/generic.pb.dart'; +import 'package:star_lock/talk/startChart/start_chart_manage.dart'; +import 'package:star_lock/tools/storage.dart'; class ScpMessageBaseHandle { + final startChartManage = StartChartManage(); + + final audioManager = AudioPlayerManager(); + + // 通话保持超时监听定时器管理 + final talkePingOverTimeTimerManager = TalkPingOverTimeTimerManager( + timeoutInSeconds: 5, + ); + + + bool checkGenericRespSuccess(GenericResp genericResp) { if (genericResp == null) return false; final code = genericResp.code; @@ -14,4 +33,14 @@ class ScpMessageBaseHandle { void log({required String text}) { AppLog.log('==========${text}'); } + + // 播放铃声 + void playRingtone() async { + await audioManager.playRingtone(); + } + + // 停止播放铃声 + void stopRingtone() async { + await audioManager.stopRingtone(); + } } diff --git a/lib/talk/startChart/start_chart_manage.dart b/lib/talk/startChart/start_chart_manage.dart index 0230c6aa..6b5f8595 100644 --- a/lib/talk/startChart/start_chart_manage.dart +++ b/lib/talk/startChart/start_chart_manage.dart @@ -4,10 +4,8 @@ import 'dart:typed_data'; import 'package:convert/convert.dart'; import 'package:fast_rsa/fast_rsa.dart' as fastRsa; -import 'package:flutter_easyloading/flutter_easyloading.dart'; import 'package:get/get.dart'; import 'package:pointycastle/export.dart' as pc; -import 'package:star_lock/appRouters.dart'; import 'package:star_lock/app_settings/app_settings.dart'; import 'package:star_lock/flavors.dart'; import 'package:star_lock/network/start_chart_api.dart'; @@ -15,17 +13,12 @@ import 'package:star_lock/talk/startChart/command/message_command.dart'; import 'package:star_lock/talk/startChart/constant/ip_constant.dart'; import 'package:star_lock/talk/startChart/constant/listen_addr_type_constant.dart'; import 'package:star_lock/talk/startChart/constant/payload_type_constant.dart'; -import 'package:star_lock/talk/startChart/constant/udp_constant.dart'; -import 'package:star_lock/talk/startChart/entity/heartbeat_response.dart'; -import 'package:star_lock/talk/startChart/entity/login_response.dart'; import 'package:star_lock/talk/startChart/entity/relay_info_entity.dart'; import 'package:star_lock/talk/startChart/entity/report_information_data.dart'; import 'package:star_lock/talk/startChart/entity/scp_message.dart'; import 'package:star_lock/talk/startChart/entity/star_chart_register_node_entity.dart'; import 'package:star_lock/talk/startChart/handle/scp_message_handle.dart'; import 'package:star_lock/talk/startChart/handle/scp_message_handler_factory.dart'; -import 'package:star_lock/talk/startChart/proto/gateway_reset.pb.dart'; -import 'package:star_lock/talk/startChart/proto/generic.pb.dart'; import 'package:star_lock/tools/deviceInfo_utils.dart'; import 'package:star_lock/tools/storage.dart'; import 'package:uuid/uuid.dart'; @@ -67,9 +60,13 @@ class StartChartManage { bool isOnlineStartChartServer = false; // 星图是否上线成功 int reStartOnlineStartChartServerIntervalTime = 1; // 重新上线星图服务任务间隔(s) Timer? reStartOnlineStartChartServerTimer; // 重新上线定时器 + int talkPingIntervalTime = 1; // 发送通话保持消息间隔(s) + Timer? talkPingTimer; // 发送通话保持消息定时器 String relayPeerId = ''; // 中继peerId + bool _calling = false; // 是否处于通话中 + // 星图服务初始化 Future init() async { if (isOnlineStartChartServer && _udpSocket != null) { @@ -122,6 +119,16 @@ class StartChartManage { } } + /// 判断是否通话中 + bool checkIsCalling() { + return _calling; + } + + /// 设置通话状态 + void changeCallingStatus(bool status) { + _calling = status; + } + // 初始化udp Future _onlineRelayService() async { var addressIListenFrom = InternetAddress.anyIPv4; @@ -211,9 +218,57 @@ class StartChartManage { await _sendMessage(message: message); } - // 发送通话保持消息 - void sendTalkPingMessage( + // 发送同意接听消息 + void sendTalkAcceptMessage( {required String ToPeerId, required int gatewayId}) async { + final message = MessageCommand.talkAcceptMessage( + ToPeerId: ToPeerId, + FromPeerId: FromPeerId, + ); + await _sendMessage(message: message); + } + + // 发送拒绝接听消息 + void sendTalkRejectMessage({ + required String ToPeerId, + required int gatewayId, + }) async { + final message = MessageCommand.talkRejectMessage( + ToPeerId: ToPeerId, + FromPeerId: FromPeerId, + ); + await _sendMessage(message: message); + } + + // 回复成功消息 + void sendGenericRespSuccessMessage( + {required String ToPeerId, + required String FromPeerId, + required int PayloadType}) async { + final message = MessageCommand.genericRespSuccessMessage( + ToPeerId: ToPeerId, + FromPeerId: FromPeerId, + PayloadType: PayloadType, + ); + await _sendMessage(message: message); + } + + // 回复失败消息 + void sendGenericRespErrorMessage( + {required String ToPeerId, + required String FromPeerId, + required int PayloadType}) async { + final message = MessageCommand.genericRespErrorMessage( + ToPeerId: ToPeerId, + FromPeerId: FromPeerId, + PayloadType: PayloadType, + ); + await _sendMessage(message: message); + } + + // 发送通话保持消息 + Future sendTalkPingMessage( + {required String ToPeerId, required String FromPeerId}) async { final message = MessageCommand.talkPingMessage( ToPeerId: ToPeerId, FromPeerId: FromPeerId, @@ -597,4 +652,26 @@ class StartChartManage { _log(text: '❌ 处理udp返回数据时遇到错误---> $e'); } } + + /// 通话保持定时器 + void startTalkPingMessageTimer() { + talkPingTimer ??= Timer.periodic( + Duration( + seconds: talkPingIntervalTime, + ), + (Timer timer) async { + // 重新发送上线消息 + await sendTalkPingMessage( + ToPeerId: ToPeerId, + FromPeerId: FromPeerId, + ); + }, + ); + } + + // 停止通话保持 + void stopTalkPingMessageTimer() { + talkPingTimer?.cancel(); + talkPingTimer = null; // 清除定时器引用 + } }