@Test
public void verifyDefaultUrl() throws Exception {
    // Given
    HttpClient httpClient = mock(HttpClient.class);
    ConsulRawClient client = ConsulRawClient.Builder.builder()
            .setHttpClient(httpClient)
            .setHost(HOST)
            .setPort(PORT)
            .build();

    // When
    client.makeGetRequest(ENDPOINT, EMPTY_QUERY_PARAMS);

    // Then
    ArgumentCaptor<HttpUriRequest> calledUri = ArgumentCaptor.forClass(HttpUriRequest.class);
    verify(httpClient).execute(calledUri.capture(), any(ResponseHandler.class));
    assertEquals(EXPECTED_AGENT_ADDRESS_NO_PATH, calledUri.getValue().getURI().toString());
}
 

@Test
public void verifyUrlWithPath() throws Exception {
    // Given
    HttpClient httpClient = mock(HttpClient.class);
    ConsulRawClient client = ConsulRawClient.Builder.builder()
            .setHttpClient(httpClient)
            .setHost(HOST)
            .setPort(PORT)
            .setPath(PATH)
            .build();

    // When
    client.makeGetRequest(ENDPOINT, EMPTY_QUERY_PARAMS);

    // Then
    ArgumentCaptor<HttpUriRequest> calledUri = ArgumentCaptor.forClass(HttpUriRequest.class);
    verify(httpClient).execute(calledUri.capture(), any(ResponseHandler.class));
    assertEquals(EXPECTED_AGENT_ADDRESS, calledUri.getValue().getURI().toString());
}
 

@Bean
@Primary
public ConsulClient consulClient(ConsulProperties consulProperties,
                                 ConsulConfigProperties consulConfigProperties) {
    final int agentPort = consulProperties.getPort();
    final String agentHost = !StringUtils.isEmpty(consulProperties.getScheme())
            ? consulProperties.getScheme() + "://" + consulProperties.getHost()
            : consulProperties.getHost();

    logger.info("Init consul host: " + agentHost + " port: " + agentPort);
    if (consulProperties.getTls() != null) {
        ConsulProperties.TLSConfig tls = consulProperties.getTls();
        TLSConfig tlsConfig = new TLSConfig(
                tls.getKeyStoreInstanceType(),
                tls.getCertificatePath(),
                tls.getCertificatePassword(),
                tls.getKeyStorePath(),
                tls.getKeyStorePassword()
        );
        return new ConsulClient(agentHost, agentPort, tlsConfig);
    }
    HttpRequestInterceptor httpRequestInterceptor = new BmsCommonInterceptor();
    BmsHttpTransport httpTransport = new BmsHttpTransport(httpRequestInterceptor);
    ConsulRawClient rawClient = new ConsulRawClient(httpTransport.getHttpClient(),
            agentHost, agentPort, consulConfigProperties.getPath());
    return new ConsulClient(rawClient);
}
 

@Test
public void tlsConfigured() {
	CatalogConsulClient client = (CatalogConsulClient) ReflectionTestUtils
			.getField(this.consulClient, "catalogClient");
	ConsulRawClient rawClient = (ConsulRawClient) ReflectionTestUtils.getField(client,
			"rawClient");
	HttpTransport httpTransport = (HttpTransport) ReflectionTestUtils
			.getField(rawClient, "httpTransport");
	assertThat(httpTransport).isInstanceOf(DefaultHttpsTransport.class);
}
 

public static ConsulClient createClient(String apiAddress, int apiPort, TlsConfiguration tlsConfiguration) throws Exception {
    HttpClient httpClient = createHttpClient(tlsConfiguration.getClientCert(), tlsConfiguration.getClientKey(), tlsConfiguration.getServerCert());
    ConsulRawClient rawClient = new ConsulRawClient("https://" + apiAddress + ':' + apiPort, httpClient);
    Field agentAddress = ReflectionUtils.findField(ConsulRawClient.class, "agentAddress");
    ReflectionUtils.makeAccessible(agentAddress);
    ReflectionUtils.setField(agentAddress, rawClient, "https://" + apiAddress + ':' + apiPort + "/consul");
    return new ConsulClient(rawClient);
}
 

public AclConsulClient(ConsulRawClient rawClient) {
	this.rawClient = rawClient;
}
 

public AclConsulClient() {
	this(new ConsulRawClient());
}
 

public AclConsulClient(TLSConfig tlsConfig) {
	this(new ConsulRawClient(tlsConfig));
}
 

public AclConsulClient(String agentHost) {
	this(new ConsulRawClient(agentHost));
}
 

public AclConsulClient(String agentHost, TLSConfig tlsConfig) {
	this(new ConsulRawClient(agentHost, tlsConfig));
}
 

public AclConsulClient(String agentHost, int agentPort) {
	this(new ConsulRawClient(agentHost, agentPort));
}
 

public AclConsulClient(String agentHost, int agentPort, TLSConfig tlsConfig) {
	this(new ConsulRawClient(agentHost, agentPort, tlsConfig));
}
 

public StatusConsulClient(ConsulRawClient rawClient) {
	this.rawClient = rawClient;
}
 

public StatusConsulClient() {
	this(new ConsulRawClient());
}
 

public StatusConsulClient(TLSConfig tlsConfig) {
	this(new ConsulRawClient(tlsConfig));
}
 

public StatusConsulClient(String agentHost) {
	this(new ConsulRawClient(agentHost));
}
 

public StatusConsulClient(String agentHost, TLSConfig tlsConfig) {
	this(new ConsulRawClient(agentHost, tlsConfig));
}
 

public StatusConsulClient(String agentHost, int agentPort) {
	this(new ConsulRawClient(agentHost, agentPort));
}
 

public StatusConsulClient(String agentHost, int agentPort, TLSConfig tlsConfig) {
	this(new ConsulRawClient(agentHost, agentPort, tlsConfig));
}
 

public QueryConsulClient(String agentHost) {
	this(new ConsulRawClient(agentHost));
}
 

public QueryConsulClient(String agentHost, TLSConfig tlsConfig) {
	this(new ConsulRawClient(agentHost, tlsConfig));
}
 

public QueryConsulClient(String agentHost, int agentPort) {
	this(new ConsulRawClient(agentHost, agentPort));
}
 

public QueryConsulClient(String agentHost, int agentPort, TLSConfig tlsConfig) {
	this(new ConsulRawClient(agentHost, agentPort, tlsConfig));
}
 

public SessionConsulClient(ConsulRawClient rawClient) {
	this.rawClient = rawClient;
}
 

public SessionConsulClient() {
	this(new ConsulRawClient());
}
 

public SessionConsulClient(String agentHost) {
	this(new ConsulRawClient(agentHost));
}
 

public SessionConsulClient(String agentHost, int agentPort) {
	this(new ConsulRawClient(agentHost, agentPort));
}
 

public AgentConsulClient(ConsulRawClient rawClient) {
	this.rawClient = rawClient;
}
 

public AgentConsulClient() {
	this(new ConsulRawClient());
}
 

public AgentConsulClient(TLSConfig tlsConfig) {
	this(new ConsulRawClient(tlsConfig));
}