close #146: websocket implemented

Api/api-app/pom.xml

@@ -208,6 +208,6 @@
                 </executions>
             </plugin>
         </plugins>
-        <finalName>opex-accountant</finalName>
+        <finalName>opex-api</finalName>
     </build>
 </project>

Api/api-app/src/main/kotlin/co/nilin/opex/app/ApiApp.kt

@@ -1,23 +1,9 @@
 package co.nilin.opex.app
 
-import org.springframework.beans.factory.annotation.Value
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication
-import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.ComponentScan
-import org.springframework.security.core.annotation.AuthenticationPrincipal
-import springfox.documentation.builders.*
-import springfox.documentation.builders.PathSelectors.regex
-import springfox.documentation.service.*
-import springfox.documentation.spi.DocumentationType
-import springfox.documentation.spi.service.contexts.SecurityContext
-import springfox.documentation.spring.web.plugins.Docket
-import springfox.documentation.swagger.web.SecurityConfiguration
-import springfox.documentation.swagger.web.SecurityConfigurationBuilder
 import springfox.documentation.swagger2.annotations.EnableSwagger2
-import java.security.Principal
-import java.util.Collections.singletonList
-
 
 @SpringBootApplication
 @ComponentScan("co.nilin.opex")

Api/api-ports/api-binance-rest/src/main/kotlin/co/nilin/opex/port/api/binance/config/SecurityConfig.kt

@@ -30,6 +30,7 @@ class SecurityConfig(private val webClient: WebClient) {
             .pathMatchers("/v3/ticker/**").permitAll()
             .pathMatchers("/v3/exchangeInfo").permitAll()
             .pathMatchers("/v3/klines").permitAll()
+            .pathMatchers("/socket").permitAll()
             .pathMatchers("/**").hasAuthority("SCOPE_trust")
             .anyExchange().authenticated()
             .and()

Deployment/docker-compose.yml

@@ -306,21 +306,30 @@ services:
     deploy:
       restart_policy:
         condition: on-failure
-  nginx:
-    image: jboesl/docker-nginx-headers-more
-    container_name: opex_nginx
-    volumes:
-      - ./nginx.conf:/etc/nginx/nginx.conf
-      - $DATA/www:/data/www
+  websocket:
+    container_name: websocket
+    build:
+      context: ../Websocket/websocket-app
+      dockerfile: Dockerfile
     ports:
-      - 80:80
-    depends_on:
-      - wallet
-      - auth
-      - matching-gateway
-      - api
+      - 127.0.0.1:8097:8097
+      - 127.0.0.1:1054:1044
+    environment:
+      - JAVA_OPTS=-Xmx256m -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=1044
+      - SPRING_PROFILES_DEFAULT=docker
+      - KAFKA_IP_PORT=kafka:9092
+      - CONSUL_HOST=consul
+      - DB_IP_PORT=postgres-api
     networks:
       - opex
+    depends_on:
+      - zookeeper
+      - kafka
+      - consul
+      - postgres-api
+    deploy:
+      restart_policy:
+        condition: on-failure
   bc-gateway:
     container_name: bc-gateway
     build:
@@ -366,6 +375,21 @@ services:
     deploy:
       restart_policy:
         condition: on-failure
+  nginx:
+    image: jboesl/docker-nginx-headers-more
+    container_name: opex_nginx
+    volumes:
+      - ./nginx.conf:/etc/nginx/nginx.conf
+      - $DATA/www:/data/www
+    ports:
+      - 80:80
+    depends_on:
+      - wallet
+      - auth
+      - matching-gateway
+      - api
+    networks:
+      - opex
 networks:
   opex:
     driver: bridge

Deployment/nginx.conf

@@ -27,6 +27,10 @@ http {
         server storage:8096;
     }
 
+    upstream docker-websocket {
+        server storage:8097;
+    }
+
     proxy_set_header   Host $host;
     proxy_set_header   X-Real-IP $remote_addr;
     proxy_set_header   X-Forwarded-For $proxy_add_x_forwarded_for;
@@ -70,6 +74,11 @@ http {
             rewrite ^/storage/(.*)$ /$1 break;
         }
 
+        location /stream {
+            proxy_pass http://docker-websocket;
+            rewrite ^/stream/(.*)$ /$1 break;
+        }
+
         location /api {
             proxy_pass http://docker-api;
             rewrite ^/api(.*)$ $1 break;

Jenkins/Jenkinsfile.deploy.groovy

@@ -47,6 +47,10 @@ pipeline {
                     dir("Storage") {
                         sh 'mvn -B  clean install'
                     }
+
+                    dir("Websocket") {
+                        sh 'mvn -B  clean install'
+                    }
                 }
 
             }

Websocket/pom.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         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>co.nilin.opex</groupId>
+    <artifactId>websocket-root</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <name>websocket-root</name>
+    <packaging>pom</packaging>
+    <description>Websocket root module</description>
+    <modules>
+        <module>websocket-app</module>
+        <module>websocket-core</module>
+        <module>websocket-ports/websocket-eventlistener-kafka</module>
+        <module>websocket-ports/websocket-persister-postgres</module>
+    </modules>
+</project>

Websocket/websocket-app/.gitignore

@@ -0,0 +1,33 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### 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/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

Websocket/websocket-app/Dockerfile

@@ -0,0 +1,5 @@
+FROM openjdk:8-jdk-alpine
+VOLUME /tmp
+ARG JAR_FILE=target/*.jar
+COPY ${JAR_FILE} app.jar
+ENTRYPOINT ["sh", "-c", "java ${JAVA_OPTS} -jar /app.jar"]