feat: Implementación Sistema de Procesamiento de Transacciones con CQRS y EDA - Kenny Luque #481
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…ndling and configuration feat(cache): add Redis cache configuration and implement caching logic in transaction service fix(consumer): update transaction consumer to handle validated transactions and improve error handling refactor(transaction): streamline transaction controller and service methods for better readability and performance chore(constants): update Kafka topic constants to reflect new naming conventions test(utils): add utility function for checking required keys in objects
- Removed unused dependencies from package.json and pnpm-lock.yaml. - Updated Kafka module to subscribe to new topic KAFKA_TOPIC_TRANSACTION_DEBEZIUM. - Refactored ValidationController to handle Debezium events and removed GetTransactionDto. - Simplified cache update logic in ValidationService. - Added Dockerfiles for antifraud_service and transaction_service. - Adjusted docker-compose.yml to use relative paths for env files. - Updated configuration for Kafka consumer group IDs. - Enhanced TransactionConsumerController to process Debezium messages. - Implemented Redis caching in TransactionService and TransactionModule. - Cleaned up tsconfig.json output directory structure.
…integration - Create README.md with service description, architecture, and API documentation. - Implement CreateTransactionInput DTO for transaction creation with validation. - Define GraphQL types for Transaction, TransactionTypeInfo, and TransactionStatusInfo. - Establish structure for handling transactions using CQRS pattern with PostgreSQL and Redis.
…rrency handling strategies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Descripción
Este PR introduce la implementación del sistema de procesamiento de transacciones basado en microservicios, siguiendo patrones CQRS y EDA. Configura la infraestructura necesaria y los dos servicios principales: Transaction Service y AntiFraud Service.
transaction_service: Microservicio NestJS con API GraphQL y REST para crear y consultar transacciones. Implementa CQRS con PostgreSQL (escritura) y Redis (lectura/caché).antifraud_service: Microservicio NestJS que consume eventos Kafka (Debezium) para validar transacciones y publica resultados en Kafka.wal_level=logical.createTransaction,getTransaction) en Transaction Service.Dockerfileoptimizados (multi-etapa) para ambos servicios NestJS usandopnpm.README.mdprincipal con instrucciones de configuración y ejecución paso a paso.README.mddetallados para cada microservicio (transaction_service,antifraud_service) con descripción de API, flujos y diagramas.