Como Integrar a API de CPF em uma Aplicação Spring Boot

// pom.xml (dependências relevantes)
// spring-boot-starter-web
// spring-boot-starter-validation
// jackson-databind
// lombok (opcional)

// application.yml
// cpfhub:
// api-key: ${CPFHUB_API_KEY}
// base-url: https://api.cpfhub.io
// timeout:
// connect: 5000
// read: 10000

// CpfHubProperties.java
package com.exemplo.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "cpfhub")
public class CpfHubProperties {

    private String apiKey;
    private String baseUrl = "https://api.cpfhub.io";
    private Timeout timeout = new Timeout();

    public static class Timeout {
    private int connect = 5000;
    private int read = 10000;

    // Getters e setters
    public int getConnect() { return connect; }
    public void setConnect(int connect) { this.connect = connect; }
    public int getRead() { return read; }
    public void setRead(int read) { this.read = read; }
    }

    // Getters e setters
    public String getApiKey() { return apiKey; }
    public void setApiKey(String apiKey) { this.apiKey = apiKey; }
    public String getBaseUrl() { return baseUrl; }
    public void setBaseUrl(String baseUrl) { this.baseUrl = baseUrl; }
    public Timeout getTimeout() { return timeout; }
    public void setTimeout(Timeout timeout) { this.timeout = timeout; }
}

// CpfResponse.java
package com.exemplo.dto;

import com.fasterxml.jackson.annotation.JsonProperty;

public class CpfResponse {

    private boolean success;
    private CpfData data;

    // Getters e setters
    public boolean isSuccess() { return success; }
    public void setSuccess(boolean success) { this.success = success; }
    public CpfData getData() { return data; }
    public void setData(CpfData data) { this.data = data; }
}

// CpfData.java
public class CpfData {

    private String cpf;
    private String name;
    private String nameUpper;
    private String gender;
    private String birthDate;
    private int day;
    private int month;
    private int year;

    // Getters e setters
    public String getCpf() { return cpf; }
    public void setCpf(String cpf) { this.cpf = cpf; }
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
    public String getNameUpper() { return nameUpper; }
    public void setNameUpper(String nameUpper) { this.nameUpper = nameUpper; }
    public String getGender() { return gender; }
    public void setGender(String gender) { this.gender = gender; }
    public String getBirthDate() { return birthDate; }
    public void setBirthDate(String birthDate) { this.birthDate = birthDate; }
    public int getDay() { return day; }
    public void setDay(int day) { this.day = day; }
    public int getMonth() { return month; }
    public void setMonth(int month) { this.month = month; }
    public int getYear() { return year; }
    public void setYear(int year) { this.year = year; }
}

// CpfService.java
package com.exemplo.service;

import com.exemplo.config.CpfHubProperties;
import com.exemplo.dto.CpfData;
import com.exemplo.dto.CpfResponse;
import com.exemplo.exception.CpfNaoEncontradoException;
import com.exemplo.exception.CpfHubApiException;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.RestTemplate;

import java.time.Duration;

@Service
public class CpfService {

    private final RestTemplate restTemplate;
    private final CpfHubProperties properties;

    public CpfService(
    RestTemplateBuilder builder,
    CpfHubProperties properties) {
    this.properties = properties;
    this.restTemplate = builder
    .setConnectTimeout(Duration.ofMillis(
    properties.getTimeout().getConnect()))
    .setReadTimeout(Duration.ofMillis(
    properties.getTimeout().getRead()))
    .build();
    }

    public CpfData consultar(String cpf) {
    String cpfLimpo = cpf.replaceAll("\\D", "");
    validarFormatoCpf(cpfLimpo);

    HttpHeaders headers = new HttpHeaders();
    headers.set("x-api-key", properties.getApiKey());

    HttpEntity<Void> entity = new HttpEntity<>(headers);

    try {
    ResponseEntity<CpfResponse> response = restTemplate.exchange(
    properties.getBaseUrl() + "/cpf/" + cpfLimpo,
    HttpMethod.GET,
    entity,
    CpfResponse.class
    );

    CpfResponse body = response.getBody();
    if (body != null && body.isSuccess()) {
    return body.getData();
    }

    throw new CpfNaoEncontradoException(
    "CPF " + cpfLimpo + " nao encontrado"
    );
    } catch (HttpClientErrorException.Unauthorized e) {
    throw new CpfHubApiException("API key invalida");
    } catch (HttpClientErrorException e) {
    throw new CpfHubApiException(
    "Erro na API: " + e.getStatusCode()
    );
    }
    }

    private void validarFormatoCpf(String cpf) {
    if (cpf == null || !cpf.matches("\\d{11}")) {
    throw new IllegalArgumentException(
    "CPF deve conter 11 digitos"
    );
    }
    }
}

// CpfController.java
package com.exemplo.controller;

import com.exemplo.dto.CpfData;
import com.exemplo.service.CpfService;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import java.util.Map;

@RestController
@RequestMapping("/api/cpf")
public class CpfController {

    private final CpfService cpfService;

    public CpfController(CpfService cpfService) {
    this.cpfService = cpfService;
    }

    @GetMapping("/{cpf}")
    public ResponseEntity<Map<String, Object>> consultar(
    @PathVariable String cpf) {
    CpfData dados = cpfService.consultar(cpf);
    return ResponseEntity.ok(Map.of(
    "sucesso", true,
    "dados", dados
    ));
    }
}

// GlobalExceptionHandler.java
@RestControllerAdvice
public class GlobalExceptionHandler {

    @ExceptionHandler(CpfNaoEncontradoException.class)
    public ResponseEntity<Map<String, String>> handleCpfNaoEncontrado(
    CpfNaoEncontradoException ex) {
    return ResponseEntity.status(404).body(Map.of(
    "erro", ex.getMessage()
    ));
    }

    @ExceptionHandler(IllegalArgumentException.class)
    public ResponseEntity<Map<String, String>> handleArgumentoInvalido(
    IllegalArgumentException ex) {
    return ResponseEntity.badRequest().body(Map.of(
    "erro", ex.getMessage()
    ));
    }

    @ExceptionHandler(CpfHubApiException.class)
    public ResponseEntity<Map<String, String>> handleApiException(
    CpfHubApiException ex) {
    return ResponseEntity.status(502).body(Map.of(
    "erro", ex.getMessage()
    ));
    }
}

// CpfServiceTest.java
@SpringBootTest
class CpfServiceTest {

    @MockBean
    private RestTemplate restTemplate;

    @Autowired
    private CpfService cpfService;

    @Test
    void deveRetornarDadosQuandoCpfEncontrado() {
    CpfResponse response = new CpfResponse();
    response.setSuccess(true);
    CpfData data = new CpfData();
    data.setCpf("12345678901");
    data.setName("Joao da Silva");
    data.setGender("M");
    response.setData(data);

    // Configurar mock...

    CpfData resultado = cpfService.consultar("12345678901");
    assertEquals("Joao da Silva", resultado.getName());
    }

    @Test
    void deveLancarExcecaoQuandoCpfInvalido() {
    assertThrows(
    IllegalArgumentException.class,
    () -> cpfService.consultar("123")
    );
    }
}