Skip to content

GitLab

D
DECIDE_Components
Commit 1e4581b6 authored by Alonso Ibarra, Juncal's avatar Alonso Ibarra, Juncal
Browse files
Options

Merge branch 'master' of https://git.code.tecnalia.com/DECIDE_Public/DECIDE_Components

parents cd665732 7d4f471c
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 20275 additions and 11 deletions
MCSLA/mcsla-service/.gitignore 0 → 100644
View file @ 1e4581b6
# Created by .ignore support plugin (hsz.mobi)
### JetBrains template
# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
*.iml
# User-specific stuff:
.idea/**/workspace.xml
.idea/**/tasks.xml
.idea/dictionaries
# Sensitive or high-churn files:
.idea/**/dataSources/
.idea/**/dataSources.ids
.idea/**/dataSources.xml
.idea/**/dataSources.local.xml
.idea/**/sqlDataSources.xml
.idea/**/dynamic.xml
.idea/**/uiDesigner.xml
# Gradle:
.idea/**/gradle.xml
.idea/**/libraries
# CMake
cmake-build-debug/
# Mongo Explorer plugin:
.idea/**/mongoSettings.xml
## File-based project format:
*.iws
## Plugin-specific files:
# IntelliJ
out/
# mpeltonen/sbt-idea plugin
.idea_modules/
# JIRA plugin
atlassian-ide-plugin.xml
# Cursive Clojure plugin
.idea/replstate.xml
# Crashlytics plugin (for Android Studio and IntelliJ)
com_crashlytics_export_strings.xml
crashlytics.properties
crashlytics-build.properties
fabric.properties
### Maven template
target/
pom.xml.tag
pom.xml.releaseBackup
pom.xml.versionsBackup
pom.xml.next
release.properties
dependency-reduced-pom.xml
buildNumber.properties
.mvn/timing.properties
# Avoid ignoring Maven wrapper jar file (.jar files are usually ignored)
!/.mvn/wrapper/maven-wrapper.jar
### Eclipse template
.metadata
bin/
tmp/
*.tmp
*.bak
*.swp
*~.nib
local.properties
.settings/
.loadpath
.recommenders
# External tool builders
.externalToolBuilders/
# Locally stored "Eclipse launch configurations"
*.launch
# PyDev specific (Python IDE for Eclipse)
*.pydevproject
# CDT-specific (C/C++ Development Tooling)
.cproject
# Java annotation processor (APT)
.factorypath
# PDT-specific (PHP Development Tools)
.buildpath
# sbteclipse plugin
.target
# Tern plugin
.tern-project
# TeXlipse plugin
.texlipse
# STS (Spring Tool Suite)
.springBeans
# Code Recommenders
.recommenders/
# Scala IDE specific (Scala & Java development for Eclipse)
.cache-main
.scala_dependencies
.worksheet
MCSLA/mcsla-service/.gitlab-ci.yml 0 → 100644
View file @ 1e4581b6
stages:
- build
- deploy
build:
stage: build
tags:
- docker
image: maven:3.6.0-jdk-10
script:
- "mvn clean package -U -B -DskipTests"
only:
- master
artifacts:
paths:
- target
register:
stage: deploy
tags:
- docker
image: docker:latest
variables:
DOCKER_DRIVER: overlay2
services:
- docker:dind
only:
- master
script:
- docker login -u "gitlab-ci-token" -p "$CI_JOB_TOKEN" $CI_REGISTRY
- docker build --pull -t "$CI_REGISTRY_IMAGE" .
- docker push "$CI_REGISTRY_IMAGE"
MCSLA/mcsla-service/Dockerfile 0 → 100644
View file @ 1e4581b6
FROM openjdk:8-jre
ENV VERTICLE_FILE mcsla-service-fat.jar
# Set the location of the verticles
ENV VERTICLE_HOME /usr/verticles
EXPOSE 8080
RUN addgroup --system vertx && adduser --system --group vertx
# Copy your fat jar to the container
COPY target/$VERTICLE_FILE $VERTICLE_HOME/
RUN chown -R vertx $VERTICLE_HOME
RUN chmod -R g+w $VERTICLE_HOME
USER vertx
# Launch the verticle
WORKDIR $VERTICLE_HOME
ENTRYPOINT ["sh", "-c"]
CMD ["exec java -Xmx2048m -jar $VERTICLE_FILE -Dvertx.logger-delegate-factory-class-name=io.vertx.core.logging.SLF4JLogDelegateFactory -Dvertx.metrics.options.enabled=true"]
MCSLA/mcsla-service/LICENSE.txt 0 → 100644
View file @ 1e4581b6
This diff is collapsed.
MCSLA/mcsla-service/README.md 0 → 100644
View file @ 1e4581b6
# DECIDE MCSLA Service
## Build
Clone repo and build with maven.
```bash
$ git clone https://gitlab.fokus.fraunhofer.de/DECIDE/mcsla-service.git
$ cd mcsla-service
$ mvn clean package
```
You will find the built artifacts in the `target` directory.
## Install
No installation required. To run the service, do:
```bash
$ java -jar target/mcsla-service
```
## Configuration
The following environment variables are read:
* DECIDE_REPOS_BASE_DIR
The path to the base for cloning remote repositories
* DECIDE_ACSMI_DISCOVERY_SERVICE_URI
The address of the ACSmI discovery service
## Docker
```bash
$ docker build -t decide/mcsla-service .
$ docker run -it -p 8080:8080 decide/mcsla-service
```
## Interface
The root context shows the OpenAPI documentation.
## License
[GNU Affero General Public License Version 3](LICENSE.txt)
\ No newline at end of file
MCSLA/mcsla-service/pom.xml 0 → 100644
View file @ 1e4581b6
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>eu.DECIDEh2020</groupId>
<artifactId>mcsla-service</artifactId>
<version>0.0.5-SNAPSHOT</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<vertx.version>3.5.4</vertx.version>
<main.verticle>eu.DECIDEh2020.mcsla.service.MainVerticle</main.verticle>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-dependencies</artifactId>
<version>${vertx.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-core</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-hazelcast</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-web</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-web-client</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-web-api-contract</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-health-check</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-dropwizard-metrics</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-config</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-rx-java2</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-service-proxy</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-codegen</artifactId>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-junit5</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>eu.DECIDEh2020</groupId>
<artifactId>app-controller</artifactId>
<version>0.0.16-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>eu.DECIDEh2020</groupId>
<artifactId>mcsla-core</artifactId>
<version>0.0.3-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
</dependencies>
<build>
<pluginManagement>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.0</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
<encoding>${project.build.sourceEncoding}</encoding>
<useIncrementalCompilation>false</useIncrementalCompilation>
<annotationProcessors>
<annotationProcessor>io.vertx.codegen.CodeGenProcessor</annotationProcessor>
</annotationProcessors>
<generatedSourcesDirectory>${project.basedir}/src/main/generated</generatedSourcesDirectory>
<compilerArgs>
<arg>-Acodegen.output=${project.basedir}/src/main</arg>
</compilerArgs>
</configuration>
</plugin>
<plugin>
<artifactId>maven-clean-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<filesets>
<fileset>
<directory>${project.basedir}/src/main/generated</directory>
</fileset>
</filesets>
</configuration>
</plugin>
</plugins>
</pluginManagement>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.1.1</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<filters>
<filter>
<artifact>*:*</artifact>
<excludes>
<exclude>META-INF/*.SF</exclude>
<exclude>META-INF/*.DSA</exclude>
<exclude>META-INF/*.RSA</exclude>
</excludes>
</filter>
</filters>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<manifestEntries>
<Main-Class>io.vertx.core.Launcher</Main-Class>
<Main-Verticle>${main.verticle}</Main-Verticle>
</manifestEntries>
</transformer>
<transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
<resource>META-INF/services/io.vertx.core.spi.VerticleFactory</resource>
</transformer>
</transformers>
<outputFile>${project.build.directory}/${project.artifactId}-fat.jar</outputFile>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
MCSLA/mcsla-service/src/main/java/eu/DECIDEh2020/mcsla/service/MainVerticle.java 0 → 100644
View file @ 1e4581b6
/*
* Copyright (c) 2017 Fraunhofer FOKUS.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the
* GNU AGPL v3 which accompanies
* this distribution, and is available at
* http://www.gnu.org/licenses/agpl.txt
*
* Contributors:
* Simon Dutkowski Fraunhofer FOKUS
*
* Initially developed in the context of DECIDE EU project www.DECIDE-h2020.eu
*/
package eu.DECIDEh2020.mcsla.service;
import eu.DECIDEh2020.mcsla.service.repositories.RepositoriesService;
import eu.DECIDEh2020.mcsla.service.repositories.RepositoriesVerticle;
import io.vertx.config.ConfigRetriever;
import io.vertx.config.ConfigRetrieverOptions;
import io.vertx.config.ConfigStoreOptions;
import io.vertx.core.*;
import io.vertx.core.http.HttpMethod;
import io.vertx.core.http.HttpServer;
import io.vertx.core.http.HttpServerOptions;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.dropwizard.MetricsService;
import io.vertx.ext.healthchecks.HealthCheckHandler;
import io.vertx.ext.healthchecks.Status;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.RoutingContext;
import io.vertx.ext.web.api.RequestParameter;
import io.vertx.ext.web.api.RequestParameters;
import io.vertx.ext.web.api.contract.RouterFactoryOptions;
import io.vertx.ext.web.api.contract.openapi3.OpenAPI3RouterFactory;
import io.vertx.ext.web.handler.CorsHandler;
import io.vertx.ext.web.handler.StaticHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Arrays;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class MainVerticle extends AbstractVerticle {
private Logger log = LoggerFactory.getLogger(getClass());
private RepositoriesService repositories;
@Override
public void start(Future<Void> startFuture) {
MetricsService metrics = MetricsService.create(vertx);
ConfigStoreOptions storeOptions = new ConfigStoreOptions()
.setType("env")
.setConfig(new JsonObject().put("keys", new JsonArray().add("DECIDE_REPOS_BASE_DIR").add("DECIDE_ACSMI_DISCOVERY_SERVICE_URI")));
ConfigRetriever retriever = ConfigRetriever.create(vertx, new ConfigRetrieverOptions().addStore(storeOptions));
Future<JsonObject> configFuture = ConfigRetriever.getConfigAsFuture(retriever);
configFuture.compose(config -> {
log.debug("config read");
Future<Void> repositoriesFuture = Future.future();
vertx.deployVerticle(RepositoriesVerticle.class, new DeploymentOptions().setWorker(true).setConfig(config), result -> {
if (result.succeeded()) {
log.debug("repositories verticle deployed successfully");
repositories = RepositoriesService.createProxy(vertx, "decide.mcsla.service.repositories.queue");
repositoriesFuture.complete();
} else {
repositoriesFuture.fail(result.cause());
}
});
repositoriesFuture.setHandler(res -> {
if (res.succeeded()) {
log.debug("all verticles deployed");
OpenAPI3RouterFactory.create(vertx, "webroot/openapi.yaml", ar -> {
if (ar.succeeded()) {
OpenAPI3RouterFactory routerFactory = ar.result();
RouterFactoryOptions roptions = new RouterFactoryOptions().setMountNotImplementedHandler(true).setMountValidationFailureHandler(true);
routerFactory.setOptions(roptions);
routerFactory.addHandlerByOperationId("initApplication", this::handleInitApplication);
routerFactory.addHandlerByOperationId("getApplication", this::handleGetApplication);
routerFactory.addHandlerByOperationId("resetApplication", this::handleResetApplication);
routerFactory.addHandlerByOperationId("aggregateServiceObjective", this::handleAggregation);
routerFactory.addHandlerByOperationId("setMcsla", this::handleMcsla);
Router router = routerFactory.getRouter();
router.route().order(0).handler(CorsHandler.create("*").allowedMethods(Stream.of(HttpMethod.GET, HttpMethod.POST).collect(Collectors.toSet())));
router.route("/*").handler(StaticHandler.create());
HealthCheckHandler hch = HealthCheckHandler.create(vertx);
hch.register("simple-ok", future -> future.complete(Status.OK()));
hch.register("info", future -> future.complete(Status.OK(new JsonObject().put("build", 1))));
router.get("/health").handler(hch);
router.get("/metrics").produces("application/json").handler(routingContext -> {
JsonObject m = metrics.getMetricsSnapshot(vertx);
if (m != null) {
routingContext.response().setStatusCode(200).end(m.encodePrettily());
} else {
routingContext.response().setStatusCode(503).end();
}
});
HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
server.requestHandler(router::accept).listen();
startFuture.complete();
} else {
// Something went wrong during router factory initialization
startFuture.fail(ar.cause());
}
});
} else {
startFuture.fail(res.cause());
}
});
}, startFuture);
}
private void handleInitApplication(RoutingContext context) {
RequestParameters params = context.get("parsedParameters");
RequestParameter uriParam = params.queryParameter("uri");
String uri = uriParam != null && uriParam.isString() && !uriParam.isEmpty() ? uriParam.getString() : "";
RequestParameter tokenParam = params.queryParameter("token");
String token = tokenParam != null && tokenParam.isString() && !tokenParam.isEmpty() ? tokenParam.getString() : "";
RequestParameter usernameParam = params.queryParameter("username");
String username = usernameParam != null && usernameParam.isString() && !usernameParam.isEmpty() ? usernameParam.getString() : "";
RequestParameter passwordParam = params.queryParameter("password");
String password = passwordParam != null && passwordParam.isString() && !passwordParam.isEmpty() ? passwordParam.getString() : "";
RequestParameter pathParam = params.queryParameter("path");
String path = pathParam != null && pathParam.isString() && !pathParam.isEmpty() ? pathParam.getString() : null;
if (path != null) {
} else {
repositories.initRepository(uri, token, username, password, res -> {
JsonObject result = null;
if (res.succeeded()) {
result = res.result();
result.put("success", true);
} else {
result = new JsonObject().put("success", false);
result.put("error", new JsonObject().put("message", res.cause().getMessage()));
}
context.response().end(result.toBuffer());
});
}
}
private void handleGetApplication(RoutingContext context) {
RequestParameters params = context.get("parsedParameters");
RequestParameter nameParam = params.pathParameter("name");
String name = nameParam != null && nameParam.isString() && !nameParam.isEmpty() ? nameParam.getString() : "";
repositories.getApplication(name, res -> {
JsonObject result = new JsonObject();
if (res.succeeded()) {
result.put("success", true);
result.put("app", res.result());
} else {
result.put("success", false);
result.put("error", new JsonObject().put("message", res.cause().getMessage()));
}
context.response().end(result.toBuffer());
});
}
private void handleResetApplication(RoutingContext context) {
RequestParameters params = context.get("parsedParameters");
RequestParameter nameParam = params.pathParameter("name");
String name = nameParam != null && nameParam.isString() && !nameParam.isEmpty() ? nameParam.getString() : "";
repositories.resetApplication(name, res -> {
JsonObject result = new JsonObject();
if (res.succeeded()) {
result.put("success", true);
result.put("app", res.result());
} else {
result.put("success", false);
result.put("error", new JsonObject().put("message", res.cause().getMessage()));
}
context.response().end(result.toBuffer());