真实 HTTP 集成测试

import java.io.ByteArrayInputStream;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.util.Map;
import java.util.zip.GZIPInputStream;
import nexus.io.context.BootConfiguration;
import nexus.io.context.Context;
import nexus.io.tio.boot.TioApplication;
import nexus.io.tio.boot.server.TioBootServer;
import nexus.io.tio.http.server.util.Resps;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;

public class HttpIntegrationTest {
  static Context context;
  static HttpClient client;
  static final int PORT = Integer.getInteger("test.http.port", 18781);

  @BeforeAll
  static void start() {
    BootConfiguration configuration = () ->
      TioBootServer.me().getRequestRouter().add("/health", request -> {
        var response = Resps.json(request, Map.of("status", "ok"));
        if (!"GET".equals(request.getRequestLine().getMethod().toString())) {
          response = Resps.json(request, Map.of("error", "method"));
          response.setStatus(405);
        }
        return response;
      });
    context = TioApplication.run(configuration, new String[] {
      "--server.port=" + PORT, "--server.context-path=/test"
    });
    client = HttpClient.newBuilder().connectTimeout(Duration.ofSeconds(3)).build();
  }

  @AfterAll
  static void stop() {
    try {
      if (client != null) client.close();
    } finally {
      if (context != null) context.close();
    }
  }

  @Test
  void externalPathAndResponse() throws Exception {
    var request = HttpRequest.newBuilder(URI.create("http://127.0.0.1:" + PORT + "/test/health"))
      .timeout(Duration.ofSeconds(5)).GET().build();
    var response = client.send(request, HttpResponse.BodyHandlers.ofByteArray());
    assertEquals(200, response.statusCode());
    assertTrue(text(response).contains("\"ok\""));
  }

  @Test
  void rejectsPost() throws Exception {
    var request = HttpRequest.newBuilder(URI.create("http://127.0.0.1:" + PORT + "/test/health"))
      .timeout(Duration.ofSeconds(5)).POST(HttpRequest.BodyPublishers.noBody()).build();
    assertEquals(405, client.send(request, HttpResponse.BodyHandlers.discarding()).statusCode());
  }

  static String text(HttpResponse<byte[]> response) throws Exception {
    byte[] bytes = response.body();
    if (response.headers().firstValue("Content-Encoding").orElse("").equalsIgnoreCase("gzip")) {
      try (var gzip = new GZIPInputStream(new ByteArrayInputStream(bytes))) {
        bytes = gzip.readAllBytes();
      }
    }
    return new String(bytes, StandardCharsets.UTF_8);
  }
}