BankAdapterClient.java

package com.checkout.paymentgw.payment.client;

import com.checkout.paymentgw.payment.api.dto.PostPaymentRequest;
import com.checkout.paymentgw.payment.exception.BankErrorException;
import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import io.github.resilience4j.retry.annotation.Retry;
import io.github.resilience4j.timelimiter.annotation.TimeLimiter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.HttpServerErrorException;
import org.springframework.web.client.RestClient;

/**
 * Anti-corruption layer wrapper around {@code bank-adapter-service}. The downstream
 * service is the only place that knows the bank's wire format; this client only
 * speaks the internal canonical model.
 */
@Component
public class BankAdapterClient {

    private static final Logger LOG = LoggerFactory.getLogger(BankAdapterClient.class);

    private final RestClient http;

    public BankAdapterClient(RestClient.Builder builder,
                             org.springframework.beans.factory.annotation.Value("${payment.bank-adapter-base-url}")
                             String baseUrl) {
        this.http = builder.baseUrl(baseUrl).build();
    }

    /**
     * @throws BankErrorException for any non-2xx outcome. The caller decides
     *         whether to translate it to {@code DECLINED}, {@code FAILED}, or 5xx.
     */
    @CircuitBreaker(name = "bankAdapter")
    @Retry(name = "bankAdapter")
    @TimeLimiter(name = "bankAdapter")
    public BankAuthorisation authorise(PostPaymentRequest request) {
        LOG.debug("authorise call to bank-adapter");
        try {
            BankAuthorisation response = http.post()
                    .uri("/internal/authorise")
                    .body(request)
                    .retrieve()
                    .body(BankAuthorisation.class);
            if (response == null) {
                throw new BankErrorException(HttpStatus.BAD_GATEWAY, "empty response");
            }
            return response;
        } catch (HttpServerErrorException.ServiceUnavailable e) {
            throw new BankErrorException(HttpStatus.SERVICE_UNAVAILABLE, e.getMessage());
        } catch (HttpServerErrorException e) {
            throw new BankErrorException(HttpStatus.BAD_GATEWAY, e.getMessage());
        } catch (HttpClientErrorException e) {
            throw new BankErrorException(HttpStatus.BAD_REQUEST, e.getMessage());
        }
    }
}