Use codeinclude #1158

use codeinclude for the elasticsearch module documentation

Author: raynigon

docs/modules/elasticsearch.md

@@ -9,45 +9,25 @@ Note that it's based on the [official Docker image](https://www.elastic.co/guide
 
 You can start an elasticsearch container instance from any Java application by using:
 
-```java
-// Create the elasticsearch container.
-ElasticsearchContainer container = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.4.1");
+<!--codeinclude-->
+[Using an Elasticsearch container](../../modules/elasticsearch/src/test/java/org/testcontainers/containers/ElasticsearchDocumentationTest.java) inside_block:httpClientContainerStart
+[Using an Elasticsearch container](../../modules/elasticsearch/src/test/java/org/testcontainers/containers/ElasticsearchDocumentationTest.java) inside_block:transportClientContainerStart
+[Using an Elasticsearch container](../../modules/elasticsearch/src/test/java/org/testcontainers/containers/ElasticsearchDocumentationTest.java) inside_block:httpClientContainerStop
+<!--/codeinclude-->
 
-// Start the container. This step might take some time...
-container.start();
-
-// Do whatever you want with the rest client ...
-final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
-credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "changeme"));
-RestClient restClient = RestClient.builder(HttpHost.create(container.getHttpHostAddress()))
-        .setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider))
-        .build();
-Response response = restClient.performRequest(new Request("GET", "/"));
-
-// ... or the transport client
-TransportAddress transportAddress = new TransportAddress(container.getTcpHost());
-Settings settings = Settings.builder().put("cluster.name", "docker-cluster").build();
-TransportClient transportClient = new PreBuiltTransportClient(settings)
-    .addTransportAddress(transportAddress);
-ClusterHealthResponse healths = transportClient.admin().cluster().prepareHealth().get();
-
-// Stop the container.
-container.stop();
-```
 
 Note that if you are still using the [TransportClient](https://www.elastic.co/guide/en/elasticsearch/client/java-api/6.3/transport-client.html)
 (not recommended as it is deprecated), the default cluster name is set to `docker-cluster` so you need to change `cluster.name` setting
 or set `client.transport.ignore_cluster_name` to `true`.
 
 ## Choose your Elasticsearch license
 
-If you prefer to start a Docker image with the pure OSS version (which means with no security or
-other advanced features), you can use this instead:
+If you prefer to start a Docker image with the pure OSS version (which means with no security in older versions or
+other new and advanced features), you can use this instead:
 
-```java
-// Create the elasticsearch container.
-ElasticsearchContainer container = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch-oss:6.4.1");
-```
+<!--codeinclude-->
+[Using an Elasticsearch container](../../modules/elasticsearch/src/test/java/org/testcontainers/containers/ElasticsearchDocumentationTest.java) inside_block:oosContainer
+<!--/codeinclude-->
 
 ## Adding this module to your project dependencies
 

modules/elasticsearch/src/test/java/org/testcontainers/elasticsearch/ElasticsearchDocumentationTest.java

@@ -0,0 +1,88 @@
+package org.testcontainers.elasticsearch;
+
+import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+
+import org.apache.http.HttpHost;
+import org.apache.http.auth.AuthScope;
+import org.apache.http.auth.UsernamePasswordCredentials;
+import org.apache.http.client.CredentialsProvider;
+import org.apache.http.impl.client.BasicCredentialsProvider;
+import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
+import org.elasticsearch.client.Request;
+import org.elasticsearch.client.Response;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.transport.TransportClient;
+import org.elasticsearch.cluster.health.ClusterHealthStatus;
+import org.elasticsearch.common.settings.Settings;
+import org.elasticsearch.common.transport.TransportAddress;
+import org.elasticsearch.transport.client.PreBuiltTransportClient;
+import org.junit.Test;
+
+public class ElasticsearchDocumentationTest {
+
+    @Test
+    public void containerWithHttpClient() throws IOException {
+        // httpClientContainerStart {
+        // Create the elasticsearch container.
+        ElasticsearchContainer container = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.4.1");
+
+        // Start the container. This step might take some time...
+        container.start();
+
+        // Do whatever you want with the rest client ...
+        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "changeme"));
+        RestClient restClient = RestClient.builder(HttpHost.create(container.getHttpHostAddress()))
+            .setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider))
+            .build();
+        Response response = restClient.performRequest(new Request("GET", "/"));
+        // }
+        // Compare Result
+        assertEquals(response.getStatusLine().getStatusCode(), 200);
+
+        // httpClientContainerStop {
+        // Stop the container.
+        container.stop();
+        // }
+    }
+
+    @Test
+    public void containerWithTransportClient() {
+        // Create the elasticsearch container.
+        ElasticsearchContainer container = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.4.1");
+
+        // Start the container. This step might take some time...
+        container.start();
+
+        // transportClientContainerStart {
+        // ... or the transport client
+        TransportAddress transportAddress = new TransportAddress(container.getTcpHost());
+        Settings settings = Settings.builder().put("cluster.name", "docker-cluster").build();
+        TransportClient transportClient = new PreBuiltTransportClient(settings)
+            .addTransportAddress(transportAddress);
+        ClusterHealthResponse healths = transportClient.admin().cluster().prepareHealth().get();
+        // }
+        // Compare Result
+        assertEquals(ClusterHealthStatus.GREEN, healths.getStatus());
+
+        // Stop the container.
+        container.stop();
+    }
+
+    @Test
+    public void containerWithOpenSourceImage() {
+        // oosContainer {
+        // Create the elasticsearch container.
+        ElasticsearchContainer container = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch-oss:6.4.1");
+        // }
+
+        // Start the container. This step might take some time...
+        container.start();
+
+        // Stop the container.
+        container.stop();
+    }
+
+}