APIs del Día a Día: Fechas, Texto, Ficheros, HTTP y Logging

public class Vencimientos {
    private final Clock reloj;

    public Vencimientos(Clock reloj) { this.reloj = reloj; }

    public Instant fechaLimite(Duration plazo) {
        return Instant.now(reloj).plus(plazo);                 // momento exacto, en UTC
    }

    public String paraUsuario(Instant momento, ZoneId zona) {
        return DateTimeFormatter.ofPattern("d 'de' MMMM, HH:mm", Locale.forLanguageTag("es"))
            .format(momento.atZone(zona));                     // se convierte solo al mostrar
    }
}

// En el test: tiempo fijo y resultado reproducible
var reloj = Clock.fixed(Instant.parse("2026-10-28T10:00:00Z"), ZoneOffset.UTC);
var v = new Vencimientos(reloj);

assertThat(v.fechaLimite(Duration.ofHours(48)))
    .isEqualTo(Instant.parse("2026-10-30T10:00:00Z"));
assertThat(v.paraUsuario(Instant.parse("2026-10-28T10:00:00Z"), ZoneId.of("America/Mexico_City")))
    .isEqualTo("28 de octubre, 04:00");

public final class Matriculas {
    // 4 cifras + 3 consonantes sin vocales, Ñ ni Q (formato español desde 2000)
    private static final Pattern MATRICULA =
        Pattern.compile("^(?<numero>\\d{4})\\s?(?<letras>[BCDFGHJKLMNPRSTVWXYZ]{3})$");

    public static Optional<String> normalizar(String entrada) {
        if (entrada == null || entrada.length() > 10) return Optional.empty();
        Matcher m = MATRICULA.matcher(entrada.strip().toUpperCase(Locale.ROOT));
        return m.matches()
            ? Optional.of(m.group("numero") + " " + m.group("letras"))
            : Optional.empty();
    }
}

String informe = """
    Informe de matrículas
    ---------------------
    Válidas:   %d
    Inválidas: %d
    """.formatted(validas, invalidas);

var csv = new StringBuilder();
for (var t : tareas) {
    csv.append(t.id()).append(';').append(t.titulo()).append('\n');
}

Path entrada = Path.of("datos", "ventas.csv");
Path salida = Path.of("informes", "ventas-por-mes.txt");

Map<YearMonth, BigDecimal> porMes;
try (Stream<String> lineas = Files.lines(entrada, StandardCharsets.UTF_8)) {
    porMes = lineas
        .skip(1)                                          // cabecera
        .map(Venta::desdeCsv)                             // Optional<Venta>
        .flatMap(Optional::stream)                        // descarta las líneas inválidas
        .collect(Collectors.groupingBy(
            v -> YearMonth.from(v.fecha()),
            TreeMap::new,
            Collectors.reducing(BigDecimal.ZERO, Venta::importe, BigDecimal::add)));
}

Files.createDirectories(salida.getParent());
String texto = porMes.entrySet().stream()
    .map(e -> e.getKey() + ": " + e.getValue())
    .collect(Collectors.joining(System.lineSeparator()));
Files.writeString(salida, texto, StandardCharsets.UTF_8);

public class ClienteTipos {
    private static final Logger log = LoggerFactory.getLogger(ClienteTipos.class);

    private final HttpClient http = HttpClient.newBuilder()
        .connectTimeout(Duration.ofSeconds(2))
        .followRedirects(HttpClient.Redirect.NORMAL)
        .build();

    public Optional<String> tipoDeCambio(String moneda) {
        var peticion = HttpRequest.newBuilder(URI.create("https://api.ejemplo.com/tipos/" + moneda))
            .timeout(Duration.ofSeconds(3))
            .header("Accept", "application/json")
            .GET()
            .build();
        try {
            HttpResponse<String> respuesta = http.send(peticion, HttpResponse.BodyHandlers.ofString());
            if (respuesta.statusCode() != 200) {               // 4xx y 5xx no lanzan excepción
                log.warn("Tipo de cambio {} respondió {}", moneda, respuesta.statusCode());
                return Optional.empty();
            }
            return Optional.of(respuesta.body());
        } catch (HttpTimeoutException e) {
            log.warn("Timeout consultando {}", moneda, e);
            return Optional.empty();
        } catch (IOException e) {
            throw new UncheckedIOException(e);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();                // no te tragues la interrupción
            throw new IllegalStateException(e);
        }
    }
}

public class CobrosService {
    private static final Logger log = LoggerFactory.getLogger(CobrosService.class);

    public void cobrar(Pedido pedido) {
        MDC.put("pedidoId", pedido.id().toString());   // aparece en todas las líneas de este hilo
        try {
            log.info("Cobrando pedido de {} €", pedido.total());
            pasarela.cobrar(pedido);
            log.debug("Pedido cobrado: {}", pedido);    // solo se formatea si DEBUG está activo
        } catch (PagoRechazadoException e) {
            log.warn("Pago rechazado: {}", e.motivo()); // anómalo pero esperado
        } catch (RuntimeException e) {
            log.error("Fallo inesperado cobrando el pedido {}", pedido.id(), e);  // con stack trace
            throw e;
        } finally {
            MDC.remove("pedidoId");
        }
    }
}

// application.properties
// logging.level.root=INFO
// logging.level.com.miempresa.cobros=DEBUG
// logging.pattern.console=%d{HH:mm:ss} %-5level [%X{pedidoId}] %logger{36} - %msg%n