refactoring

lib/data/datasources/event_remote_data_source.dart

@@ -0,0 +1,145 @@
+import 'dart:convert';
+import 'package:afterwork/core/constants/urls.dart';
+import 'package:afterwork/data/models/event_model.dart';
+import 'package:http/http.dart' as http;
+import '../../core/errors/exceptions.dart';
+
+class EventRemoteDataSource {
+  final http.Client client;
+
+  EventRemoteDataSource(this.client);
+
+  /// Récupérer tous les événements depuis l'API.
+  Future<List<EventModel>> getAllEvents() async {
+    print('Récupération de tous les événements depuis ${Urls.baseUrl}/events');
+
+    final response = await client.get(Uri.parse('${Urls.baseUrl}/events'));
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode == 200) {
+      final List<dynamic> jsonResponse = json.decode(response.body);
+      print('Réponse JSON reçue: $jsonResponse');
+      return jsonResponse.map((event) => EventModel.fromJson(event)).toList();
+    } else {
+      print('Erreur lors de la récupération des événements: ${response.body}');
+      throw ServerException();
+    }
+  }
+
+  /// Créer un nouvel événement via l'API.
+  Future<EventModel> createEvent(EventModel event) async {
+    print('Création d\'un nouvel événement avec les données: ${event.toJson()}');
+
+    final response = await client.post(
+      Uri.parse(Urls.eventsUrl),
+      headers: {'Content-Type': 'application/json'},
+      body: jsonEncode(event.toJson()),
+    );
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode == 201) {
+      print('Événement créé avec succès');
+      return EventModel.fromJson(json.decode(response.body));
+    } else {
+      print('Erreur lors de la création de l\'événement: ${response.body}');
+      throw ServerException();
+    }
+  }
+
+  /// Récupérer un événement spécifique par son ID.
+  Future<EventModel> getEventById(String id) async {
+    print('Récupération de l\'événement avec l\'ID: $id');
+
+    final response = await client.get(Uri.parse('${Urls.eventsUrl}/$id'));
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode == 200) {
+      print('Événement récupéré avec succès');
+      return EventModel.fromJson(json.decode(response.body));
+    } else {
+      print('Erreur lors de la récupération de l\'événement: ${response.body}');
+      throw ServerException();
+    }
+  }
+
+  /// Mettre à jour un événement existant.
+  Future<EventModel> updateEvent(String id, EventModel event) async {
+    print('Mise à jour de l\'événement avec l\'ID: $id, données: ${event.toJson()}');
+
+    final response = await client.put(
+      Uri.parse('${Urls.eventsUrl}/$id'),
+      headers: {'Content-Type': 'application/json'},
+      body: jsonEncode(event.toJson()),
+    );
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode == 200) {
+      print('Événement mis à jour avec succès');
+      return EventModel.fromJson(json.decode(response.body));
+    } else {
+      print('Erreur lors de la mise à jour de l\'événement: ${response.body}');
+      throw ServerException();
+    }
+  }
+
+  /// Supprimer un événement par son ID.
+  Future<void> deleteEvent(String id) async {
+    print('Suppression de l\'événement avec l\'ID: $id');
+
+    final response = await client.delete(Uri.parse('${Urls.eventsUrl}/$id'));
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode != 204) {
+      print('Erreur lors de la suppression de l\'événement: ${response.body}');
+      throw ServerException();
+    } else {
+      print('Événement supprimé avec succès');
+    }
+  }
+
+  /// Participer à un événement.
+  Future<EventModel> participateInEvent(String eventId, String userId) async {
+    print('Participation à l\'événement avec l\'ID: $eventId, utilisateur: $userId');
+
+    final response = await client.post(
+      Uri.parse('${Urls.eventsUrl}/$eventId/participate'),
+      headers: {'Content-Type': 'application/json'},
+      body: jsonEncode({'userId': userId}),
+    );
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode == 200) {
+      print('Participation réussie');
+      return EventModel.fromJson(json.decode(response.body));
+    } else {
+      print('Erreur lors de la participation à l\'événement: ${response.body}');
+      throw ServerException();
+    }
+  }
+
+  /// Réagir à un événement.
+  Future<void> reactToEvent(String eventId, String userId) async {
+    print('Réaction à l\'événement avec l\'ID: $eventId, utilisateur: $userId');
+
+    final response = await client.post(
+      Uri.parse('${Urls.eventsUrl}/$eventId/react'),
+      headers: {'Content-Type': 'application/json'},
+      body: jsonEncode({'userId': userId}),
+    );
+
+    print('Statut de la réponse: ${response.statusCode}');
+
+    if (response.statusCode != 200) {
+      print('Erreur lors de la réaction à l\'événement: ${response.body}');
+      throw ServerException();
+    } else {
+      print('Réaction réussie');
+    }
+  }
+}

lib/data/datasources/user_remote_data_source.dart

@@ -1,6 +1,7 @@
 import 'dart:convert';
-import 'package:afterwork/data/models/user_model.dart';
+
 import 'package:afterwork/core/constants/urls.dart';
+import 'package:afterwork/data/models/user_model.dart';
 import 'package:http/http.dart' as http;
 
 import '../../core/errors/exceptions.dart';
@@ -10,7 +11,8 @@ class UserRemoteDataSource {
 
   UserRemoteDataSource(this.client);
 
-  Future<UserModel> authenticateUser(String email, String password) async {
+  // Authentifier l'utilisateur
+  Future<UserModel> authenticateUser(String email, String password, String userId) async {
     if (email.isEmpty || password.isEmpty) {
       throw Exception('Email ou mot de passe vide');
     }
@@ -34,8 +36,9 @@ class UserRemoteDataSource {
     }
   }
 
+  // Récupérer un utilisateur par ID
   Future<UserModel> getUser(String id) async {
-    final response = await client.get(Uri.parse('${Urls.baseUrl}/user/$id'));
+    final response = await client.get(Uri.parse('${Urls.baseUrl}/users/$id'));
 
     if (response.statusCode == 200) {
       return UserModel.fromJson(json.decode(response.body));
@@ -43,4 +46,45 @@ class UserRemoteDataSource {
       throw ServerException();
     }
   }
+
+  // Créer un nouvel utilisateur
+  Future<UserModel> createUser(UserModel user) async {
+    final response = await client.post(
+      Uri.parse('${Urls.baseUrl}/users'),
+      headers: {'Content-Type': 'application/json'},
+      body: jsonEncode(user.toJson()),
+    );
+
+    if (response.statusCode == 201) {
+      return UserModel.fromJson(json.decode(response.body));
+    } else {
+      throw ServerException();
+    }
+  }
+
+  // Mettre à jour un utilisateur
+  Future<UserModel> updateUser(UserModel user) async {
+    final response = await client.put(
+      Uri.parse('${Urls.baseUrl}/users/${user.userId}'),
+      headers: {'Content-Type': 'application/json'},
+      body: jsonEncode(user.toJson()),
+    );
+
+    if (response.statusCode == 200) {
+      return UserModel.fromJson(json.decode(response.body));
+    } else {
+      throw ServerException();
+    }
+  }
+
+  // Supprimer un utilisateur par ID
+  Future<void> deleteUser(String id) async {
+    final response = await client.delete(
+      Uri.parse('${Urls.baseUrl}/users/$id'),
+    );
+
+    if (response.statusCode != 204) {
+      throw ServerException();
+    }
+  }
 }