lionsdev/afterwork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactoring

Browse Source
This commit is contained in:
DahoudG
2024-11-02 15:27:26 +00:00
parent 8e625c1080
commit 9cf96b7acf
44 changed files with 2281 additions and 354 deletions
Download Patch File Download Diff File Expand all files Collapse all files

137
lib/data/datasources/user_remote_data_source.dart
View File

@@ -5,136 +5,181 @@ import 'package:http/http.dart' as http;
import '../../core/errors/exceptions.dart';
/// Classe pour gérer les opérations API pour les utilisateurs.
/// Chaque action est loguée pour faciliter la traçabilité et le débogage.
/// Toutes les actions sont loguées pour faciliter la traçabilité et le débogage.
class UserRemoteDataSource {
// Client HTTP injecté pour réaliser les appels réseau
final http.Client client;
/// Constructeur avec injection du client HTTP
UserRemoteDataSource(this.client);
/// Authentifie un utilisateur avec l'email et le mot de passe en clair.
/// Authentifie un utilisateur avec l'email et le mot de passe.
/// Si l'authentification réussit, retourne un objet `UserModel`.
/// Les erreurs sont gérées et toutes les actions sont loguées.
Future<UserModel> authenticateUser(String email, String password) async {
print("Tentative d'authentification pour l'email : $email");
print("[LOG] Tentative d'authentification pour l'email : $email");
try {
// Requête POST avec l'email et le mot de passe en clair
// Préparation des données d'authentification à envoyer
final Map<String, dynamic> body = {
'email': email,
'motDePasse': password,
};
print("[DEBUG] Données envoyées pour authentification : $body");
// Envoi de la requête HTTP POST pour authentifier l'utilisateur
final response = await client.post(
Uri.parse('${Urls.baseUrl}/users/authenticate'),
headers: {'Content-Type': 'application/json'},
body: jsonEncode({
'email': email,
'motDePasse': password, // Le mot de passe est envoyé en clair pour le moment
}),
body: jsonEncode(body),
);
print("Réponse du serveur pour l'authentification : ${response.statusCode} - ${response.body}");
// Log de la réponse reçue du serveur
print("[LOG] Réponse du serveur : ${response.statusCode} - ${response.body}");
if (response.statusCode == 200) {
// Si l'authentification réussit, retourne l'utilisateur
return UserModel.fromJson(jsonDecode(response.body));
final userData = jsonDecode(response.body);
if (userData['userId'] != null && userData['userId'].isNotEmpty) {
print("[LOG] Utilisateur authentifié avec succès. ID: ${userData['userId']}");
return UserModel.fromJson(userData);
} else {
print("[ERROR] L'ID utilisateur est manquant dans la réponse.");
throw Exception("ID utilisateur manquant.");
}
} else if (response.statusCode == 401) {
// Gestion des erreurs d'authentification
throw UnauthorizedException();
print("[ERROR] Authentification échouée : Mot de passe incorrect.");
throw UnauthorizedException("Mot de passe incorrect.");
} else {
throw ServerException();
print("[ERROR] Erreur du serveur. Code : ${response.statusCode}");
throw ServerExceptionWithMessage("Erreur inattendue : ${response.body}");
}
} catch (e) {
print("Erreur d'authentification : $e");
print("[ERROR] Erreur lors de l'authentification : $e");
throw Exception("Erreur lors de l'authentification : $e");
}
}
/// Récupère un utilisateur par son identifiant et logue les étapes.
/// Récupère un utilisateur par son identifiant.
/// Les erreurs et les succès sont logués pour un suivi complet.
Future<UserModel> getUser(String id) async {
print("Tentative de récupération de l'utilisateur avec l'ID : $id");
print("[LOG] Tentative de récupération de l'utilisateur avec l'ID : $id");
try {
// Envoi de la requête GET pour obtenir l'utilisateur par son ID
final response = await client.get(Uri.parse('${Urls.baseUrl}/users/$id'));
print("Réponse du serveur pour getUser : ${response.statusCode} - ${response.body}");
print("[LOG] Réponse du serveur pour getUser : ${response.statusCode} - ${response.body}");
if (response.statusCode == 200) {
// Utilisateur trouvé, retour de l'objet UserModel
return UserModel.fromJson(json.decode(response.body));
} else if (response.statusCode == 404) {
print("Utilisateur non trouvé.");
}
// Gestion du cas où l'utilisateur n'est pas trouvé
else if (response.statusCode == 404) {
print("[ERROR] Utilisateur non trouvé.");
throw UserNotFoundException();
} else {
}
// Gestion des autres erreurs serveur
else {
print("[ERROR] Erreur du serveur lors de la récupération de l'utilisateur.");
throw ServerException();
}
} catch (e) {
print("Erreur lors de la récupération de l'utilisateur : $e");
print("[ERROR] Erreur lors de la récupération de l'utilisateur : $e");
throw Exception("Erreur lors de la récupération de l'utilisateur : $e");
}
}
/// Crée un nouvel utilisateur et logue les détails de la requête.
/// Crée un nouvel utilisateur dans le backend.
/// Toutes les actions, succès ou erreurs sont logués pour un suivi précis.
Future<UserModel> createUser(UserModel user) async {
print("Création d'un nouvel utilisateur : ${user.toJson()}");
print("[LOG] Création d'un nouvel utilisateur : ${user.toJson()}");
try {
// Envoi de la requête POST pour créer un nouvel utilisateur
final response = await client.post(
Uri.parse('${Urls.baseUrl}/users'),
headers: {'Content-Type': 'application/json'},
body: jsonEncode(user.toJson()),
body: jsonEncode(user.toJson()), // Conversion du modèle utilisateur en JSON
);
print("Réponse du serveur pour createUser : ${response.statusCode} - ${response.body}");
print("[LOG] Réponse du serveur pour createUser : ${response.statusCode} - ${response.body}");
if (response.statusCode == 201) {
// Utilisateur créé avec succès
return UserModel.fromJson(json.decode(response.body));
} else if (response.statusCode == 409) {
// Gestion des conflits (utilisateur déjà existant)
}
// Gestion des conflits (ex: utilisateur déjà existant)
else if (response.statusCode == 409) {
print("[ERROR] Conflit lors de la création de l'utilisateur : Utilisateur déjà existant.");
throw ConflictException();
} else {
}
// Gestion des autres erreurs serveur
else {
print("[ERROR] Erreur du serveur lors de la création de l'utilisateur.");
throw ServerException();
}
} catch (e) {
print("Erreur lors de la création de l'utilisateur : $e");
print("[ERROR] Erreur lors de la création de l'utilisateur : $e");
throw Exception("Erreur lors de la création de l'utilisateur : $e");
}
}
/// Met à jour un utilisateur existant et logue les étapes.
/// Met à jour un utilisateur existant.
/// Chaque étape est loguée pour faciliter le débogage.
Future<UserModel> updateUser(UserModel user) async {
print("Mise à jour de l'utilisateur : ${user.toJson()}");
print("[LOG] Mise à jour de l'utilisateur : ${user.toJson()}");
try {
// Envoi de la requête PUT pour mettre à jour un utilisateur
final response = await client.put(
Uri.parse('${Urls.baseUrl}/users/${user.userId}'),
headers: {'Content-Type': 'application/json'},
body: jsonEncode(user.toJson()),
body: jsonEncode(user.toJson()), // Conversion du modèle utilisateur en JSON
);
print("Réponse du serveur pour updateUser : ${response.statusCode} - ${response.body}");
print("[LOG] Réponse du serveur pour updateUser : ${response.statusCode} - ${response.body}");
if (response.statusCode == 200) {
// Mise à jour réussie
return UserModel.fromJson(json.decode(response.body));
} else if (response.statusCode == 404) {
// Gestion des cas où l'utilisateur n'est pas trouvé
}
// Gestion du cas où l'utilisateur n'est pas trouvé
else if (response.statusCode == 404) {
print("[ERROR] Utilisateur non trouvé.");
throw UserNotFoundException();
} else {
}
// Gestion des autres erreurs serveur
else {
print("[ERROR] Erreur du serveur lors de la mise à jour de l'utilisateur.");
throw ServerException();
}
} catch (e) {
print("Erreur lors de la mise à jour de l'utilisateur : $e");
print("[ERROR] Erreur lors de la mise à jour de l'utilisateur : $e");
throw Exception("Erreur lors de la mise à jour de l'utilisateur : $e");
}
}
/// Supprime un utilisateur et logue chaque étape.
/// Supprime un utilisateur par son identifiant.
/// Les erreurs et succès sont logués pour garantir un suivi complet.
Future<void> deleteUser(String id) async {
print("Tentative de suppression de l'utilisateur avec l'ID : $id");
print("[LOG] Tentative de suppression de l'utilisateur avec l'ID : $id");
try {
// Envoi de la requête DELETE pour supprimer un utilisateur
final response = await client.delete(Uri.parse('${Urls.baseUrl}/users/$id'));
print("Réponse du serveur pour deleteUser : ${response.statusCode} - ${response.body}");
print("[LOG] Réponse du serveur pour deleteUser : ${response.statusCode} - ${response.body}");
if (response.statusCode != 204) {
print("Erreur lors de la suppression de l'utilisateur.");
// Vérification du succès de la suppression
if (response.statusCode == 204) {
print("[LOG] Utilisateur supprimé avec succès.");
}
// Gestion des autres erreurs serveur
else {
print("[ERROR] Erreur du serveur lors de la suppression de l'utilisateur.");
throw ServerException();
} else {
print("Utilisateur supprimé avec succès.");
}
} catch (e) {
print("Erreur lors de la suppression de l'utilisateur : $e");
print("[ERROR] Erreur lors de la suppression de l'utilisateur : $e");
throw Exception("Erreur lors de la suppression de l'utilisateur : $e");
}
}