update to current version

all initial features implemented
tbd:
   etrack
   front

src/main/java/com/release11/klaus/model/constraints/HttpCode.java

@@ -0,0 +1,19 @@
+package com.release11.klaus.model.constraints;
+
+import javax.validation.Constraint;
+import javax.validation.Payload;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+
+@Target({ ElementType.FIELD})
+@Retention(RetentionPolicy.RUNTIME)
+@Constraint(validatedBy = HttpCodeValidation.class )
+public @interface HttpCode {
+    String message() default "must be a valid http code";
+
+    Class<?>[] groups() default { };
+    Class<? extends Payload>[] payload() default { };
+}

src/main/java/com/release11/klaus/model/constraints/HttpCodeValidation.java

@@ -0,0 +1,28 @@
+package com.release11.klaus.model.constraints;
+
+import com.release11.klaus.repository.MockedResponseRepository;
+import org.springframework.http.HttpStatus;
+
+import javax.validation.ConstraintValidator;
+import javax.validation.ConstraintValidatorContext;
+import java.util.EnumSet;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+public class HttpCodeValidation implements ConstraintValidator<HttpCode, Integer> {
+    private Set<Integer> allowedValues;
+
+    @Override
+    public void initialize(HttpCode targetEnum) {
+        allowedValues = Stream.of(HttpStatus.values())
+                .map(HttpStatus::value)
+                .collect(Collectors.toSet());
+    }
+
+    @Override
+    public boolean isValid(Integer integer, ConstraintValidatorContext context) {
+        return allowedValues.contains(integer);
+    }
+}

src/main/java/com/release11/klaus/repository/LogsRepository.java

@@ -0,0 +1,12 @@
+package com.release11.klaus.repository;
+
+import com.release11.klaus.utilis.BusinessKey;
+import org.springframework.stereotype.Repository;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+
+@Repository
+public interface LogsRepository {
+    String getLogsByBusinessKeys(List<BusinessKey> businessKeys, ZonedDateTime zonedDateTime);
+}

src/main/java/com/release11/klaus/utilis/BusinessKey.java

@@ -0,0 +1,16 @@
+package com.release11.klaus.utilis;
+
+import lombok.AllArgsConstructor;
+
+@AllArgsConstructor
+public enum BusinessKey {
+    INTERFACE_NAME("interfaceName"),
+    CLIENT_UUID("clientUUID"),
+    MESSAGE_ID("messageId");
+
+    private final String phrase;
+
+    public String getReasonPhrase() {
+        return this.phrase;
+    }
+}

src/main/java/com/release11/klaus/utilis/TrackingClient.java

@@ -0,0 +1,18 @@
+package com.release11.klaus.utilis;
+
+import org.slf4j.MDC;
+
+import java.util.Map;
+
+public final class TrackingClient {
+
+    private TrackingClient(){};
+
+    public static void setBusinessKeys(Map<BusinessKey, String> businessKeysMap){
+        for (Map.Entry<BusinessKey, String> entry : businessKeysMap.entrySet()) {
+            MDC.put(entry.getKey().getReasonPhrase(), entry.getValue());
+        }
+    }
+
+
+}

src/main/resources/logback.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <include resource="org/springframework/boot/logging/logback/base.xml"/>
+    <!--https://github.com/kmtong/logback-redis-appender-->
+    <appender name="LOGSTASH" class="com.cwbase.logback.RedisAppender">
+        <host>localhost</host>
+        <port>6379</port>
+        <key>logstash</key>
+        <layout class="ch.qos.logback.classic.PatternLayout">
+            <!--https://logging.apache.org/log4j/1.2/apidocs/org/apache/log4j/PatternLayout.html-->
+            <Pattern>
+                {"date" : "%d{yyyy-MM-dd}", "timestamp":"%d{HH:mm:ss}", "businessKeys": ["interfaceName": "%X{interfaceName}", "clientUUID": "%X{clientUUID}", "messageId": "%X{messageId}"],"thread":"%t","level":"%-5level", "message":"%msg"}%n
+            </Pattern>
+        </layout>
+    </appender>
+    <appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender">
+        <appender-ref ref="LOGSTASH" />
+    </appender>
+    <root level="DEBUG">
+        <appender-ref ref="ASYNC" />
+        <appender-ref ref="CONSOLE" />
+        <appender-ref ref="FILE" />
+    </root>
+</configuration>
+
+

src/main/resources/static/js/main.js

@@ -0,0 +1,38 @@
+
+function httpGet()
+{
+  var clientUUID = document.getElementById("getClientUUID").value;
+   var mockedResponseId = document.getElementById("getMockedResponseId").value;
+   var url = "http://localhost:8097/klaus/v1/get/" + clientUUID + "/" + mockedResponseId;
+    var xmlHttp = new XMLHttpRequest();
+    xmlHttp.open( "GET", url, false ); // false for synchronous request
+    xmlHttp.send( null );
+
+    var container = document.getElementById("getMockedResponse");
+    var headers = xmlHttp.getAllResponseHeaders();
+    container.appendChild(document.createTextNode(headers));
+    container.appendChild(document.createTextNode("Your message: "));
+    container.appendChild(document.createElement("br"));
+    container.appendChild(document.createTextNode((xmlHttp.responseText)));
+    return xmlHttp.responseText;
+
+}
+
+        var numberOfHeaders = 0;
+            function addFields(){
+            var container = document.getElementById("headers");
+
+                numberOfHeaders++;
+                container.appendChild(document.createElement("br"));
+                container.appendChild(document.createTextNode("Header " + (numberOfHeaders)));
+                var headerInput = document.createElement("input");
+                headerInput.type = "text";
+                headerInput.name = "header";
+                container.appendChild(headerInput);
+
+                container.appendChild(document.createTextNode("Value " + (numberOfHeaders)));
+                var valueInput = document.createElement("input");
+                valueInput.type = "text";
+                valueInput.name = "value";
+                container.appendChild(valueInput);
+        }