D6/geo
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: Version 3.3.4 - Nouvelle architecture pages, optimisations widgets Flutter et API

Browse Source 
- Mise à jour VERSION vers 3.3.4
- Optimisations et révisions architecture API (deploy-api.sh, scripts de migration)
- Ajout documentation Stripe Tap to Pay complète
- Migration vers polices Inter Variable pour Flutter
- Optimisations build Android et nettoyage fichiers temporaires
- Amélioration système de déploiement avec gestion backups
- Ajout scripts CRON et migrations base de données

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
pierre
2025-10-05 20:11:15 +02:00
parent 242a90720e
commit b6584c83fa
1625 changed files with 145669 additions and 51249 deletions
Download Patch File Download Diff File Expand all files Collapse all files

105
app/lib/chat/services/chat_service.dart
View File

@@ -1,4 +1,5 @@
import 'dart:async';
import 'package:flutter/foundation.dart';
import 'package:dio/dio.dart';
import 'package:hive_flutter/hive_flutter.dart';
import 'package:uuid/uuid.dart';
@@ -77,7 +78,7 @@ class ChatService {
// Faire la sync initiale complète au login
await _instance!.getRooms(forceFullSync: true);
print('✅ Sync initiale complète effectuée au login');
debugPrint('✅ Sync initiale complète effectuée au login');
// Démarrer la synchronisation incrémentale périodique
_instance!._startSync();
@@ -106,11 +107,11 @@ class ChatService {
} else if (response.data is Map && response.data['data'] != null) {
return List<Map<String, dynamic>>.from(response.data['data']);
} else {
print('⚠️ Format inattendu pour /chat/recipients: ${response.data.runtimeType}');
debugPrint('⚠️ Format inattendu pour /chat/recipients: ${response.data.runtimeType}');
return [];
}
} catch (e) {
print('⚠️ Erreur getPossibleRecipients: $e');
debugPrint('⚠️ Erreur getPossibleRecipients: $e');
// Fallback sur logique locale selon le rôle
return _getLocalRecipients();
}
@@ -137,7 +138,7 @@ class ChatService {
Future<List<Room>> getRooms({bool forceFullSync = false}) async {
// Vérifier la connectivité
if (!connectivityService.isConnected) {
print('📵 Pas de connexion réseau - utilisation du cache');
debugPrint('📵 Pas de connexion réseau - utilisation du cache');
return _roomsBox.values.toList()
..sort((a, b) => (b.lastMessageAt ?? b.createdAt)
.compareTo(a.lastMessageAt ?? a.createdAt));
@@ -154,13 +155,13 @@ class ChatService {
if (needsFullSync || _lastSyncTimestamp == null) {
// Synchronisation complète
print('🔄 Synchronisation complète des rooms...');
debugPrint('🔄 Synchronisation complète des rooms...');
response = await _dio.get('/chat/rooms');
_lastFullSync = now;
} else {
// Synchronisation incrémentale
final isoTimestamp = _lastSyncTimestamp!.toUtc().toIso8601String();
print('🔄 Synchronisation incrémentale depuis $isoTimestamp');
// debugPrint('🔄 Synchronisation incrémentale depuis $isoTimestamp');
response = await _dio.get('/chat/rooms', queryParameters: {
'updated_after': isoTimestamp,
});
@@ -169,20 +170,20 @@ class ChatService {
// Extraire le timestamp de synchronisation fourni par l'API
if (response.data is Map && response.data['sync_timestamp'] != null) {
_lastSyncTimestamp = DateTime.parse(response.data['sync_timestamp']);
print('⏰ Timestamp de sync reçu de l\'API: $_lastSyncTimestamp');
// debugPrint('⏰ Timestamp de sync reçu de l\'API: $_lastSyncTimestamp');
// Sauvegarder le timestamp pour la prochaine session
await _saveSyncTimestamp();
} else {
// L'API doit toujours retourner un sync_timestamp
print('⚠️ Attention: L\'API n\'a pas retourné de sync_timestamp');
debugPrint('⚠️ Attention: L\'API n\'a pas retourné de sync_timestamp');
// On utilise le timestamp actuel comme fallback mais ce n'est pas idéal
_lastSyncTimestamp = now;
}
// Vérifier s'il y a des changements (pour sync incrémentale)
if (!needsFullSync && response.data is Map && response.data['has_changes'] == false) {
print('✅ Aucun changement depuis la dernière sync');
// debugPrint('✅ Aucun changement depuis la dernière sync');
return _roomsBox.values.toList()
..sort((a, b) => (b.lastMessageAt ?? b.createdAt)
.compareTo(a.lastMessageAt ?? a.createdAt));
@@ -194,7 +195,7 @@ class ChatService {
if (response.data['rooms'] != null) {
roomsData = response.data['rooms'] as List;
final hasChanges = response.data['has_changes'] ?? true;
print('✅ Réponse API: ${roomsData.length} rooms, has_changes: $hasChanges');
debugPrint('✅ Réponse API: ${roomsData.length} rooms, has_changes: $hasChanges');
} else if (response.data['data'] != null) {
roomsData = response.data['data'] as List;
} else {
@@ -221,7 +222,7 @@ class ChatService {
final room = Room.fromJson(json);
rooms.add(room);
} catch (e) {
print('❌ Erreur parsing room: $e');
debugPrint('❌ Erreur parsing room: $e');
}
}
@@ -258,17 +259,17 @@ class ChatService {
// Sauvegarder uniquement si le message n'existe pas déjà
if (!_messagesBox.containsKey(message.id) && message.id.isNotEmpty) {
await _messagesBox.put(message.id, message);
print('📩 Nouveau message ajouté depuis sync: ${message.id} dans room ${room.id}');
debugPrint('📩 Nouveau message ajouté depuis sync: ${message.id} dans room ${room.id}');
} else if (message.id.isEmpty) {
print('⚠️ Message avec ID vide ignoré');
debugPrint('⚠️ Message avec ID vide ignoré');
}
} catch (e) {
print('⚠️ Erreur lors du traitement d\'un message récent: $e');
debugPrint('⚠️ Erreur lors du traitement d\'un message récent: $e');
}
}
}
}
print('💾 Sync complète: ${rooms.length} rooms sauvegardées');
debugPrint('💾 Sync complète: ${rooms.length} rooms sauvegardées');
} else {
// Sync incrémentale : mettre à jour uniquement les changements
for (final room in rooms) {
@@ -288,7 +289,7 @@ class ChatService {
createdBy: room.createdBy ?? existingRoom?.createdBy,
);
print('💾 Sauvegarde room ${roomToSave.title} (${roomToSave.id}): createdBy=${roomToSave.createdBy}');
debugPrint('💾 Sauvegarde room ${roomToSave.title} (${roomToSave.id}): createdBy=${roomToSave.createdBy}');
await _roomsBox.put(roomToSave.id, roomToSave);
// Traiter les messages récents de la room
@@ -299,12 +300,12 @@ class ChatService {
// Sauvegarder uniquement si le message n'existe pas déjà
if (!_messagesBox.containsKey(message.id) && message.id.isNotEmpty) {
await _messagesBox.put(message.id, message);
print('📩 Nouveau message ajouté depuis sync: ${message.id} dans room ${room.id}');
debugPrint('📩 Nouveau message ajouté depuis sync: ${message.id} dans room ${room.id}');
} else if (message.id.isEmpty) {
print('⚠️ Message avec ID vide ignoré');
debugPrint('⚠️ Message avec ID vide ignoré');
}
} catch (e) {
print('⚠️ Erreur lors du traitement d\'un message récent: $e');
debugPrint('⚠️ Erreur lors du traitement d\'un message récent: $e');
}
}
}
@@ -324,9 +325,9 @@ class ChatService {
await _messagesBox.delete(msgId);
}
print('🗑️ Room $roomId supprimée avec ${messagesToDelete.length} messages');
debugPrint('🗑️ Room $roomId supprimée avec ${messagesToDelete.length} messages');
}
print('💾 Sync incrémentale: ${rooms.length} rooms mises à jour, ${deletedRoomIds.length} supprimées');
debugPrint('💾 Sync incrémentale: ${rooms.length} rooms mises à jour, ${deletedRoomIds.length} supprimées');
}
// Mettre à jour les stats globales
@@ -341,7 +342,7 @@ class ChatService {
..sort((a, b) => (b.lastMessageAt ?? b.createdAt)
.compareTo(a.lastMessageAt ?? a.createdAt));
} catch (e) {
print('❌ Erreur sync rooms: $e');
debugPrint('❌ Erreur sync rooms: $e');
// Fallback sur le cache local
return _roomsBox.values.toList()
..sort((a, b) => (b.lastMessageAt ?? b.createdAt)
@@ -375,7 +376,7 @@ class ChatService {
// Sauvegarder immédiatement dans Hive
await _roomsBox.put(tempId, tempRoom);
print('💾 Room temporaire sauvée: $tempId');
debugPrint('💾 Room temporaire sauvée: $tempId');
try {
// Vérifier les permissions localement d'abord
@@ -402,7 +403,7 @@ class ChatService {
// Vérifier si la room a été mise en queue (offline)
if (response.data != null && response.data['queued'] == true) {
print('📵 Room mise en file d\'attente pour synchronisation: $tempId');
debugPrint('📵 Room mise en file d\'attente pour synchronisation: $tempId');
return tempRoom; // Retourner la room temporaire
}
@@ -413,7 +414,7 @@ class ChatService {
// Remplacer la room temporaire par la room réelle
await _roomsBox.delete(tempId);
await _roomsBox.put(realRoom.id, realRoom);
print('✅ Room temporaire $tempId remplacée par ${realRoom.id}');
debugPrint('✅ Room temporaire $tempId remplacée par ${realRoom.id}');
return realRoom;
}
@@ -421,7 +422,7 @@ class ChatService {
return tempRoom;
} catch (e) {
print('⚠️ Erreur création room: $e - La room sera synchronisée plus tard');
debugPrint('⚠️ Erreur création room: $e - La room sera synchronisée plus tard');
// La room reste en local avec isSynced = false
return tempRoom;
}
@@ -497,10 +498,10 @@ class ChatService {
unreadRemaining = response.data['unread_count'] ?? 0;
if (markedAsRead > 0) {
print('✅ $markedAsRead messages marqués comme lus automatiquement');
debugPrint('✅ $markedAsRead messages marqués comme lus automatiquement');
}
} else {
print('⚠️ Format inattendu pour les messages: ${response.data.runtimeType}');
debugPrint('⚠️ Format inattendu pour les messages: ${response.data.runtimeType}');
messagesData = [];
}
@@ -508,9 +509,9 @@ class ChatService {
.map((json) => Message.fromJson(json, _currentUserId, roomId: roomId))
.toList();
print('📨 Messages reçus pour room $roomId: ${messages.length}');
debugPrint('📨 Messages reçus pour room $roomId: ${messages.length}');
for (final msg in messages) {
print(' - ${msg.id}: "${msg.content}" de ${msg.senderName} (${msg.senderId}) isMe: ${msg.isMe}');
debugPrint(' - ${msg.id}: "${msg.content}" de ${msg.senderName} (${msg.senderId}) isMe: ${msg.isMe}');
}
// Sauvegarder dans Hive (en limitant à 100 messages par room)
@@ -543,7 +544,7 @@ class ChatService {
'marked_as_read': markedAsRead,
};
} catch (e) {
print('Erreur getMessages: $e');
debugPrint('Erreur getMessages: $e');
// Fallback sur le cache local
final cachedMessages = _messagesBox.values
.where((m) => m.roomId == roomId)
@@ -566,14 +567,14 @@ class ChatService {
// Vérifier si le message n'existe pas déjà
if (!_messagesBox.containsKey(message.id) && message.id.isNotEmpty) {
await _messagesBox.put(message.id, message);
print('💾 Message sauvé: ${message.id} dans room ${message.roomId}');
debugPrint('💾 Message sauvé: ${message.id} dans room ${message.roomId}');
addedCount++;
} else if (_messagesBox.containsKey(message.id)) {
print('⚠️ Message ${message.id} existe déjà, ignoré pour éviter duplication');
debugPrint('⚠️ Message ${message.id} existe déjà, ignoré pour éviter duplication');
}
}
print('📊 Résumé: ${addedCount} nouveaux messages ajoutés sur ${newMessages.length} reçus');
debugPrint('📊 Résumé: ${addedCount} nouveaux messages ajoutés sur ${newMessages.length} reçus');
// Après l'ajout, récupérer TOUS les messages de la room pour le nettoyage
final allRoomMessages = _messagesBox.values
@@ -584,7 +585,7 @@ class ChatService {
// Si on dépasse 100 messages, supprimer les plus anciens
if (allRoomMessages.length > 100) {
final messagesToDelete = allRoomMessages.skip(100).toList();
print('🗑️ Suppression de ${messagesToDelete.length} anciens messages');
debugPrint('🗑️ Suppression de ${messagesToDelete.length} anciens messages');
for (final message in messagesToDelete) {
await _messagesBox.delete(message.id);
}
@@ -610,10 +611,10 @@ class ChatService {
await _messagesBox.delete(msgId);
}
print('✅ Room $roomId supprimée avec succès');
debugPrint('✅ Room $roomId supprimée avec succès');
return true;
} catch (e) {
print('❌ Erreur suppression room: $e');
debugPrint('❌ Erreur suppression room: $e');
throw Exception('Impossible de supprimer la conversation');
}
}
@@ -639,7 +640,7 @@ class ChatService {
// Sauvegarder immédiatement dans Hive pour affichage instantané
await _messagesBox.put(tempId, tempMessage);
print('💾 Message temporaire sauvé: $tempId');
debugPrint('💾 Message temporaire sauvé: $tempId');
// Mettre à jour la room localement pour affichage immédiat
final room = _roomsBox.get(roomId);
@@ -666,7 +667,7 @@ class ChatService {
// Vérifier si le message a été mis en queue (offline)
if (response.data != null && response.data['queued'] == true) {
print('📵 Message mis en file d\'attente pour synchronisation: $tempId');
debugPrint('📵 Message mis en file d\'attente pour synchronisation: $tempId');
return tempMessage; // Retourner le message temporaire
}
@@ -679,12 +680,12 @@ class ChatService {
roomId: roomId
);
print('📨 Message envoyé avec ID réel: ${realMessage.id}');
debugPrint('📨 Message envoyé avec ID réel: ${realMessage.id}');
// Remplacer le message temporaire par le message réel
await _messagesBox.delete(tempId);
await _messagesBox.put(realMessage.id, realMessage);
print('✅ Message temporaire $tempId remplacé par ${realMessage.id}');
debugPrint('✅ Message temporaire $tempId remplacé par ${realMessage.id}');
return realMessage;
}
@@ -693,7 +694,7 @@ class ChatService {
return tempMessage;
} catch (e) {
print('⚠️ Erreur envoi message: $e - Le message sera synchronisé plus tard');
debugPrint('⚠️ Erreur envoi message: $e - Le message sera synchronisé plus tard');
// Le message reste en local avec isSynced = false
return tempMessage;
}
@@ -711,11 +712,11 @@ class ChatService {
final timestamp = metaBox.get('last_sync_timestamp');
if (timestamp != null) {
_lastSyncTimestamp = DateTime.parse(timestamp);
print('📅 Dernier timestamp de sync restauré: $_lastSyncTimestamp');
debugPrint('📅 Dernier timestamp de sync restauré: $_lastSyncTimestamp');
}
}
} catch (e) {
print('⚠️ Impossible de charger le timestamp de sync: $e');
debugPrint('⚠️ Impossible de charger le timestamp de sync: $e');
}
}
@@ -734,7 +735,7 @@ class ChatService {
await metaBox.put('last_sync_timestamp', _lastSyncTimestamp!.toIso8601String());
} catch (e) {
print('⚠️ Impossible de sauvegarder le timestamp de sync: $e');
debugPrint('⚠️ Impossible de sauvegarder le timestamp de sync: $e');
}
}
@@ -744,7 +745,7 @@ class ChatService {
_syncTimer = Timer.periodic(_syncInterval, (_) async {
// Vérifier la connectivité avant de synchroniser
if (!connectivityService.isConnected) {
print('📵 Pas de connexion - sync ignorée');
debugPrint('📵 Pas de connexion - sync ignorée');
return;
}
@@ -753,28 +754,28 @@ class ChatService {
});
// Pas de sync immédiate ici car déjà faite dans init()
print('⏰ Timer de sync incrémentale démarré (toutes les 15 secondes)');
debugPrint('⏰ Timer de sync incrémentale démarré (toutes les 15 secondes)');
}
/// Mettre en pause les synchronisations (app en arrière-plan)
void pauseSyncs() {
_syncTimer?.cancel();
print('⏸️ Timer de sync arrêté (app en arrière-plan)');
debugPrint('⏸️ Timer de sync arrêté (app en arrière-plan)');
}
/// Reprendre les synchronisations (app au premier plan)
void resumeSyncs() {
if (_syncTimer == null || !_syncTimer!.isActive) {
_startSync();
print('▶️ Timer de sync redémarré (app au premier plan)');
debugPrint('▶️ Timer de sync redémarré (app au premier plan)');
// Faire une sync immédiate au retour au premier plan
// pour rattraper les messages manqués
if (connectivityService.isConnected) {
getRooms().then((_) {
print('✅ Sync de rattrapage effectuée');
debugPrint('✅ Sync de rattrapage effectuée');
}).catchError((e) {
print('⚠️ Erreur sync de rattrapage: $e');
debugPrint('⚠️ Erreur sync de rattrapage: $e');
});
}
}