Initial commit

build.gradle.kts

@@ -0,0 +1,71 @@
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
+
+plugins {
+ id("org.springframework.boot") version "2.3.3.RELEASE"
+ id("io.spring.dependency-management") version "1.0.10.RELEASE"
+ kotlin("jvm") version "1.3.72"
+ kotlin("plugin.spring") version "1.3.72"
+ id("java")
+}
+
+group = "com.teyyihan"
+version = "1.0"
+java.sourceCompatibility = JavaVersion.VERSION_11
+
+repositories {
+ mavenCentral()
+}
+
+dependencies {
+ implementation("org.springframework.boot:spring-boot-starter-webflux")
+ implementation("org.springframework.boot:spring-boot-starter-security")
+
+
+ implementation("org.springframework.security:spring-security-oauth2-jose:5.3.4.RELEASE")
+ implementation("org.springframework.security:spring-security-oauth2-client:5.3.4.RELEASE")
+ implementation("org.springframework.security:spring-security-oauth2-resource-server:5.3.4.RELEASE")
+
+
+
+ // Keycloak
+ implementation("org.keycloak:keycloak-admin-client:11.0.2")
+
+ // Reactive
+ implementation("org.springframework.boot:spring-boot-starter-data-mongodb-reactive")
+ implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor")
+
+ // Validation
+ implementation("javax.validation:validation-api:2.0.1.Final")
+
+ // Retrofit
+ implementation("com.squareup.retrofit2:retrofit:2.9.0")
+ implementation("com.squareup.retrofit2:converter-moshi:2.9.0")
+
+ implementation("com.auth0:java-jwt:3.10.3")
+
+ implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+ implementation("io.projectreactor.kotlin:reactor-kotlin-extensions")
+ implementation("org.jetbrains.kotlin:kotlin-reflect")
+ implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8")
+ testImplementation("org.springframework.boot:spring-boot-starter-test") {
+ exclude(group = "org.junit.vintage", module = "junit-vintage-engine")
+ }
+ testImplementation("io.projectreactor:reactor-test")
+}
+
+tasks.withType<Test> {
+ useJUnitPlatform()
+}
+
+tasks.withType<KotlinCompile> {
+ kotlinOptions {
+ freeCompilerArgs = listOf("-Xjsr305=strict")
+ jvmTarget = "11"
+ }
+}
+
+tasks.register<Copy>("copyJar") {
+ from(file("$buildDir/libs/e2ee_chat-1.0.jar"))
+ into(file("docker-compose/spring_app"))
+}
+

docker-compose/coms/remove_all_image.ps1

@@ -0,0 +1 @@
+docker rmi $(docker images -a -q)

docker-compose/coms/remove_all_volumes.ps1

@@ -0,0 +1 @@
+docker volume rm $(docker volume ls -q)

docker-compose/docker-compose.yml

@@ -0,0 +1,63 @@
+version: '3'
+
+volumes:
+ postgres_data:
+ driver: local
+
+services:
+
+ postgres:
+ image: postgres
+ container_name: postgresql
+ volumes:
+ - ./db/postgres_data:/var/lib/postgresql/data
+ environment:
+ POSTGRES_DB: keycloak
+ POSTGRES_USER: keycloak
+ POSTGRES_PASSWORD: password
+
+ keycloak:
+ image: quay.io/keycloak/keycloak:latest
+ container_name: keycloak
+ volumes:
+ - ./imports:/data/imports
+ environment:
+ DB_VENDOR: POSTGRES
+ DB_ADDR: postgres
+ DB_DATABASE: keycloak
+ DB_USER: keycloak
+ DB_SCHEMA: public
+ DB_PASSWORD: password
+ KEYCLOAK_USER: teyyihan
+ KEYCLOAK_PASSWORD: teyyihan
+ command:
+ - "-Djboss.socket.binding.port-offset=1"
+ - "-Dkeycloak.profile.feature.upload_scripts=enabled"
+ - "-b 0.0.0.0 -Dkeycloak.import=/data/imports/realm-export.json"
+ ports:
+ - 8081:8081
+ depends_on:
+ - postgres
+
+ mongodb:
+ image: mongo
+ container_name: mongodb
+ environment:
+ - MONGO_INITDB_DATABASE=e2ee
+ - MONGO_INIT_ROOT_USERNAME=teyyihan
+ - MONGO_INIT_ROOT_PASSWORD=teyyihan
+ volumes:
+ - ./db/mongo-volume:/data/db
+ ports:
+ - 27017-27019:27017-27019
+
+ spring:
+ build: spring_app/
+ ports:
+ - 8080:8080
+ container_name: spring
+ depends_on:
+ - keycloak
+ - mongodb
+ links:
+ - mongodb

docker-compose/spring_app/Dockerfile

@@ -0,0 +1,4 @@
+FROM openjdk:14
+COPY e2ee_chat-1.0.jar /
+COPY wait-for-it.sh /
+ENTRYPOINT ["./wait-for-it.sh", "mongodb:27017","--timeout=60", "--", "./wait-for-it.sh", "keycloak:8081","--timeout=60", "--", "java", "-jar","e2ee_chat-1.0.jar"]

docker-compose/spring_app/wait-for-it.sh

@@ -0,0 +1,182 @@
+#!/usr/bin/env bash
+# Use this script to test if a given TCP host/port are available
+
+WAITFORIT_cmdname=${0##*/}
+
+echoerr() { if [[ $WAITFORIT_QUIET -ne 1 ]]; then echo "$@" 1>&2; fi }
+
+usage()
+{
+ cat << USAGE >&2
+Usage:
+ $WAITFORIT_cmdname host:port [-s] [-t timeout] [-- command args]
+ -h HOST | --host=HOST Host or IP under test
+ -p PORT | --port=PORT TCP port under test
+ Alternatively, you specify the host and port as host:port
+ -s | --strict Only execute subcommand if the test succeeds
+ -q | --quiet Don't output any status messages
+ -t TIMEOUT | --timeout=TIMEOUT
+ Timeout in seconds, zero for no timeout
+ -- COMMAND ARGS Execute command with args after the test finishes
+USAGE
+ exit 1
+}
+
+wait_for()
+{
+ if [[ $WAITFORIT_TIMEOUT -gt 0 ]]; then
+ echoerr "$WAITFORIT_cmdname: waiting $WAITFORIT_TIMEOUT seconds for $WAITFORIT_HOST:$WAITFORIT_PORT"
+ else
+ echoerr "$WAITFORIT_cmdname: waiting for $WAITFORIT_HOST:$WAITFORIT_PORT without a timeout"
+ fi
+ WAITFORIT_start_ts=$(date +%s)
+ while :
+ do
+ if [[ $WAITFORIT_ISBUSY -eq 1 ]]; then
+ nc -z $WAITFORIT_HOST $WAITFORIT_PORT
+ WAITFORIT_result=$?
+ else
+ (echo -n > /dev/tcp/$WAITFORIT_HOST/$WAITFORIT_PORT) >/dev/null 2>&1
+ WAITFORIT_result=$?
+ fi
+ if [[ $WAITFORIT_result -eq 0 ]]; then
+ WAITFORIT_end_ts=$(date +%s)
+ echoerr "$WAITFORIT_cmdname: $WAITFORIT_HOST:$WAITFORIT_PORT is available after $((WAITFORIT_end_ts - WAITFORIT_start_ts)) seconds"
+ break
+ fi
+ sleep 1
+ done
+ return $WAITFORIT_result
+}
+
+wait_for_wrapper()
+{
+ # In order to support SIGINT during timeout: http:https://unix.stackexchange.com/a/57692
+ if [[ $WAITFORIT_QUIET -eq 1 ]]; then
+ timeout $WAITFORIT_BUSYTIMEFLAG $WAITFORIT_TIMEOUT $0 --quiet --child --host=$WAITFORIT_HOST --port=$WAITFORIT_PORT --timeout=$WAITFORIT_TIMEOUT &
+ else
+ timeout $WAITFORIT_BUSYTIMEFLAG $WAITFORIT_TIMEOUT $0 --child --host=$WAITFORIT_HOST --port=$WAITFORIT_PORT --timeout=$WAITFORIT_TIMEOUT &
+ fi
+ WAITFORIT_PID=$!
+ trap "kill -INT -$WAITFORIT_PID" INT
+ wait $WAITFORIT_PID
+ WAITFORIT_RESULT=$?
+ if [[ $WAITFORIT_RESULT -ne 0 ]]; then
+ echoerr "$WAITFORIT_cmdname: timeout occurred after waiting $WAITFORIT_TIMEOUT seconds for $WAITFORIT_HOST:$WAITFORIT_PORT"
+ fi
+ return $WAITFORIT_RESULT
+}
+
+# process arguments
+while [[ $# -gt 0 ]]
+do
+ case "$1" in
+ *:* )
+ WAITFORIT_hostport=(${1//:/ })
+ WAITFORIT_HOST=${WAITFORIT_hostport[0]}
+ WAITFORIT_PORT=${WAITFORIT_hostport[1]}
+ shift 1
+ ;;
+ --child)
+ WAITFORIT_CHILD=1
+ shift 1
+ ;;
+ -q | --quiet)
+ WAITFORIT_QUIET=1
+ shift 1
+ ;;
+ -s | --strict)
+ WAITFORIT_STRICT=1
+ shift 1
+ ;;
+ -h)
+ WAITFORIT_HOST="$2"
+ if [[ $WAITFORIT_HOST == "" ]]; then break; fi
+ shift 2
+ ;;
+ --host=*)
+ WAITFORIT_HOST="${1#*=}"
+ shift 1
+ ;;
+ -p)
+ WAITFORIT_PORT="$2"
+ if [[ $WAITFORIT_PORT == "" ]]; then break; fi
+ shift 2
+ ;;
+ --port=*)
+ WAITFORIT_PORT="${1#*=}"
+ shift 1
+ ;;
+ -t)
+ WAITFORIT_TIMEOUT="$2"
+ if [[ $WAITFORIT_TIMEOUT == "" ]]; then break; fi
+ shift 2
+ ;;
+ --timeout=*)
+ WAITFORIT_TIMEOUT="${1#*=}"
+ shift 1
+ ;;
+ --)
+ shift
+ WAITFORIT_CLI=("$@")
+ break
+ ;;
+ --help)
+ usage
+ ;;
+ *)
+ echoerr "Unknown argument: $1"
+ usage
+ ;;
+ esac
+done
+
+if [[ "$WAITFORIT_HOST" == "" || "$WAITFORIT_PORT" == "" ]]; then
+ echoerr "Error: you need to provide a host and port to test."
+ usage
+fi
+
+WAITFORIT_TIMEOUT=${WAITFORIT_TIMEOUT:-15}
+WAITFORIT_STRICT=${WAITFORIT_STRICT:-0}
+WAITFORIT_CHILD=${WAITFORIT_CHILD:-0}
+WAITFORIT_QUIET=${WAITFORIT_QUIET:-0}
+
+# Check to see if timeout is from busybox?
+WAITFORIT_TIMEOUT_PATH=$(type -p timeout)
+WAITFORIT_TIMEOUT_PATH=$(realpath $WAITFORIT_TIMEOUT_PATH 2>/dev/null || readlink -f $WAITFORIT_TIMEOUT_PATH)
+
+WAITFORIT_BUSYTIMEFLAG=""
+if [[ $WAITFORIT_TIMEOUT_PATH =~ "busybox" ]]; then
+ WAITFORIT_ISBUSY=1
+ # Check if busybox timeout uses -t flag
+ # (recent Alpine versions don't support -t anymore)
+ if timeout &>/dev/stdout | grep -q -e '-t '; then
+ WAITFORIT_BUSYTIMEFLAG="-t"
+ fi
+else
+ WAITFORIT_ISBUSY=0
+fi
+
+if [[ $WAITFORIT_CHILD -gt 0 ]]; then
+ wait_for
+ WAITFORIT_RESULT=$?
+ exit $WAITFORIT_RESULT
+else
+ if [[ $WAITFORIT_TIMEOUT -gt 0 ]]; then
+ wait_for_wrapper
+ WAITFORIT_RESULT=$?
+ else
+ wait_for
+ WAITFORIT_RESULT=$?
+ fi
+fi
+
+if [[ $WAITFORIT_CLI != "" ]]; then
+ if [[ $WAITFORIT_RESULT -ne 0 && $WAITFORIT_STRICT -eq 1 ]]; then
+ echoerr "$WAITFORIT_cmdname: strict mode, refusing to execute subprocess"
+ exit $WAITFORIT_RESULT
+ fi
+ exec "${WAITFORIT_CLI[@]}"
+else
+ exit $WAITFORIT_RESULT
+fi

src/main/kotlin/com/teyyihan/e2ee_chat/E2eeChatApplication.kt

@@ -0,0 +1,43 @@
+package com.teyyihan.e2ee_chat
+
+import org.keycloak.OAuth2Constants
+import org.keycloak.admin.client.Keycloak
+import org.keycloak.admin.client.KeycloakBuilder
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.boot.autoconfigure.SpringBootApplication
+import org.springframework.boot.runApplication
+import org.springframework.context.annotation.Bean
+
+@SpringBootApplication
+class E2eeChatApplication{
+
+
+ private val serverUrl: String = "http:https://keycloak:8081/auth"
+// private val serverUrl: String = "http:https://localhost:8081/auth"
+
+ private val realm: String = "master"
+
+ private val clientId: String = "admin-cli"
+
+ private val username: String = "teyyihan"
+
+ private val password: String = "teyyihan"
+
+ @Bean
+ fun provideKeycloak(): Keycloak{
+ return KeycloakBuilder.builder()
+ .serverUrl(serverUrl)
+ .realm(realm)
+ .grantType(OAuth2Constants.PASSWORD)
+ .clientId(clientId)
+ .username(username)
+ .password(password)
+ .build()
+ }
+}
+
+fun main(args: Array<String>) {
+ runApplication<E2eeChatApplication>(*args)
+}
+
+