优化录制、停止录制逻辑

This commit is contained in:
2026-06-05 14:30:56 +08:00
parent c0aa2db6db
commit d598b36449
2 changed files with 22 additions and 33 deletions

View File

@@ -7,7 +7,6 @@ import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:permission_handler/permission_handler.dart';
import 'package:recording_tool/core/logging/app_logger.dart';
import 'package:recording_tool/core/permission/permission_service.dart';
import 'package:recording_tool/core/utils/rate_limiter.dart';
import 'package:recording_tool/features/recording/model/model_clipboard.dart';
import 'package:recording_tool/features/recording/model/model_recording.dart';
import 'package:recording_tool/features/recording/model/model_recording_session.dart';
@@ -32,24 +31,17 @@ enum ClipboardReadResult {
}
class RecordingViewModel extends Notifier<RecordingModel> {
static const Duration _recordingActionInterval = Duration(milliseconds: 300);
static const Object _startRecordingThrottleKey = 'recording.session.start';
static const Object _stopRecordingThrottleKey = 'recording.session.stop';
static final _defaultClipboard = ClipboardRecordingModel(
title: '',
address: '',
);
StreamSubscription<RecordingStatus>? _statusSubscription;
final _rateLimit = RateLimitHub();
@override
RecordingModel build() {
ref.onDispose(_dispose);
return RecordingModel(
clipboardRecordingModel: _defaultClipboard,
);
return RecordingModel(clipboardRecordingModel: _defaultClipboard);
}
void _updateSession(
@@ -214,7 +206,9 @@ class RecordingViewModel extends Notifier<RecordingModel> {
return const [];
}
bool _isGalleryPermissionGranted(Map<Permission, PermissionStatus> permissions) {
bool _isGalleryPermissionGranted(
Map<Permission, PermissionStatus> permissions,
) {
for (final permission in _galleryPermissions()) {
if (permissions[permission]?.isGranted ?? false) {
return true;
@@ -223,21 +217,7 @@ class RecordingViewModel extends Notifier<RecordingModel> {
return _galleryPermissions().isEmpty;
}
bool _tryAcquireRecordingAction(Object key) {
var executed = false;
_rateLimit.throttle<void>(
key: key,
value: null,
duration: _recordingActionInterval,
options: const ThrottleOptions(leading: true, trailing: false),
onCallback: (_) => executed = true,
);
return executed;
}
Future<void> startRecording({bool enableDoNotDisturb = true}) async {
if (!_tryAcquireRecordingAction(_startRecordingThrottleKey)) return;
final session = state.session;
if (!session.isPreviewReady ||
session.isRecording ||
@@ -277,8 +257,6 @@ class RecordingViewModel extends Notifier<RecordingModel> {
}
Future<void> stopRecording() async {
if (!_tryAcquireRecordingAction(_stopRecordingThrottleKey)) return;
if (!state.session.isRecording) return;
try {
@@ -346,7 +324,6 @@ class RecordingViewModel extends Notifier<RecordingModel> {
}
Future<void> _dispose() async {
_rateLimit.clear();
await _statusSubscription?.cancel();
}
}