V1.0.0

.coveralls.yml

@@ -0,0 +1,2 @@
+repo_token: nV7wobmoTexZCucPnylWvD6VmRGl0s1nH
+

README.md

@@ -1,19 +1,17 @@
-[![Build Status](https://travis-ci.org/stackroute/boeing-wave3-mashup.svg?branch=master)](https://travis-ci.org/stackroute/boeing-wave3-mashup)
-[![codecov](https://codecov.io/gh/stackroute/boeing-wave3-mashup/branch/master/graph/badge.svg)](https://codecov.io/gh/stackroute/boeing-wave3-mashup)
-![](https://img.shields.io/codecov/c/github/stackroute/boeing-wave3-mashup.svg?style=flat)
+[![Build Status](https://travis-ci.org/stackroute/boeing-wave3-mashup.svg?branch=v1.0.0)](https://travis-ci.org/stackroute/boeing-wave3-mashup)
+[![codecov](https://codecov.io/gh/stackroute/boeing-wave3-mashup/branch/v1.0.0/graph/badge.svg)](https://codecov.io/gh/stackroute/boeing-wave3-mashup)
 
+![](https://img.shields.io/codecov/c/github/stackroute/boeing-wave3-mashup.svg?style=flat)
 ![](https://img.shields.io/snyk/vulnerabilities/github/stackroute/boeing-wave3-mashup.svg?style=popout)
-![](https://img.shields.io/github/issues/stackroute/boeing-wave3-mashup.svg?style=popout)
 
+![](https://img.shields.io/github/issues/stackroute/boeing-wave3-mashup.svg?style=popout)
 ![](https://img.shields.io/github/contributors/stackroute/boeing-wave3-mashup.svg?style=popout)
 ![](https://img.shields.io/github/last-commit/stackroute/boeing-wave3-mashup.svg?style=popout)
-
 ![](https://img.shields.io/github/repo-size/stackroute/boeing-wave3-mashup.svg?style=popout)
+
 [![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](https://opensource.org/licenses/Apache-2.0)
 
 ****Running the System****
 
 Run ```mvn clean compile package``` on all the services
 
-
-

authentication-service/.gitignore

@@ -0,0 +1,25 @@
+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+/build/

authentication-service/Dockerfile

@@ -0,0 +1,6 @@
+FROM openjdk:10
+
+ADD ./target/authentication-service-0.0.1-SNAPSHOT.jar authentication-service.jar
+EXPOSE 8021
+
+ENTRYPOINT ["java","-jar","authentication-service.jar"]

authentication-service/pom.xml

@@ -0,0 +1,117 @@
+<?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>
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>2.1.2.RELEASE</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+	<groupId>com.stackroute</groupId>
+	<artifactId>authentication-service</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<name>authentication-service</name>
+	<description>Authentication Service</description>
+
+	<properties>
+		<java.version>10</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-jpa</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-security</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+			<scope>runtime</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.security</groupId>
+			<artifactId>spring-security-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>io.jsonwebtoken</groupId>
+			<artifactId>jjwt</artifactId>
+			<version>0.9.0</version>
+		</dependency>
+
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger2</artifactId>
+			<version>2.6.1</version>
+			<scope>compile</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger-ui</artifactId>
+			<version>2.6.1</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.kafka</groupId>
+			<artifactId>spring-kafka</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.kafka</groupId>
+			<artifactId>spring-kafka-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.codehaus.jackson</groupId>
+			<artifactId>jackson-xc</artifactId>
+			<version>1.9.11</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-actuator</artifactId>
+		</dependency>
+        <!--<dependency>-->
+            <!--<groupId>org.springframework.cloud</groupId>-->
+            <!--<artifactId>spring-cloud-netflix-eureka-client</artifactId>-->
+            <!--<version>2.1.0.RELEASE</version>-->
+        <!--</dependency>-->
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+			<version>2.0.2.RELEASE</version>
+		</dependency>
+
+        <!--<dependency>-->
+			<!--<groupId>org.springframework.cloud</groupId>-->
+			<!--<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>-->
+			<!--<version>2.0.2.RELEASE</version>-->
+		<!--</dependency>-->
+
+
+	</dependencies>
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+
+
+</project>

authentication-service/src/main/java/com/stackroute.authenticationservice/authenticationserviceApplication.java

@@ -0,0 +1,17 @@
+package com.stackroute.authenticationservice;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
+@EnableEurekaClient
+@SpringBootApplication
+public class authenticationserviceApplication {
+
+	public static void main(String[] args) {
+
+		SpringApplication.run(authenticationserviceApplication.class, args);
+	}
+
+}
+

authentication-service/src/main/java/com/stackroute.authenticationservice/config/KafkaConfiguration.java

@@ -0,0 +1,36 @@
+package com.stackroute.authenticationservice.config;
+
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.common.serialization.StringDeserializer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.annotation.EnableKafka;
+import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
+import org.springframework.kafka.core.ConsumerFactory;
+import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@EnableKafka
+@Configuration
+public class KafkaConfiguration {
+    @Bean
+    public ConsumerFactory<String,String> consumerFactory(){
+        Map<String,Object> config = new HashMap<>();
+
+        config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
+        config.put(ConsumerConfig.GROUP_ID_CONFIG,"group_id");
+        config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+        config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,StringDeserializer.class);
+
+        return new DefaultKafkaConsumerFactory<>(config);
+    }
+
+    @Bean
+    public ConcurrentKafkaListenerContainerFactory<String,String> kafkaListenerContainerFactory(){
+        ConcurrentKafkaListenerContainerFactory<String,String> factory = new ConcurrentKafkaListenerContainerFactory();
+        factory.setConsumerFactory(consumerFactory());
+        return factory;
+    }
+}

authentication-service/src/main/java/com/stackroute.authenticationservice/config/SwaggerConfig.java

@@ -0,0 +1,22 @@
+package com.stackroute.authenticationservice.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+import static springfox.documentation.builders.PathSelectors.regex;
+
+@Configuration
+@EnableSwagger2
+public class SwaggerConfig {
+    @Bean
+    public Docket productApi() {
+        return new Docket(DocumentationType.SWAGGER_2)
+                .select().apis(RequestHandlerSelectors.basePackage("com.grokonez.jwtauthentication.controller"))
+                .paths(regex("/api/auth.*"))
+                .build();
+    }
+}

authentication-service/src/main/java/com/stackroute.authenticationservice/controller/AuthRestAPIs.java

@@ -0,0 +1,62 @@
+package com.stackroute.authenticationservice.controller;
+
+import java.util.HashSet;
+import java.util.Set;
+
+import javax.validation.Valid;
+
+import com.stackroute.authenticationservice.message.request.LoginForm;
+import com.stackroute.authenticationservice.message.response.JwtResponse;
+import com.stackroute.authenticationservice.repository.RoleRepository;
+import com.stackroute.authenticationservice.repository.UserRepository;
+import com.stackroute.authenticationservice.security.jwt.JwtProvider;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.authentication.AuthenticationManager;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+
+@CrossOrigin("*")
+@RestController
+@RequestMapping("/api/auth")
+public class AuthRestAPIs {
+
+	@Autowired
+	AuthenticationManager authenticationManager;
+
+	@Autowired
+	UserRepository userRepository;
+
+	@Autowired
+	RoleRepository roleRepository;
+
+	@Autowired
+	PasswordEncoder encoder;
+
+	@Autowired
+	JwtProvider jwtProvider;
+
+	@PostMapping("/signin")
+	public ResponseEntity<?> authenticateUser(@Valid @RequestBody LoginForm loginRequest) {
+
+		Authentication authentication = authenticationManager.authenticate(
+				new UsernamePasswordAuthenticationToken(loginRequest.getUsername(), loginRequest.getPassword()));
+
+		SecurityContextHolder.getContext().setAuthentication(authentication);
+
+		String jwt = jwtProvider.generateJwtToken(authentication);
+		UserDetails userDetails = (UserDetails) authentication.getPrincipal();
+
+		return ResponseEntity.ok(new JwtResponse(jwt, userDetails.getUsername(), userDetails.getAuthorities()));
+	}
+}

authentication-service/src/main/java/com/stackroute.authenticationservice/controller/TestRestAPIs.java

@@ -0,0 +1,29 @@
+package com.stackroute.authenticationservice.controller;
+
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@CrossOrigin(origins = "*", maxAge = 3600)
+@RestController
+public class TestRestAPIs {
+
+	@GetMapping("/api/test/user")
+	@PreAuthorize("hasRole('USER') or hasRole('ADMIN')")
+	public String userAccess() {
+		return ">>> User Contents!";
+	}
+
+	@GetMapping("/api/test/pm")
+	@PreAuthorize("hasRole('PM') or hasRole('ADMIN')")
+	public String projectManagementAccess() {
+		return ">>> Project Management Board";
+	}
+
+	@GetMapping("/api/test/admin")
+	@PreAuthorize("hasRole('ADMIN')")
+	public String adminAccess() {
+		return ">>> Admin Contents";
+	}
+}

authentication-service/src/main/java/com/stackroute.authenticationservice/message/request/LoginForm.java

@@ -0,0 +1,30 @@
+package com.stackroute.authenticationservice.message.request;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Size;
+
+public class LoginForm {
+    @NotBlank
+    @Size(min=3, max = 60)
+    private String username;
+
+    @NotBlank
+    @Size(min = 6, max = 40)
+    private String password;
+
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+}