java-challenge Raul Ortiz

.gitignore

@@ -0,0 +1,33 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

antifraud-service/Dockerfile

@@ -0,0 +1,4 @@
+FROM openjdk:11-jre-slim
+#COPY wait-for-kafka.sh /wait-for-kafka.sh
+COPY target/antifraud-service-0.0.1-SNAPSHOT.jar antifraud-service.jar
+ENTRYPOINT ["java", "-jar", "/antifraud-service.jar"]

antifraud-service/pom.xml

@@ -0,0 +1,129 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.2.0.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.yape.antifraud</groupId>
+    <artifactId>antifraud-service</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>antifraud-service</name>
+    <description>antifraud</description>
+    <properties>
+        <java.version>11</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.28</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger2</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger-ui</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.plugin</groupId>
+            <artifactId>spring-plugin-core</artifactId>
+            <version>1.2.0.RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>javax.validation</groupId>
+            <artifactId>validation-api</artifactId>
+            <version>2.0.1.Final</version>
+        </dependency>
+        <!-- Spring Boot Starter for Kafka -->
+        <dependency>
+            <groupId>org.springframework.kafka</groupId>
+            <artifactId>spring-kafka</artifactId>
+        </dependency>
+        <!-- Reactor Kafka for reactive Kafka support -->
+        <dependency>
+            <groupId>io.projectreactor.kafka</groupId>
+            <artifactId>reactor-kafka</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.kafka</groupId>
+            <artifactId>spring-kafka</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.7.3</version>
+                <configuration>
+                    <excludes>
+                        <exclude>
+                            <groupId>org.projectlombok</groupId>
+                            <artifactId>lombok</artifactId>
+                        </exclude>
+                    </excludes>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.jacoco</groupId>
+                <artifactId>jacoco-maven-plugin</artifactId>
+                <version>0.8.5</version>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>prepare-agent</goal>
+                        </goals>
+                    </execution>
+                    <execution>
+                        <id>report</id>
+                        <phase>test</phase>
+                        <goals>
+                            <goal>report</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

antifraud-service/src/main/java/com/yape/antifraud/AntifraudServiceApplication.java

@@ -0,0 +1,38 @@
+package com.yape.antifraud;
+
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.core.env.Environment;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+@Slf4j
+@SpringBootApplication
+public class AntifraudServiceApplication {
+  static { System.setProperty("os.arch", "i686_64"); }
+  public static void main(String[] args) throws UnknownHostException {
+
+    Environment env = SpringApplication.run(AntifraudServiceApplication.class, args).getEnvironment();
+    log.info("\n----------------------------------------------------------\n\t"
+            .concat("Application '{}' is running! Access URLs:\n\t")
+            .concat("Local: \t\thttp://localhost:{}\n\t")
+            .concat("External: \thttp://{}:{}\n\t")
+            .concat("DB: \t{}\n\t")
+            .concat("Profile(s): \t{}\n----------------------------------------------------------"),
+        env.getProperty("spring.application.name"),
+        env.getProperty("server.port"),
+        InetAddress.getLocalHost().getHostAddress(),
+        env.getProperty("server.port"),
+        env.getProperty("spring.data.mongodb.database"),
+        env.getActiveProfiles());
+
+    String configServerStatus = env.getProperty("configserver.status");
+    log.info("\n----------------------------------------------------------\n\t"
+            .concat("Config Server: \t{}\n----------------------------------------------------------"),
+        configServerStatus == null ? "Not found or not setup for this application" : configServerStatus);
+  }
+
+}

antifraud-service/src/main/java/com/yape/antifraud/config/JsonMessageConverterConfig.java

@@ -0,0 +1,14 @@
+package com.yape.antifraud.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter;
+import org.springframework.kafka.support.converter.JsonMessageConverter;
+
+@Configuration
+public class JsonMessageConverterConfig {
+    @Bean
+    public JsonMessageConverter jsonMessageConverter() {
+        return new ByteArrayJsonMessageConverter();
+    }
+}

antifraud-service/src/main/java/com/yape/antifraud/config/KafkaConfig.java

@@ -0,0 +1,98 @@
+package com.yape.antifraud.config;
+
+import com.yape.antifraud.model.entity.Transaction;
+import org.apache.kafka.clients.admin.AdminClient;
+import org.apache.kafka.clients.admin.NewTopic;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.common.serialization.StringDeserializer;
+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.config.ConcurrentKafkaListenerContainerFactory;
+import org.springframework.kafka.core.ConsumerFactory;
+import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
+import org.springframework.kafka.core.KafkaAdmin;
+import org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate;
+import org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate;
+import org.springframework.kafka.support.serializer.ErrorHandlingDeserializer;
+import org.springframework.kafka.support.serializer.JsonDeserializer;
+import org.springframework.kafka.support.serializer.JsonSerializer;
+import reactor.kafka.sender.SenderOptions;
+import reactor.kafka.receiver.ReceiverOptions;
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class KafkaConfig {
+
+    @Value("${spring.kafka.bootstrap-servers}")
+    private String bootstrapServers;
+
+    @Bean
+    public ReactiveKafkaProducerTemplate<String, Transaction> reactiveKafkaProducerTemplate() {
+        Map<String, Object> configProps = new HashMap<>();
+        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
+        configProps.put(JsonDeserializer.TRUSTED_PACKAGES,"*");
+        configProps.put(JsonSerializer.ADD_TYPE_INFO_HEADERS, false); // Disable type info headers
+
+        SenderOptions<String, Transaction> senderOptions = SenderOptions.create(configProps);
+        return new ReactiveKafkaProducerTemplate<>(senderOptions);
+    }
+
+    @Bean
+    public ReactiveKafkaConsumerTemplate<String, Transaction> reactiveKafkaConsumerTemplate() {
+        Map<String, Object> props = new HashMap<>();
+        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ErrorHandlingDeserializer.class.getName());
+        props.put(ErrorHandlingDeserializer.VALUE_DESERIALIZER_CLASS, JsonDeserializer.class.getName());
+        props.put(JsonDeserializer.VALUE_DEFAULT_TYPE, Transaction.class.getName());
+        props.put(JsonDeserializer.TRUSTED_PACKAGES, "com.yape.transaction.model.entity,com.yape.antifraud.model.entity");
+
+        ReceiverOptions<String, Transaction> receiverOptions = ReceiverOptions.create(props);
+        return new ReactiveKafkaConsumerTemplate<>(receiverOptions);
+    }
+    @Bean
+    public ConsumerFactory<String, Transaction> consumerFactory() {
+        Map<String, Object> props = new HashMap<>();
+        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ErrorHandlingDeserializer.class);
+        props.put(ErrorHandlingDeserializer.VALUE_DESERIALIZER_CLASS, JsonDeserializer.class.getName());
+        props.put(JsonDeserializer.VALUE_DEFAULT_TYPE, "com.yape.antifraud.model.entity.Transaction");
+        props.put(JsonDeserializer.TRUSTED_PACKAGES, "com.yape.antifraud.model.entity");
+        return new DefaultKafkaConsumerFactory<>(props);
+    }
+    @Bean
+    public ConcurrentKafkaListenerContainerFactory<String, Transaction> kafkaListenerContainerFactory() {
+        ConcurrentKafkaListenerContainerFactory<String, Transaction> factory = new ConcurrentKafkaListenerContainerFactory<>();
+        factory.setConsumerFactory(consumerFactory());
+        return factory;
+    }
+
+    @Bean
+    public KafkaAdmin kafkaAdmin() {
+        KafkaAdmin kafkaAdmin = new KafkaAdmin(Collections.singletonMap("bootstrap.servers", bootstrapServers));
+        kafkaAdmin.setAutoCreate(true);
+        return kafkaAdmin;
+    }
+
+    @Bean
+    public AdminClient adminClient() {
+        return AdminClient.create(kafkaAdmin().getConfig());
+    }
+
+    @Bean
+    public NewTopic topic() {
+        return new NewTopic("transactionCreated", 1, (short) 1);
+    }
+
+}
+
+

antifraud-service/src/main/java/com/yape/antifraud/model/entity/Transaction.java

@@ -0,0 +1,23 @@
+package com.yape.antifraud.model.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import java.time.LocalDateTime;
+
+@Document(collection = "transactions")
+@Getter
+@Setter
+public class Transaction {
+    @Id
+    private String transactionExternalId;
+    private String accountExternalIdDebit;
+    private String accountExternalIdCredit;
+    private String transferTypeId;
+    private Double value;
+    private String status;
+    private LocalDateTime createdAt;
+
+}

antifraud-service/src/main/java/com/yape/antifraud/model/request/TransactionRequest.java

@@ -0,0 +1,18 @@
+package com.yape.antifraud.model.request;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@Builder
+public class TransactionRequest {
+
+    private String accountExternalIdDebit;
+    private String accountExternalIdCredit;
+    private Integer transferTypeId;
+    private Double value;
+}

antifraud-service/src/main/java/com/yape/antifraud/repository/TransactionRepository.java

@@ -0,0 +1,12 @@
+package com.yape.antifraud.repository;
+
+import com.yape.antifraud.model.entity.Transaction;
+import org.apache.kafka.common.protocol.types.Field;
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.UUID;
+
+@Repository
+public interface TransactionRepository extends ReactiveMongoRepository<Transaction, String> {
+}

antifraud-service/src/main/java/com/yape/antifraud/service/AntiFraudService.java

@@ -0,0 +1,8 @@
+package com.yape.antifraud.service;
+
+import com.yape.antifraud.model.entity.Transaction;
+import reactor.core.publisher.Mono;
+
+public interface AntiFraudService {
+    Mono<Transaction> validateTransaction(Transaction transaction);
+}

antifraud-service/src/main/java/com/yape/antifraud/service/KafkaConsumerService.java

@@ -0,0 +1,7 @@
+package com.yape.antifraud.service;
+
+import com.yape.antifraud.model.entity.Transaction;
+
+public interface KafkaConsumerService {
+    void consume(Transaction transaction);
+}