summaryrefslogtreecommitdiffstats
path: root/test/mock/src/main
diff options
context:
space:
mode:
authorGeora Barsky <georab@amdocs.com>2017-09-22 12:47:03 -0400
committerGeora Barsky <georab@amdocs.com>2017-09-22 12:47:03 -0400
commit46c1a40e6cb283f7d42270b877401d584d168494 (patch)
treec2d1d25b4c0df3d7d8f9225eb9624e0d350c158e /test/mock/src/main
parent8a984bcdd1118c15723fc18dc737a609eb6978c9 (diff)
Sniro Emulator - Move to different location
Change location of sniro emulator project from intgration/test/mock to integration/test/mocks/sniroemulator Change-Id: I808525d0d8ec23e785a5f06b7ba43a003a00d6fc JIRA-ID: INT-215 Signed-off-by: Geora Barsky <georab@amdocs.com>
Diffstat (limited to 'test/mock/src/main')
-rw-r--r--test/mock/src/main/docker/Dockerfile19
-rw-r--r--test/mock/src/main/docker/docker-entrypoint.sh5
-rw-r--r--test/mock/src/main/java/org/onap/integration/test/mock/MockApplication.java122
-rw-r--r--test/mock/src/main/java/org/onap/integration/test/mock/extension/WebhookDefinition.java101
-rw-r--r--test/mock/src/main/java/org/onap/integration/test/mock/extension/Webhooks.java100
-rw-r--r--test/mock/src/main/resources/application.properties1
6 files changed, 0 insertions, 348 deletions
diff --git a/test/mock/src/main/docker/Dockerfile b/test/mock/src/main/docker/Dockerfile
deleted file mode 100644
index b1bf4d93c..000000000
--- a/test/mock/src/main/docker/Dockerfile
+++ /dev/null
@@ -1,19 +0,0 @@
-FROM openjdk:8-jre
-
-MAINTAINER Geora Barsky <georab@amdocs.com>
-
-RUN mkdir -p /var/wiremock/lib/
-
-ADD mock.jar /var/wiremock/lib/app.jar
-
-WORKDIR /home/wiremock
-
-COPY docker-entrypoint.sh /
-RUN chmod 700 /docker-entrypoint.sh
-
-VOLUME /home/wiremock
-EXPOSE 8080 8081 9999
-
-ENTRYPOINT ["/docker-entrypoint.sh"]
-
-CMD ["java", "-jar","/var/wiremock/lib/app.jar"] \ No newline at end of file
diff --git a/test/mock/src/main/docker/docker-entrypoint.sh b/test/mock/src/main/docker/docker-entrypoint.sh
deleted file mode 100644
index 47364a270..000000000
--- a/test/mock/src/main/docker/docker-entrypoint.sh
+++ /dev/null
@@ -1,5 +0,0 @@
-#!/bin/bash
-
-touch /app.jar
-
-java -Xms1024m -Xmx1024m -jar /var/wiremock/lib/app.jar \ No newline at end of file
diff --git a/test/mock/src/main/java/org/onap/integration/test/mock/MockApplication.java b/test/mock/src/main/java/org/onap/integration/test/mock/MockApplication.java
deleted file mode 100644
index 115cb252a..000000000
--- a/test/mock/src/main/java/org/onap/integration/test/mock/MockApplication.java
+++ /dev/null
@@ -1,122 +0,0 @@
-package org.onap.integration.test.mock;
-
-import static com.github.tomakehurst.wiremock.client.ResponseDefinitionBuilder.responseDefinition;
-import static com.github.tomakehurst.wiremock.client.WireMock.anyUrl;
-import static com.github.tomakehurst.wiremock.core.WireMockApp.FILES_ROOT;
-import static com.github.tomakehurst.wiremock.core.WireMockApp.MAPPINGS_ROOT;
-import static com.github.tomakehurst.wiremock.http.RequestMethod.ANY;
-import static com.github.tomakehurst.wiremock.matching.RequestPatternBuilder.newRequestPattern;
-import static java.lang.System.out;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-import com.github.tomakehurst.wiremock.WireMockServer;
-import com.github.tomakehurst.wiremock.common.ConsoleNotifier;
-import com.github.tomakehurst.wiremock.common.FatalStartupException;
-import com.github.tomakehurst.wiremock.common.FileSource;
-import com.github.tomakehurst.wiremock.core.WireMockConfiguration;
-import com.github.tomakehurst.wiremock.http.ResponseDefinition;
-import com.github.tomakehurst.wiremock.matching.RequestPattern;
-import com.github.tomakehurst.wiremock.standalone.MappingsLoader;
-import com.github.tomakehurst.wiremock.stubbing.StubMapping;
-import com.github.tomakehurst.wiremock.stubbing.StubMappings;
-
-@SpringBootApplication
-public class MockApplication {
-
-
- private static final String BANNER= " \n" +
-" ******** **** **** ## \n" +
-" **######** ###* *### ## \n" +
-" *##******##* ##*** ***## ##\n" +
-" **#* *#** ##*#* *#*## ## \n" +
-" *#* *#* ##****** ******* ##****** ##*#* *#*## ******* ****** ## *** \n" +
-" *#* *#* ##*####* *######* ##*####** ##*#* *#*## **#####** **####** ## *#** \n" +
-" *#* *#* ##****#* *#****#* ##** **#* ## *** *** ## *#** **#* *#****#* ## **#** \n" +
-" *# #* ##* *#* #* ##* *#* ## *#* *#* ## *#* *#* *#* *#* ##**#** \n" +
-" *#* *#* ##* ## ****## ##* *#* ## *#* *#* ## *#* *#* *#* ##*##* \n" +
-" *#* *#* ## ## **###### ## #* ## *#* *#* ## *# #* *# ##**#** \n" +
-" *#* *#* ## ## *#****## ##* *#* ## *#*#* ## *#* *#* *#* ##**##* \n" +
-" **#* *#** ## ## *#* *## ##* *#* ## *#*#* ## *#* *#* *#* *#* ## *#** \n" +
-" *##******##* ## ## *#* **##* ##** **#* ## *#*#* ## *#** **#* *#****#* ## **#* \n" +
-" **######** ## ## *#######* ##*####* ## *###* ## **#####** **####** ## *#** \n" +
-" ******** ## ## *******#* ##****** ## *#* ## ******* ****** ## *#* \n" +
-" ## \n" +
-" ## \n" +
-" ## \n" +
-" ** \n" ;
-
- static {
- System.setProperty("org.mortbay.log.class", "com.github.tomakehurst.wiremock.jetty.LoggerAdapter");
- }
-
- private WireMockServer wireMockServer;
-
- public static void main(String[] args) {
- SpringApplication.run(MockApplication.class, args);
- //new WireMockServerRunner().run("--port 9999");
- new MockApplication().run(args);
- }
-
- public void run(String... args) {
-
- WireMockConfiguration options = WireMockConfiguration.options();
- options.port(9999);
- FileSource fileSource = options.filesRoot();
- fileSource.createIfNecessary();
- FileSource filesFileSource = fileSource.child(FILES_ROOT);
- filesFileSource.createIfNecessary();
- FileSource mappingsFileSource = fileSource.child(MAPPINGS_ROOT);
- mappingsFileSource.createIfNecessary();
-
- // Register extension
- options.extensions("org.onap.integration.test.mock.extension.Webhooks");
- // Register notifier
- options.notifier(new ConsoleNotifier(true));
- wireMockServer = new WireMockServer(options);
-
- wireMockServer.enableRecordMappings(mappingsFileSource, filesFileSource);
-
- //if (options.specifiesProxyUrl()) {
- // addProxyMapping(options.proxyUrl());
- //}
-
- try {
- wireMockServer.start();
- out.println(BANNER);
- out.println();
- out.println(options);
- } catch (FatalStartupException e) {
- System.err.println(e.getMessage());
- System.exit(1);
- }
- }
-
- private void addProxyMapping(final String baseUrl) {
- wireMockServer.loadMappingsUsing(new MappingsLoader() {
- @Override
- public void loadMappingsInto(StubMappings stubMappings) {
- RequestPattern requestPattern = newRequestPattern(ANY, anyUrl()).build();
- ResponseDefinition responseDef = responseDefinition()
- .proxiedFrom(baseUrl)
- .build();
-
- StubMapping proxyBasedMapping = new StubMapping(requestPattern, responseDef);
- proxyBasedMapping.setPriority(10); // Make it low priority so that existing stubs will take precedence
- stubMappings.addMapping(proxyBasedMapping);
- }
- });
- }
-
- public void stop() {
- wireMockServer.stop();
- }
-
- public boolean isRunning() {
- return wireMockServer.isRunning();
- }
-
- public int port() { return wireMockServer.port(); }
-
-}
diff --git a/test/mock/src/main/java/org/onap/integration/test/mock/extension/WebhookDefinition.java b/test/mock/src/main/java/org/onap/integration/test/mock/extension/WebhookDefinition.java
deleted file mode 100644
index dff99fd41..000000000
--- a/test/mock/src/main/java/org/onap/integration/test/mock/extension/WebhookDefinition.java
+++ /dev/null
@@ -1,101 +0,0 @@
-package org.onap.integration.test.mock.extension;
-
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.github.tomakehurst.wiremock.http.Body;
-import com.github.tomakehurst.wiremock.http.HttpHeader;
-import com.github.tomakehurst.wiremock.http.HttpHeaders;
-import com.github.tomakehurst.wiremock.http.RequestMethod;
-
-import java.net.URI;
-import java.util.List;
-
-import static com.google.common.collect.Lists.newArrayList;
-
-public class WebhookDefinition {
-
- private RequestMethod method;
- private URI url;
- private List<HttpHeader> headers;
- private Body body = Body.none();
-
- @JsonCreator
- public WebhookDefinition(@JsonProperty("method") RequestMethod method,
- @JsonProperty("url") URI url,
- @JsonProperty("headers") HttpHeaders headers,
- @JsonProperty("body") String body,
- @JsonProperty("base64Body") String base64Body) {
- this.method = method;
- this.url = url;
- this.headers = newArrayList(headers.all());
- this.body = Body.fromOneOf(null, body, null, base64Body);
- }
-
- public WebhookDefinition() {
- }
-
- public RequestMethod getMethod() {
- return method;
- }
-
- public URI getUrl() {
- return url;
- }
-
- public HttpHeaders getHeaders() {
- return new HttpHeaders(headers);
- }
-
- public String getBase64Body() {
- return body.isBinary() ? body.asBase64() : null;
- }
-
- public String getBody() {
- return body.isBinary() ? null : body.asString();
- }
-
- @JsonIgnore
- public byte[] getBinaryBody() {
- return body.asBytes();
- }
-
- public WebhookDefinition withMethod(RequestMethod method) {
- this.method = method;
- return this;
- }
-
- public WebhookDefinition withUrl(URI url) {
- this.url = url;
- return this;
- }
-
- public WebhookDefinition withUrl(String url) {
- withUrl(URI.create(url));
- return this;
- }
-
- public WebhookDefinition withHeaders(List<HttpHeader> headers) {
- this.headers = headers;
- return this;
- }
-
- public WebhookDefinition withHeader(String key, String... values) {
- if (headers == null) {
- headers = newArrayList();
- }
-
- headers.add(new HttpHeader(key, values));
- return this;
- }
-
- public WebhookDefinition withBody(String body) {
- this.body = new Body(body);
- return this;
- }
-
- public WebhookDefinition withBinaryBody(byte[] body) {
- this.body = new Body(body);
- return this;
- }
-}
diff --git a/test/mock/src/main/java/org/onap/integration/test/mock/extension/Webhooks.java b/test/mock/src/main/java/org/onap/integration/test/mock/extension/Webhooks.java
deleted file mode 100644
index cb17ba658..000000000
--- a/test/mock/src/main/java/org/onap/integration/test/mock/extension/Webhooks.java
+++ /dev/null
@@ -1,100 +0,0 @@
-package org.onap.integration.test.mock.extension;
-
-import com.github.tomakehurst.wiremock.common.Notifier;
-import com.github.tomakehurst.wiremock.core.Admin;
-import com.github.tomakehurst.wiremock.extension.Parameters;
-import com.github.tomakehurst.wiremock.extension.PostServeAction;
-import com.github.tomakehurst.wiremock.http.HttpClientFactory;
-import com.github.tomakehurst.wiremock.http.HttpHeader;
-import com.github.tomakehurst.wiremock.stubbing.ServeEvent;
-import org.apache.http.HttpResponse;
-import org.apache.http.client.HttpClient;
-import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
-import org.apache.http.client.methods.HttpUriRequest;
-import org.apache.http.entity.ByteArrayEntity;
-import org.apache.http.util.EntityUtils;
-
-import java.io.IOException;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-
-import static com.github.tomakehurst.wiremock.common.Exceptions.throwUnchecked;
-import static com.github.tomakehurst.wiremock.common.LocalNotifier.notifier;
-import static com.github.tomakehurst.wiremock.http.HttpClientFactory.getHttpRequestFor;
-import static java.util.concurrent.TimeUnit.SECONDS;
-
-public class Webhooks extends PostServeAction {
-
- private final ScheduledExecutorService scheduler;
- private final HttpClient httpClient;
-
- public Webhooks() {
- scheduler = Executors.newScheduledThreadPool(10);
- httpClient = HttpClientFactory.createClient();
- }
-
- @Override
- public String getName() {
- return "webhook";
- }
-
- @Override
- public void doAction(ServeEvent serveEvent, Admin admin, Parameters parameters) {
- final WebhookDefinition definition = parameters.as(WebhookDefinition.class);
- final Notifier notifier = notifier();
-
- scheduler.schedule(
- new Runnable() {
- @Override
- public void run() {
- HttpUriRequest request = buildRequest(definition);
-
- try {
- HttpResponse response = httpClient.execute(request);
- notifier.info(
- String.format("Webhook %s request to %s returned status %s\n\n%s",
- definition.getMethod(),
- definition.getUrl(),
- response.getStatusLine(),
- EntityUtils.toString(response.getEntity())
- )
- );
- System.out.println(String.format("Webhook %s request to %s returned status %s\n\n%s",
- definition.getMethod(),
- definition.getUrl(),
- response.getStatusLine(),
- EntityUtils.toString(response.getEntity())
- )
- );
- } catch (IOException e) {
- throwUnchecked(e);
- }
- }
- },
- 0L,
- SECONDS
- );
- }
-
- private static HttpUriRequest buildRequest(WebhookDefinition definition) {
- HttpUriRequest request = getHttpRequestFor(
- definition.getMethod(),
- definition.getUrl().toString()
- );
-
- for (HttpHeader header: definition.getHeaders().all()) {
- request.addHeader(header.key(), header.firstValue());
- }
-
- if (definition.getMethod().hasEntity()) {
- HttpEntityEnclosingRequestBase entityRequest = (HttpEntityEnclosingRequestBase) request;
- entityRequest.setEntity(new ByteArrayEntity(definition.getBinaryBody()));
- }
-
- return request;
- }
-
- public static WebhookDefinition webhook() {
- return new WebhookDefinition();
- }
-}
diff --git a/test/mock/src/main/resources/application.properties b/test/mock/src/main/resources/application.properties
deleted file mode 100644
index 51ad5ebf4..000000000
--- a/test/mock/src/main/resources/application.properties
+++ /dev/null
@@ -1 +0,0 @@
-server.port=9090