feat(ai-training): ajout validation OpenCV, gestion des logs et modération des contributions
- Backend IA : - Intégration d'OpenCV (WebAssembly) pour la détection et certification des cibles (anneaux concentriques, confiance). - Ajout du système de journalisation complet des uploads (SQLite, IP, appareil, statut, métadonnées). - Implémentation du système de modération (bannissement/débannissement de wallets, rejet 403 avec motifs). - Harmonisation des codes d'erreur et messages JSON (UPLOAD_SUCCESS, WALLET_BANNED, etc.). - Dashboard Next.js : page dédiée aux logs avec filtres, export CSV et actions de modération en un clic. - Application Mobile (Flutter) : - Encapsulation des réponses d'export dans AiExportResult avec gestion fine des erreurs et statuts. - Mise à jour du disclaimer de participation à l'entraînement IA avec avertissements stricts de bannissement. - Révocation de l'envoi de photos et affichage d'un bandeau explicatif en cas de suspension. - Ajout d'un bouton manuel « Actualiser mon statut » dans les paramètres pour synchroniser l'état du compte. - Possibilité de configurer l'URL/IP du serveur IA directement depuis les paramètres.
This commit is contained in:
streaper2
@@ -8,16 +8,62 @@ import '../data/models/shot.dart';
|
||||
import '../data/models/target_type.dart';
|
||||
import 'wallet_identity_service.dart';
|
||||
|
||||
class AiExportService {
|
||||
// Utilise 10.0.2.2 pour l'émulateur Android, sinon localhost.
|
||||
// Pour un appareil physique, il faudra utiliser l'IP locale du PC (ex: 192.168.1.X).
|
||||
static String get _defaultApiUrl {
|
||||
if (Platform.isAndroid) {
|
||||
return 'http://10.0.2.2:3000/api/upload';
|
||||
}
|
||||
return 'http://localhost:3000/api/upload';
|
||||
/// Résultat détaillé de l'exportation vers le serveur IA
|
||||
class AiExportResult {
|
||||
final bool isSuccess;
|
||||
final String code;
|
||||
final String message;
|
||||
final String? reason;
|
||||
final bool isBanned;
|
||||
final Map<String, dynamic>? targetValidation;
|
||||
|
||||
AiExportResult({
|
||||
required this.isSuccess,
|
||||
required this.code,
|
||||
required this.message,
|
||||
this.reason,
|
||||
this.isBanned = false,
|
||||
this.targetValidation,
|
||||
});
|
||||
|
||||
factory AiExportResult.success({
|
||||
String? message,
|
||||
Map<String, dynamic>? targetValidation,
|
||||
}) {
|
||||
return AiExportResult(
|
||||
isSuccess: true,
|
||||
code: 'UPLOAD_SUCCESS',
|
||||
message: message ?? 'Export réussi vers le serveur IA !',
|
||||
targetValidation: targetValidation,
|
||||
);
|
||||
}
|
||||
|
||||
factory AiExportResult.banned({
|
||||
String? reason,
|
||||
String? message,
|
||||
}) {
|
||||
return AiExportResult(
|
||||
isSuccess: false,
|
||||
code: 'WALLET_BANNED',
|
||||
isBanned: true,
|
||||
reason: reason,
|
||||
message: message ?? 'Votre participation au programme d\'entraînement IA a été suspendue par la modération.',
|
||||
);
|
||||
}
|
||||
|
||||
factory AiExportResult.error({
|
||||
String? code,
|
||||
required String message,
|
||||
}) {
|
||||
return AiExportResult(
|
||||
isSuccess: false,
|
||||
code: code ?? 'UPLOAD_ERROR',
|
||||
message: message,
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
class AiExportService {
|
||||
/// Extrait les informations de l'appareil
|
||||
Future<Map<String, dynamic>> _getDeviceInfo() async {
|
||||
final DeviceInfoPlugin deviceInfoPlugin = DeviceInfoPlugin();
|
||||
@@ -45,7 +91,7 @@ class AiExportService {
|
||||
}
|
||||
|
||||
/// Exporte l'image et les données de plotting vers le serveur
|
||||
Future<bool> exportData({
|
||||
Future<AiExportResult> exportData({
|
||||
required String imagePath,
|
||||
required String sessionId,
|
||||
required TargetType targetType,
|
||||
@@ -58,23 +104,23 @@ class AiExportService {
|
||||
String? apiUrl,
|
||||
}) async {
|
||||
try {
|
||||
final url = Uri.parse(apiUrl ?? _defaultApiUrl);
|
||||
final walletService = WalletIdentityService();
|
||||
final baseUrl = await walletService.getServerBaseUrl();
|
||||
final effectiveUrl = apiUrl ?? '$baseUrl/api/upload';
|
||||
final url = Uri.parse(effectiveUrl);
|
||||
final request = http.MultipartRequest('POST', url);
|
||||
|
||||
// 1. Prepare image
|
||||
final file = File(imagePath);
|
||||
if (!await file.exists()) {
|
||||
throw Exception('Le fichier image n\'existe pas');
|
||||
return AiExportResult.error(
|
||||
code: 'FILE_NOT_FOUND',
|
||||
message: 'Le fichier image cible est introuvable.',
|
||||
);
|
||||
}
|
||||
|
||||
// Read image metadata (approximate dimensions since decoding image can be heavy)
|
||||
// On the frontend we usually have aspectRatio, here we use generic values if not available.
|
||||
final deviceData = await _getDeviceInfo();
|
||||
|
||||
// We approximate the target corners from center and radius
|
||||
// radius is relative (0 to 1). We need image width/height to get pixels.
|
||||
// But we can just pass relative corners as well, or a normalized bounding box.
|
||||
// Let's create normalized corners (0 to 1).
|
||||
final corners = [
|
||||
{"norm_x": targetCenterX - targetRadius, "norm_y": targetCenterY - targetRadius},
|
||||
{"norm_x": targetCenterX + targetRadius, "norm_y": targetCenterY - targetRadius},
|
||||
@@ -98,7 +144,6 @@ class AiExportService {
|
||||
}).toList();
|
||||
|
||||
// Get and hash the wallet identity
|
||||
final walletService = WalletIdentityService();
|
||||
final phrase = await walletService.getIdentityPhrase();
|
||||
final phraseBytes = utf8.encode(phrase);
|
||||
final walletHash = sha256.convert(phraseBytes).toString();
|
||||
@@ -113,7 +158,6 @@ class AiExportService {
|
||||
"type": targetType.name,
|
||||
"distance_meters": distanceMeters,
|
||||
"weapon": weaponName,
|
||||
// The backend could extract exact width/height from the image.
|
||||
},
|
||||
"plotting": {
|
||||
"target_corners": corners,
|
||||
@@ -121,29 +165,61 @@ class AiExportService {
|
||||
}
|
||||
};
|
||||
|
||||
// Add fields to request
|
||||
request.fields['plotting'] = jsonEncode(plottingJson);
|
||||
|
||||
// Add file
|
||||
request.files.add(
|
||||
await http.MultipartFile.fromPath('photo', imagePath),
|
||||
);
|
||||
|
||||
// Send request
|
||||
final response = await request.send();
|
||||
final streamedResponse = await request.send().timeout(
|
||||
const Duration(seconds: 15),
|
||||
onTimeout: () => throw Exception('Délai d\'attente dépassé (timeout)'),
|
||||
);
|
||||
|
||||
if (response.statusCode == 200) {
|
||||
final responseData = await response.stream.bytesToString();
|
||||
debugPrint('Export réussi: $responseData');
|
||||
return true;
|
||||
final responseBody = await streamedResponse.stream.bytesToString();
|
||||
Map<String, dynamic> responseJson = {};
|
||||
try {
|
||||
responseJson = jsonDecode(responseBody);
|
||||
} catch (_) {}
|
||||
|
||||
final statusCode = streamedResponse.statusCode;
|
||||
|
||||
if (statusCode == 200) {
|
||||
debugPrint('Export réussi: $responseBody');
|
||||
return AiExportResult.success(
|
||||
message: responseJson['message'] ?? 'Photo et données exportées avec succès.',
|
||||
targetValidation: responseJson['target_validation'] as Map<String, dynamic>?,
|
||||
);
|
||||
} else if (statusCode == 403 || responseJson['code'] == 'WALLET_BANNED') {
|
||||
final reason = responseJson['reason'] ?? 'Non-respect des règles de contribution';
|
||||
debugPrint('Export rejeté (banni): $reason');
|
||||
// Persister le bannissement localement et couper l'envoi de photos
|
||||
await walletService.setBanned(true, reason: reason);
|
||||
return AiExportResult.banned(
|
||||
reason: reason,
|
||||
message: responseJson['error'] ?? 'Votre wallet a été suspendu par la modération.',
|
||||
);
|
||||
} else if (statusCode == 400) {
|
||||
return AiExportResult.error(
|
||||
code: responseJson['code'] ?? 'BAD_REQUEST',
|
||||
message: responseJson['error'] ?? 'Requête d\'export invalide.',
|
||||
);
|
||||
} else {
|
||||
final errorData = await response.stream.bytesToString();
|
||||
debugPrint('Erreur d\'export: ${response.statusCode} - $errorData');
|
||||
return false;
|
||||
return AiExportResult.error(
|
||||
code: responseJson['code'] ?? 'SERVER_ERROR',
|
||||
message: responseJson['error'] ?? 'Erreur serveur ($statusCode).',
|
||||
);
|
||||
}
|
||||
} on SocketException {
|
||||
return AiExportResult.error(
|
||||
code: 'NETWORK_ERROR',
|
||||
message: 'Impossible de joindre le serveur IA. Vérifiez l\'adresse IP ou votre connexion.',
|
||||
);
|
||||
} catch (e) {
|
||||
debugPrint('Exception lors de l\'export: $e');
|
||||
return false;
|
||||
return AiExportResult.error(
|
||||
code: 'UNKNOWN_ERROR',
|
||||
message: 'Erreur lors de l\'export: $e',
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import 'dart:math';
|
||||
import 'dart:convert';
|
||||
import 'package:crypto/crypto.dart';
|
||||
import 'package:http/http.dart' as http;
|
||||
import 'package:shared_preferences/shared_preferences.dart';
|
||||
import 'package:device_info_plus/device_info_plus.dart';
|
||||
import 'dart:io';
|
||||
@@ -9,6 +10,9 @@ import 'package:flutter/foundation.dart';
|
||||
class WalletIdentityService {
|
||||
static const String _prefsKey = 'wallet_identity_phrase';
|
||||
static const String _uploadEnabledKey = 'is_ai_upload_enabled';
|
||||
static const String _bannedKey = 'wallet_is_banned';
|
||||
static const String _banReasonKey = 'wallet_ban_reason';
|
||||
static const String _serverUrlKey = 'ai_server_url';
|
||||
|
||||
// A standard list of 256 words (8 bits of entropy per word)
|
||||
static const List<String> _wordList = [
|
||||
@@ -40,18 +44,96 @@ class WalletIdentityService {
|
||||
'bulk', 'bullet', 'bundle', 'bunker', 'burden', 'burger', 'burst', 'bus', 'business', 'butter'
|
||||
];
|
||||
|
||||
/// Vérifie si l'utilisateur a accepté l'envoi de données à l'IA
|
||||
/// Retourne l'URL de base du serveur configuré (ex: http://192.168.1.50:3000 ou http://10.0.2.2:3000)
|
||||
Future<String> getServerBaseUrl() async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
final customUrl = prefs.getString(_serverUrlKey);
|
||||
if (customUrl != null && customUrl.trim().isNotEmpty) {
|
||||
return customUrl.trim().replaceAll(RegExp(r'/api/upload/?$'), '');
|
||||
}
|
||||
if (Platform.isAndroid) {
|
||||
return 'http://10.0.2.2:3000';
|
||||
}
|
||||
return 'http://localhost:3000';
|
||||
}
|
||||
|
||||
/// Définit une URL personnalisée pour le serveur IA
|
||||
Future<void> setServerBaseUrl(String url) async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
final cleanUrl = url.trim().replaceAll(RegExp(r'/api/upload/?$'), '');
|
||||
await prefs.setString(_serverUrlKey, cleanUrl);
|
||||
}
|
||||
|
||||
/// Vérifie si l'utilisateur a accepté l'envoi de données à l'IA (et n'est pas banni)
|
||||
Future<bool> isUploadEnabled() async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
final isBanned = prefs.getBool(_bannedKey) ?? false;
|
||||
if (isBanned) return false;
|
||||
return prefs.getBool(_uploadEnabledKey) ?? false;
|
||||
}
|
||||
|
||||
/// Active ou désactive l'envoi de données
|
||||
Future<void> setUploadEnabled(bool enabled) async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
final isBanned = prefs.getBool(_bannedKey) ?? false;
|
||||
if (isBanned) {
|
||||
await prefs.setBool(_uploadEnabledKey, false);
|
||||
return;
|
||||
}
|
||||
await prefs.setBool(_uploadEnabledKey, enabled);
|
||||
}
|
||||
|
||||
/// Vérifie si ce wallet/utilisateur est banni en local
|
||||
Future<bool> isBanned() async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
return prefs.getBool(_bannedKey) ?? false;
|
||||
}
|
||||
|
||||
/// Récupère le motif de bannissement enregistré
|
||||
Future<String?> getBanReason() async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
return prefs.getString(_banReasonKey);
|
||||
}
|
||||
|
||||
/// Enregistre l'état de bannissement et le motif
|
||||
Future<void> setBanned(bool banned, {String? reason}) async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
await prefs.setBool(_bannedKey, banned);
|
||||
if (banned) {
|
||||
await prefs.setString(_banReasonKey, reason ?? 'Photos non conformes aux règles de tir');
|
||||
await prefs.setBool(_uploadEnabledKey, false);
|
||||
} else {
|
||||
await prefs.remove(_banReasonKey);
|
||||
}
|
||||
}
|
||||
|
||||
/// Synchronise le statut de modération/bannissement avec le serveur backend
|
||||
Future<bool> syncBanStatus() async {
|
||||
try {
|
||||
final phrase = await getIdentityPhrase();
|
||||
final phraseBytes = utf8.encode(phrase);
|
||||
final walletHash = sha256.convert(phraseBytes).toString();
|
||||
final baseUrl = await getServerBaseUrl();
|
||||
|
||||
final res = await http.get(Uri.parse('$baseUrl/api/stats/$walletHash')).timeout(
|
||||
const Duration(seconds: 4),
|
||||
);
|
||||
if (res.statusCode == 200) {
|
||||
final data = jsonDecode(res.body);
|
||||
final isBannedOnServer = data['is_banned'] == true;
|
||||
if (isBannedOnServer) {
|
||||
await setBanned(true, reason: data['ban_reason']);
|
||||
} else {
|
||||
await setBanned(false);
|
||||
}
|
||||
return isBannedOnServer;
|
||||
}
|
||||
} catch (e) {
|
||||
debugPrint('Erreur synchro ban: $e');
|
||||
}
|
||||
return await isBanned();
|
||||
}
|
||||
|
||||
/// Gets the unique 15-word identity phrase
|
||||
Future<String> getIdentityPhrase() async {
|
||||
final prefs = await SharedPreferences.getInstance();
|
||||
|
||||
Reference in New Issue
Block a user