Deploy

README.md

@@ -44,6 +44,20 @@ Além de seu propósito funcional, o sistema serve como aplicação prática de
 
 ---
 
+## 🗺️ Diagramas
+
+<figure>
+  <img src="docs/fluxo.png" width="800">
+  <figcaption><strong>Figura 1:</strong> Arquitetura do projeto</figcaption>
+</figure>
+
+<figure>
+  <img src="docs/deploy_to_aws.png" width="800">
+  <figcaption><strong>Figura 2:</strong> Fluxo de deploy</figcaption>
+</figure>
+
+---
+
 ## 📚 Documentação da API
 
 A coleção completa de endpoints, exemplos de requisições e esquemas de resposta está disponível no Postman:

back/microsservicos/aluguel/bin/aluguel_dart.dart

@@ -15,11 +15,27 @@ import 'package:aluguel_dart/application/get_aluguel_usecase.dart';
 import 'package:aluguel_dart/application/create_aluguel_usecase.dart';
 import 'package:aluguel_dart/application/update_aluguel_usecase.dart';
 import 'package:aluguel_dart/application/delete_aluguel_usecase.dart';
+import 'package:aluguel_dart/application/verify_door_code_usecase.dart';
 import 'package:aluguel_dart/domain/repositories/aluguel_repository.dart';
 import 'package:aluguel_dart/presentation/http/controllers/get_aluguel_controller.dart';
 import 'package:aluguel_dart/presentation/http/controllers/create_aluguel_controller.dart';
 import 'package:aluguel_dart/presentation/http/controllers/update_aluguel_controller.dart';
 import 'package:aluguel_dart/presentation/http/controllers/delete_aluguel_controller.dart';
+import 'package:aluguel_dart/presentation/http/controllers/get_door_hash_controller.dart';
+
+Future<void> _shutdownServer(HttpServer server, String message) async {
+  stdout.writeln(message);
+  try {
+    await closeRabbitMQConnection();
+  } catch (e) {
+    stderr.writeln('Erro ao fechar RabbitMQ: $e');
+  } finally {
+    try {
+      await server.close(force: true);
+    } catch (_) {}
+    exit(0);
+  }
+}
 
 Future<void> main() async {
   final AluguelRepository repo = Environments.getAluguelRepo();
@@ -29,12 +45,14 @@ Future<void> main() async {
   final updateAluguelUsecase = UpdateAluguelUsecase(repository: repo);
   final deleteAluguelUsecase = DeleteAluguelUsecase(repository: repo);
   final getAllAluguelUsecase = GetAllAluguelUsecase(repository: repo);
+  final verifyDoorCodeUsecase = VerifyDoorCodeUsecase(repository: repo);
 
   final getController = GetAluguelController(getAluguelUsecase);
   final createController = CreateAluguelController(createAluguelUsecase);
   final updateController = UpdateAluguelController(updateAluguelUsecase);
   final deleteController = DeleteAluguelController(deleteAluguelUsecase);
   final getAllAluguelController = GetAllAluguelController(getAllAluguelUsecase);
+  final getDoorHashController = GetDoorHashController(verifyDoorCodeUsecase);
 
   final router = Router()
     ..mount(
@@ -44,7 +62,8 @@ Future<void> main() async {
         createController: createController,
         updateController: updateController,
         deleteController: deleteController,
-        getAllAluguelController: getAllAluguelController
+        getAllAluguelController: getAllAluguelController,
+        getDoorHashController: getDoorHashController,
       ).call,
     );
 
@@ -57,30 +76,12 @@ Future<void> main() async {
   final server = await io.serve(handler, InternetAddress.anyIPv4, port);
   print('Aluguel. Porta: $port');
   await startQueue();
-  ProcessSignal.sigint.watch().listen((_) async {
-    stdout.writeln('Service aluguel interrupted!');
-    try {
-      await closeRabbitMQConnection();
-    } catch (e) {
-      stderr.writeln('Erro ao fechar RabbitMQ: $e');
-    } finally {
-      try {
-        await server.close(force: true);
-      } catch (_) {}
-      exit(0);
-    }
-  });
-  ProcessSignal.sigterm.watch().listen((_) async {
-    stdout.writeln('Service aluguel terminated!');
-    try {
-      await closeRabbitMQConnection();
-    } catch (e) {
-      stderr.writeln('Erro ao fechar RabbitMQ: $e');
-    } finally {
-      try {
-        await server.close(force: true);
-      } catch (_) {}
-      exit(0);
-    }
-  });
+  ProcessSignal.sigint.watch().listen(
+    (_) async => _shutdownServer(server, 'Service aluguel interrupted!'),
+  );
+  if (!Platform.isWindows) {
+    ProcessSignal.sigterm.watch().listen(
+      (_) async => _shutdownServer(server, 'Service aluguel terminated!'),
+    );
+  }
 }

back/microsservicos/aluguel/lib/application/create_aluguel_usecase.dart

@@ -11,23 +11,24 @@ class CreateAluguelUsecase {
   Future<Aluguel> call({
     required String userId,
     required String workspaceId,
-    required int startDate, 
-    required int endDate,   
+    required int startDate,
+    required int endDate,
     required int people,
-    required num finalPrice,
+    required num finalPrice
   }) async {
-
     if (endDate < startDate) {
       throw StateError('endDate não pode ser menor que startDate.');
     }
     if (people <= 0) {
-      throw StateError('O número de pessoas para a reserva deve ser diferente de null e maior que.');
+      throw StateError(
+        'O número de pessoas para a reserva deve ser diferente de null e maior que zero.',
+      );
     }
     if (finalPrice < 0) {
       throw StateError('finalPrice não pode ser negativo.');
     }
 
-    Aluguel createdAluguel = await repository.createAluguel(
+    final createdAluguel = await repository.createAluguel(
       userId: userId,
       workspaceId: workspaceId,
       startDate: startDate,
@@ -37,18 +38,18 @@ class CreateAluguelUsecase {
       status: 'PENDING',
     );
 
-    RabbitMQEvent aluguelCreated = RabbitMQEvent(eventType: 'AluguelCreated', payload: createdAluguel.toJson());
+    final aluguelCreated = RabbitMQEvent(
+      eventType: 'AluguelCreated',
+      payload: createdAluguel.toJson(),
+    );
 
-    final published = await publishEvent('aluguel.created', aluguelCreated.toJson());
+    final published =
+        await publishEvent('aluguel.created', aluguelCreated.toJson());
 
-    if(published){
+    if (published) {
       return createdAluguel;
     } else {
       throw StateError('Não foi possível criar o aluguel');
     }
-
   }
 }
-
-
-

back/microsservicos/aluguel/lib/application/get_aluguel_usecase.dart

@@ -5,7 +5,7 @@ class GetAluguelUsecase {
   final AluguelRepository repository;
 
   GetAluguelUsecase({required this.repository});
-  
+
   Future<Aluguel> call(String id) async {
     if (id.isEmpty) {
       throw ArgumentError('ID do aluguel não pode ser vazio.');

back/microsservicos/aluguel/lib/application/update_aluguel_usecase.dart

@@ -1,3 +1,5 @@
+import 'dart:math';
+
 import 'package:aluguel_dart/domain/entities/aluguel.dart';
 import 'package:aluguel_dart/domain/repositories/aluguel_repository.dart';
 
@@ -8,13 +10,12 @@ class UpdateAluguelUsecase {
 
   Future<Aluguel> call(
     String id, {
-    int? startDate, 
+    int? startDate,
     int? endDate,
     int? people,
     double? finalPrice,
     String? status,
   }) async {
-
     if (startDate != null && endDate != null && endDate < startDate) {
       throw StateError('endDate não pode ser menor que startDate.');
     }
@@ -25,13 +26,24 @@ class UpdateAluguelUsecase {
       throw StateError('finalPrice não pode ser negativo.');
     }
 
+    String? desiredDoorCode = Random().nextInt(100000).toString().padLeft(5, '0');
+
+    if (status != null &&
+        status.toUpperCase() == 'CONFIRMED') {
+      final current = await repository.getAluguel(id);
+      if (current == null) {
+        throw StateError('aluguel_not_found');
+      }
+    }
+
     return repository.updateAluguel(
       id,
       startDate: startDate,
       endDate: endDate,
       people: people,
       finalPrice: finalPrice,
       status: status,
+      doorCode: desiredDoorCode,
     );
   }
 }

back/microsservicos/aluguel/lib/application/verify_door_code_usecase.dart

@@ -0,0 +1,61 @@
+import 'package:aluguel_dart/domain/entities/aluguel.dart';
+import 'package:aluguel_dart/domain/repositories/aluguel_repository.dart';
+import 'package:aluguel_dart/infrastructure/clients/rabbitmq/rabbitmq.dart';
+
+class VerifyDoorCodeUsecase {
+  final AluguelRepository repository;
+
+  VerifyDoorCodeUsecase({required this.repository});
+
+  Future<String> call({
+    required String doorCode,
+  }) async {
+    final normalizedDoorCode = doorCode.trim();
+
+    if (!RegExp(r'^\d{5}$').hasMatch(normalizedDoorCode)) {
+      throw StateError('door code invalid');
+    }
+
+    final allAlugueis = await repository.getAllAluguel();
+
+    if (allAlugueis == null || allAlugueis.isEmpty) {
+      throw StateError('door code not found');
+    }
+
+    final nowEpoch = DateTime.now().millisecondsSinceEpoch ~/ 1000;
+
+    Aluguel? matchingAluguel;
+
+    for (final aluguel in allAlugueis.values) {
+      final storedDoor = aluguel.doorCode?.trim();
+      if (storedDoor == null || storedDoor.isEmpty) {
+        continue;
+      }
+      if (storedDoor != normalizedDoorCode) {
+        continue;
+      }
+      if (aluguel.status.toUpperCase() != 'CONFIRMED') {
+        continue;
+      }
+      if (nowEpoch < aluguel.startDate || nowEpoch > aluguel.endDate) {
+        continue;
+      }
+      matchingAluguel = aluguel;
+      break;
+    }
+
+    if (matchingAluguel == null) {
+      throw StateError('door code not found');
+    }
+
+    final doorSerial = await fetchDoorCodeFromCatalog(
+      matchingAluguel.workspaceId,
+    );
+
+    if (doorSerial == null || doorSerial.trim().isEmpty) {
+      throw StateError('door serial not found');
+    }
+
+    return doorSerial.trim();
+  }
+}

back/microsservicos/aluguel/lib/domain/entities/aluguel.dart

@@ -7,6 +7,7 @@ class Aluguel {
   final int people;
   final double finalPrice;
   final String status;
+  final String? doorCode;
   final int createdAt;
   final int updatedAt;
 
@@ -19,6 +20,7 @@ class Aluguel {
     required this.people,
     required this.finalPrice,
     required this.status,
+    this.doorCode,
     required this.createdAt,
     required this.updatedAt,
   });
@@ -33,6 +35,7 @@ class Aluguel {
       'people': people,
       'finalPrice': finalPrice,
       'status': status,
+      'doorCode': doorCode,
       'createdAt': createdAt,
       'updatedAt': updatedAt,
     };

back/microsservicos/aluguel/lib/domain/repositories/aluguel_repository.dart

@@ -22,8 +22,11 @@ abstract class AluguelRepository {
     int? people,
     double? finalPrice,
     String? status,
+    String? doorCode,
   });
 
 
   Future<void> deleteAluguel(String id);
-}
+
+  Future<Aluguel?> getDoorAluguel(String doorCode);
+}