Qlyra/lib/core/utils/debug_session_log.dart

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();
}