sevenhill/Qlyra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: лог экспорт

Browse Source
This commit is contained in:
Jganenokk
2026-06-29 20:26:52 +07:00
parent cd1ebaee24
commit a855b302ee
4 changed files with 490 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/backend/api.dart
+16
View File
@@ -15,6 +15,7 @@ import '../core/transport/receiver.dart';
import '../core/transport/sender.dart';
import '../core/transport/traffic_monitor.dart';
import '../core/transport/vpn_bypass.dart';
import '../core/utils/debug_session_log.dart';
import '../core/utils/logger.dart';
import 'package:device_info_plus/device_info_plus.dart';
@@ -291,12 +292,27 @@ class Api {
/// Отправляет запрос и ждёт ответ от сервера.
Future<Packet> sendRequest(int opcode, Map<dynamic, dynamic> payload) {
final seq = _sender.send(_connection, opcode, payload);
DebugSessionLog.instance.recordRequest(opcode, seq, payload);
return _dispatcher
.registerPending(seq)
.timeout(
ServerConfig.requestTimeout,
onTimeout: () =>
throw TimeoutException('${Opcode.name(opcode)} таймаут'),
)
.then(
(packet) {
DebugSessionLog.instance.recordResponse(
seq,
packet.cmd,
packet.payload,
);
return packet;
},
onError: (Object e, StackTrace st) {
DebugSessionLog.instance.recordError(seq, e);
Error.throwWithStackTrace(e, st);
},
);
}
lib/core/utils/debug_session_log.dart
+365
View File
@@ -0,0 +1,365 @@
import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'dart:typed_data';
import 'package:path_provider/path_provider.dart';
import '../protocol/opcode_map.dart';
class _LogEntry {
final int opcode;
final int seq;
final DateTime requestTime;
final dynamic request;
DateTime? responseTime;
int? cmd;
dynamic response;
String? error;
_LogEntry({
required this.opcode,
required this.seq,
required this.requestTime,
required this.request,
});
Map<String, dynamic> toJson() => {
'opcode': opcode,
'seq': seq,
'requestTime': requestTime.toIso8601String(),
'request': request,
if (responseTime != null) 'responseTime': responseTime!.toIso8601String(),
if (cmd != null) 'cmd': cmd,
if (response != null) 'response': response,
if (error != null) 'error': error,
};
static _LogEntry fromJson(Map data) {
final entry = _LogEntry(
opcode: (data['opcode'] as num?)?.toInt() ?? 0,
seq: (data['seq'] as num?)?.toInt() ?? 0,
requestTime:
DateTime.tryParse(data['requestTime']?.toString() ?? '') ??
DateTime.fromMillisecondsSinceEpoch(0),
request: data['request'],
);
final rt = data['responseTime']?.toString();
if (rt != null) entry.responseTime = DateTime.tryParse(rt);
entry.cmd = (data['cmd'] as num?)?.toInt();
entry.response = data['response'];
entry.error = data['error']?.toString();
return entry;
}
}
class _SessionData {
final DateTime startedAt;
final List<_LogEntry> entries;
final bool truncated;
_SessionData({
required this.startedAt,
required this.entries,
this.truncated = false,
});
static _SessionData fromJson(Map data) {
final list = data['entries'];
final entries = <_LogEntry>[];
if (list is List) {
for (final e in list) {
if (e is Map) entries.add(_LogEntry.fromJson(e));
}
}
return _SessionData(
startedAt:
DateTime.tryParse(data['startedAt']?.toString() ?? '') ??
DateTime.fromMillisecondsSinceEpoch(0),
entries: entries,
truncated: data['truncated'] == true,
);
}
}
/// Персистентный лог запросов для кнопки «Отладочный лог».
///
/// Хранит ВСЕ запросы (с payload) за последние [_maxSessions] заходов в
/// приложение: каждый запуск — отдельная сессия-файл, старые ротируются.
/// Пинги идут мимо [Api.sendRequest], поэтому в лог не попадают.
///
/// Payload сохраняется уже отредактированным — токен скрыт целиком, от номера
/// остаются первые 3 символа, остальное видно. Поэтому секреты не лежат на диске.
class DebugSessionLog {
DebugSessionLog._();
static final DebugSessionLog instance = DebugSessionLog._();
static const int _maxSessions = 3;
static const int _maxEntriesPerSession = 2000;
static const Duration _flushDebounce = Duration(seconds: 3);
Directory? _dir;
File? _currentFile;
DateTime? _currentStart;
final List<_LogEntry> _entries = [];
bool _truncated = false;
bool _initialized = false;
bool _dirty = false;
Timer? _flushTimer;
Future<void> init() async {
if (_initialized) return;
_initialized = true;
_currentStart = DateTime.now();
try {
final base = await getApplicationSupportDirectory();
final dir = Directory('${base.path}/debug_sessions');
if (!await dir.exists()) await dir.create(recursive: true);
_dir = dir;
await _rotate();
_currentFile = File(
'${dir.path}/session_${_currentStart!.millisecondsSinceEpoch}.json',
);
} catch (_) {
_dir = null;
_currentFile = null;
}
}
void recordRequest(int opcode, int seq, dynamic payload) {
_entries.add(
_LogEntry(
opcode: opcode,
seq: seq,
requestTime: DateTime.now(),
request: _redact(payload),
),
);
if (_entries.length > _maxEntriesPerSession) {
_entries.removeRange(0, _entries.length - _maxEntriesPerSession);
_truncated = true;
}
_scheduleFlush();
}
void recordResponse(int seq, int cmd, dynamic payload) {
final entry = _findPending(seq);
if (entry == null) return;
entry.responseTime = DateTime.now();
entry.cmd = cmd;
entry.response = _redact(payload);
_scheduleFlush();
}
void recordError(int seq, Object error) {
final entry = _findPending(seq);
if (entry == null) return;
entry.responseTime = DateTime.now();
entry.error = error.toString();
_scheduleFlush();
}
_LogEntry? _findPending(int seq) {
for (var i = _entries.length - 1; i >= 0; i--) {
final entry = _entries[i];
if (entry.seq == seq &&
entry.responseTime == null &&
entry.error == null) {
return entry;
}
}
return null;
}
void _scheduleFlush() {
_dirty = true;
if (_currentFile == null) return;
_flushTimer ??= Timer(_flushDebounce, () {
_flushTimer = null;
_flush();
});
}
Future<void> _flush() async {
final file = _currentFile;
if (file == null || !_dirty) return;
_dirty = false;
try {
final data = jsonEncode({
'startedAt': _currentStart?.toIso8601String(),
'truncated': _truncated,
'entries': _entries.map((e) => e.toJson()).toList(),
});
await file.writeAsString(data);
} catch (_) {}
}
Future<void> flushNow() async {
_flushTimer?.cancel();
_flushTimer = null;
await _flush();
}
Future<void> _rotate() async {
final files = await _sessionFiles();
const keep = _maxSessions - 1;
if (files.length <= keep) return;
for (final file in files.take(files.length - keep)) {
try {
await file.delete();
} catch (_) {}
}
}
Future<List<File>> _sessionFiles() async {
final dir = _dir;
if (dir == null) return [];
final entries = await dir.list().toList();
final files = entries.whereType<File>().where((f) {
final name = f.uri.pathSegments.last;
return name.startsWith('session_') && name.endsWith('.json');
}).toList();
files.sort((a, b) => _startMillis(a).compareTo(_startMillis(b)));
return files;
}
int _startMillis(File file) {
final name = file.uri.pathSegments.last;
final digits = name.substring(
'session_'.length,
name.length - '.json'.length,
);
return int.tryParse(digits) ?? 0;
}
Future<String?> buildExport({String? endpoint}) async {
final sessions = <_SessionData>[];
final dir = _dir;
if (dir != null) {
for (final file in await _sessionFiles()) {
if (_currentFile != null && file.path == _currentFile!.path) continue;
try {
final decoded = jsonDecode(await file.readAsString());
if (decoded is Map) sessions.add(_SessionData.fromJson(decoded));
} catch (_) {}
}
}
sessions.add(
_SessionData(
startedAt: _currentStart ?? DateTime.now(),
entries: List.of(_entries),
truncated: _truncated,
),
);
sessions.sort((a, b) => a.startedAt.compareTo(b.startedAt));
final lastN = sessions.length > _maxSessions
? sessions.sublist(sessions.length - _maxSessions)
: sessions;
final totalEntries = lastN.fold<int>(0, (sum, s) => sum + s.entries.length);
if (totalEntries == 0) return null;
final buffer = StringBuffer();
buffer.writeln('Komet — отладочный лог');
if (endpoint != null) buffer.writeln('Сервер: $endpoint');
buffer.writeln('Экспортирован: ${DateTime.now().toIso8601String()}');
buffer.writeln('Заходов в приложение: ${lastN.length}');
buffer.writeln('Всего запросов: $totalEntries');
buffer.writeln('Скрыто: токен полностью, номер кроме первых 3 символов');
buffer.writeln();
for (var s = 0; s < lastN.length; s++) {
final session = lastN[s];
buffer.writeln('==================================================');
buffer.writeln('ЗАХОД #${s + 1} — ${session.startedAt.toIso8601String()}');
buffer.writeln(
'запросов: ${session.entries.length}'
'${session.truncated ? ' (обрезано до $_maxEntriesPerSession)' : ''}',
);
buffer.writeln('==================================================');
buffer.writeln();
for (var i = 0; i < session.entries.length; i++) {
_writeEntry(buffer, i + 1, session.entries[i]);
}
}
return buffer.toString();
}
void _writeEntry(StringBuffer buffer, int index, _LogEntry e) {
buffer.writeln('----- запрос #$index -----');
buffer.writeln('время: ${e.requestTime.toIso8601String()}');
buffer.writeln('opcode: ${e.opcode} (${Opcode.name(e.opcode)})');
buffer.writeln('seq: ${e.seq}');
buffer.writeln('=> payload:');
buffer.writeln(_pretty(e.request));
if (e.error != null) {
buffer.writeln('<= ошибка: ${e.error}');
} else if (e.responseTime != null) {
buffer.writeln(
'<= ответ: ${e.responseTime!.toIso8601String()} '
'cmd ${e.cmd} (${_cmdName(e.cmd)})',
);
buffer.writeln('payload:');
buffer.writeln(_pretty(e.response));
} else {
buffer.writeln('<= (ответ не получен)');
}
buffer.writeln();
}
String _pretty(dynamic value) {
try {
return const JsonEncoder.withIndent(' ').convert(value);
} catch (_) {
return value.toString();
}
}
}
String _cmdName(int? cmd) {
switch (cmd) {
case 0:
return 'request';
case 1:
return 'ok';
case 2:
return 'notFound';
case 3:
return 'error';
default:
return 'cmd$cmd';
}
}
bool _isTokenKey(String key) => key.toLowerCase().contains('token');
bool _isPhoneKey(String key) {
final k = key.toLowerCase();
return k.contains('phone') || k == 'msisdn';
}
String _maskPhone(dynamic value) {
final text = value?.toString() ?? '';
if (text.length <= 3) return text;
return '${text.substring(0, 3)}***';
}
dynamic _redact(dynamic value) {
if (value is Map) {
final out = <String, dynamic>{};
value.forEach((k, v) {
final key = k.toString();
if (_isTokenKey(key)) {
out[key] = '***';
} else if (_isPhoneKey(key)) {
out[key] = _maskPhone(v);
} else {
out[key] = _redact(v);
}
});
return out;
}
if (value is List) return value.map(_redact).toList();
if (value is Uint8List) return '<bytes: ${value.length}>';
if (value is num || value is bool || value is String) return value;
return value?.toString();
}
lib/frontend/screens/profile/debug_menu_screen.dart
+101
View File
@@ -1,6 +1,8 @@
import 'dart:convert';
import 'dart:io';
import 'package:cached_network_image/cached_network_image.dart';
import 'package:file_picker/file_picker.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:material_symbols_icons/symbols.dart';
@@ -16,6 +18,8 @@ import '../../../core/config/app_media_cache.dart';
import '../../../core/protocol/opcode_map.dart';
import '../../../core/storage/app_database.dart';
import '../../../core/protocol/packet.dart';
import '../../../core/transport/traffic_monitor.dart';
import '../../../core/utils/debug_session_log.dart';
import '../../../core/utils/format.dart';
import '../../../core/utils/logger.dart';
import '../../../core/utils/media_cache.dart';
@@ -70,6 +74,44 @@ class _DebugMenuScreenState extends State<DebugMenuScreen> {
if (mounted) setState(() => _cacheSize = size);
}
Future<void> _exportDebugLog() async {
final content = await DebugSessionLog.instance.buildExport(
endpoint: TrafficMonitor.instance.activeEndpoint,
);
if (content == null) {
if (mounted) showCustomNotification(context, 'Нет запросов для лога');
return;
}
final bytes = Uint8List.fromList(utf8.encode(content));
final fileName = 'komet_debug_${_fileStamp(DateTime.now())}.txt';
final isMobile = Platform.isAndroid || Platform.isIOS;
try {
final path = await FilePicker.platform.saveFile(
dialogTitle: 'Сохранить отладочный лог',
fileName: fileName,
type: FileType.any,
bytes: isMobile ? bytes : null,
);
if (path == null) return;
if (!isMobile) {
await File(path).writeAsBytes(bytes);
}
if (mounted) {
showCustomNotification(context, 'Лог сохранён: $path');
}
} catch (e) {
if (mounted) {
showCustomNotification(context, 'Не удалось сохранить лог: $e');
}
}
}
String _fileStamp(DateTime t) {
String two(int n) => n.toString().padLeft(2, '0');
return '${t.year}${two(t.month)}${two(t.day)}_'
'${two(t.hour)}${two(t.minute)}${two(t.second)}';
}
Future<void> _clearCache() async {
if (_clearingCache) return;
setState(() => _clearingCache = true);
@@ -253,6 +295,65 @@ class _DebugMenuScreenState extends State<DebugMenuScreen> {
SliverToBoxAdapter(
child: Padding(
padding: const EdgeInsets.fromLTRB(16, 8, 16, 0),
child: Material(
color: cs.surfaceContainerHigh,
borderRadius: BorderRadius.circular(20),
child: InkWell(
borderRadius: BorderRadius.circular(20),
onTap: _exportDebugLog,
child: Padding(
padding: const EdgeInsets.symmetric(
horizontal: 20,
vertical: 17,
),
child: Row(
children: [
Icon(
Symbols.bug_report,
color: cs.onSurfaceVariant,
size: 22,
weight: 400,
),
const SizedBox(width: 16),
Expanded(
child: Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text(
'Отладочный лог',
style: TextStyle(
color: cs.onSurface,
fontSize: 16,
fontWeight: FontWeight.w500,
),
),
const SizedBox(height: 2),
Text(
'Все запросы за последние 3 захода в приложение',
style: TextStyle(
color: cs.onSurfaceVariant,
fontSize: 13,
),
),
],
),
),
Icon(
Symbols.save_alt,
color: cs.onSurfaceVariant,
size: 22,
weight: 400,
),
],
),
),
),
),
),
),
SliverToBoxAdapter(
child: Padding(
padding: const EdgeInsets.fromLTRB(16, 12, 16, 0),
child: appState == null
? const SizedBox.shrink()
: ValueListenableBuilder<bool>(
lib/main.dart
+8
View File
@@ -56,6 +56,7 @@ import 'core/transport/traffic_monitor.dart';
import 'core/transport/vpn_bypass.dart';
import 'core/storage/token_storage.dart';
import 'core/utils/haptics.dart';
import 'core/utils/debug_session_log.dart';
import 'core/protocol/packet.dart';
import 'frontend/debug/fps_overlay_layer.dart';
import 'frontend/screens/auth/login_screen.dart';
@@ -130,6 +131,7 @@ void main() async {
final digitalIdNativeFuture = AppDigitalIdNative.load();
final showExtraInfoFuture = AppShowExtraInfo.load();
final trafficCaptureFuture = TrafficMonitor.instance.load();
final debugLogFuture = DebugSessionLog.instance.init();
final packageInfo = await packageInfoFuture;
isOnemeFlavor = packageInfo.packageName == 'ru.oneme.app';
@@ -176,6 +178,7 @@ void main() async {
AppDigitalIdNative.current.value = await digitalIdNativeFuture;
AppShowExtraInfo.current.value = await showExtraInfoFuture;
await trafficCaptureFuture;
await debugLogFuture;
runApp(
KometApp(
initialLocale: initialLocale,
@@ -404,6 +407,11 @@ class KometAppState extends State<KometApp>
@override
void didChangeAppLifecycleState(AppLifecycleState state) {
if (state == AppLifecycleState.paused ||
state == AppLifecycleState.hidden ||
state == AppLifecycleState.detached) {
DebugSessionLog.instance.flushNow();
}
if (state != AppLifecycleState.resumed) return;
if (AppThemeModeConfig.current.value != AppThemeMode.schedule) return;
_rescheduleSwitch();