import java.io.IOException;

import org.apache.http.HttpHost;
import org.elasticsearch.client.Request;
import org.elasticsearch.client.Response;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;

import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.instrumentation.elasticsearch.rest.v7_0.ElasticsearchRest7Telemetry;

public class Application {
    public static void main(String[] args) throws IOException {
        RestClientBuilder restClientBuilder = RestClient.builder(HttpHost.create("http://127.0.0.1:9200")); // <-- suppose it's an unreachable host.
        try (RestClient lowLevelClient = restClientBuilder.build()) {
            RestClient enhancedRestClient = ElasticsearchRest7Telemetry.builder(GlobalOpenTelemetry.get()).build()
                    .wrap(lowLevelClient);
            Response rsp = enhancedRestClient.performRequest(new Request("GET", "test/")); // <--  java.net.ConnectException is expected to be thrown here but nothing happens
            System.out.println(rsp); // <-- `null` is printed
            Response realRsp = lowLevelClient.performRequest(new Request("GET", "test/")); // <-- java.net.ConnectException is thrown
            System.out.println(realRsp);

            RestHighLevelClient highLevelClient = new RestHighLevelClient(enhancedRestClient, RestClient::close,
                    Collections.emptyList()) {
            };
            System.out.println(highLevelClient.get(new GetRequest("test").id("1"), RequestOptions.DEFAULT)); // <-- java.lang.NullPointerException is thrown due to performRequest returning null
        }
    }
}