Initial move

Author: emichaf

.gitignore

@@ -0,0 +1,19 @@
+# Eclipse
+.classpath
+.project
+.settings/
+
+# Intellij
+.idea/
+*.iml
+*.iws
+
+# Mac
+.DS_Store
+
+# Maven
+log/
+target/
+
+# Others
+derby.log

.travis.yml

@@ -0,0 +1,14 @@
+sudo: required
+
+language: java
+
+services: 
+
+jdk:
+  - oraclejdk8
+  
+before_install:
+  - chmod +x pom.xml
+  
+script:
+  - mvn -DskipTests

README.md

@@ -0,0 +1,75 @@
+<!---
+   Copyright 2017 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 Intelligence
+Eiffel Intelligence is a real time data aggregation and analysis solution for Eiffel events. While Eiffel represents an event based architecture, Eiffel Intelligence addresses the need of stakeholders to view the current state of the system by bridging the divide from immutable events to mutable state representation.
+
+This repository contains a software implementation based on the Eiffel protocol. For more information on Eiffel, its vocabulary, descriptions, guides and schemas, please see [the Eiffel repository](https://github.com/Ericsson/eiffel). For news, discussions and questions, please visit the [Eiffel Community Google group](https://groups.google.com/forum/#!forum/eiffel-community).
+
+Eiffel Intelligence is licensed under the [Apache License 2.0](./LICENSE).
+
+## How to Propose Changes
+
+Anyone is welcome to propose changes to this repository by creating a new [Issue](https://github.com/Ericsson/eiffel-intelligence/issues) ticket in GitHub. These requests may concern anything contained in the repo: changes to documentation, changes to interfaces, changes to implementations, additional tests et cetera.
+
+When posting a new issue, try to be as precise as possible and phrase your arguments for your request carefully. Keep in mind that collaborative software develpoment is often an exercise in finding workable compromises between multiple and often conflicting needs. In particular, pay attention to the following:
+1. What type of change is requested?
+1. Why would you like to see this change?
+1. Can you provide any concrete examples?
+1. Which arguments in favor can you think of?
+1. Which arguments against can you think of, and why are they outweighed by the arguments in favor?
+
+Also, keep in mind that just as anyone is welcome to propose a change, anyone is welcome to disagree with and criticize that proposal.
+
+## How to Contribute
+Contributions can be made by anyone using the standard [GitHub Fork and Pull model](https://help.github.com/articles/about-pull-requests). When making a pull request, keep a few things in mind.
+1. Always explicitly connect a pull request to an Issue. See How to Propose Changes above for further information.
+1. Make sure you target the correct branch. If you are unsure which branch is appropriate, ask in the Issue thread.
+1. Pull Requests will be publicly reviewed, criticized, and potentially rejected. Don't take it personally.
+
+### Reviewing and Merging Pull Requests
+We use the Squash and Merge model, which means that all commits in a Pull Request get squashed into a single commit in the target branch. In other words, the revision history will look like a string of single commits corresponding one-to-one with Issues.
+
+Pull requests can be merged by members of the [Eiffel team](https://github.com/orgs/Ericsson/teams/eiffel). There is a certain protocol to adhere to, however, as well as expectations on membership.
+1. All members of the Eiffel team are expected to make the effort to participate in the review of Pull Requests. Every member may not review everything in detail, but everyone can make the effort to chime in on some. Remember that expedient high quality reviews are crucial to the long term survival of any open source project.
+1. Eiffel team members are strongly encouraged to participate in reviews even if they do not feel entirely qualified to assess the pull request. Looking at changes and participating in review discussions is one of the best ways to learn, and presents an excellent opportunity to ask questions. And remember, participating in a review is not the same as having to make the final decision.
+1. Anyone can participate in reviews, not only Eiffel team members.
+1. A Pull Request should be approved by at least two Eiffel team members (including the one doing the merging). For this to function well, the above point on participation is critical.
+1. Do not feel any pressure to merge Pull Requests. Unless you feel confident about what you are doing, don't press that big green button. Instead, ask a more senior member to make the decision.
+1. When squashing and merging, ensure that the description reflects the change. Detailing every individual commit in the Pull Request is unnecessary, as they are squashed anyway. Instead, describe the change as a single thing. That description should always include an Issue reference, and should focus on WHY the change was made, to provide the reader with context. See [this excellent guide](https://chris.beams.io/posts/git-commit) on writing good commit messages.
+
+### License Management
+To be accepted into the repository, contributions must be licensed under the Apache License 2.0. Consequently, a license notice shall be included in suitable comment syntax where applicable. This license notice shall state the copyright holder(s) and point to the commit history for a full list of individual contributors, on the following format:
+
+> Copyright <Year(s)> <Copyright holder of original contribution [and others].>  
+> For a full list of individual contributors, please see the commit history.
+
+The copyright holder is either the individual contributor if they act on their own behalf, or any organization on whose behalf they contribute. When multiple copyright holders have contributed to the same file, the copyright notice shall be appended "and others". The copyright year(s) shall reflect the year(s) of contribution(s) and be updated accordingly when new contributions are made to the file. To exemplify, the copyright notice of an original contribution made by Jane Doe acting on behalf of Ericsson AB may read:
+
+> Copyright 2017 Ericsson AB.  
+> For a full list of individual contributors, please see the commit history.
+
+When John Doe, acting on his own behalf, makes a subsequent addition to the same file, the notice will be updated accordingly:
+
+> Copyright 2017 Ericsson AB and others.  
+> For a full list of individual contributors, please see the commit history.
+
+When John Doe makes a subsequent contribution the following year, the notice will again be updated:
+
+> Copyright 2017-2018 Ericsson AB and others.  
+> For a full list of individual contributors, please see the commit history.
+

pom.xml

@@ -0,0 +1,67 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?><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>com.ericsson.ei.frontend</groupId>
+	<artifactId>ei-frontend</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<packaging>jar</packaging>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>1.5.4.RELEASE</version>
+		<relativePath/> <!-- ..  lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+		<java.version>1.8</java.version>
+		<fabric8.mode>kubernetes</fabric8.mode>
+   	</properties>
+
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-actuator</artifactId>
+			<version>1.5.4.RELEASE</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+			<version>1.5.4.RELEASE</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-hystrix</artifactId>
+			<version>1.3.1.RELEASE</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
+			<version>1.3.1.RELEASE</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-thymeleaf</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-devtools</artifactId>
+			<optional>true</optional>
+		</dependency>
+	</dependencies>
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		    </plugins>
+
+	  </build>
+
+
+</project>
+

src/main/docker/Dockerfile

@@ -0,0 +1,4 @@
+FROM fabric8/java-jboss-openjdk8-jdk:1.2
+ENV JAVA_APP_DIR=/deployments
+EXPOSE 8080 8778 9779
+COPY maven /deployments/

src/main/java/com.ericsson.ei.frontend/EI_FrontEnd_Application.java

@@ -0,0 +1,16 @@
+package com.ericsson.ei.frontend;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class EI_FrontEnd_Application {
+
+    public static final Logger log = LoggerFactory.getLogger(EI_FrontEnd_Application.class);
+
+    public static void main(String[] args) {
+        SpringApplication.run(EI_FrontEnd_Application.class, args);
+    }
+}

src/main/java/com.ericsson.ei.frontend/SubscriptionFilesController.java

@@ -0,0 +1,48 @@
+package com.ericsson.ei.frontend;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStream;
+
+import javax.servlet.ServletContext;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Controller;
+import org.springframework.util.FileCopyUtils;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+public class SubscriptionFilesController {
+	
+	@Value("${ei.subscriptionFilePath}") private String subscriptionFilePath;
+    private static final String APPLICATION_JSON = "application/json";
+
+    
+    @RequestMapping(value = "/download/subscriptiontemplate", method = RequestMethod.GET, produces = APPLICATION_JSON)
+    public @ResponseBody void downloadA(HttpServletResponse response) throws IOException {
+        File file = getFile(subscriptionFilePath);
+        InputStream in = new FileInputStream(file);
+
+        response.setContentType(APPLICATION_JSON);
+        response.setHeader("Content-Disposition", "attachment; filename=" + file.getName());
+        response.setHeader("Content-Length", String.valueOf(file.length()));
+        FileCopyUtils.copy(in, response.getOutputStream());
+    }
+
+    
+    private File getFile(String filePath) throws FileNotFoundException {
+        File file = new File(filePath);
+        if (!file.exists()){
+            throw new FileNotFoundException("File " + '"' + filePath + '"' + " was not found.");
+        }
+        return file;
+    }
+}
+

src/main/java/com.ericsson.ei.frontend/WebController.java

@@ -0,0 +1,45 @@
+package com.ericsson.ei.frontend;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+
+@Controller
+@ConfigurationProperties(prefix="ei")
+public class WebController {
+
+    private String backendServiceHost;
+    private int backendServicePort;
+
+
+    @RequestMapping("/")
+    public String greeting(Model model) {
+
+        String backendServiceUrl = String.format("http://%s:%d", backendServiceHost, backendServicePort);
+
+        model.addAttribute("backendServiceUrl", backendServiceUrl);  // inject in DOM for AJAX etc
+
+        return "index";
+    }
+
+    // Backend host and port (Getter & Setters), application.properties -> greeting.xxx
+    public String getBackendServiceHost() {
+        return backendServiceHost;
+    }
+
+    public void setBackendServiceHost(String backendServiceHost) {
+        this.backendServiceHost = backendServiceHost;
+    }
+
+    public int getBackendServicePort() {
+        return backendServicePort;
+    }
+
+    public void setBackendServicePort(int backendServicePort) {
+        this.backendServicePort = backendServicePort;
+    }
+
+}

src/main/resources/application.properties

@@ -0,0 +1,17 @@
+# REST api returns json in pretty format with jackson
+spring.jackson.default-property-inclusion=non_null
+
+spring.application.name=ei-frontend
+  #${project.artifactId}
+
+server.port=8080
+
+######## EI Backend
+ei.backendServiceHost=localhost
+ei.backendServicePort=8090
+
+###### Subscription Template file ########
+ei.subscriptionFilePath=./src/main/resources/subscriptions/subscriptionsTemplate.json
+
+
+