diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..4c4975b
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,111 @@
+# ============================================
+# Spring Boot (Java + Maven)
+# ============================================
+
+# Compiled class files
+*.class
+
+*.war
+*.ear
+
+# Logs
+*.log
+logs/
+spring.log
+
+# Temporary files
+*.tmp
+*.bak
+*.swp
+*.swo
+*.old
+*.orig
+
+# ============================================
+# Maven
+# ============================================
+target/
+.mvn/
+!.mvn/wrapper/maven-wrapper.jar
+.settings/
+dependency-reduced-pom.xml
+release.properties
+pom.xml.tag
+pom.xml.releaseBackup
+pom.xml.versionsBackup
+pom.xml.next
+pom.xml.backup
+buildNumber.properties
+
+# ============================================
+# IntelliJ IDEA
+# ============================================
+.idea/
+*.iml
+*.iws
+out/
+.idea_modules/
+.idea/workspace.xml
+.idea/tasks.xml
+.idea/dictionaries
+.idea/httpRequests
+.idea/caches/
+.idea/libraries/
+
+# ============================================
+# VS Code (opcional si usas ambos IDEs)
+# ============================================
+.vscode/
+.history/
+
+# ============================================
+# Environment / Configuration
+# ============================================
+.env
+*.env.local
+*.key
+*.pem
+*.crt
+*.jks
+*.p12
+*.der
+
+# Spring configuration files (keep templates only)
+application-*.yml
+application-*.yaml
+application-*.properties
+!application-example.yml
+!application-example.yaml
+!application-example.properties
+
+# ============================================
+# Test / Coverage
+# ============================================
+test-output/
+surefire-reports/
+jacoco.exec
+reports/
+coverage/
+
+# ============================================
+# OS files
+# ============================================
+# macOS
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Windows
+Thumbs.db
+ehthumbs.db
+Desktop.ini
+
+# Linux
+*~
+
+# ============================================
+# Misc
+# ============================================
+bin/
+tmp/
+.cache/
\ No newline at end of file
diff --git a/README.md b/README.md
index 7f832ad..880397d 100644
--- a/README.md
+++ b/README.md
@@ -1,14 +1,11 @@
-# Yape Code Challenge :rocket:
+# Transaction Service – Yape Code Challenge
-Our code challenge will let you marvel us with your Jedi coding skills :smile:.
+Este proyecto implementa un **microservicio de transacciones** desarrollado con **Spring Boot 3 - WEBFLUX**, siguiendo el enfoque de **Arquitectura Hexagonal (Ports & Adapters)** y un **flujo event-driven con Kafka**.
-Don't forget that the proper way to submit your work is to fork the repo and create a PR :wink: ... have fun !!
-- [Yape Code Challenge :rocket:](#yape-code-challenge-rocket)
-- [Problem](#problem)
-- [Tech Stack](#tech-stack)
- - [Optional](#optional)
-- [Send us your challenge](#send-us-your-challenge)
+Todos los endpoints intercambian datos en **JSON** y el sistema está preparado para ejecutarse **localmente con Docker Compose**.
+
+---
# Problem
@@ -31,54 +28,243 @@ Every transaction with a value greater than 1000 should be rejected.
Anti-Fraud -- Send transaction Status Rejected event--> Transaction
Transaction -- Update transaction Status event--> transactionDatabase[(Database)]
```
+---
-# Tech Stack
+## Arquitectura
-
- - Java. You can use any framework you want
- - Any database
- - Kafka
-
+El proyecto sigue **Arquitectura Hexagonal**, separando claramente responsabilidades:
+
+```
+├── application
+│ ├── dto
+│ ├── service
+│ └── usecase
+├── domain
+│ ├── model
+│ └── port
+├── infrastructure
+│ ├── inbound
+│ │ ├── rest
+│ │ └── kafka
+│ ├── outbound
+│ │ ├── persistence
+│ │ └── kafka
+│ └── config
+```
+
+---
+> [!TIP]
+> **Sobre la estructura de repositorios separados:**
+> El servicio **Anti-Fraud** se gestiona en un repositorio independiente.
+> En un entorno real, cada microservicio tiene su propio ciclo de vida y equipo.
+> Para este challenge, se facilita la revisión incluyendo un paquete de despliegue unificado dentro de la carpeta `devops`.
+
+## Ejecución local (sin Docker)
+
+### Requisitos
+- Java 17
+- Maven 3.9+
+- PostgreSQL
+- Kafka + Zookeeper
+
+### Compilar y ejecutar tests
+```bash
+mvn clean compile
+mvn test
+mvn verify
+```
+
+Reporte JaCoCo:
+```
+target/site/jacoco/index.html
+```
+
+
+## Docker Compose (PostgreSQL + Kafka + Transaction Service + Antifraud)
+
+### Requisitos
+- Docker y Docker Compose
-We do provide a `Dockerfile` to help you get started with a dev environment.
+### 1) Construir el `.jar`
+Desde la raíz del proyecto (donde está el `pom.xml`):
-You must have two resources:
+```bash
+mvn clean package
+```
+
+El ejecutable jar se genera en:
+
+```
+target/transaction-service-0.0.1.jar
+```
+
+> Empaquetar mas pruebas unitarias & cobertura:
+> ```bash
+> mvn clean verify
+> ```
+
+## ***Antifraud Service***
+
+El servicio de **Antifraud** se encuentra implementado en un repositorio independiente y
+se integra con este microservicio mediante eventos Kafka.
+
+Repositorio:
+ https://github.com/alessandrojre/antifraud-service
-1. Resource to create a transaction that must containt:
+En el entorno local, el `docker compose` levanta automáticamente este servicio para simular el flujo completo:
+Transaction Service → Kafka → Antifraud Service → Kafka → Transaction Service.
+
+
+## Levantar el ecosistema con Docker Compose
+### Requisitos
+- El archivo `antifraud-service-0.0.1.jar` debe existir en `devops/antifraud/`
+
+Ubícate en la carpeta `devops` (donde está el `docker-compose.yml`) y ejecuta:
+
+```bash
+ ./up_all_services.sh
+```
+> Si tienes problemas de permisos:
+```bash
+ chmod +x up_all_services.sh
+```
+
+#### Windows
+Si usas **Git Bash** (recomendado):
+```bash
+sh up_all_services.sh
+```
+Si usas **PowerShell o CMD**:
+```bash
+docker compose up -d --build
+```
+
+---
+
+### 2) Detener y limpiar el entorno
+
+#### Linux / macOS
+```bash
+./down_all_services.sh
+```
+
+#### Windows (Git Bash)
+```bash
+sh down_all_services.sh
+```
+> Si tienes problemas de permisos:
+```bash
+ chmod +x down_all_services.sh
+```
+---
+
+
+Ver contenedores activos:
+
+```bash
+ docker ps
+```
+Para ver logs:
+
+```bash
+ docker compose logs -f
+```
+---
+
+## Probar endpoints REST
+
+### Crear transacción aprobada
+```bash
+curl --location --request POST 'http://localhost:8080/transactions' \
+--header 'Content-Type: application/json' \
+--data-raw '{
+ "accountExternalIdDebit": "11111111-1111-1111-1111-111111111111",
+ "accountExternalIdCredit": "22222222-2222-2222-2222-222222222222",
+ "transferTypeId": 1,
+ "value": 150.75
+}'
+```
+
+Response:
+```json
+{
+ "transactionExternalId": "83a3d905-ee35-4201-9958-0fde4d7267b8"
+}
+```
+
+
+### Crear transacción rechazada
+```bash
+curl --location --request POST 'http://localhost:8080/transactions' \
+--header 'Content-Type: application/json' \
+--data-raw '{
+ "accountExternalIdDebit": "11111111-1111-1111-1111-111111111111",
+ "accountExternalIdCredit": "22222222-2222-2222-2222-222222222222",
+ "transferTypeId": 1,
+ "value": 1500.00
+}'
+```
+
+Response:
```json
{
- "accountExternalIdDebit": "Guid",
- "accountExternalIdCredit": "Guid",
- "tranferTypeId": 1,
- "value": 120
+ "transactionExternalId": "e65b68b9-b0a2-4f19-b816-ae226992601c"
}
```
+---
+
-2. Resource to retrieve a transaction
+### Obtener transacción por ID
+```bash
+curl --location --request GET \
+'http://localhost:8080/transactions/{transactionExternalId}'
+```
+
+Response:
```json
{
- "transactionExternalId": "Guid",
+ "transactionExternalId": "83a3d905-ee35-4201-9958-0fde4d7267b8",
"transactionType": {
- "name": ""
+ "name": "TRANSFER"
},
"transactionStatus": {
- "name": ""
+ "name": "APPROVED"
},
- "value": 120,
- "createdAt": "Date"
+ "value": 150.75,
+ "createdAt": "2025-12-29T00:00:00Z"
}
```
-## Optional
+---
-You can use any approach to store transaction data but you should consider that we may deal with high volume scenarios where we have a huge amount of writes and reads for the same data at the same time. How would you tackle this requirement?
+## Docker Compose
+
+Levantar todo el entorno:
+```bash
+docker compose up --build
+```
+## o el siguiente comando ubicado en el directorio devops
+
+```bash
+ ./up_all_services.sh
+```
-You can use Graphql;
+Servicios:
+- Transaction Service → 8080
+- Antifraud Service → 8081
+- PostgreSQL → 5432
+- Kafka → 9092
-# Send us your challenge
+---
-When you finish your challenge, after forking a repository, you **must** open a pull request to our repository. There are no limitations to the implementation, you can follow the programming paradigm, modularization, and style that you feel is the most appropriate solution.
+## Stack Tecnológico
-If you have any questions, please let us know.
\ No newline at end of file
+- **Java 17** & **Spring Boot 3.5 (WebFlux)**
+- **Project Reactor**: Manejo de flujos no bloqueantes (Mono/Flux).
+- **R2DBC**: Driver de base de datos reactivo para PostgreSQL.
+- **Kafka**: Mensajería asíncrona optimizada para alto volumen.
+- **PostgreSQL**: Persistencia relacional.
+- **Docker & Docker Compose**: Orquestación local.
+- **JUnit 5 & JaCoCo**: Pruebas unitarias y cobertura de código.
diff --git a/devops/Dockerfile b/devops/Dockerfile
new file mode 100644
index 0000000..8d21248
--- /dev/null
+++ b/devops/Dockerfile
@@ -0,0 +1,19 @@
+FROM eclipse-temurin:17-jre-alpine
+
+# Install curl
+RUN apk add --no-cache curl
+
+RUN addgroup -S spring && adduser -S spring -G spring
+USER spring
+
+WORKDIR /app
+
+ARG JAR_FILE=target/*.jar
+COPY ${JAR_FILE} app.jar
+
+ENV JAVA_OPTS="-Xms256m -Xmx512m"
+ENV SPRING_PROFILES_ACTIVE=default
+
+EXPOSE 8080
+
+ENTRYPOINT ["sh", "-c", "java $JAVA_OPTS -jar app.jar"]
\ No newline at end of file
diff --git a/devops/antifraud/Dockerfile b/devops/antifraud/Dockerfile
new file mode 100644
index 0000000..2d9b4e9
--- /dev/null
+++ b/devops/antifraud/Dockerfile
@@ -0,0 +1,13 @@
+FROM eclipse-temurin:17-jre-alpine
+
+RUN addgroup -S spring && adduser -S spring -G spring
+USER spring
+
+WORKDIR /app
+
+COPY antifraud-service-0.0.1.jar app.jar
+
+ENV JAVA_OPTS=""
+EXPOSE 8081
+
+ENTRYPOINT ["sh", "-c", "java $JAVA_OPTS -jar app.jar"]
diff --git a/devops/antifraud/antifraud-service-0.0.1.jar b/devops/antifraud/antifraud-service-0.0.1.jar
new file mode 100644
index 0000000..c4337d2
Binary files /dev/null and b/devops/antifraud/antifraud-service-0.0.1.jar differ
diff --git a/devops/docker-compose.yml b/devops/docker-compose.yml
new file mode 100644
index 0000000..e4a569f
--- /dev/null
+++ b/devops/docker-compose.yml
@@ -0,0 +1,100 @@
+services:
+ postgres:
+ image: postgres:14
+ container_name: postgres
+ ports:
+ - "5432:5432"
+ environment:
+ POSTGRES_DB: transactionsdb
+ POSTGRES_USER: postgres
+ POSTGRES_PASSWORD: postgres
+ volumes:
+ - pgdata:/var/lib/postgresql/data
+
+ zookeeper:
+ image: confluentinc/cp-zookeeper:5.5.3
+ container_name: zookeeper
+ environment:
+ ZOOKEEPER_CLIENT_PORT: 2181
+ healthcheck:
+ test: ["CMD", "bash", "-c", "echo ruok | nc -w 2 localhost 2181 | grep imok"]
+ interval: 10s
+ timeout: 5s
+ retries: 10
+
+ kafka:
+ image: confluentinc/cp-enterprise-kafka:5.5.3
+ container_name: kafka
+ depends_on: [zookeeper]
+ environment:
+ KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"
+ KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
+ KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
+ KAFKA_BROKER_ID: 1
+ KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+ KAFKA_JMX_PORT: 9991
+ ports:
+ - "9092:9092"
+ healthcheck:
+ test: ["CMD", "bash", "-c", "kafka-topics --bootstrap-server kafka:29092 --list >/dev/null 2>&1"]
+ interval: 10s
+ timeout: 5s
+ retries: 10
+
+ # Crea tópicos necesarios para el flujo
+ kafka-init:
+ image: confluentinc/cp-enterprise-kafka:5.5.3
+ container_name: kafka-init
+ depends_on: [kafka]
+ command: >
+ bash -c "
+ kafka-topics --bootstrap-server kafka:29092 --create --if-not-exists --topic transaction.created --partitions 3 --replication-factor 1 &&
+ kafka-topics --bootstrap-server kafka:29092 --create --if-not-exists --topic transaction.status.updated --partitions 3 --replication-factor 1
+ "
+ restart: "no"
+
+ transaction-service:
+ build:
+ context: ..
+ dockerfile: devops/Dockerfile
+ image: transaction-service:local
+ container_name: transaction-service
+ depends_on:
+ - postgres
+ - kafka
+ - kafka-init
+ restart: on-failure
+ environment:
+ SPRING_R2DBC_URL: r2dbc:postgresql://postgres:5432/transactionsdb
+ SPRING_R2DBC_POOL_MAX_SIZE: 50
+ # URL para JDBC (Flyway)
+ SPRING_DATASOURCE_URL: jdbc:postgresql://postgres:5432/transactionsdb
+ SPRING_DATASOURCE_USERNAME: postgres
+ SPRING_DATASOURCE_PASSWORD: postgres
+ TX_CREATED_TOPIC: "transaction.created"
+ TX_STATUS_UPDATED_TOPIC: "transaction.status.updated"
+ SPRING_KAFKA_BOOTSTRAP_SERVERS: kafka:29092
+ SPRING_KAFKA_CONSUMER_GROUP_ID: transaction-service-group
+ ports:
+ - "8080:8080"
+
+ antifraud-service:
+ build:
+ context: ./antifraud
+ dockerfile: Dockerfile
+ image: antifraud-service:local
+ container_name: antifraud-service
+ depends_on:
+ - kafka
+ - kafka-init
+ environment:
+ #ANTIFRAUD_LIMIT configurable#
+ ANTIFRAUD_LIMIT: 1000
+ TOPIC_CREATED: "transaction.created"
+ TOPIC_UPDATED: "transaction.status.updated"
+ SPRING_KAFKA_BOOTSTRAP_SERVERS: kafka:29092
+ SPRING_KAFKA_CONSUMER_AUTO_OFFSET_RESET: earliest
+ ports:
+ - "8081:8081"
+volumes:
+ pgdata:
\ No newline at end of file
diff --git a/devops/down_all_services.sh b/devops/down_all_services.sh
new file mode 100755
index 0000000..73152ab
--- /dev/null
+++ b/devops/down_all_services.sh
@@ -0,0 +1,7 @@
+#!/bin/bash
+echo "Deteniendo servicios de Yape Challenge..."
+
+# Detiene contenedores y elimina volumen
+docker compose down -v
+
+echo "success: Servicios detenidos correctamente."
\ No newline at end of file
diff --git a/devops/up_all_services.sh b/devops/up_all_services.sh
new file mode 100755
index 0000000..21f2d8d
--- /dev/null
+++ b/devops/up_all_services.sh
@@ -0,0 +1,11 @@
+#!/bin/bash
+echo "Iniciando infraestructura de Yape Challenge..."
+
+docker compose up -d postgres zookeeper kafka kafka-init
+
+echo "Inicializando kafka..."
+sleep 10
+
+docker compose up -d transaction-service antifraud-service
+
+echo "success: Transaction API: http://localhost:8080 | Antifraud: http://localhost:8081"
\ No newline at end of file
diff --git a/docker-compose.yml b/docker-compose.yml
deleted file mode 100644
index 6e9a9c5..0000000
--- a/docker-compose.yml
+++ /dev/null
@@ -1,25 +0,0 @@
-version: "3.7"
-services:
- postgres:
- image: postgres:14
- ports:
- - "5432:5432"
- environment:
- - POSTGRES_USER=postgres
- - POSTGRES_PASSWORD=postgres
- zookeeper:
- image: confluentinc/cp-zookeeper:5.5.3
- environment:
- ZOOKEEPER_CLIENT_PORT: 2181
- kafka:
- image: confluentinc/cp-enterprise-kafka:5.5.3
- depends_on: [zookeeper]
- environment:
- KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"
- KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
- KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
- KAFKA_BROKER_ID: 1
- KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
- KAFKA_JMX_PORT: 9991
- ports:
- - 9092:9092
\ No newline at end of file
diff --git a/mvnw b/mvnw
new file mode 100755
index 0000000..bd8896b
--- /dev/null
+++ b/mvnw
@@ -0,0 +1,295 @@
+#!/bin/sh
+# ----------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+# ----------------------------------------------------------------------------
+
+# ----------------------------------------------------------------------------
+# Apache Maven Wrapper startup batch script, version 3.3.4
+#
+# Optional ENV vars
+# -----------------
+# JAVA_HOME - location of a JDK home dir, required when download maven via java source
+# MVNW_REPOURL - repo url base for downloading maven distribution
+# MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+# MVNW_VERBOSE - true: enable verbose log; debug: trace the mvnw script; others: silence the output
+# ----------------------------------------------------------------------------
+
+set -euf
+[ "${MVNW_VERBOSE-}" != debug ] || set -x
+
+# OS specific support.
+native_path() { printf %s\\n "$1"; }
+case "$(uname)" in
+CYGWIN* | MINGW*)
+ [ -z "${JAVA_HOME-}" ] || JAVA_HOME="$(cygpath --unix "$JAVA_HOME")"
+ native_path() { cygpath --path --windows "$1"; }
+ ;;
+esac
+
+# set JAVACMD and JAVACCMD
+set_java_home() {
+ # For Cygwin and MinGW, ensure paths are in Unix format before anything is touched
+ if [ -n "${JAVA_HOME-}" ]; then
+ if [ -x "$JAVA_HOME/jre/sh/java" ]; then
+ # IBM's JDK on AIX uses strange locations for the executables
+ JAVACMD="$JAVA_HOME/jre/sh/java"
+ JAVACCMD="$JAVA_HOME/jre/sh/javac"
+ else
+ JAVACMD="$JAVA_HOME/bin/java"
+ JAVACCMD="$JAVA_HOME/bin/javac"
+
+ if [ ! -x "$JAVACMD" ] || [ ! -x "$JAVACCMD" ]; then
+ echo "The JAVA_HOME environment variable is not defined correctly, so mvnw cannot run." >&2
+ echo "JAVA_HOME is set to \"$JAVA_HOME\", but \"\$JAVA_HOME/bin/java\" or \"\$JAVA_HOME/bin/javac\" does not exist." >&2
+ return 1
+ fi
+ fi
+ else
+ JAVACMD="$(
+ 'set' +e
+ 'unset' -f command 2>/dev/null
+ 'command' -v java
+ )" || :
+ JAVACCMD="$(
+ 'set' +e
+ 'unset' -f command 2>/dev/null
+ 'command' -v javac
+ )" || :
+
+ if [ ! -x "${JAVACMD-}" ] || [ ! -x "${JAVACCMD-}" ]; then
+ echo "The java/javac command does not exist in PATH nor is JAVA_HOME set, so mvnw cannot run." >&2
+ return 1
+ fi
+ fi
+}
+
+# hash string like Java String::hashCode
+hash_string() {
+ str="${1:-}" h=0
+ while [ -n "$str" ]; do
+ char="${str%"${str#?}"}"
+ h=$(((h * 31 + $(LC_CTYPE=C printf %d "'$char")) % 4294967296))
+ str="${str#?}"
+ done
+ printf %x\\n $h
+}
+
+verbose() { :; }
+[ "${MVNW_VERBOSE-}" != true ] || verbose() { printf %s\\n "${1-}"; }
+
+die() {
+ printf %s\\n "$1" >&2
+ exit 1
+}
+
+trim() {
+ # MWRAPPER-139:
+ # Trims trailing and leading whitespace, carriage returns, tabs, and linefeeds.
+ # Needed for removing poorly interpreted newline sequences when running in more
+ # exotic environments such as mingw bash on Windows.
+ printf "%s" "${1}" | tr -d '[:space:]'
+}
+
+scriptDir="$(dirname "$0")"
+scriptName="$(basename "$0")"
+
+# parse distributionUrl and optional distributionSha256Sum, requires .mvn/wrapper/maven-wrapper.properties
+while IFS="=" read -r key value; do
+ case "${key-}" in
+ distributionUrl) distributionUrl=$(trim "${value-}") ;;
+ distributionSha256Sum) distributionSha256Sum=$(trim "${value-}") ;;
+ esac
+done <"$scriptDir/.mvn/wrapper/maven-wrapper.properties"
+[ -n "${distributionUrl-}" ] || die "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
+
+case "${distributionUrl##*/}" in
+maven-mvnd-*bin.*)
+ MVN_CMD=mvnd.sh _MVNW_REPO_PATTERN=/maven/mvnd/
+ case "${PROCESSOR_ARCHITECTURE-}${PROCESSOR_ARCHITEW6432-}:$(uname -a)" in
+ *AMD64:CYGWIN* | *AMD64:MINGW*) distributionPlatform=windows-amd64 ;;
+ :Darwin*x86_64) distributionPlatform=darwin-amd64 ;;
+ :Darwin*arm64) distributionPlatform=darwin-aarch64 ;;
+ :Linux*x86_64*) distributionPlatform=linux-amd64 ;;
+ *)
+ echo "Cannot detect native platform for mvnd on $(uname)-$(uname -m), use pure java version" >&2
+ distributionPlatform=linux-amd64
+ ;;
+ esac
+ distributionUrl="${distributionUrl%-bin.*}-$distributionPlatform.zip"
+ ;;
+maven-mvnd-*) MVN_CMD=mvnd.sh _MVNW_REPO_PATTERN=/maven/mvnd/ ;;
+*) MVN_CMD="mvn${scriptName#mvnw}" _MVNW_REPO_PATTERN=/org/apache/maven/ ;;
+esac
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-,maven-mvnd--}/
+[ -z "${MVNW_REPOURL-}" ] || distributionUrl="$MVNW_REPOURL$_MVNW_REPO_PATTERN${distributionUrl#*"$_MVNW_REPO_PATTERN"}"
+distributionUrlName="${distributionUrl##*/}"
+distributionUrlNameMain="${distributionUrlName%.*}"
+distributionUrlNameMain="${distributionUrlNameMain%-bin}"
+MAVEN_USER_HOME="${MAVEN_USER_HOME:-${HOME}/.m2}"
+MAVEN_HOME="${MAVEN_USER_HOME}/wrapper/dists/${distributionUrlNameMain-}/$(hash_string "$distributionUrl")"
+
+exec_maven() {
+ unset MVNW_VERBOSE MVNW_USERNAME MVNW_PASSWORD MVNW_REPOURL || :
+ exec "$MAVEN_HOME/bin/$MVN_CMD" "$@" || die "cannot exec $MAVEN_HOME/bin/$MVN_CMD"
+}
+
+if [ -d "$MAVEN_HOME" ]; then
+ verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+ exec_maven "$@"
+fi
+
+case "${distributionUrl-}" in
+*?-bin.zip | *?maven-mvnd-?*-?*.zip) ;;
+*) die "distributionUrl is not valid, must match *-bin.zip or maven-mvnd-*.zip, but found '${distributionUrl-}'" ;;
+esac
+
+# prepare tmp dir
+if TMP_DOWNLOAD_DIR="$(mktemp -d)" && [ -d "$TMP_DOWNLOAD_DIR" ]; then
+ clean() { rm -rf -- "$TMP_DOWNLOAD_DIR"; }
+ trap clean HUP INT TERM EXIT
+else
+ die "cannot create temp dir"
+fi
+
+mkdir -p -- "${MAVEN_HOME%/*}"
+
+# Download and Install Apache Maven
+verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+verbose "Downloading from: $distributionUrl"
+verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+# select .zip or .tar.gz
+if ! command -v unzip >/dev/null; then
+ distributionUrl="${distributionUrl%.zip}.tar.gz"
+ distributionUrlName="${distributionUrl##*/}"
+fi
+
+# verbose opt
+__MVNW_QUIET_WGET=--quiet __MVNW_QUIET_CURL=--silent __MVNW_QUIET_UNZIP=-q __MVNW_QUIET_TAR=''
+[ "${MVNW_VERBOSE-}" != true ] || __MVNW_QUIET_WGET='' __MVNW_QUIET_CURL='' __MVNW_QUIET_UNZIP='' __MVNW_QUIET_TAR=v
+
+# normalize http auth
+case "${MVNW_PASSWORD:+has-password}" in
+'') MVNW_USERNAME='' MVNW_PASSWORD='' ;;
+has-password) [ -n "${MVNW_USERNAME-}" ] || MVNW_USERNAME='' MVNW_PASSWORD='' ;;
+esac
+
+if [ -z "${MVNW_USERNAME-}" ] && command -v wget >/dev/null; then
+ verbose "Found wget ... using wget"
+ wget ${__MVNW_QUIET_WGET:+"$__MVNW_QUIET_WGET"} "$distributionUrl" -O "$TMP_DOWNLOAD_DIR/$distributionUrlName" || die "wget: Failed to fetch $distributionUrl"
+elif [ -z "${MVNW_USERNAME-}" ] && command -v curl >/dev/null; then
+ verbose "Found curl ... using curl"
+ curl ${__MVNW_QUIET_CURL:+"$__MVNW_QUIET_CURL"} -f -L -o "$TMP_DOWNLOAD_DIR/$distributionUrlName" "$distributionUrl" || die "curl: Failed to fetch $distributionUrl"
+elif set_java_home; then
+ verbose "Falling back to use Java to download"
+ javaSource="$TMP_DOWNLOAD_DIR/Downloader.java"
+ targetZip="$TMP_DOWNLOAD_DIR/$distributionUrlName"
+ cat >"$javaSource" <<-END
+ public class Downloader extends java.net.Authenticator
+ {
+ protected java.net.PasswordAuthentication getPasswordAuthentication()
+ {
+ return new java.net.PasswordAuthentication( System.getenv( "MVNW_USERNAME" ), System.getenv( "MVNW_PASSWORD" ).toCharArray() );
+ }
+ public static void main( String[] args ) throws Exception
+ {
+ setDefault( new Downloader() );
+ java.nio.file.Files.copy( java.net.URI.create( args[0] ).toURL().openStream(), java.nio.file.Paths.get( args[1] ).toAbsolutePath().normalize() );
+ }
+ }
+ END
+ # For Cygwin/MinGW, switch paths to Windows format before running javac and java
+ verbose " - Compiling Downloader.java ..."
+ "$(native_path "$JAVACCMD")" "$(native_path "$javaSource")" || die "Failed to compile Downloader.java"
+ verbose " - Running Downloader.java ..."
+ "$(native_path "$JAVACMD")" -cp "$(native_path "$TMP_DOWNLOAD_DIR")" Downloader "$distributionUrl" "$(native_path "$targetZip")"
+fi
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+if [ -n "${distributionSha256Sum-}" ]; then
+ distributionSha256Result=false
+ if [ "$MVN_CMD" = mvnd.sh ]; then
+ echo "Checksum validation is not supported for maven-mvnd." >&2
+ echo "Please disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties." >&2
+ exit 1
+ elif command -v sha256sum >/dev/null; then
+ if echo "$distributionSha256Sum $TMP_DOWNLOAD_DIR/$distributionUrlName" | sha256sum -c - >/dev/null 2>&1; then
+ distributionSha256Result=true
+ fi
+ elif command -v shasum >/dev/null; then
+ if echo "$distributionSha256Sum $TMP_DOWNLOAD_DIR/$distributionUrlName" | shasum -a 256 -c >/dev/null 2>&1; then
+ distributionSha256Result=true
+ fi
+ else
+ echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." >&2
+ echo "Please install either command, or disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties." >&2
+ exit 1
+ fi
+ if [ $distributionSha256Result = false ]; then
+ echo "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised." >&2
+ echo "If you updated your Maven version, you need to update the specified distributionSha256Sum property." >&2
+ exit 1
+ fi
+fi
+
+# unzip and move
+if command -v unzip >/dev/null; then
+ unzip ${__MVNW_QUIET_UNZIP:+"$__MVNW_QUIET_UNZIP"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -d "$TMP_DOWNLOAD_DIR" || die "failed to unzip"
+else
+ tar xzf${__MVNW_QUIET_TAR:+"$__MVNW_QUIET_TAR"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -C "$TMP_DOWNLOAD_DIR" || die "failed to untar"
+fi
+
+# Find the actual extracted directory name (handles snapshots where filename != directory name)
+actualDistributionDir=""
+
+# First try the expected directory name (for regular distributions)
+if [ -d "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" ]; then
+ if [ -f "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain/bin/$MVN_CMD" ]; then
+ actualDistributionDir="$distributionUrlNameMain"
+ fi
+fi
+
+# If not found, search for any directory with the Maven executable (for snapshots)
+if [ -z "$actualDistributionDir" ]; then
+ # enable globbing to iterate over items
+ set +f
+ for dir in "$TMP_DOWNLOAD_DIR"/*; do
+ if [ -d "$dir" ]; then
+ if [ -f "$dir/bin/$MVN_CMD" ]; then
+ actualDistributionDir="$(basename "$dir")"
+ break
+ fi
+ fi
+ done
+ set -f
+fi
+
+if [ -z "$actualDistributionDir" ]; then
+ verbose "Contents of $TMP_DOWNLOAD_DIR:"
+ verbose "$(ls -la "$TMP_DOWNLOAD_DIR")"
+ die "Could not find Maven distribution directory in extracted archive"
+fi
+
+verbose "Found extracted Maven distribution directory: $actualDistributionDir"
+printf %s\\n "$distributionUrl" >"$TMP_DOWNLOAD_DIR/$actualDistributionDir/mvnw.url"
+mv -- "$TMP_DOWNLOAD_DIR/$actualDistributionDir" "$MAVEN_HOME" || [ -d "$MAVEN_HOME" ] || die "fail to move MAVEN_HOME"
+
+clean || :
+exec_maven "$@"
diff --git a/mvnw.cmd b/mvnw.cmd
new file mode 100644
index 0000000..92450f9
--- /dev/null
+++ b/mvnw.cmd
@@ -0,0 +1,189 @@
+<# : batch portion
+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements. See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership. The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License. You may obtain a copy of the License at
+@REM
+@REM http://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied. See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Apache Maven Wrapper startup batch script, version 3.3.4
+@REM
+@REM Optional ENV vars
+@REM MVNW_REPOURL - repo url base for downloading maven distribution
+@REM MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+@REM MVNW_VERBOSE - true: enable verbose log; others: silence the output
+@REM ----------------------------------------------------------------------------
+
+@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
+@SET __MVNW_CMD__=
+@SET __MVNW_ERROR__=
+@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
+@SET PSModulePath=
+@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
+ IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
+)
+@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
+@SET __MVNW_PSMODULEP_SAVE=
+@SET __MVNW_ARG0_NAME__=
+@SET MVNW_USERNAME=
+@SET MVNW_PASSWORD=
+@IF NOT "%__MVNW_CMD__%"=="" ("%__MVNW_CMD__%" %*)
+@echo Cannot start maven from wrapper >&2 && exit /b 1
+@GOTO :EOF
+: end batch / begin powershell #>
+
+$ErrorActionPreference = "Stop"
+if ($env:MVNW_VERBOSE -eq "true") {
+ $VerbosePreference = "Continue"
+}
+
+# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
+$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
+if (!$distributionUrl) {
+ Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
+}
+
+switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
+ "maven-mvnd-*" {
+ $USE_MVND = $true
+ $distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
+ $MVN_CMD = "mvnd.cmd"
+ break
+ }
+ default {
+ $USE_MVND = $false
+ $MVN_CMD = $script -replace '^mvnw','mvn'
+ break
+ }
+}
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-,maven-mvnd--}/
+if ($env:MVNW_REPOURL) {
+ $MVNW_REPO_PATTERN = if ($USE_MVND -eq $False) { "/org/apache/maven/" } else { "/maven/mvnd/" }
+ $distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace "^.*$MVNW_REPO_PATTERN",'')"
+}
+$distributionUrlName = $distributionUrl -replace '^.*/',''
+$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
+
+$MAVEN_M2_PATH = "$HOME/.m2"
+if ($env:MAVEN_USER_HOME) {
+ $MAVEN_M2_PATH = "$env:MAVEN_USER_HOME"
+}
+
+if (-not (Test-Path -Path $MAVEN_M2_PATH)) {
+ New-Item -Path $MAVEN_M2_PATH -ItemType Directory | Out-Null
+}
+
+$MAVEN_WRAPPER_DISTS = $null
+if ((Get-Item $MAVEN_M2_PATH).Target[0] -eq $null) {
+ $MAVEN_WRAPPER_DISTS = "$MAVEN_M2_PATH/wrapper/dists"
+} else {
+ $MAVEN_WRAPPER_DISTS = (Get-Item $MAVEN_M2_PATH).Target[0] + "/wrapper/dists"
+}
+
+$MAVEN_HOME_PARENT = "$MAVEN_WRAPPER_DISTS/$distributionUrlNameMain"
+$MAVEN_HOME_NAME = ([System.Security.Cryptography.SHA256]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
+$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
+
+if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
+ Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+ Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
+ exit $?
+}
+
+if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
+ Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
+}
+
+# prepare tmp dir
+$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
+$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
+$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
+trap {
+ if ($TMP_DOWNLOAD_DIR.Exists) {
+ try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+ catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+ }
+}
+
+New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
+
+# Download and Install Apache Maven
+Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+Write-Verbose "Downloading from: $distributionUrl"
+Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+$webclient = New-Object System.Net.WebClient
+if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
+ $webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
+}
+[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
+$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
+if ($distributionSha256Sum) {
+ if ($USE_MVND) {
+ Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
+ }
+ Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
+ if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
+ Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
+ }
+}
+
+# unzip and move
+Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
+
+# Find the actual extracted directory name (handles snapshots where filename != directory name)
+$actualDistributionDir = ""
+
+# First try the expected directory name (for regular distributions)
+$expectedPath = Join-Path "$TMP_DOWNLOAD_DIR" "$distributionUrlNameMain"
+$expectedMvnPath = Join-Path "$expectedPath" "bin/$MVN_CMD"
+if ((Test-Path -Path $expectedPath -PathType Container) -and (Test-Path -Path $expectedMvnPath -PathType Leaf)) {
+ $actualDistributionDir = $distributionUrlNameMain
+}
+
+# If not found, search for any directory with the Maven executable (for snapshots)
+if (!$actualDistributionDir) {
+ Get-ChildItem -Path "$TMP_DOWNLOAD_DIR" -Directory | ForEach-Object {
+ $testPath = Join-Path $_.FullName "bin/$MVN_CMD"
+ if (Test-Path -Path $testPath -PathType Leaf) {
+ $actualDistributionDir = $_.Name
+ }
+ }
+}
+
+if (!$actualDistributionDir) {
+ Write-Error "Could not find Maven distribution directory in extracted archive"
+}
+
+Write-Verbose "Found extracted Maven distribution directory: $actualDistributionDir"
+Rename-Item -Path "$TMP_DOWNLOAD_DIR/$actualDistributionDir" -NewName $MAVEN_HOME_NAME | Out-Null
+try {
+ Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
+} catch {
+ if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
+ Write-Error "fail to move MAVEN_HOME"
+ }
+} finally {
+ try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+ catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+}
+
+Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..2071733
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,193 @@
+
+
+ 4.0.0
+
+
+ org.springframework.boot
+ spring-boot-starter-parent
+ 3.4.1
+
+
+ com.yape
+ transaction-service
+ 0.0.1
+ Transaction Service
+ Yape Code Challenge - Transaction Service
+
+
+ 17
+ UTF-8
+ 3.25.3
+ 0.8.12
+ 2.16.1
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-webflux
+
+
+
+ org.springframework.boot
+ spring-boot-starter-validation
+
+
+
+ org.springframework.boot
+ spring-boot-starter-actuator
+
+
+
+ org.springframework.boot
+ spring-boot-starter-data-r2dbc
+
+
+
+ org.postgresql
+ r2dbc-postgresql
+ runtime
+
+
+
+ io.r2dbc
+ r2dbc-pool
+
+
+
+ org.flywaydb
+ flyway-core
+
+
+ org.flywaydb
+ flyway-database-postgresql
+
+
+ org.postgresql
+ postgresql
+ runtime
+
+
+
+ org.springframework.kafka
+ spring-kafka
+
+
+
+ io.projectreactor.kafka
+ reactor-kafka
+
+
+
+ org.projectlombok
+ lombok
+ true
+
+
+
+ commons-io
+ commons-io
+ ${commons-io.version}
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+
+ io.projectreactor
+ reactor-test
+ test
+
+
+
+ org.springframework.kafka
+ spring-kafka-test
+ test
+
+
+
+ org.assertj
+ assertj-core
+ ${assertj.version}
+ test
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ true ${java.version}
+
+
+
+ org.apache.maven.plugins
+ maven-surefire-plugin
+
+
+ org.jacoco
+ jacoco-maven-plugin
+ ${jacoco.version}
+
+
+
+ prepare-agent
+
+
+
+ report
+ test
+
+ report
+
+
+
+ jacoco-check
+
+ check
+
+
+
+
+ BUNDLE
+
+
+ LINE
+ COVEREDRATIO
+ 0.80
+
+
+
+
+
+
+
+
+
+ **/*Application.class
+ **/infrastructure/config/**
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+ org.projectlombok
+ lombok
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/MainApplication.java b/src/main/java/com/yape/transaction/MainApplication.java
new file mode 100644
index 0000000..02a0193
--- /dev/null
+++ b/src/main/java/com/yape/transaction/MainApplication.java
@@ -0,0 +1,13 @@
+package com.yape.transaction;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class MainApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(MainApplication.class, args);
+ }
+
+}
diff --git a/src/main/java/com/yape/transaction/application/dto/CreateTransactionCommand.java b/src/main/java/com/yape/transaction/application/dto/CreateTransactionCommand.java
new file mode 100644
index 0000000..d61739e
--- /dev/null
+++ b/src/main/java/com/yape/transaction/application/dto/CreateTransactionCommand.java
@@ -0,0 +1,13 @@
+package com.yape.transaction.application.dto;
+
+import java.math.BigDecimal;
+import java.util.UUID;
+
+public record CreateTransactionCommand(
+ UUID transactionExternalId,
+ UUID accountExternalIdDebit,
+ UUID accountExternalIdCredit,
+ Integer transferTypeId,
+ BigDecimal value
+) {
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/application/dto/TransactionView.java b/src/main/java/com/yape/transaction/application/dto/TransactionView.java
new file mode 100644
index 0000000..d03282c
--- /dev/null
+++ b/src/main/java/com/yape/transaction/application/dto/TransactionView.java
@@ -0,0 +1,15 @@
+package com.yape.transaction.application.dto;
+
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+public record TransactionView(
+ UUID transactionExternalId,
+ String transactionTypeName,
+ String transactionStatusName,
+ BigDecimal value,
+ Instant createdAt
+) {
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/application/service/TransactionService.java b/src/main/java/com/yape/transaction/application/service/TransactionService.java
new file mode 100644
index 0000000..ec1c52e
--- /dev/null
+++ b/src/main/java/com/yape/transaction/application/service/TransactionService.java
@@ -0,0 +1,80 @@
+package com.yape.transaction.application.service;
+
+import com.yape.transaction.application.dto.CreateTransactionCommand;
+import com.yape.transaction.application.dto.TransactionView;
+import com.yape.transaction.application.usecase.CreateTransactionUseCase;
+import com.yape.transaction.application.usecase.GetTransactionUseCase;
+import com.yape.transaction.application.usecase.UpdateTransactionStatusUseCase;
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.model.TransactionStatus;
+import com.yape.transaction.domain.model.TransactionType;
+import com.yape.transaction.domain.port.TransactionEventPublisherPort;
+import com.yape.transaction.domain.port.TransactionRepositoryPort;
+import com.yape.transaction.infrastructure.inbound.rest.exception.BusinessException;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+public class TransactionService implements CreateTransactionUseCase,
+ GetTransactionUseCase,
+ UpdateTransactionStatusUseCase {
+
+ private final TransactionRepositoryPort transactionRepository;
+ private final TransactionEventPublisherPort transactionEventPublisher;
+
+ public TransactionService(TransactionRepositoryPort transactionRepository,
+ TransactionEventPublisherPort transactionEventPublisher) {
+ this.transactionRepository = transactionRepository;
+ this.transactionEventPublisher = transactionEventPublisher;
+ }
+
+ @Override
+ public Mono create(CreateTransactionCommand command) {
+ TransactionType transactionType = TransactionType.fromId(command.transferTypeId());
+
+ UUID newTransactionId = UUID.randomUUID();
+
+ Transaction transaction = Transaction.createPending(
+ newTransactionId,
+ command.accountExternalIdDebit(),
+ command.accountExternalIdCredit(),
+ transactionType,
+ command.value()
+ );
+
+ return transactionRepository.save(transaction)
+ .flatMap(savedTransaction ->
+ transactionEventPublisher.publishTransactionCreated(savedTransaction)
+ .thenReturn(savedTransaction)
+ );
+ }
+
+ @Override
+ public Mono getById(UUID transactionExternalId) {
+ return transactionRepository.findById(transactionExternalId)
+ .map(transaction -> new TransactionView(
+ transaction.getId(),
+ transaction.getType().name(),
+ transaction.getStatus().name(),
+ transaction.getValue(),
+ transaction.getCreatedAt()
+ ))
+ .switchIfEmpty(Mono.error(new BusinessException("Transaction not found: " + transactionExternalId)));
+ }
+
+ @Override
+ public Mono updateStatus(UUID transactionExternalId, String newStatusName) {
+ return transactionRepository.findById(transactionExternalId)
+ .flatMap(transaction -> {
+ TransactionStatus newStatus = TransactionStatus.valueOf(newStatusName.toUpperCase());
+
+ if (transaction.getStatus() != TransactionStatus.PENDING) {
+ return Mono.empty();
+ }
+
+ transaction.updateStatus(newStatus);
+ return transactionRepository.save(transaction);
+ })
+ .then();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/application/usecase/CreateTransactionUseCase.java b/src/main/java/com/yape/transaction/application/usecase/CreateTransactionUseCase.java
new file mode 100644
index 0000000..17a8c9d
--- /dev/null
+++ b/src/main/java/com/yape/transaction/application/usecase/CreateTransactionUseCase.java
@@ -0,0 +1,9 @@
+package com.yape.transaction.application.usecase;
+
+import com.yape.transaction.application.dto.CreateTransactionCommand;
+import com.yape.transaction.domain.model.Transaction;
+import reactor.core.publisher.Mono;
+
+public interface CreateTransactionUseCase {
+ Mono create(CreateTransactionCommand createTransactionCommand);
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/application/usecase/GetTransactionUseCase.java b/src/main/java/com/yape/transaction/application/usecase/GetTransactionUseCase.java
new file mode 100644
index 0000000..b651831
--- /dev/null
+++ b/src/main/java/com/yape/transaction/application/usecase/GetTransactionUseCase.java
@@ -0,0 +1,10 @@
+package com.yape.transaction.application.usecase;
+
+import com.yape.transaction.application.dto.TransactionView;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+public interface GetTransactionUseCase {
+ Mono getById(UUID transactionExternalId);
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/application/usecase/UpdateTransactionStatusUseCase.java b/src/main/java/com/yape/transaction/application/usecase/UpdateTransactionStatusUseCase.java
new file mode 100644
index 0000000..7832112
--- /dev/null
+++ b/src/main/java/com/yape/transaction/application/usecase/UpdateTransactionStatusUseCase.java
@@ -0,0 +1,9 @@
+package com.yape.transaction.application.usecase;
+
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+public interface UpdateTransactionStatusUseCase {
+ Mono updateStatus(UUID transactionExternalId, String transactionNewStatusName);
+}
diff --git a/src/main/java/com/yape/transaction/domain/model/Transaction.java b/src/main/java/com/yape/transaction/domain/model/Transaction.java
new file mode 100644
index 0000000..1cbae44
--- /dev/null
+++ b/src/main/java/com/yape/transaction/domain/model/Transaction.java
@@ -0,0 +1,42 @@
+package com.yape.transaction.domain.model;
+
+import lombok.Getter;
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+@Getter
+public class Transaction {
+ private final UUID id;
+ private final UUID accountExternalIdDebit;
+ private final UUID accountExternalIdCredit;
+ private final TransactionType type;
+ private final BigDecimal value;
+ private final Instant createdAt;
+ private TransactionStatus status;
+
+ public Transaction(UUID id, UUID debit, UUID credit, TransactionType type,
+ BigDecimal value, TransactionStatus status, Instant createdAt) {
+ this.id = id;
+ this.accountExternalIdDebit = debit;
+ this.accountExternalIdCredit = credit;
+ this.type = type;
+ this.value = value;
+ this.status = status;
+ this.createdAt = createdAt;
+ }
+
+ public void updateStatus(TransactionStatus newStatus) {
+ if (newStatus == null) throw new IllegalArgumentException("status is required");
+ this.status = newStatus;
+ }
+
+ public static Transaction createPending(UUID transactionId, UUID debit, UUID credit,
+ TransactionType type, BigDecimal value) {
+ return new Transaction(transactionId, debit, credit, type, value,
+ TransactionStatus.PENDING, Instant.now());
+ }
+
+ public void approve() { this.status = TransactionStatus.APPROVED; }
+ public void reject() { this.status = TransactionStatus.REJECTED; }
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/domain/model/TransactionStatus.java b/src/main/java/com/yape/transaction/domain/model/TransactionStatus.java
new file mode 100644
index 0000000..b4da76c
--- /dev/null
+++ b/src/main/java/com/yape/transaction/domain/model/TransactionStatus.java
@@ -0,0 +1,7 @@
+package com.yape.transaction.domain.model;
+
+public enum TransactionStatus {
+ PENDING,
+ APPROVED,
+ REJECTED
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/domain/model/TransactionType.java b/src/main/java/com/yape/transaction/domain/model/TransactionType.java
new file mode 100644
index 0000000..bb09d4e
--- /dev/null
+++ b/src/main/java/com/yape/transaction/domain/model/TransactionType.java
@@ -0,0 +1,26 @@
+package com.yape.transaction.domain.model;
+
+import lombok.Getter;
+
+import java.util.Arrays;
+
+@Getter
+public enum TransactionType {
+ TRANSFER(1);
+
+ private final int id;
+
+ TransactionType(int id) {
+ this.id = id;
+ }
+
+ public static TransactionType fromId(Integer id) {
+ if (id == null) {
+ throw new IllegalArgumentException("Transaction type ID cannot be null");
+ }
+ return Arrays.stream(values())
+ .filter(type -> type.id == id)
+ .findFirst()
+ .orElseThrow(() -> new IllegalArgumentException("Unsupported transaction type ID: " + id));
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/domain/port/TransactionEventPublisherPort.java b/src/main/java/com/yape/transaction/domain/port/TransactionEventPublisherPort.java
new file mode 100644
index 0000000..137972d
--- /dev/null
+++ b/src/main/java/com/yape/transaction/domain/port/TransactionEventPublisherPort.java
@@ -0,0 +1,8 @@
+package com.yape.transaction.domain.port;
+
+import com.yape.transaction.domain.model.Transaction;
+import reactor.core.publisher.Mono;
+
+public interface TransactionEventPublisherPort {
+ Mono publishTransactionCreated(Transaction transaction);
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/domain/port/TransactionRepositoryPort.java b/src/main/java/com/yape/transaction/domain/port/TransactionRepositoryPort.java
new file mode 100644
index 0000000..a7f1990
--- /dev/null
+++ b/src/main/java/com/yape/transaction/domain/port/TransactionRepositoryPort.java
@@ -0,0 +1,13 @@
+package com.yape.transaction.domain.port;
+
+import com.yape.transaction.domain.model.Transaction;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+public interface TransactionRepositoryPort {
+
+ Mono save(Transaction transaction);
+
+ Mono findById(UUID transactionExternalId);
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/infrastructure/config/ApplicationBeansConfig.java b/src/main/java/com/yape/transaction/infrastructure/config/ApplicationBeansConfig.java
new file mode 100644
index 0000000..2504e46
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/config/ApplicationBeansConfig.java
@@ -0,0 +1,25 @@
+package com.yape.transaction.infrastructure.config;
+
+import com.yape.transaction.application.service.TransactionService;
+import com.yape.transaction.domain.port.TransactionEventPublisherPort;
+import com.yape.transaction.domain.port.TransactionRepositoryPort;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ApplicationBeansConfig {
+
+ @Bean
+ public TransactionService transactionService(TransactionRepositoryPort transactionRepository,
+ TransactionEventPublisherPort transactionEventPublisher) {
+ return new TransactionService(transactionRepository, transactionEventPublisher);
+ }
+
+ @Bean(name = "kafkaTopicsProperties")
+ @ConfigurationProperties(prefix = "yape.kafka.topics")
+ public KafkaTopicsProperties kafkaTopicsProperties() {
+ return new KafkaTopicsProperties();
+ }
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/infrastructure/config/KafkaConsumerConfig.java b/src/main/java/com/yape/transaction/infrastructure/config/KafkaConsumerConfig.java
new file mode 100644
index 0000000..87820fd
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/config/KafkaConsumerConfig.java
@@ -0,0 +1,41 @@
+package com.yape.transaction.infrastructure.config;
+
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.common.serialization.StringDeserializer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.env.Environment;
+import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
+import org.springframework.kafka.core.*;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class KafkaConsumerConfig {
+
+ @Bean
+ public ConsumerFactory consumerFactory(Environment env) {
+ String bootstrapServers = env.getProperty("spring.kafka.bootstrap-servers", "kafka:29092");
+
+ Map props = new HashMap<>();
+ props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+ props.put(ConsumerConfig.GROUP_ID_CONFIG, "transaction-service");
+ props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
+
+ props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+ props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+
+ return new DefaultKafkaConsumerFactory<>(props);
+ }
+
+ @Bean
+ public ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory(
+ ConsumerFactory consumerFactory
+ ) {
+ ConcurrentKafkaListenerContainerFactory factory =
+ new ConcurrentKafkaListenerContainerFactory<>();
+ factory.setConsumerFactory(consumerFactory);
+ return factory;
+ }
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/config/KafkaProducerConfig.java b/src/main/java/com/yape/transaction/infrastructure/config/KafkaProducerConfig.java
new file mode 100644
index 0000000..543405a
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/config/KafkaProducerConfig.java
@@ -0,0 +1,32 @@
+package com.yape.transaction.infrastructure.config;
+
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.common.serialization.StringSerializer;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.core.*;
+import org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate;
+import org.springframework.kafka.support.serializer.JsonSerializer;
+import reactor.kafka.sender.SenderOptions;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class KafkaProducerConfig {
+
+ @Bean
+ public ReactiveKafkaProducerTemplate reactiveKafkaProducerTemplate(
+ @Value("${spring.kafka.bootstrap-servers}") String bootstrapServers) {
+ Map props = new HashMap<>();
+ props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+ props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+ props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
+ props.put(JsonSerializer.ADD_TYPE_INFO_HEADERS, false);
+
+ SenderOptions senderOptions = SenderOptions.create(props);
+ return new ReactiveKafkaProducerTemplate<>(senderOptions);
+ }
+
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/config/KafkaTopicsProperties.java b/src/main/java/com/yape/transaction/infrastructure/config/KafkaTopicsProperties.java
new file mode 100644
index 0000000..6be3792
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/config/KafkaTopicsProperties.java
@@ -0,0 +1,30 @@
+package com.yape.transaction.infrastructure.config;
+
+import jakarta.validation.constraints.NotBlank;
+import org.springframework.validation.annotation.Validated;
+
+@Validated
+public class KafkaTopicsProperties {
+
+ @NotBlank
+ private String transactionCreated;
+
+ @NotBlank
+ private String transactionStatusUpdated;
+
+ public String getTransactionCreated() {
+ return transactionCreated;
+ }
+
+ public void setTransactionCreated(String transactionCreated) {
+ this.transactionCreated = transactionCreated;
+ }
+
+ public String getTransactionStatusUpdated() {
+ return transactionStatusUpdated;
+ }
+
+ public void setTransactionStatusUpdated(String transactionStatusUpdated) {
+ this.transactionStatusUpdated = transactionStatusUpdated;
+ }
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedConsumer.java b/src/main/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedConsumer.java
new file mode 100644
index 0000000..db6a931
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedConsumer.java
@@ -0,0 +1,42 @@
+package com.yape.transaction.infrastructure.inbound.kafka;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.yape.transaction.application.usecase.UpdateTransactionStatusUseCase;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+public class TransactionStatusUpdatedConsumer {
+
+ private static final Logger log = LoggerFactory.getLogger(TransactionStatusUpdatedConsumer.class);
+
+ private final UpdateTransactionStatusUseCase useCase;
+ private final ObjectMapper objectMapper;
+
+ public TransactionStatusUpdatedConsumer(UpdateTransactionStatusUseCase useCase,
+ ObjectMapper objectMapper) {
+ this.useCase = useCase;
+ this.objectMapper = objectMapper;
+ }
+
+ @KafkaListener(
+ topics = "#{@kafkaTopicsProperties.transactionStatusUpdated}",
+ groupId = "${spring.kafka.consumer.group-id}"
+ )
+ public void onMessage(String message) {
+ Mono.just(message)
+ .handle((msg, sink) -> {
+ try {
+ sink.next(objectMapper.readValue(msg, TransactionStatusUpdatedEvent.class));
+ } catch (Exception exception) {
+ sink.error(new RuntimeException("Error deserializando: " + exception.getMessage()));
+ }
+ })
+ .flatMap(event -> useCase.updateStatus(event.getTransactionExternalId(), event.getStatus()))
+ .doOnError(error -> log.error("Error crítico procesando evento de estado: {}", error.getMessage()))
+ .subscribe();
+ }
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedEvent.java b/src/main/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedEvent.java
new file mode 100644
index 0000000..306f313
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedEvent.java
@@ -0,0 +1,21 @@
+package com.yape.transaction.infrastructure.inbound.kafka;
+
+import lombok.Getter;
+
+import java.util.UUID;
+
+@Getter
+public class TransactionStatusUpdatedEvent {
+
+ private UUID transactionExternalId;
+ private String status;
+
+ public TransactionStatusUpdatedEvent() {
+ }
+
+ public TransactionStatusUpdatedEvent(UUID transactionExternalId, String status) {
+ this.transactionExternalId = transactionExternalId;
+ this.status = status;
+ }
+
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/controller/TransactionController.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/controller/TransactionController.java
new file mode 100644
index 0000000..4657cb5
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/controller/TransactionController.java
@@ -0,0 +1,57 @@
+package com.yape.transaction.infrastructure.inbound.rest.controller;
+
+import com.yape.transaction.application.dto.CreateTransactionCommand;
+import com.yape.transaction.application.usecase.CreateTransactionUseCase;
+import com.yape.transaction.application.usecase.GetTransactionUseCase;
+import com.yape.transaction.infrastructure.inbound.rest.dto.CreateTransactionRequest;
+import com.yape.transaction.infrastructure.inbound.rest.dto.TransactionResponse;
+import com.yape.transaction.infrastructure.inbound.rest.mapper.TransactionMapper;
+import jakarta.validation.Valid;
+import org.springframework.http.HttpStatus;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+@RestController
+@Validated
+@RequestMapping("/transactions")
+public class TransactionController {
+ private final CreateTransactionUseCase createTransactionUseCase;
+ private final GetTransactionUseCase getTransactionUseCase;
+ private final TransactionMapper transactionMapper;
+
+ public TransactionController(CreateTransactionUseCase createTransactionUseCase,
+ TransactionMapper transactionMapper,
+ GetTransactionUseCase getTransactionUseCase) {
+ this.createTransactionUseCase = createTransactionUseCase;
+ this.transactionMapper = transactionMapper;
+ this.getTransactionUseCase = getTransactionUseCase;
+ }
+
+ @PostMapping
+ @ResponseStatus(HttpStatus.CREATED)
+ public Mono create(@Valid @RequestBody CreateTransactionRequest request) {
+ return createTransactionUseCase.create(new CreateTransactionCommand(
+ request.transactionExternalId(),
+ request.accountExternalIdDebit(),
+ request.accountExternalIdCredit(),
+ request.transferTypeId(),
+ request.value()
+ )).map(transactionMapper::toResponse);
+ }
+
+ @GetMapping("/{id}")
+ public Mono getById(@PathVariable UUID id) {
+ return getTransactionUseCase.getById(id)
+ .map(view -> new TransactionResponse(
+ view.transactionExternalId(),
+ new TransactionResponse.TransactionTypeResponse(view.transactionTypeName()),
+ new TransactionResponse.TransactionStatusResponse(view.transactionStatusName()),
+ view.value(),
+ view.createdAt()
+ ));
+ }
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/dto/CreateTransactionRequest.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/dto/CreateTransactionRequest.java
new file mode 100644
index 0000000..0ce0f80
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/dto/CreateTransactionRequest.java
@@ -0,0 +1,25 @@
+package com.yape.transaction.infrastructure.inbound.rest.dto;
+
+import jakarta.validation.constraints.DecimalMin;
+import jakarta.validation.constraints.NotNull;
+
+import java.math.BigDecimal;
+import java.util.UUID;
+
+public record CreateTransactionRequest(
+ @NotNull
+ UUID transactionExternalId,
+
+ @NotNull
+ UUID accountExternalIdDebit,
+
+ @NotNull
+ UUID accountExternalIdCredit,
+
+ @NotNull
+ Integer transferTypeId,
+
+ @NotNull
+ @DecimalMin(value = "0.01")
+ BigDecimal value
+) {}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/dto/TransactionResponse.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/dto/TransactionResponse.java
new file mode 100644
index 0000000..1ec6208
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/dto/TransactionResponse.java
@@ -0,0 +1,16 @@
+package com.yape.transaction.infrastructure.inbound.rest.dto;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+public record TransactionResponse(
+ UUID transactionExternalId,
+ TransactionTypeResponse transactionType,
+ TransactionStatusResponse transactionStatus,
+ BigDecimal value,
+ Instant createdAt
+) {
+ public record TransactionTypeResponse(String name) {}
+ public record TransactionStatusResponse(String name) {}
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/ApiExceptionHandler.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/ApiExceptionHandler.java
new file mode 100644
index 0000000..1d78018
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/ApiExceptionHandler.java
@@ -0,0 +1,46 @@
+package com.yape.transaction.infrastructure.inbound.rest.exception;
+
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.http.server.reactive.ServerHttpRequest;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.bind.support.WebExchangeBindException;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RestControllerAdvice
+public class ApiExceptionHandler {
+
+
+ @ExceptionHandler(WebExchangeBindException.class)
+ public ResponseEntity handleValidation(WebExchangeBindException exception) {
+ List fieldErrorItems = exception.getBindingResult().getFieldErrors()
+ .stream()
+ .map(fieldError -> new FieldErrorItem(fieldError.getField(), fieldError.getDefaultMessage()))
+ .collect(Collectors.toList());
+
+ return ResponseEntity.badRequest()
+ .body(ErrorResponse.of("Solicitud inválida", fieldErrorItems));
+ }
+
+ @ExceptionHandler(DataIntegrityViolationException.class)
+ public ResponseEntity handleConflict(DataIntegrityViolationException exception) {
+ return ResponseEntity.status(HttpStatus.CONFLICT)
+ .body(ErrorResponse.of("La transacción ya existe"));
+ }
+
+ @ExceptionHandler(BusinessException.class)
+ public ResponseEntity handleBusiness(BusinessException businessException) {
+ return ResponseEntity.status(HttpStatus.BAD_REQUEST)
+ .body(ErrorResponse.of(businessException.getMessage()));
+ }
+
+ @ExceptionHandler(Exception.class)
+ public ResponseEntity handleGeneric(Exception exception, ServerHttpRequest serverHttpRequest) {
+ return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
+ .body(ErrorResponse.of("Error interno del servidor"));
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/BusinessException.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/BusinessException.java
new file mode 100644
index 0000000..cf2251d
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/BusinessException.java
@@ -0,0 +1,5 @@
+package com.yape.transaction.infrastructure.inbound.rest.exception;
+
+public class BusinessException extends RuntimeException {
+ public BusinessException(String message) { super(message); }
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/ErrorResponse.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/ErrorResponse.java
new file mode 100644
index 0000000..9753df1
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/ErrorResponse.java
@@ -0,0 +1,35 @@
+package com.yape.transaction.infrastructure.inbound.rest.exception;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.util.List;
+
+@Getter
+@Setter
+@NoArgsConstructor
+public class ErrorResponse {
+
+ private String message;
+ private List errors;
+
+ public ErrorResponse(String message) {
+ this.message = message;
+ }
+
+ public ErrorResponse(String message, List errors) {
+ this.message = message;
+ this.errors = errors;
+ }
+
+ public static ErrorResponse of(String message) {
+ return new ErrorResponse(message);
+ }
+
+ public static ErrorResponse of(String message, List errors) {
+ return new ErrorResponse(message, (errors == null || errors.isEmpty()) ? null : errors);
+ }
+
+
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/FieldErrorItem.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/FieldErrorItem.java
new file mode 100644
index 0000000..710b4bc
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/exception/FieldErrorItem.java
@@ -0,0 +1,16 @@
+package com.yape.transaction.infrastructure.inbound.rest.exception;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+public class FieldErrorItem {
+
+ private String field;
+ private String message;
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/inbound/rest/mapper/TransactionMapper.java b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/mapper/TransactionMapper.java
new file mode 100644
index 0000000..1195faa
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/inbound/rest/mapper/TransactionMapper.java
@@ -0,0 +1,19 @@
+package com.yape.transaction.infrastructure.inbound.rest.mapper;
+
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.infrastructure.inbound.rest.dto.TransactionResponse;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TransactionMapper {
+
+ public TransactionResponse toResponse(Transaction transaction) {
+ return new TransactionResponse(
+ transaction.getId(),
+ new TransactionResponse.TransactionTypeResponse(transaction.getType().name()),
+ new TransactionResponse.TransactionStatusResponse(transaction.getStatus().name()),
+ transaction.getValue(),
+ transaction.getCreatedAt()
+ );
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionCreatedEvent.java b/src/main/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionCreatedEvent.java
new file mode 100644
index 0000000..29abce8
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionCreatedEvent.java
@@ -0,0 +1,39 @@
+package com.yape.transaction.infrastructure.outbound.kafka;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+@Getter
+public class TransactionCreatedEvent {
+
+ private UUID transactionExternalId;
+ private UUID accountExternalIdDebit;
+ private UUID accountExternalIdCredit;
+ private Integer transferTypeId;
+ private BigDecimal value;
+ private Instant createdAt;
+
+ public TransactionCreatedEvent() {
+ }
+
+ public TransactionCreatedEvent(
+ UUID transactionExternalId,
+ UUID accountExternalIdDebit,
+ UUID accountExternalIdCredit,
+ Integer transferTypeId,
+ BigDecimal value,
+ Instant createdAt
+ ) {
+ this.transactionExternalId = transactionExternalId;
+ this.accountExternalIdDebit = accountExternalIdDebit;
+ this.accountExternalIdCredit = accountExternalIdCredit;
+ this.transferTypeId = transferTypeId;
+ this.value = value;
+ this.createdAt = createdAt;
+ }
+
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionEventProducer.java b/src/main/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionEventProducer.java
new file mode 100644
index 0000000..276a8fe
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionEventProducer.java
@@ -0,0 +1,43 @@
+package com.yape.transaction.infrastructure.outbound.kafka;
+
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.port.TransactionEventPublisherPort;
+import com.yape.transaction.infrastructure.config.KafkaTopicsProperties;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+public class TransactionEventProducer implements TransactionEventPublisherPort {
+
+ private final KafkaTemplate kafkaTemplate;
+ private final KafkaTopicsProperties topics;
+
+ public TransactionEventProducer(KafkaTemplate kafkaTemplate,
+ KafkaTopicsProperties topics) {
+ this.kafkaTemplate = kafkaTemplate;
+ this.topics = topics;
+ }
+
+ @Override
+ public Mono publishTransactionCreated(Transaction transaction) {
+
+ TransactionCreatedEvent transactionCreatedEvent = new TransactionCreatedEvent(
+ transaction.getId(),
+ transaction.getAccountExternalIdDebit(),
+ transaction.getAccountExternalIdCredit(),
+ transaction.getType().getId(),
+ transaction.getValue(),
+ transaction.getCreatedAt()
+ );
+
+ return Mono.fromCompletionStage(() ->
+ kafkaTemplate.send(
+ topics.getTransactionCreated(),
+ transaction.getId().toString(),
+ transactionCreatedEvent
+ )
+ ).then();
+ }
+
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionEntity.java b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionEntity.java
new file mode 100644
index 0000000..40d9700
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionEntity.java
@@ -0,0 +1,54 @@
+package com.yape.transaction.infrastructure.outbound.persistence;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.annotation.Transient;
+import org.springframework.data.domain.Persistable;
+import org.springframework.data.relational.core.mapping.Column;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+@Table("transactions")
+@Getter
+@Setter
+@NoArgsConstructor
+public class TransactionEntity implements Persistable {
+
+ @Id
+ private UUID id;
+ @Column("account_external_id_debit")
+ private UUID accountExternalIdDebit;
+ @Column("account_external_id_credit")
+ private UUID accountExternalIdCredit;
+ private String type;
+ private String status;
+ private BigDecimal value;
+ @Column("created_at")
+ private Instant createdAt;
+
+ @Transient
+ private boolean isNewRecord = false;
+
+ public TransactionEntity(UUID id, UUID accountExternalIdDebit, UUID accountExternalIdCredit,
+ String type, String status, BigDecimal value,
+ Instant createdAt, boolean isNewRecord) {
+ this.id = id;
+ this.accountExternalIdDebit = accountExternalIdDebit;
+ this.accountExternalIdCredit = accountExternalIdCredit;
+ this.type = type;
+ this.status = status;
+ this.value = value;
+ this.createdAt = createdAt;
+ this.isNewRecord = isNewRecord;
+ }
+
+ @Override
+ public boolean isNew() {
+ return isNewRecord;
+ }
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionR2dbcRepository.java b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionR2dbcRepository.java
new file mode 100644
index 0000000..bafcba7
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionR2dbcRepository.java
@@ -0,0 +1,8 @@
+package com.yape.transaction.infrastructure.outbound.persistence;
+
+import org.springframework.data.repository.reactive.ReactiveCrudRepository;
+
+import java.util.UUID;
+
+public interface TransactionR2dbcRepository extends ReactiveCrudRepository {
+}
diff --git a/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionRepositoryAdapter.java b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionRepositoryAdapter.java
new file mode 100644
index 0000000..97a8d06
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/TransactionRepositoryAdapter.java
@@ -0,0 +1,36 @@
+package com.yape.transaction.infrastructure.outbound.persistence;
+
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.port.TransactionRepositoryPort;
+import com.yape.transaction.infrastructure.outbound.persistence.mapper.TransactionPersistenceMapper;
+import org.springframework.stereotype.Repository;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+@Repository
+public class TransactionRepositoryAdapter implements TransactionRepositoryPort {
+
+ private final TransactionR2dbcRepository transactionR2dbcRepository;
+ private final TransactionPersistenceMapper mapper;
+
+ public TransactionRepositoryAdapter(TransactionR2dbcRepository transactionR2dbcRepository,
+ TransactionPersistenceMapper mapper) {
+ this.transactionR2dbcRepository = transactionR2dbcRepository;
+ this.mapper = mapper;
+ }
+
+ @Override
+ public Mono save(Transaction transaction) {
+ TransactionEntity entity = mapper.toEntity(transaction);
+
+ return transactionR2dbcRepository.save(entity)
+ .map(mapper::toDomain);
+ }
+
+ @Override
+ public Mono findById(UUID transactionExternalId) {
+ return transactionR2dbcRepository.findById(transactionExternalId)
+ .map(mapper::toDomain);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/mapper/TransactionPersistenceMapper.java b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/mapper/TransactionPersistenceMapper.java
new file mode 100644
index 0000000..b1149d1
--- /dev/null
+++ b/src/main/java/com/yape/transaction/infrastructure/outbound/persistence/mapper/TransactionPersistenceMapper.java
@@ -0,0 +1,36 @@
+package com.yape.transaction.infrastructure.outbound.persistence.mapper;
+
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.model.TransactionStatus;
+import com.yape.transaction.domain.model.TransactionType;
+import com.yape.transaction.infrastructure.outbound.persistence.TransactionEntity;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TransactionPersistenceMapper {
+
+ public TransactionEntity toEntity(Transaction domain) {
+ return new TransactionEntity(
+ domain.getId(),
+ domain.getAccountExternalIdDebit(),
+ domain.getAccountExternalIdCredit(),
+ domain.getType().name(),
+ domain.getStatus().name(),
+ domain.getValue(),
+ domain.getCreatedAt(),
+ domain.getStatus() == TransactionStatus.PENDING
+ );
+ }
+
+ public Transaction toDomain(TransactionEntity entity) {
+ return new Transaction(
+ entity.getId(),
+ entity.getAccountExternalIdDebit(),
+ entity.getAccountExternalIdCredit(),
+ TransactionType.valueOf(entity.getType()),
+ entity.getValue(),
+ TransactionStatus.valueOf(entity.getStatus()),
+ entity.getCreatedAt()
+ );
+ }
+}
\ No newline at end of file
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
new file mode 100644
index 0000000..ecaf4a2
--- /dev/null
+++ b/src/main/resources/application.yml
@@ -0,0 +1,48 @@
+server:
+ port: ${SERVER_PORT:8080}
+
+spring:
+ r2dbc:
+ url: r2dbc:postgresql://${DB_HOST:localhost}:${DB_PORT:5432}/${DB_NAME:transactionsdb}
+ username: ${DB_USERNAME:postgres}
+ password: ${DB_PASSWORD:postgres}
+ pool:
+ initial-size: 10
+ max-size: 50
+ max-idle-time: 30m
+ validation-query: SELECT 1
+
+ datasource:
+ url: jdbc:postgresql://${DB_HOST:localhost}:${DB_PORT:5432}/${DB_NAME:transactionsdb}
+ username: ${DB_USERNAME:postgres}
+ password: ${DB_PASSWORD:postgres}
+ driver-class-name: org.postgresql.Driver
+
+ flyway:
+ enabled: true
+ locations: classpath:db/migration
+
+ kafka:
+ producer:
+ acks: all
+ retries: 3
+ enable.idempotence: true
+ consumer:
+ group-id: ${TX_GROUP_ID:transaction-service}
+ auto-offset-reset: latest
+ enable-auto-commit: false
+ isolation-level: read_committed
+ bootstrap-servers: ${SPRING_KAFKA_BOOTSTRAP_SERVERS:localhost:9092}
+
+yape:
+ kafka:
+ topics:
+ transaction-created: ${TX_CREATED_TOPIC:transaction.created}
+ transaction-status-updated: ${TX_STATUS_UPDATED_TOPIC:transaction.status.updated}
+
+
+management:
+ endpoints:
+ web:
+ exposure:
+ include: health, info, metrics
\ No newline at end of file
diff --git a/src/main/resources/db/migration/v1_create_transactions_table.sql b/src/main/resources/db/migration/v1_create_transactions_table.sql
new file mode 100644
index 0000000..ec0b014
--- /dev/null
+++ b/src/main/resources/db/migration/v1_create_transactions_table.sql
@@ -0,0 +1,10 @@
+CREATE TABLE transactions (
+ id UUID PRIMARY KEY, --transactionExternalId
+ account_external_id_debit UUID NOT NULL,
+ account_external_id_credit UUID NOT NULL,
+ transfer_type_id INT NOT NULL,
+ status VARCHAR(20) NOT NULL,
+ value DECIMAL(19,2) NOT NULL,
+ created_at TIMESTAMP NOT NULL
+);
+CREATE INDEX idx_transactions_created_at ON transactions(created_at);
\ No newline at end of file
diff --git a/src/test/java/com/yape/transaction/MainApplicationTests.java b/src/test/java/com/yape/transaction/MainApplicationTests.java
new file mode 100644
index 0000000..54e9105
--- /dev/null
+++ b/src/test/java/com/yape/transaction/MainApplicationTests.java
@@ -0,0 +1,11 @@
+package com.yape.transaction;
+
+import org.junit.jupiter.api.Test;
+
+class MainApplicationTests {
+
+ @Test
+ void contextLoads() {
+ }
+
+}
diff --git a/src/test/java/com/yape/transaction/application/service/TransactionServiceTest.java b/src/test/java/com/yape/transaction/application/service/TransactionServiceTest.java
new file mode 100644
index 0000000..65ec6d5
--- /dev/null
+++ b/src/test/java/com/yape/transaction/application/service/TransactionServiceTest.java
@@ -0,0 +1,214 @@
+package com.yape.transaction.application.service;
+
+import com.yape.transaction.application.dto.CreateTransactionCommand;
+import com.yape.transaction.application.dto.TransactionView;
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.model.TransactionStatus;
+import com.yape.transaction.domain.model.TransactionType;
+import com.yape.transaction.domain.port.TransactionEventPublisherPort;
+import com.yape.transaction.domain.port.TransactionRepositoryPort;
+import com.yape.transaction.infrastructure.inbound.rest.exception.BusinessException;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class TransactionServiceTest {
+
+ @Mock
+ TransactionRepositoryPort transactionRepository;
+
+ @Mock
+ TransactionEventPublisherPort transactionEventPublisher;
+
+ @InjectMocks
+ TransactionService service;
+
+ @Captor
+ ArgumentCaptor transactionCaptor;
+
+ @BeforeEach
+ void setUp() {
+
+ }
+
+ @Test
+ void returnCreatedTransactionAndPublishEvent() {
+ // given
+ UUID externalTransactionIdFromRequest = UUID.randomUUID();
+ UUID debit = UUID.randomUUID();
+ UUID credit = UUID.randomUUID();
+
+ CreateTransactionCommand command = new CreateTransactionCommand(
+ externalTransactionIdFromRequest,
+ debit,
+ credit,
+ 1,
+ new BigDecimal("25.50")
+ );
+
+ when(transactionRepository.save(any(Transaction.class)))
+ .thenAnswer(inv -> Mono.just(inv.getArgument(0)));
+
+ when(transactionEventPublisher.publishTransactionCreated(any(Transaction.class)))
+ .thenReturn(Mono.empty());
+
+ // act
+ Mono result = service.create(command);
+
+ // then
+ StepVerifier.create(result)
+ .assertNext(saved -> {
+ assertThat(saved.getId()).isNotNull();
+ assertThat(saved.getAccountExternalIdDebit()).isEqualTo(debit);
+ assertThat(saved.getAccountExternalIdCredit()).isEqualTo(credit);
+ assertThat(saved.getType()).isEqualTo(TransactionType.TRANSFER);
+ assertThat(saved.getValue()).isEqualByComparingTo("25.50");
+ assertThat(saved.getStatus()).isEqualTo(TransactionStatus.PENDING);
+ assertThat(saved.getCreatedAt()).isNotNull();
+ })
+ .verifyComplete();
+
+ verify(transactionRepository, times(1)).save(transactionCaptor.capture());
+ verify(transactionEventPublisher, times(1)).publishTransactionCreated(any(Transaction.class));
+
+
+
+ assertThat(transactionCaptor.getValue().getId()).isNotEqualTo(externalTransactionIdFromRequest);
+ }
+
+ @Test
+ void returnTransactionViewWhenTransactionExists() {
+ // given
+ UUID id = UUID.randomUUID();
+ Transaction transaction = new Transaction(
+ id,
+ UUID.randomUUID(),
+ UUID.randomUUID(),
+ TransactionType.TRANSFER,
+ new BigDecimal("10.00"),
+ TransactionStatus.APPROVED,
+ Instant.parse("2026-01-05T10:00:00Z")
+ );
+
+ when(transactionRepository.findById(id)).thenReturn(Mono.just(transaction));
+
+ // act
+ Mono result = service.getById(id);
+
+ // then
+ StepVerifier.create(result)
+ .assertNext(view -> {
+ assertThat(view.transactionExternalId()).isEqualTo(id);
+ assertThat(view.transactionTypeName()).isEqualTo("TRANSFER");
+ assertThat(view.transactionStatusName()).isEqualTo("APPROVED");
+ assertThat(view.value()).isEqualByComparingTo("10.00");
+ assertThat(view.createdAt()).isEqualTo(Instant.parse("2026-01-05T10:00:00Z"));
+ })
+ .verifyComplete();
+
+ verify(transactionRepository).findById(id);
+ }
+
+ @Test
+ void throwBusinessErrorWhenTransactionNotFound() {
+ UUID id = UUID.randomUUID();
+ when(transactionRepository.findById(id)).thenReturn(Mono.empty());
+
+ Mono result = service.getById(id);
+
+ StepVerifier.create(result)
+ .expectErrorSatisfies(err -> {
+ assertThat(err).isInstanceOf(BusinessException.class);
+ assertThat(err.getMessage()).contains("Transaction not found: " + id);
+ })
+ .verify();
+
+ verify(transactionRepository).findById(id);
+ }
+
+ @Test
+ void returnUpdatedStatusWhenTransactionIsPending() {
+ // given
+ UUID id = UUID.randomUUID();
+ Transaction transaction = Transaction.createPending(
+ id, UUID.randomUUID(), UUID.randomUUID(), TransactionType.TRANSFER, new BigDecimal("1.00")
+ );
+
+ when(transactionRepository.findById(id)).thenReturn(Mono.just(transaction));
+ when(transactionRepository.save(any(Transaction.class)))
+ .thenAnswer(inv -> Mono.just(inv.getArgument(0)));
+
+ // act
+ Mono result = service.updateStatus(id, "APPROVED");
+
+ // then
+ StepVerifier.create(result)
+ .verifyComplete();
+
+ assertThat(transaction.getStatus()).isEqualTo(TransactionStatus.APPROVED);
+ verify(transactionRepository).findById(id);
+ verify(transactionRepository).save(any(Transaction.class));
+ }
+
+ @Test
+ void returnNothingWhenTransactionIsNotPending() {
+ // given
+ UUID id = UUID.randomUUID();
+ Transaction transaction = new Transaction(
+ id, UUID.randomUUID(), UUID.randomUUID(),
+ TransactionType.TRANSFER, new BigDecimal("2.00"),
+ TransactionStatus.APPROVED, Instant.now()
+ );
+
+ when(transactionRepository.findById(id)).thenReturn(Mono.just(transaction));
+
+ // act
+ Mono result = service.updateStatus(id, "REJECTED");
+
+ // then
+ StepVerifier.create(result)
+ .verifyComplete();
+
+ assertThat(transaction.getStatus()).isEqualTo(TransactionStatus.APPROVED);
+ verify(transactionRepository).findById(id);
+ verify(transactionRepository, never()).save(any());
+ }
+
+ @Test
+ void throwErrorWhenStatusNameIsInvalid() {
+ // given
+ UUID id = UUID.randomUUID();
+ Transaction transaction = Transaction.createPending(
+ id, UUID.randomUUID(), UUID.randomUUID(), TransactionType.TRANSFER, new BigDecimal("3.00")
+ );
+
+ when(transactionRepository.findById(id)).thenReturn(Mono.just(transaction));
+
+ // act
+ Mono result = service.updateStatus(id, "NOT_A_STATUS");
+
+ // then
+ StepVerifier.create(result)
+ .expectError(IllegalArgumentException.class)
+ .verify();
+
+ verify(transactionRepository).findById(id);
+ verify(transactionRepository, never()).save(any());
+ }
+}
diff --git a/src/test/java/com/yape/transaction/domain/model/TransactionTest.java b/src/test/java/com/yape/transaction/domain/model/TransactionTest.java
new file mode 100644
index 0000000..724685f
--- /dev/null
+++ b/src/test/java/com/yape/transaction/domain/model/TransactionTest.java
@@ -0,0 +1,47 @@
+package com.yape.transaction.domain.model;
+
+import org.junit.jupiter.api.Test;
+
+import java.math.BigDecimal;
+import java.util.UUID;
+
+import static org.assertj.core.api.Assertions.*;
+
+class TransactionTest {
+
+ @Test
+ void throwErrorWhenStatusIsNull() {
+ Transaction transaction = Transaction.createPending(
+ UUID.randomUUID(), UUID.randomUUID(), UUID.randomUUID(),
+ TransactionType.TRANSFER, new BigDecimal("1.00")
+ );
+
+ assertThatThrownBy(() -> transaction.updateStatus(null))
+ .isInstanceOf(IllegalArgumentException.class)
+ .hasMessageContaining("status is required");
+ }
+
+ @Test
+ void returnApprovedStatusWhenApproveIsCalled() {
+ Transaction transaction = Transaction.createPending(
+ UUID.randomUUID(), UUID.randomUUID(), UUID.randomUUID(),
+ TransactionType.TRANSFER, new BigDecimal("1.00")
+ );
+
+ transaction.approve();
+
+ assertThat(transaction.getStatus()).isEqualTo(TransactionStatus.APPROVED);
+ }
+
+ @Test
+ void returnRejectedStatusWhenRejectIsCalled() {
+ Transaction transaction = Transaction.createPending(
+ UUID.randomUUID(), UUID.randomUUID(), UUID.randomUUID(),
+ TransactionType.TRANSFER, new BigDecimal("1.00")
+ );
+
+ transaction.reject();
+
+ assertThat(transaction.getStatus()).isEqualTo(TransactionStatus.REJECTED);
+ }
+}
diff --git a/src/test/java/com/yape/transaction/domain/model/TransactionTypeTest.java b/src/test/java/com/yape/transaction/domain/model/TransactionTypeTest.java
new file mode 100644
index 0000000..601e1e7
--- /dev/null
+++ b/src/test/java/com/yape/transaction/domain/model/TransactionTypeTest.java
@@ -0,0 +1,35 @@
+package com.yape.transaction.domain.model;
+
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.*;
+
+class TransactionTypeTest {
+
+ @Test
+ void returnTransferWhenIdIsValid() {
+ Integer id = 1;
+
+ TransactionType type = TransactionType.fromId(id);
+
+ assertThat(type).isEqualTo(TransactionType.TRANSFER);
+ }
+
+ @Test
+ void throwErrorWhenIdIsNull() {
+ Integer id = null;
+
+ assertThatThrownBy(() -> TransactionType.fromId(id))
+ .isInstanceOf(IllegalArgumentException.class)
+ .hasMessageContaining("cannot be null");
+ }
+
+ @Test
+ void throwErrorWhenIdIsNotSupported() {
+ Integer id = 99;
+
+ assertThatThrownBy(() -> TransactionType.fromId(id))
+ .isInstanceOf(IllegalArgumentException.class)
+ .hasMessageContaining("Unsupported transaction type ID: 99");
+ }
+}
diff --git a/src/test/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedConsumerTest.java b/src/test/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedConsumerTest.java
new file mode 100644
index 0000000..9e5e757
--- /dev/null
+++ b/src/test/java/com/yape/transaction/infrastructure/inbound/kafka/TransactionStatusUpdatedConsumerTest.java
@@ -0,0 +1,65 @@
+package com.yape.transaction.infrastructure.inbound.kafka;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.yape.transaction.application.usecase.UpdateTransactionStatusUseCase;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class TransactionStatusUpdatedConsumerTest {
+
+ @Mock
+ UpdateTransactionStatusUseCase useCase;
+
+ private ObjectMapper objectMapper;
+ private TransactionStatusUpdatedConsumer consumer;
+
+ @BeforeEach
+ void setUp() {
+ objectMapper = new ObjectMapper();
+ consumer = new TransactionStatusUpdatedConsumer(useCase, objectMapper);
+ }
+
+ @Test
+ void returnUpdateStatusWhenMessageIsValid() throws Exception {
+ UUID txId = UUID.randomUUID();
+ String message = objectMapper.writeValueAsString(new TransactionStatusUpdatedEvent(txId, "APPROVED"));
+
+ when(useCase.updateStatus(txId, "APPROVED")).thenReturn(Mono.empty());
+
+ consumer.onMessage(message);
+
+ verify(useCase, timeout(500).times(1)).updateStatus(txId, "APPROVED");
+ verifyNoMoreInteractions(useCase);
+ }
+
+ @Test
+ void returnNothingWhenMessageIsInvalid() {
+ String invalidJson = "{not-valid-json";
+
+ consumer.onMessage(invalidJson);
+
+ verify(useCase, after(300).never()).updateStatus(any(), any());
+ verifyNoInteractions(useCase);
+ }
+
+ @Test
+ void returnUpdateStatusWhenStatusIsLowercase() throws Exception {
+ UUID transactionID = UUID.randomUUID();
+ String message = objectMapper.writeValueAsString(new TransactionStatusUpdatedEvent(transactionID, "approved"));
+
+ when(useCase.updateStatus(transactionID, "approved")).thenReturn(Mono.empty());
+
+ consumer.onMessage(message);
+
+ verify(useCase, timeout(500).times(1)).updateStatus(transactionID, "approved");
+ }
+}
diff --git a/src/test/java/com/yape/transaction/infrastructure/inbound/rest/TransactionControllerTest.java b/src/test/java/com/yape/transaction/infrastructure/inbound/rest/TransactionControllerTest.java
new file mode 100644
index 0000000..5f903c2
--- /dev/null
+++ b/src/test/java/com/yape/transaction/infrastructure/inbound/rest/TransactionControllerTest.java
@@ -0,0 +1,133 @@
+package com.yape.transaction.infrastructure.inbound.rest.controller;
+
+import com.yape.transaction.application.dto.TransactionView;
+import com.yape.transaction.application.usecase.CreateTransactionUseCase;
+import com.yape.transaction.application.usecase.GetTransactionUseCase;
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.model.TransactionStatus;
+import com.yape.transaction.domain.model.TransactionType;
+import com.yape.transaction.infrastructure.inbound.rest.mapper.TransactionMapper;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.reactive.WebFluxTest;
+import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.context.annotation.Import;
+import org.springframework.http.MediaType;
+import org.springframework.test.web.reactive.server.WebTestClient;
+import reactor.core.publisher.Mono;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+@WebFluxTest(controllers = TransactionController.class)
+@Import({TransactionMapper.class})
+class TransactionControllerTest {
+
+ @Autowired
+ WebTestClient webTestClient;
+
+ @MockBean
+ CreateTransactionUseCase createTransactionUseCase;
+
+ @MockBean
+ GetTransactionUseCase getTransactionUseCase;
+
+ @Test
+ void returnCreatedAndBody() {
+ UUID txId = UUID.randomUUID();
+ UUID debit = UUID.randomUUID();
+ UUID credit = UUID.randomUUID();
+
+ Transaction saved = new Transaction(
+ txId, debit, credit,
+ TransactionType.TRANSFER,
+ new BigDecimal("12.34"),
+ TransactionStatus.PENDING,
+ Instant.parse("2026-01-05T10:00:00Z")
+ );
+
+ when(createTransactionUseCase.create(any())).thenReturn(Mono.just(saved));
+
+ String body = """
+ {
+ "transactionExternalId": "%s",
+ "accountExternalIdDebit": "%s",
+ "accountExternalIdCredit": "%s",
+ "transferTypeId": 1,
+ "value": 12.34
+ }
+ """.formatted(txId, debit, credit);
+
+ webTestClient.post()
+ .uri("/transactions")
+ .contentType(MediaType.APPLICATION_JSON)
+ .bodyValue(body)
+ .exchange()
+ .expectStatus().isCreated()
+ .expectHeader().contentTypeCompatibleWith(MediaType.APPLICATION_JSON)
+ .expectBody()
+ .jsonPath("$.transactionExternalId").isEqualTo(txId.toString())
+ .jsonPath("$.transactionType.name").isEqualTo("TRANSFER")
+ .jsonPath("$.transactionStatus.name").isEqualTo("PENDING")
+ .jsonPath("$.value").isEqualTo(12.34);
+
+ verify(createTransactionUseCase, times(1)).create(any());
+ }
+
+ @Test
+ void returnStatusBadRequestValueInvalid() {
+ UUID txId = UUID.randomUUID();
+ UUID debit = UUID.randomUUID();
+ UUID credit = UUID.randomUUID();
+
+ String body = """
+ {
+ "transactionExternalId": "%s",
+ "accountExternalIdDebit": "%s",
+ "accountExternalIdCredit": "%s",
+ "transferTypeId": 1,
+ "value": 0.00
+ }
+ """.formatted(txId, debit, credit);
+
+ webTestClient.post()
+ .uri("/transactions")
+ .contentType(MediaType.APPLICATION_JSON)
+ .bodyValue(body)
+ .exchange()
+ .expectStatus().isBadRequest();
+
+ verifyNoInteractions(createTransactionUseCase);
+ }
+
+ @Test
+ void returnTransactionById() {
+ UUID id = UUID.randomUUID();
+ TransactionView view = new TransactionView(
+ id,
+ "TRANSFER",
+ "APPROVED",
+ new BigDecimal("99.99"),
+ Instant.parse("2026-01-05T10:00:00Z")
+ );
+
+ when(getTransactionUseCase.getById(id)).thenReturn(Mono.just(view));
+
+ webTestClient.get()
+ .uri("/transactions/{id}", id)
+ .exchange()
+ .expectStatus().isOk()
+ .expectHeader().contentTypeCompatibleWith(MediaType.APPLICATION_JSON)
+ .expectBody()
+ .jsonPath("$.transactionExternalId").isEqualTo(id.toString())
+ .jsonPath("$.transactionType.name").isEqualTo("TRANSFER")
+ .jsonPath("$.transactionStatus.name").isEqualTo("APPROVED")
+ .jsonPath("$.value").isEqualTo(99.99);
+
+ verify(getTransactionUseCase, times(1)).getById(id);
+ }
+}
diff --git a/src/test/java/com/yape/transaction/infrastructure/inbound/rest/mapper/TransactionMapperTest.java b/src/test/java/com/yape/transaction/infrastructure/inbound/rest/mapper/TransactionMapperTest.java
new file mode 100644
index 0000000..e106cce
--- /dev/null
+++ b/src/test/java/com/yape/transaction/infrastructure/inbound/rest/mapper/TransactionMapperTest.java
@@ -0,0 +1,45 @@
+package com.yape.transaction.infrastructure.inbound.rest.mapper;
+
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.model.TransactionStatus;
+import com.yape.transaction.domain.model.TransactionType;
+import com.yape.transaction.infrastructure.inbound.rest.dto.TransactionResponse;
+import org.junit.jupiter.api.Test;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+class TransactionMapperTest {
+
+ private final TransactionMapper mapper = new TransactionMapper();
+
+ @Test
+ void returnResponseMappedFromTransaction() {
+ // given
+ UUID id = UUID.randomUUID();
+ Instant createdAt = Instant.parse("2026-01-05T10:00:00Z");
+
+ Transaction transaction = new Transaction(
+ id,
+ UUID.randomUUID(),
+ UUID.randomUUID(),
+ TransactionType.TRANSFER,
+ new BigDecimal("20.00"),
+ TransactionStatus.PENDING,
+ createdAt
+ );
+
+ // when
+ TransactionResponse response = mapper.toResponse(transaction);
+
+ // then
+ assertThat(response.transactionExternalId()).isEqualTo(id);
+ assertThat(response.transactionType().name()).isEqualTo("TRANSFER");
+ assertThat(response.transactionStatus().name()).isEqualTo("PENDING");
+ assertThat(response.value()).isEqualByComparingTo("20.00");
+ assertThat(response.createdAt()).isEqualTo(createdAt);
+ }
+}
diff --git a/src/test/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionEventProducerTest.java b/src/test/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionEventProducerTest.java
new file mode 100644
index 0000000..c72ef0f
--- /dev/null
+++ b/src/test/java/com/yape/transaction/infrastructure/outbound/kafka/TransactionEventProducerTest.java
@@ -0,0 +1,79 @@
+package com.yape.transaction.infrastructure.outbound.kafka;
+
+import com.yape.transaction.domain.model.Transaction;
+import com.yape.transaction.domain.model.TransactionStatus;
+import com.yape.transaction.domain.model.TransactionType;
+import com.yape.transaction.infrastructure.config.KafkaTopicsProperties;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.kafka.core.KafkaTemplate;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class TransactionEventProducerTest {
+
+ @Mock
+ KafkaTemplate kafkaTemplate;
+
+ @Captor
+ ArgumentCaptor