Files
Qlyra/lib/frontend/screens/auth/code_confirmation_screen.dart
sevenhill b22654b99f
Build Android (FCM) / build-android-fcm (push) Canceled after 0s
Build Android / build-android (push) Canceled after 0s
Build iOS / build-ios (push) Canceled after 0s
Build Linux / build-linux (push) Canceled after 0s
Build macOS / build-macos (push) Canceled after 0s
Build Windows / build-windows (push) Canceled after 0s
Native crypto / native-crypto (push) Canceled after 0s
Release (main) / android (oneme) (push) Canceled after 0s
Release (main) / android (qlyra) (push) Canceled after 0s
Release (main) / windows (push) Canceled after 0s
Release (main) / linux (push) Canceled after 0s
Release (main) / macos (push) Canceled after 0s
Release (main) / ios (push) Canceled after 0s
Release (main) / release (push) Canceled after 0s
Update Qlyra to 1.0.13 with messaging, media and plugin improvements
2026-09-10 17:55:55 +03:00

587 lines
20 KiB
Dart

import 'dart:async';
import 'package:flutter/material.dart';
import 'package:qlyra/l10n/app_localizations.dart';
import 'package:flutter/services.dart';
import 'package:material_symbols_icons/symbols.dart';
import 'password_2fa_screen.dart';
import 'registration_screen.dart';
import 'session_stale_recovery.dart';
import '../../../backend/api.dart';
import '../../../core/protocol/packet.dart';
import '../../../core/utils/sms_code_listener.dart';
import '../../../main.dart';
import '../../widgets/custom_notification.dart';
import '../../widgets/login_success_screen.dart';
import '../../widgets/small_spinner.dart';
class CodeConfirmationScreen extends StatefulWidget {
final String phoneNumber;
final String rawPhone;
final String token;
const CodeConfirmationScreen({
super.key,
required this.phoneNumber,
required this.rawPhone,
required this.token,
});
@override
State<CodeConfirmationScreen> createState() => _CodeConfirmationScreenState();
}
class _CodeConfirmationScreenState extends State<CodeConfirmationScreen>
with TickerProviderStateMixin, SessionStaleRecovery {
final TextEditingController _codeController = TextEditingController();
final FocusNode _focusNode = FocusNode();
final SmsCodeListener _smsListener = SmsCodeListener();
int _timerSeconds = 30;
Timer? _timer;
Timer? _errorTimer;
String? _errorMessage;
late AnimationController _shakeController;
late Animation<double> _shakeAnimation;
bool _keyboardScheduled = false;
Animation<double>? _routeAnimation;
AnimationStatusListener? _routeAnimationListener;
late String _token;
bool _verifying = false;
bool _resending = false;
@override
String get connectionDroppedMessage =>
'Соединение прервалось, восстанавливаем…';
@override
void initState() {
super.initState();
_token = widget.token;
startSessionRecovery();
_startTimer();
_listenForSmsCode();
_shakeController = AnimationController(
vsync: this,
duration: const Duration(milliseconds: 500),
);
_shakeAnimation = TweenSequence<double>([
TweenSequenceItem(tween: Tween(begin: 0.0, end: -8.0), weight: 1),
TweenSequenceItem(tween: Tween(begin: -8.0, end: 8.0), weight: 2),
TweenSequenceItem(tween: Tween(begin: 8.0, end: -8.0), weight: 2),
TweenSequenceItem(tween: Tween(begin: -8.0, end: 8.0), weight: 2),
TweenSequenceItem(tween: Tween(begin: 8.0, end: -4.0), weight: 2),
TweenSequenceItem(tween: Tween(begin: -4.0, end: 0.0), weight: 1),
]).animate(CurvedAnimation(parent: _shakeController, curve: Curves.linear));
}
@override
void didChangeDependencies() {
super.didChangeDependencies();
_scheduleKeyboardOpen();
}
@override
void dispose() {
if (_routeAnimationListener != null) {
_routeAnimation?.removeStatusListener(_routeAnimationListener!);
}
_smsListener.dispose();
stopSessionRecovery();
_timer?.cancel();
_errorTimer?.cancel();
_shakeController.dispose();
_codeController.dispose();
_focusNode.dispose();
super.dispose();
}
@override
Future<void> recoverStaleSession() async {
if (recovering) return;
setState(() => recovering = true);
try {
if (api.state != SessionState.online) {
final back = await api.stateStream
.firstWhere((s) => s == SessionState.online)
.timeout(
const Duration(seconds: 12),
onTimeout: () => SessionState.disconnected,
);
if (back != SessionState.online) {
if (mounted) {
showCustomNotification(context, 'Нет соединения с сервером');
}
return;
}
}
if (!mounted) return;
setState(() {
sessionEpoch = api.sessionEpoch;
dropNotified = false;
});
showCustomNotification(context, 'Соединение восстановлено');
} catch (e) {
if (mounted) {
showCustomNotification(
context,
'Не удалось восстановить соединение: $e',
);
}
} finally {
if (mounted) setState(() => recovering = false);
}
}
void _scheduleKeyboardOpen() {
if (_keyboardScheduled) return;
_keyboardScheduled = true;
final animation = ModalRoute.of(context)?.animation;
if (animation == null || animation.status == AnimationStatus.completed) {
WidgetsBinding.instance.addPostFrameCallback((_) {
if (mounted) _openKeyboard();
});
return;
}
_routeAnimation = animation;
_routeAnimationListener = (status) {
if (status == AnimationStatus.completed) {
animation.removeStatusListener(_routeAnimationListener!);
_routeAnimationListener = null;
if (mounted) _openKeyboard();
}
};
animation.addStatusListener(_routeAnimationListener!);
}
void _openKeyboard() {
if (!_focusNode.hasFocus) {
_focusNode.requestFocus();
}
SystemChannels.textInput.invokeMethod<void>('TextInput.show');
}
void _startTimer() {
_timer?.cancel();
_timerSeconds = 30;
_timer = Timer.periodic(const Duration(seconds: 1), (timer) {
setState(() {
if (_timerSeconds > 0) {
_timerSeconds--;
} else {
_timer?.cancel();
}
});
});
}
Future<void> _listenForSmsCode() async {
await _smsListener.start((code) {
if (!mounted) return;
_applyAutoCode(code);
});
}
void _applyAutoCode(String code) {
if (_verifying || recovering || _resending) return;
if (_codeController.text == code) return;
_codeController.text = code;
_codeController.selection = TextSelection.collapsed(offset: code.length);
if (_errorMessage != null) _errorMessage = null;
setState(() {});
if (code.length == 6) _verifyCode();
}
void _showError(String message) {
_errorTimer?.cancel();
_shakeController.forward(from: 0);
setState(() => _errorMessage = message);
_errorTimer = Timer(const Duration(seconds: 3), () {
if (mounted) setState(() => _errorMessage = null);
});
}
Future<void> _resendCode() async {
if (_timerSeconds > 0 || _verifying || recovering || _resending) return;
if (sessionStale) {
await recoverStaleSession();
if (!mounted || sessionStale) return;
}
await _requestFreshCode();
}
Future<void> _requestFreshCode({bool startNew = false}) async {
if (_resending || recovering) return;
setState(() => _resending = true);
try {
final language = Localizations.localeOf(context).languageCode;
final fresh = startNew
? await accountModule.requestCode(widget.rawPhone, language: language)
: await accountModule.resendCode(widget.rawPhone, language: language);
if (!mounted) return;
_errorTimer?.cancel();
setState(() {
_token = fresh.token;
sessionEpoch = api.sessionEpoch;
dropNotified = false;
_codeController.clear();
_errorMessage = null;
});
_startTimer();
_listenForSmsCode();
} catch (e) {
if (!mounted) return;
if (isSessionStateError(e) || sessionStale) {
recoverStaleSession();
} else {
_showError(e.toString());
}
} finally {
if (mounted) setState(() => _resending = false);
}
}
Future<void> _verifyCode() async {
if (_codeController.text.length != 6 ||
recovering ||
_verifying ||
_resending) {
return;
}
if (sessionStale) {
recoverStaleSession();
return;
}
setState(() => _verifying = true);
var verified = false;
try {
final result = await accountModule.verifyCode(
_codeController.text,
_token,
);
verified = true;
if (!mounted) return;
if (result.requiresPassword) {
final trackId = result.challengeTrackId;
if (trackId == null) {
showCustomNotification(
context,
AppLocalizations.of(context)!.codeError2faMissing,
);
return;
}
Navigator.pushReplacement(
context,
MaterialPageRoute(
builder: (context) =>
Password2FAScreen(trackId: trackId, hint: result.challengeHint),
),
);
return;
}
if (result.isRegistration) {
Navigator.pushReplacement(
context,
MaterialPageRoute(
builder: (context) => RegistrationScreen(
phoneNumber: widget.phoneNumber,
registerToken: result.registerToken!,
presetAvatars: result.presetAvatars,
),
),
);
return;
}
final loginResult = await accountModule.login();
if (!mounted) return;
final avatar = await precacheLoginAvatar(
context,
loginResult.profile.baseUrl,
);
if (!mounted) return;
Navigator.pushAndRemoveUntil(
context,
PageRouteBuilder(
transitionDuration: const Duration(milliseconds: 240),
pageBuilder: (_, _, _) => LoginSuccessScreen(avatar: avatar),
transitionsBuilder: (_, animation, _, child) =>
FadeTransition(opacity: animation, child: child),
),
(route) => false,
);
} catch (e) {
if (!mounted) return;
if (!verified && isAuthSessionLostError(e)) {
if (sessionStale) await recoverStaleSession();
if (mounted && !sessionStale) await _requestFreshCode(startNew: true);
} else if (!verified && (isSessionStateError(e) || sessionStale)) {
await recoverStaleSession();
} else {
_showError(e.toString());
}
} finally {
if (mounted) setState(() => _verifying = false);
}
}
@override
Widget build(BuildContext context) {
final cs = Theme.of(context).colorScheme;
final l10n = AppLocalizations.of(context)!;
final hasError = _errorMessage != null;
return Scaffold(
backgroundColor: cs.surface,
appBar: AppBar(
backgroundColor: Colors.transparent,
elevation: 0,
leading: IconButton(
icon: Icon(Symbols.arrow_back, color: cs.onSurfaceVariant),
onPressed: () => Navigator.pop(context),
),
),
body: SafeArea(
child: Padding(
padding: const EdgeInsets.symmetric(horizontal: 20, vertical: 20),
child: Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: [
const SizedBox(height: 16),
Text(
widget.phoneNumber,
style: TextStyle(
color: cs.onSurface,
fontSize: 22,
fontWeight: FontWeight.w500,
),
),
const SizedBox(height: 12),
Text(
l10n.codeConfirmationSmsSent,
style: TextStyle(
color: cs.outline,
fontSize: 15,
fontWeight: FontWeight.w400,
height: 1.4,
),
),
const SizedBox(height: 12),
AnimatedBuilder(
animation: _shakeAnimation,
builder: (context, child) => Transform.translate(
offset: Offset(_shakeAnimation.value, 0),
child: child,
),
child: Stack(
children: [
Opacity(
opacity: 0,
child: SizedBox(
height: 0,
width: 0,
child: TextField(
controller: _codeController,
focusNode: _focusNode,
keyboardType: TextInputType.number,
autofillHints: const [AutofillHints.oneTimeCode],
inputFormatters: [
FilteringTextInputFormatter.digitsOnly,
LengthLimitingTextInputFormatter(6),
],
onChanged: (value) {
if (hasError) setState(() => _errorMessage = null);
setState(() {});
if (value.length == 6) _verifyCode();
},
),
),
),
GestureDetector(
onTap: _openKeyboard,
child: FittedBox(
child: Row(
children: List.generate(6, (index) {
final isFocused =
_codeController.text.length == index &&
_focusNode.hasFocus;
final hasValue =
_codeController.text.length > index;
final char = hasValue
? _codeController.text[index]
: '';
Color borderColor;
if (hasError && hasValue) {
borderColor = cs.error;
} else if (isFocused) {
borderColor = cs.primary;
} else if (hasValue) {
borderColor = cs.outlineVariant;
} else {
borderColor = Colors.transparent;
}
return AnimatedContainer(
duration: const Duration(milliseconds: 200),
width: 44,
height: 54,
margin: EdgeInsets.only(
right: index == 5 ? 0 : 10,
),
decoration: BoxDecoration(
color: hasError && hasValue
? cs.error.withValues(alpha: 0.1)
: cs.surfaceContainerHigh,
borderRadius: BorderRadius.circular(8),
border: Border.all(
color: borderColor,
width: 1.5,
),
),
alignment: Alignment.center,
child: AnimatedSwitcher(
duration: const Duration(milliseconds: 100),
transitionBuilder:
(
Widget child,
Animation<double> animation,
) {
return ScaleTransition(
scale: animation,
child: FadeTransition(
opacity: animation,
child: child,
),
);
},
child: Text(
char,
key: ValueKey<String>(
char +
index.toString() +
(hasError ? 'e' : ''),
),
style: TextStyle(
color: hasError && hasValue
? cs.error
: cs.onSurface,
fontSize: 20,
fontWeight: FontWeight.w600,
),
),
),
);
}),
),
),
),
],
),
),
const SizedBox(height: 16),
AnimatedSize(
duration: const Duration(milliseconds: 250),
curve: Curves.easeOutCubic,
alignment: Alignment.topLeft,
child: hasError
? Padding(
padding: const EdgeInsets.only(bottom: 8),
child: AnimatedOpacity(
opacity: hasError ? 1.0 : 0.0,
duration: const Duration(milliseconds: 200),
child: Text(
_errorMessage!,
style: TextStyle(
color: cs.error,
fontSize: 14,
fontWeight: FontWeight.w500,
height: 1.35,
),
),
),
)
: const SizedBox.shrink(),
),
GestureDetector(
onTap: _resendCode,
child: AnimatedDefaultTextStyle(
duration: const Duration(milliseconds: 200),
style: TextStyle(
color: _timerSeconds > 0 || _resending
? cs.outline
: cs.tertiary,
fontSize: 14,
fontWeight: FontWeight.w400,
),
child: Text(
_timerSeconds > 0
? l10n.codeResendInSeconds(_timerSeconds)
: l10n.codeResendSms,
),
),
),
const Spacer(),
Row(
crossAxisAlignment: CrossAxisAlignment.center,
children: [
Expanded(
child: Text(
l10n.codeConfirmation2faWarning,
style: TextStyle(
color: cs.error.withValues(alpha: 0.5),
fontSize: 13,
fontWeight: FontWeight.w400,
height: 1.35,
),
),
),
const SizedBox(width: 16),
FloatingActionButton(
onPressed: (recovering || _verifying || _resending)
? null
: () {
if (_codeController.text.length == 6) _verifyCode();
},
backgroundColor: _codeController.text.length == 6
? cs.primaryContainer
: cs.surfaceContainerHighest,
elevation: 0,
shape: RoundedRectangleBorder(
borderRadius: BorderRadius.circular(50),
),
child: recovering
? SmallSpinner(size: 24, color: cs.onPrimaryContainer)
: Icon(
Symbols.arrow_forward,
color: _codeController.text.length == 6
? cs.onPrimaryContainer
: cs.onSurfaceVariant,
),
),
],
),
const SizedBox(height: 24),
],
),
),
),
);
}
}