Feign Client Implementation Done

Author: chinthaka-dinadasa

core-banking-service/src/main/java/com/javatodev/finance/exception/EntityNotFoundException.java

@@ -0,0 +1,11 @@
+package com.javatodev.finance.exception;
+
+public class EntityNotFoundException extends SimpleBankingGlobalException{
+    public EntityNotFoundException() {
+        super("Requested entity not present in the DB.", GlobalErrorCode.ERROR_ENTITY_NOT_FOUND);
+    }
+
+    public EntityNotFoundException (String message) {
+        super(message, GlobalErrorCode.ERROR_ENTITY_NOT_FOUND);
+    }
+}

core-banking-service/src/main/java/com/javatodev/finance/exception/ErrorResponse.java

@@ -0,0 +1,27 @@
+package com.javatodev.finance.exception;
+
+public class ErrorResponse {
+    private String code;
+    private String message;
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public ErrorResponse(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+}

core-banking-service/src/main/java/com/javatodev/finance/exception/GlobalErrorCode.java

@@ -0,0 +1,8 @@
+package com.javatodev.finance.exception;
+
+public class GlobalErrorCode {
+
+    public static final String ERROR_ENTITY_NOT_FOUND = "BANK-CORE-1000";
+    public static final String INSUFFICIENT_FUNDS = "BANK-CORE-1001";
+
+}

core-banking-service/src/main/java/com/javatodev/finance/exception/GlobalExceptionHandler.java

@@ -0,0 +1,26 @@
+package com.javatodev.finance.exception;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.servlet.mvc.method.annotation.ResponseEntityExceptionHandler;
+
+import java.util.Locale;
+
+@ControllerAdvice
+public class GlobalExceptionHandler extends ResponseEntityExceptionHandler {
+
+    @ExceptionHandler(SimpleBankingGlobalException.class)
+    protected ResponseEntity handleGlobalException(SimpleBankingGlobalException e, Locale locale) {
+        return ResponseEntity
+                .badRequest()
+                .body(new ErrorResponse(e.getCode(), e.getMessage()));
+    }
+
+    @ExceptionHandler({Exception.class})
+    protected ResponseEntity handleException(Exception e, Locale locale) {
+        return ResponseEntity
+                .badRequest()
+                .body("Exception occur inside API " + e);
+    }
+}

core-banking-service/src/main/java/com/javatodev/finance/exception/SimpleBankingGlobalException.java

@@ -0,0 +1,32 @@
+package com.javatodev.finance.exception;
+
+public class SimpleBankingGlobalException extends RuntimeException {
+
+    private String code;
+    private String message;
+
+    public SimpleBankingGlobalException() {
+    }
+
+    public SimpleBankingGlobalException(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+}

core-banking-service/src/main/java/com/javatodev/finance/service/UserService.java

@@ -1,5 +1,6 @@
 package com.javatodev.finance.service;
 
+import com.javatodev.finance.exception.EntityNotFoundException;
 import com.javatodev.finance.model.dto.User;
 import com.javatodev.finance.model.entity.UserEntity;
 import com.javatodev.finance.model.mapper.UserMapper;
@@ -19,11 +20,11 @@ public class UserService {
     private final UserRepository userRepository;
 
     public User readUser(String identification) {
-        UserEntity userEntity = userRepository.findByIdentificationNumber(identification).get();
+        UserEntity userEntity = userRepository.findByIdentificationNumber(identification).orElseThrow(EntityNotFoundException::new);
         return userMapper.convertToDto(userEntity);
     }
 
     public List<User> readUsers(Pageable pageable) {
-       return userMapper.convertToDtoList(userRepository.findAll(pageable).getContent());
+        return userMapper.convertToDtoList(userRepository.findAll(pageable).getContent());
     }
 }

core-banking-service/src/main/resources/application.yml

@@ -2,7 +2,7 @@ spring:
   application:
     name: core-banking-service
   datasource:
-    url: jdbc:mysql://localhost:3306/banking_core_services
+    url: jdbc:mysql://localhost:3306/banking_core_service
     username: root
     password: password
   jpa:

internet-banking-user-service/build.gradle

@@ -21,6 +21,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-actuator'
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
+    implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
     implementation ('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client') {
         exclude group: 'javax.ws.rs', module: 'jsr311-api'
     }

internet-banking-user-service/src/main/java/com/javatodev/finance/InternetBankingUserServiceApplication.java

@@ -3,7 +3,9 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
+@EnableFeignClients
 @EnableEurekaClient
 @SpringBootApplication
 public class InternetBankingUserServiceApplication {

internet-banking-user-service/src/main/java/com/javatodev/finance/configuration/CustomFeignClientConfiguration.java

@@ -0,0 +1,15 @@
+package com.javatodev.finance.configuration;
+
+import feign.codec.ErrorDecoder;
+import org.springframework.cloud.openfeign.FeignClientProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class CustomFeignClientConfiguration extends FeignClientProperties.FeignClientConfiguration {
+
+    @Bean
+    public ErrorDecoder errorDecoder() {
+        return new CustomFeignErrorDecoder();
+    }
+}