Add docker compose yml file (#161)

Author: tobiasake

docker-compose.yml

@@ -0,0 +1,76 @@
+#################################################################################################
+#
+# Copyright 2018 Ericsson AB.
+# For a full list of individual contributors, please see the commit history.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#       http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+##################################################################################################
+# Eiffel Sandbox 
+#
+# run:         docker-compose up         
+# stop:        docker-compose stop
+# stop/remove: docker-compose down --volumes
+#
+# Cleanup/Remove (if needed):
+#     Dangling Volumes:   docker volume rm `docker volume ls -q -f dangling=true`            
+#     Unused Images:      docker images -q | xargs docker rmi
+#     Stopped containers: docker rm `docker ps -a -q` 
+#
+# Maintainer: michael.frick@ericsson.com
+##################################################################################################
+version: "2.1"
+services:
+  mymongodb-mongodb:
+    restart: always
+    image: mongo:latest
+    expose:
+      - "27017"
+    ports:
+      - "27017:27017"
+    healthcheck: 
+        test: ["CMD-SHELL","echo", "'db.stats().ok' | mongo localhost:27017/test", "--quiet"]
+        interval: 30s
+        timeout: 10s
+        retries: 5        
+    networks:
+          eiffel_2.0_1:
+            aliases:
+              - mymongodb-mongodb:27017
+
+  myrabbitmq-rabbitmq:
+    restart: always
+    image: rabbitmq:3.6.2-management
+    expose:
+      - "15672"
+      - "5672"
+    ports:
+      - "15672:15672"
+      - "5672:5672"
+    healthcheck:
+        test: ["CMD-SHELL", "if rabbitmqctl status; then \nexit 0 \nfi \nexit 1"]
+        interval: 30s
+        timeout: 10s
+        retries: 5
+    networks:
+          eiffel_2.0_1:
+            aliases:
+              - myrabbitmq-rabbitmq:5672
+              - myrabbitmq-rabbitmq:15672
+    environment:
+      - RABBITMQ_DEFAULT_PASS=myuser
+      - RABBITMQ_DEFAULT_USER=myuser
+      - RABBITMQ_DEFAULT_VHOST=/
+
+networks:
+  eiffel_2.0_1:

src/functionaltests/java/com/ericsson/ei/subscriptions/authentication/AuthenticationSteps.java

@@ -44,6 +44,7 @@ public class AuthenticationSteps extends FunctionalTestBase {
     public void beforeScenario() throws Throwable {
         httpRequest = new HttpRequest(HttpMethod.GET);
         httpRequest.setHost(hostName).setPort(applicationPort).setEndpoint("/auth/logout");
+
         String auth = "gauss:password";
         String encodedAuth = new String(Base64.encodeBase64(auth.getBytes()), "UTF-8");
         httpRequest.addHeader("Authorization", "Basic " + encodedAuth);
@@ -55,11 +56,13 @@ public void beforeScenarioSecond() {
         client_is_replaced();
     }
 
+
     @Given("^LDAP is activated$")
     public void ldap_is_activated() throws Throwable {
         String expectedContent = new JSONObject().put("security", true).toString();
         httpRequest = new HttpRequest(HttpMethod.GET);
         httpRequest.setHost(hostName).setPort(applicationPort).setEndpoint("/auth");
+
         response = httpRequest.performRequest();
         assertEquals(HttpStatus.OK, response.getStatusCode());
         assertEquals(expectedContent, response.getBody().toString());
@@ -77,7 +80,6 @@ public void request_to_rest_api(String method, String endpoint) throws Throwable
         case "GET":
             httpRequest = new HttpRequest(HttpMethod.GET);
             httpRequest.setHost(hostName).setPort(applicationPort).setEndpoint(endpoint);
-
             break;
         }
     }
@@ -132,4 +134,5 @@ public void auth_token_saved() {
     public void client_is_replaced() {
         HttpExecutor.getInstance().recreateHttpClient();
     }
+
 }

src/functionaltests/java/com/ericsson/ei/subscriptions/content/SubscriptionContentSteps.java

@@ -45,6 +45,7 @@ private void setUp() {
         postRequest = new HttpRequest(HttpMethod.POST);
         postRequest.setHost(hostName).setPort(applicationPort).setEndpoint("/subscriptions")
                 .addHeader("content-type", "application/json").addHeader("Accept", "application/json");
+
     }
 
     // SCENARIO 1

src/functionaltests/java/com/ericsson/ei/utils/HttpExecutor.java

@@ -15,20 +15,25 @@
 
 import java.io.IOException;
 
+
 public final class HttpExecutor {
 
     private static HttpExecutor instance;
     private CloseableHttpClient client = HttpClientBuilder.create().build();
     private static final Logger LOGGER = LoggerFactory.getLogger(HttpExecutor.class);
 
+    private HttpExecutor() {
+        
+    }
+    
     public static HttpExecutor getInstance() {
-        if (instance == null) {
+        if(instance == null) {
             instance = new HttpExecutor();
         }
-
+        
         return instance;
     }
-
+    
     /**
      * Close existing HttpClient and create a new one.
      *
@@ -44,35 +49,33 @@ public void recreateHttpClient() {
         }
         this.client = HttpClientBuilder.create().build();
     }
-
+    
     /**
      * Handle the response from a HTTP request
-     *
      * @param request
-     *            A HTTP request method, e.g. httpGet, httpPost
-     * @return ResponseEntity containing the resulting body, headers and status
-     *         code from request
-     */
+     *      A HTTP request method, e.g. httpGet, httpPost
+     * @return ResponseEntity
+     *      containing the json content of the http response and status code from request
+     * */
     public ResponseEntity<String> executeRequest(HttpRequestBase request) {
         int statusCode = HttpStatus.PROCESSING.value();
         String jsonContent = "";
         Header[] headers = null;
 
-        try (CloseableHttpResponse httpResponse = client.execute(request)) {
-            if (httpResponse.getEntity() != null) {
+        try(CloseableHttpResponse httpResponse = client.execute(request)) {
+            if(httpResponse.getEntity() != null) {
                 jsonContent = EntityUtils.toString(httpResponse.getEntity(), "utf-8");
             }
             statusCode = httpResponse.getStatusLine().getStatusCode();
             headers = httpResponse.getAllHeaders();
-        } catch (IOException e) {
+        } catch(IOException e) {
             LOGGER.error(e.getMessage(), e);
         }
-
+        
         MultiValueMap<String, String> headersMap = new LinkedMultiValueMap<String, String>();
         for (Header header : headers) {
             headersMap.add(header.getName(), header.getValue());
         }
-
         return new ResponseEntity<>(jsonContent, headersMap, HttpStatus.valueOf(statusCode));
     }
 }

src/functionaltests/java/com/ericsson/ei/utils/HttpRequest.java

@@ -41,11 +41,12 @@ public enum HttpMethod {
     @Getter
     protected Map<String, String> params;
 
+
     private static final Logger LOGGER = LoggerFactory.getLogger(HttpRequest.class);
 
     public HttpRequest(HttpMethod method) {
         params = new HashMap<>();
-        
+
         switch (method) {
         case POST:
             request = new HttpPost();