diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..b09ea64 --- /dev/null +++ b/.gitignore @@ -0,0 +1,44 @@ +# Generated files +bin/ +gen/ +out/ + +# Gradle files +.gradle/ +gradle/ +build/ +build/* + +# Intellij +*.iml +.idea + +# Compiled class file +*.class + +# Log file +*.log + +# BlueJ files +*.ctxt + +# Mobile Tools for Java (J2ME) +.mtj.tmp/ + +# Package Files # +*.jar +*.war +*.ear +*.zip +*.tar.gz +*.rar + +# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml +hs_err_pid* + +elk/server/elasticsearch/data + +server/deploy/deploy_playbook\.retry +jobs/deploy/deploy_playbook\.retry + +application-local.properties \ No newline at end of file diff --git a/build.gradle b/build.gradle new file mode 100644 index 0000000..ecbd124 --- /dev/null +++ b/build.gradle @@ -0,0 +1,63 @@ +buildscript { + + ext { + kotlinVersion = '1.3.71' + springBootVersion = '2.2.5.RELEASE' + } + + repositories { + mavenCentral() + maven { url "https://plugins.gradle.org/m2/" } + } + + dependencies { + classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}") + classpath("org.jetbrains.kotlin:kotlin-gradle-plugin:${kotlinVersion}") + classpath("org.jetbrains.kotlin:kotlin-allopen:${kotlinVersion}") + classpath("org.jetbrains.kotlin:kotlin-noarg:${kotlinVersion}") + } + +} + +plugins { + id 'org.springframework.boot' version '2.2.5.RELEASE' apply false +} + +allprojects { + group 'ru.touchin' +} + +subprojects { + repositories { + mavenCentral() + maven { url "https://plugins.gradle.org/m2/" } + } + + apply plugin: 'kotlin' + + sourceCompatibility = 1.8 + + compileKotlin { + kotlinOptions { + freeCompilerArgs = ["-Xjsr305=strict"] + jvmTarget = "1.8" + } + } + + compileTestKotlin { + kotlinOptions { + freeCompilerArgs = ["-Xjsr305=strict"] + jvmTarget = "1.8" + } + } + + apply plugin: 'io.spring.dependency-management' + + dependencyManagement { + imports { + mavenBom("org.springframework.boot:spring-boot-dependencies:${springBootVersion}") { + bomProperty("kotlin.version", "${kotlinVersion}") + } + } + } +} diff --git a/gradle.properties b/gradle.properties new file mode 100644 index 0000000..29e08e8 --- /dev/null +++ b/gradle.properties @@ -0,0 +1 @@ +kotlin.code.style=official \ No newline at end of file diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar new file mode 100644 index 0000000..87b738c Binary files /dev/null and b/gradle/wrapper/gradle-wrapper.jar differ diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties new file mode 100644 index 0000000..44e7c4d --- /dev/null +++ b/gradle/wrapper/gradle-wrapper.properties @@ -0,0 +1,5 @@ +distributionBase=GRADLE_USER_HOME +distributionPath=wrapper/dists +distributionUrl=https\://services.gradle.org/distributions/gradle-5.2.1-bin.zip +zipStoreBase=GRADLE_USER_HOME +zipStorePath=wrapper/dists diff --git a/gradlew b/gradlew new file mode 100755 index 0000000..af6708f --- /dev/null +++ b/gradlew @@ -0,0 +1,172 @@ +#!/usr/bin/env sh + +############################################################################## +## +## Gradle start up script for UN*X +## +############################################################################## + +# Attempt to set APP_HOME +# Resolve links: $0 may be a link +PRG="$0" +# Need this for relative symlinks. +while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG=`dirname "$PRG"`"/$link" + fi +done +SAVED="`pwd`" +cd "`dirname \"$PRG\"`/" >/dev/null +APP_HOME="`pwd -P`" +cd "$SAVED" >/dev/null + +APP_NAME="Gradle" +APP_BASE_NAME=`basename "$0"` + +# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +DEFAULT_JVM_OPTS='"-Xmx64m"' + +# Use the maximum available, or set MAX_FD != -1 to use that value. +MAX_FD="maximum" + +warn () { + echo "$*" +} + +die () { + echo + echo "$*" + echo + exit 1 +} + +# OS specific support (must be 'true' or 'false'). +cygwin=false +msys=false +darwin=false +nonstop=false +case "`uname`" in + CYGWIN* ) + cygwin=true + ;; + Darwin* ) + darwin=true + ;; + MINGW* ) + msys=true + ;; + NONSTOP* ) + nonstop=true + ;; +esac + +CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar + +# Determine the Java command to use to start the JVM. +if [ -n "$JAVA_HOME" ] ; then + if [ -x "$JAVA_HOME/jre/sh/java" ] ; then + # IBM's JDK on AIX uses strange locations for the executables + JAVACMD="$JAVA_HOME/jre/sh/java" + else + JAVACMD="$JAVA_HOME/bin/java" + fi + if [ ! -x "$JAVACMD" ] ; then + die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." + fi +else + JAVACMD="java" + which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." +fi + +# Increase the maximum file descriptors if we can. +if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then + MAX_FD_LIMIT=`ulimit -H -n` + if [ $? -eq 0 ] ; then + if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then + MAX_FD="$MAX_FD_LIMIT" + fi + ulimit -n $MAX_FD + if [ $? -ne 0 ] ; then + warn "Could not set maximum file descriptor limit: $MAX_FD" + fi + else + warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT" + fi +fi + +# For Darwin, add options to specify how the application appears in the dock +if $darwin; then + GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\"" +fi + +# For Cygwin, switch paths to Windows format before running java +if $cygwin ; then + APP_HOME=`cygpath --path --mixed "$APP_HOME"` + CLASSPATH=`cygpath --path --mixed "$CLASSPATH"` + JAVACMD=`cygpath --unix "$JAVACMD"` + + # We build the pattern for arguments to be converted via cygpath + ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null` + SEP="" + for dir in $ROOTDIRSRAW ; do + ROOTDIRS="$ROOTDIRS$SEP$dir" + SEP="|" + done + OURCYGPATTERN="(^($ROOTDIRS))" + # Add a user-defined pattern to the cygpath arguments + if [ "$GRADLE_CYGPATTERN" != "" ] ; then + OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)" + fi + # Now convert the arguments - kludge to limit ourselves to /bin/sh + i=0 + for arg in "$@" ; do + CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -` + CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option + + if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition + eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"` + else + eval `echo args$i`="\"$arg\"" + fi + i=$((i+1)) + done + case $i in + (0) set -- ;; + (1) set -- "$args0" ;; + (2) set -- "$args0" "$args1" ;; + (3) set -- "$args0" "$args1" "$args2" ;; + (4) set -- "$args0" "$args1" "$args2" "$args3" ;; + (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;; + (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;; + (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;; + (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;; + (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;; + esac +fi + +# Escape application args +save () { + for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done + echo " " +} +APP_ARGS=$(save "$@") + +# Collect all arguments for the java command, following the shell quoting and substitution rules +eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS" + +# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong +if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then + cd "$(dirname "$0")" +fi + +exec "$JAVACMD" "$@" diff --git a/gradlew.bat b/gradlew.bat new file mode 100644 index 0000000..6d57edc --- /dev/null +++ b/gradlew.bat @@ -0,0 +1,84 @@ +@if "%DEBUG%" == "" @echo off +@rem ########################################################################## +@rem +@rem Gradle startup script for Windows +@rem +@rem ########################################################################## + +@rem Set local scope for the variables with windows NT shell +if "%OS%"=="Windows_NT" setlocal + +set DIRNAME=%~dp0 +if "%DIRNAME%" == "" set DIRNAME=. +set APP_BASE_NAME=%~n0 +set APP_HOME=%DIRNAME% + +@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +set DEFAULT_JVM_OPTS="-Xmx64m" + +@rem Find java.exe +if defined JAVA_HOME goto findJavaFromJavaHome + +set JAVA_EXE=java.exe +%JAVA_EXE% -version >NUL 2>&1 +if "%ERRORLEVEL%" == "0" goto init + +echo. +echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. +echo. +echo Please set the JAVA_HOME variable in your environment to match the +echo location of your Java installation. + +goto fail + +:findJavaFromJavaHome +set JAVA_HOME=%JAVA_HOME:"=% +set JAVA_EXE=%JAVA_HOME%/bin/java.exe + +if exist "%JAVA_EXE%" goto init + +echo. +echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% +echo. +echo Please set the JAVA_HOME variable in your environment to match the +echo location of your Java installation. + +goto fail + +:init +@rem Get command-line arguments, handling Windows variants + +if not "%OS%" == "Windows_NT" goto win9xME_args + +:win9xME_args +@rem Slurp the command line arguments. +set CMD_LINE_ARGS= +set _SKIP=2 + +:win9xME_args_slurp +if "x%~1" == "x" goto execute + +set CMD_LINE_ARGS=%* + +:execute +@rem Setup the command line + +set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar + +@rem Execute Gradle +"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS% + +:end +@rem End local scope for the variables with windows NT shell +if "%ERRORLEVEL%"=="0" goto mainEnd + +:fail +rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of +rem the _cmd.exe /c_ return code! +if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1 +exit /b 1 + +:mainEnd +if "%OS%"=="Windows_NT" endlocal + +:omega diff --git a/settings.gradle b/settings.gradle new file mode 100644 index 0000000..5971c92 --- /dev/null +++ b/settings.gradle @@ -0,0 +1,5 @@ +rootProject.name = System.getProperty("rootProjectName") + ?: 'Backend-common' + +include 'utils' +include 'test-utils' diff --git a/test-utils/build.gradle b/test-utils/build.gradle new file mode 100644 index 0000000..32bb487 --- /dev/null +++ b/test-utils/build.gradle @@ -0,0 +1,19 @@ +plugins { + id 'kotlin' + id 'kotlin-spring' + id 'kotlin-jpa' + id 'eclipse' + id 'org.springframework.boot' apply false +} + +repositories { + mavenCentral() + maven { url "https://plugins.gradle.org/m2/" } +} + +dependencies { + implementation "org.jetbrains.kotlin:kotlin-stdlib" + compileOnly "org.springframework.data:spring-data-commons" + compileOnly "org.junit.jupiter:junit-jupiter" + compileOnly "org.mockito:mockito-core" +} diff --git a/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/AssertUtils.kt b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/AssertUtils.kt new file mode 100644 index 0000000..6654e70 --- /dev/null +++ b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/AssertUtils.kt @@ -0,0 +1,19 @@ +package ru.touchinstinct.utils.test.mockito + +import org.junit.jupiter.api.fail + +object AssertUtils { + + fun assertContains(container: Iterable, element: T) { + if (element !in container) { + fail("Not contains: \nElement: $element \nContainer: $container") + } + } + + fun assertContains(container: Iterable, predicate: (T) -> Boolean) { + if (container.none(predicate)) { + fail("Not contains: \nContainer: $container") + } + } + +} diff --git a/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/MockitoUtils.kt b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/MockitoUtils.kt new file mode 100644 index 0000000..97d768d --- /dev/null +++ b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/MockitoUtils.kt @@ -0,0 +1,30 @@ +package ru.touchinstinct.utils.test.mockito + +import org.mockito.ArgumentMatchers +import org.mockito.ArgumentMatchers.booleanThat +import org.mockito.ArgumentMatchers.longThat +import org.mockito.Mockito + +object MockitoUtils { + + fun anyx(matcher: ((T) -> Boolean)? = null): T { + + @Suppress("UNCHECKED_CAST") + return if (matcher == null) { + ArgumentMatchers.any() ?: (null as T) + } else { + Mockito.argThat(matcher) ?: (null as T) + } + } + + fun anyx(sample: T): T = anyx { it == sample } + + fun trueBoolean(): Boolean = booleanThat { it } + + fun anyLong(matcher: ((Long) -> Boolean)? = { true }): Long = longThat(matcher) + + fun anyType(type: Class): T = Mockito.any(type) + + inline fun mock(clazz: Class = T::class.java): T = Mockito.mock(clazz) + +} diff --git a/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/XmlTestUtils.kt b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/XmlTestUtils.kt new file mode 100644 index 0000000..855c8e4 --- /dev/null +++ b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/mockito/XmlTestUtils.kt @@ -0,0 +1,9 @@ +package ru.touchinstinct.utils.test.mockito + +import java.io.StringWriter +import javax.xml.bind.JAXBContext + +fun transformToXmlString(obj: T): String = StringWriter().let { stringWriter -> + JAXBContext.newInstance(obj::class.java).createMarshaller().marshal(obj, stringWriter) + stringWriter.toString() +} diff --git a/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/spring/data/MockRepository.kt b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/spring/data/MockRepository.kt new file mode 100644 index 0000000..d511c12 --- /dev/null +++ b/test-utils/src/main/kotlin/ru/touchinstinct/utils/test/spring/data/MockRepository.kt @@ -0,0 +1,144 @@ +package ru.touchinstinct.utils.test.spring.data + +import org.springframework.data.repository.CrudRepository +import ru.touchinstinct.utils.test.mockito.MockitoUtils.anyx +import ru.touchinstinct.utils.test.mockito.MockitoUtils.mock +import java.lang.reflect.Field +import java.util.Optional +import java.util.UUID +import java.util.concurrent.ThreadLocalRandom +import kotlin.math.absoluteValue +import org.mockito.Mockito.`when` as on + +/** + * This class is used to set up mock of repository + **/ +class MockRepository, T : Any, ID>( + val mock: R, // repository mock + private val entities: MutableList = ArrayList(), + private val idExtractor: ((T) -> ID?)? = null +) { + + companion object { + @Deprecated("idExtractor is no more required", ReplaceWith("MockRepository.create()")) + inline fun , reified T : Any, reified ID> mockRepository( + noinline idExtractor: (T) -> ID? + ): R = MockRepository.create() + + @Deprecated("idExtractor is no more required", ReplaceWith("MockRepository.create(settings)")) + inline fun , reified T : Any, reified ID> mockRepository( + noinline idExtractor: (T) -> ID?, + noinline settings: (R, MutableList) -> Unit + ): R = MockRepository.create(settings) + + inline fun , reified T : Any, reified ID> create( + noinline settings: (R, MutableList) -> Unit + ): R { + val entities = ArrayList() + + return MockRepository(mock(), entities).mock + .also { settings(it, entities) } + } + + inline fun , reified T : Any, reified ID> create(): R { + val entities = ArrayList() + + return MockRepository(mock(), entities).mock + } + + } + + init { + init() + } + + private fun init() { + on(mock.findAll()).thenAnswer { + entities + } + + on(mock.save(anyx())).thenAnswer { it -> + save(it.getArgument(0)) + } + + on(mock.saveAll(anyx>())).thenAnswer { it -> + saveAll(it.getArgument(0)) + } + + // 'findById' method does not check if id is unique. + on(mock.findById(anyx())).thenAnswer { it -> + findById(it.getArgument(0)) + } + + // 'findById' method does not check if id is unique. + on(mock.deleteAll()).thenAnswer { reset() } + + on(mock.delete(anyx())).thenAnswer { delete(it.getArgument(0)) } + + } + + private fun findById(id: ID): Optional { + + return Optional.ofNullable(entities.find { id(it) == id }) + } + + private fun save(argument: T): T { + val id = id(argument) ?: trySetId(argument) + + entities.replaceAll { entity -> if (id(entity) == id) argument else entity } + + if (entities.find { entity -> id(entity) == id } == null) { + entities.add(argument) + } + + return argument + } + + private fun saveAll(objects: List): List { + + return objects.map { save(it) } + } + + private fun delete(any: T) = entities.remove(any) + + fun reset() { + entities.clear() + } + + private fun idField(entity: T): Field { + val javaClass = (entity as Any).javaClass + + val fields = javaClass.declaredFields.toSet() + javaClass.superclass.declaredFields.toSet() + + val idFieldOrNull = fields + .firstOrNull { + it.annotations.any { annotation -> annotation.annotationClass.simpleName == "Id" } + } + ?.also { it.isAccessible = true } + + return idFieldOrNull + ?: throw IllegalStateException("Type ${javaClass.canonicalName} has no field with @Id annotation.\n" + + "Fields: ${fields.map { it.name }}") + } + + private fun id(entity: T): ID { + val idField = idField(entity) + + @Suppress("UNCHECKED_CAST") + return idField.get(entity) as ID + } + + private fun trySetId(entity: T): ID = idField(entity).let { idField -> + val id = when (idField.type) { + java.lang.String::class.java, String::class.java -> UUID.randomUUID().toString() + java.lang.Long::class.java, Long::class.java -> ThreadLocalRandom.current().nextLong().absoluteValue + else -> throw IllegalAccessException("Could not generate id of type ${idField.type.canonicalName}") + } + + idField.set(entity, id) + + @Suppress("UNCHECKED_CAST") + id as ID + } + +} diff --git a/utils/build.gradle b/utils/build.gradle new file mode 100644 index 0000000..c9a8bef --- /dev/null +++ b/utils/build.gradle @@ -0,0 +1,17 @@ +plugins { + id 'kotlin' + id 'eclipse' + id 'io.spring.dependency-management' + id 'org.springframework.boot' apply false +} + +repositories { + mavenCentral() + maven { url "https://plugins.gradle.org/m2/" } +} + +dependencies { + implementation "org.jetbrains.kotlin:kotlin-stdlib" + compileOnly "org.springframework.data:spring-data-commons" + compileOnly "io.projectreactor.kotlin:reactor-kotlin-extensions" +} diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/CollectionUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/CollectionUtils.kt new file mode 100644 index 0000000..e8c1bea --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/CollectionUtils.kt @@ -0,0 +1,6 @@ +package ru.touchinstinct.utils + +import java.math.BigDecimal + +inline fun Iterable.sumBy(selector: (T) -> BigDecimal) = + fold(BigDecimal.ZERO) { accumulator, element -> accumulator + selector(element) } diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/CommonUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/CommonUtils.kt new file mode 100644 index 0000000..35e3ce3 --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/CommonUtils.kt @@ -0,0 +1,15 @@ +package ru.touchinstinct.utils + +import org.springframework.core.io.ClassPathResource +import java.io.InputStream +import java.math.BigDecimal +import java.util.Optional + +fun getInputStreamOfResourceFile(fileName: String): InputStream = ClassPathResource(fileName).inputStream + +fun getResourceAsString(filename: String): String = getInputStreamOfResourceFile(filename) + .use { String(it.readBytes()) } + +fun Optional.getOrNull(): T? = takeIf { it.isPresent }?.get() + +fun BigDecimal.equalTo(number: BigDecimal): Boolean = compareTo(number) == 0 diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/DaoUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/DaoUtils.kt new file mode 100644 index 0000000..245da39 --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/DaoUtils.kt @@ -0,0 +1,7 @@ +package ru.touchinstinct.utils + +const val SKIP_LOCKED_PARAMETER = "javax.persistence.lock.timeout" +/** + * Const value which is used for 'SKIP LOCKED' in 'SELECT ... FOR UPDATE' query + */ +const val SKIP_LOCKED_VALUE = "-2" diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/DateUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/DateUtils.kt new file mode 100644 index 0000000..b1c211a --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/DateUtils.kt @@ -0,0 +1,38 @@ +package ru.touchinstinct.utils + +import java.time.Duration +import java.time.LocalDate +import java.time.LocalDateTime +import java.time.ZoneId +import java.time.ZonedDateTime +import java.util.TimeZone + +val MOSCOW_ZONE_ID: ZoneId = TimeZone.getTimeZone("Europe/Moscow").toZoneId() + +fun ZonedDateTime.isExpired(duration: Duration) = this.isExpired(ZonedDateTime.now().minus(duration)) + +fun ZonedDateTime.isExpired(currentDate: ZonedDateTime = ZonedDateTime.now()) = this.isBefore(currentDate) + +fun ZonedDateTime.isNotExpired(duration: Duration) = !this.isExpired(duration) + +fun ZonedDateTime.isNotExpired(currentDate: ZonedDateTime = ZonedDateTime.now()) = !this.isExpired(currentDate) + +fun ZonedDateTime.equals(arg: ZonedDateTime, maxDiff: Duration) = + Duration.between(this, arg) <= maxDiff + +fun LocalDateTime.isExpired(currentDate: LocalDateTime = LocalDateTime.now()) = this.isBefore(currentDate) + +fun LocalDateTime.isExpired(duration: Duration) = this.isBefore(LocalDateTime.now().minus(duration)) + +fun dateMin(date1: LocalDate, date2: LocalDate?): LocalDate = + if (date2 == null || date2.isAfter(date1)) date1 else date2 + +fun LocalDate.toZonedDateTime(): ZonedDateTime = atStartOfDay(MOSCOW_ZONE_ID) + +fun createLocalDate(): LocalDate = LocalDate.now() + +fun createLocalDateAtStartOfYear(): LocalDate = createLocalDate().withDayOfYear(1) + +fun LocalDate.startOfWeek(): LocalDate = this.minusDays(this.dayOfWeek.ordinal.toLong()) + +fun LocalDate.endOfWeek(): LocalDate = this.plusWeeks(1L).minusDays(this.dayOfWeek.ordinal.toLong() + 1L) diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/Empty.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/Empty.kt new file mode 100644 index 0000000..8d64cda --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/Empty.kt @@ -0,0 +1,3 @@ +package ru.touchinstinct.utils + +class Empty diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/ReactorUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/ReactorUtils.kt new file mode 100644 index 0000000..fddef9e --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/ReactorUtils.kt @@ -0,0 +1,17 @@ +package ru.touchinstinct.utils + +import reactor.core.publisher.Mono +import reactor.core.scheduler.Schedulers + +object ReactorUtils { + + fun blocking(block: () -> T): Mono = + Mono.fromCallable(block).subscribeOn(Schedulers.elastic()) + +} + +fun Mono.mapElastic(block: (T) -> Y): Mono = + flatMap { argument -> + Mono.fromCallable { block(argument) } + .subscribeOn(Schedulers.elastic()) + } diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/RepositoryUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/RepositoryUtils.kt new file mode 100644 index 0000000..35d582e --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/RepositoryUtils.kt @@ -0,0 +1,19 @@ +package ru.touchinstinct.utils + +import org.springframework.data.repository.CrudRepository + +fun CrudRepository.update(entity: T, updater: T.() -> Unit): T { + + return save(entity.apply(updater)) +} + +fun CrudRepository.upsert(entity: T, updater: (T) -> Unit): T { + + return save(entity.apply(updater)) +} + +fun T.upsertInto(repository: CrudRepository, updater: (T) -> Unit): T { + + return repository.save(also(updater)) +} + diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/SoapUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/SoapUtils.kt new file mode 100644 index 0000000..712a0b2 --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/SoapUtils.kt @@ -0,0 +1,12 @@ +package ru.touchinstinct.utils + +import org.w3c.dom.Node +import javax.xml.bind.JAXBContext + +inline fun unmarshalRequestFrom(xml: Node): T = unmarshalRequestFrom(xml, T::class.java) + +fun unmarshalRequestFrom(xml: Node, clazz: Class): T { + val jaxbUnmarshaller = JAXBContext.newInstance(clazz).createUnmarshaller() + + return jaxbUnmarshaller.unmarshal(xml, clazz).value +} diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/StringUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/StringUtils.kt new file mode 100644 index 0000000..ff49aac --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/StringUtils.kt @@ -0,0 +1,128 @@ +package ru.touchinstinct.utils + +import org.jetbrains.annotations.Contract + +private val TRANSLITERATION_TABLE: Map = mapOf( + ' ' to " ", + 'а' to "a", + 'б' to "b", + 'в' to "v", + 'г' to "g", + 'д' to "d", + 'е' to "e", + 'ё' to "e", + 'ж' to "zh", + 'з' to "z", + 'и' to "i", + 'й' to "y", + 'к' to "k", + 'л' to "l", + 'м' to "m", + 'н' to "n", + 'о' to "o", + 'п' to "p", + 'р' to "r", + 'с' to "s", + 'т' to "t", + 'у' to "u", + 'ф' to "f", + 'х' to "h", + 'ц' to "ts", + 'ч' to "ch", + 'ш' to "sh", + 'щ' to "sch", + 'ъ' to "'", + 'ы' to "i", + 'ь' to "'", + 'э' to "e", + 'ю' to "ju", + 'я' to "ja", + 'А' to "A", + 'Б' to "B", + 'В' to "V", + 'Г' to "G", + 'Д' to "D", + 'Е' to "E", + 'Ё' to "E", + 'Ж' to "Zh", + 'З' to "Z", + 'И' to "I", + 'Й' to "Y", + 'К' to "K", + 'Л' to "L", + 'М' to "M", + 'Н' to "N", + 'О' to "O", + 'П' to "P", + 'Р' to "R", + 'С' to "S", + 'Т' to "T", + 'У' to "U", + 'Ф' to "F", + 'Х' to "H", + 'Ц' to "Ts", + 'Ч' to "Ch", + 'Ш' to "Sh", + 'Щ' to "Sch", + 'Ъ' to "'", + 'Ы' to "I", + 'Ь' to "'", + 'Э' to "E", + 'Ю' to "Ju", + 'Я' to "Ja" +) + +object StringUtils { + + @Contract("hello_world -> helloWorld; HeLlO_WORld -> helloWorld; HELLO_WORLD -> helloWorld", pure = true) + fun snakeCaseToCamelCase(string: String): String { + var nextUpperCase = false + + return buildString { + for (char in string) { + when { + char == '_' -> { + nextUpperCase = true + } + + nextUpperCase -> { + this.append(char.toUpperCase()) + nextUpperCase = false + } + + !nextUpperCase -> { + this.append(char.toLowerCase()) + } + } + } + } + } + +} + +fun String.removeNonPrintableCharacters(): String { + + return this + .transliterateCyrillic() + .replace("[\\p{Cntrl}&&[^\r\n\t]]".toRegex(), "")// erases all the ASCII control characters + .replace("\\p{C}".toRegex(), "")// removes non-printable characters from Unicode + .trim() +} + +fun String.transliterateCyrillic(): String { + val builder = StringBuilder() + + for (char in this) { + if (TRANSLITERATION_TABLE.containsKey(char)) { + builder.append(TRANSLITERATION_TABLE[char]) + } else { + builder.append(char) + } + } + + return builder.toString() +} + +fun String?.orNullIfBlank(): String? = this?.takeIf { it.isNotBlank() } + +fun String?.orIfNullOrBlank(altValue: String): String = if (this.isNullOrBlank()) altValue else this diff --git a/utils/src/main/kotlin/ru/touchinstinct/utils/XmlUtils.kt b/utils/src/main/kotlin/ru/touchinstinct/utils/XmlUtils.kt new file mode 100644 index 0000000..5fe0591 --- /dev/null +++ b/utils/src/main/kotlin/ru/touchinstinct/utils/XmlUtils.kt @@ -0,0 +1,51 @@ +package ru.touchinstinct.utils + +import org.w3c.dom.Document +import org.w3c.dom.Node +import org.w3c.dom.NodeList +import java.io.ByteArrayOutputStream +import javax.xml.parsers.DocumentBuilderFactory +import javax.xml.transform.OutputKeys +import javax.xml.transform.Source +import javax.xml.transform.Transformer +import javax.xml.transform.TransformerFactory +import javax.xml.transform.dom.DOMSource +import javax.xml.transform.stream.StreamResult + +private val XML_DOCUMENT_BUILDER_FACTORY: DocumentBuilderFactory = + DocumentBuilderFactory.newInstance().apply { isNamespaceAware = true } + +private val transformerFactory = TransformerFactory.newInstance() + +fun getXmlMinified(filename: String) = getResourceAsString(filename) + .replace(">(\\s+)<".toRegex(), "><") + +fun String.parseXmlDocument(): Document = + XML_DOCUMENT_BUILDER_FACTORY.newDocumentBuilder().parse(byteInputStream()) + +fun Node.stringify(): String = DOMSource(this).stringify() + +fun Source.stringify(): String { + val streamOut = ByteArrayOutputStream() + + getDefaultTransformer().transform(this, StreamResult(streamOut)) + + return streamOut.toString(Charsets.UTF_8.name()) +} + +fun NodeList.get(localName: String): Node? { + for (i in 0 until length) { + if (item(i).localName == localName) { + + return item(i) + } + } + + return null +} + +private fun getDefaultTransformer(): Transformer = + transformerFactory.newTransformer().apply { + setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes") + setOutputProperty(OutputKeys.INDENT, "yes") + }