package com.webflux.launchadmin;

import com.plumelog.core.util.LogExceptionStackTrace;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import reactor.core.publisher.Mono;

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpHeaders;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;

@SpringBootTest
class LaunchAdminApplicationTests {

    @Test
    public void te() {
        HttpClient httpClient = HttpClient.newHttpClient();
        HttpRequest httpRequest = HttpRequest.newBuilder()
                .uri(URI.create("https://c2ba.api.huachen.cn/ip?ip=58.211.174.206"))
                .GET()
                .header("Authorization", "APPCODE 757a4a0cb5234bf283d68ec584c96607")
                .build();
        try {
            HttpResponse<String> httpResponse = httpClient.send(httpRequest, HttpResponse.BodyHandlers.ofString());

            int statusCode = httpResponse.statusCode();
            HttpHeaders headers = httpResponse.headers();
            String responseBody = httpResponse.body();

            System.out.println("Status Code: " + statusCode);
            System.out.println("Headers: " + headers);
            System.out.println("Response Body: " + responseBody);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Test
    public void testLog() {
        String val = "123abc";
        Mono.just(val).flatMap(f -> Mono.just(Integer.parseInt(f)))
                .onErrorResume(e -> Mono.error(new Exception(LogExceptionStackTrace.erroStackTrace(e).toString())))
                .subscribe(System.out::println);
    }
}