Revert "ойойойой дипсик ты что делоеш"

This reverts commit f78ca4e127.
This commit is contained in:
ivan2282
2025-11-16 20:06:01 +03:00
parent f78ca4e127
commit d479b77ad9

View File

@@ -39,7 +39,7 @@ class ApiServiceV2 {
final StreamController<Contact> _contactUpdatesController = final StreamController<Contact> _contactUpdatesController =
StreamController<Contact>.broadcast(); StreamController<Contact>.broadcast();
final StreamController<Map<String, dynamic>> _messageController = final StreamController<Map<String, dynamic>> _messageController =
StreamController<Map<String, dynamic>>.broadcast(); StreamController<Map<String, dynamic>>.broadcast();
Stream<Map<String, dynamic>> get messages => _messageController.stream; Stream<Map<String, dynamic>> get messages => _messageController.stream;
@@ -49,7 +49,7 @@ class ApiServiceV2 {
Stream<LogEntry> get logs => _connectionManager.logStream; Stream<LogEntry> get logs => _connectionManager.logStream;
Stream<HealthMetrics> get healthMetrics => Stream<HealthMetrics> get healthMetrics =>
_connectionManager.healthMetricsStream; _connectionManager.healthMetricsStream;
ConnectionInfo get currentConnectionState => _connectionManager.currentState; ConnectionInfo get currentConnectionState => _connectionManager.currentState;
@@ -66,7 +66,7 @@ class ApiServiceV2 {
_logger.logConnection('Инициализация ApiServiceV2'); _logger.logConnection('Инициализация ApiServiceV2');
try { try {
await _connectionManager.initialize(); await _connectionManager.initialize();
_setupMessageHandlers(); _setupMessageHandlers();
@@ -166,7 +166,7 @@ class ApiServiceV2 {
try { try {
await _connectionManager.connect(authToken: _authToken); await _connectionManager.connect(authToken: _authToken);
_logger.logConnection('Переподключение успешно'); _logger.logConnection('Переподключение успешно');
} catch (e) { } catch (e) {
_logger.logError('Ошибка переподключения', error: e); _logger.logError('Ошибка переподключения', error: e);
rethrow; rethrow;
} }
@@ -663,7 +663,7 @@ class ApiServiceV2 {
'reply_to': replyToMessageId, 'reply_to': replyToMessageId,
}, },
); );
final int clientMessageId = DateTime.now().millisecondsSinceEpoch; final int clientMessageId = DateTime.now().millisecondsSinceEpoch;
final payload = { final payload = {
"chatId": chatId, "chatId": chatId,
@@ -996,7 +996,7 @@ class ApiServiceV2 {
for (final message in messages) { for (final message in messages) {
for (final attach in message.attaches) { for (final attach in message.attaches) {
if (attach['_type'] == 'PHOTO' || attach['_type'] == 'SHARE') { if (attach['_type'] == 'PHOTO' || attach['_type'] == 'SHARE') {
final url = attach['url'] ?? attach['baseUrl']; final url = attach['url'] ?? attach['baseUrl'];
if (url is String && url.isNotEmpty) { if (url is String && url.isNotEmpty) {
imageUrls.add(url); imageUrls.add(url);
} }
@@ -1005,46 +1005,53 @@ class ApiServiceV2 {
} }
if (imageUrls.isNotEmpty) { if (imageUrls.isNotEmpty) {
_logger.logConnection( _logger.logConnection(
'Предзагрузка изображений из сообщений', 'Предзагрузка изображений из сообщений',
data: {'count': imageUrls.length}, data: {'count': imageUrls.length},
); );
await ImageCacheService.instance.preloadContactAvatars(imageUrls); await ImageCacheService.instance.preloadContactAvatars(imageUrls);
} }
} catch (e) { } catch (e) {
_logger.logError( _logger.logError(
'Ошибка предзагрузки изображений из сообщений', 'Ошибка предзагрузки изображений из сообщений',
error: e, error: e,
); );
} }
} }
String _gener卐卐ateDeviceId() { String _generateDeviceId() {
final timestamp = DateTime.now().millisecondsSinceEpoch; final timestamp = DateTime.now().millisecondsSinceEpoch;
final random = (timeamp % 1000000).toString().padLeft(6, '0'); final random = (timestamp % 1000000).toString().padLeft(6, '0');
return "$timestamp$random"; return "$timestamp$random";
} }
Future<Map<String, dynamic>> getStatistics() asyc {s(); Future<Map<String, dynamic>> getStatistics() async {
final cache卐viceStats = await CacheService().getCacheStats(); final imageCacheStats = await ImageCacheService.instance.getCacheStats();
final cacheServiceStats = await CacheService().getCacheStats();
final avatarCacheStats = await AvatarCacheService().getAvatarCacheStats(); final avatarCacheStats = await AvatarCacheService().getAvatarCacheStats();
final chatCacheStats = await ChatCacheService().getChatCacheStats(); final chatCacheStats = await ChatCacheService().getChatCacheStats();
return { return {
'api_service': {
'is_initialized': _isInitialized,
'has_auth_token': _authToken != null, 'has_auth_token': _authToken != null,
'mess 'message_cache_size': _messageCache.length,
'contact_cache_size': _contactCache.length,
'chats_fetched_in_session': _chatsFetchedInThisSession,
},
'connection': _connectionManager.getStatistics(), 'connection': _connectionManager.getStatistics(),
'cache_service': cacheServiceStats, 'cache_service': cacheServiceStats,
'avatar_cache': avatarCacheStats, 'avatar_cache': avatarCacheStats,
'chat_cache': chatCacheStats, 'chat_cache': chatCacheStats,
'image_cache': imageCacheStats, 'image_cache': imageCacheStats,
}; };
} }
void dispose() { void dispose() {
_messag卐eController.close(); _logger.logConnection('Освобождение ресурсов ApiServiceV2');
_connectionManager.dispose();
_messageController.close();
_contactUpdatesController.close(); _contactUpdatesController.close();
} }
} }
м