Merge branch 'feature/messages' into develop

README.MD

@@ -1,6 +1,6 @@
 # GHAST TOOLS
 
-![version: 1.11-SNAPSHOT](https://img.shields.io/badge/version-1.11--SNAPSHOT-0a0.svg?style=flat)
+![version: 1.9](https://img.shields.io/badge/version-1.9-0a0.svg?style=flat)
 ![bukkit-api: 1.12](https://img.shields.io/badge/bukkit--api-1.12-d50.svg?style=flat)
 
 Набор вспомогательных инструментов для Bukkit API.  
@@ -18,7 +18,7 @@ _Основан на версии Bukkit API 1.12._
 8. [JdbcTemplate](#jdbctemplate)
 9. [ScheduleManager](#schedulemanager)
 10. [ScheduleTask](#scheduletask)
-11. [I18n](#i18n)
+11. [Messages](#messages)
 12. [XLog](#xlog)
 13. [Подключение](#подключение)
     1. [Gradle](#gradle)
@@ -532,91 +532,110 @@ ScheduleTask scheduleTask = ...;
 scheduleTask.cancel();
 ```
 
-## I18n
+## Messages
 
-Инструмент для работы с мультиязыковыми сообщениями или просто сообщениями, которые храняться в отдельном файле.
+Инструмент для работы с параметизированными сообщениями или просто сообщениями, которые храняться в отдельном файле.
 
-Позволяет использовать шаблонизированные сообщения вида `Привет, {player}!`.
+Параметизированные сообщения имеют следующий вид: `Привет, {player}!`.
 
-### loadMessages
+### load
 
 Загрузка сообщений в инструмент.
 
-Передать можно как "мапу" с перечислением ключ-сообщение, так и `Reader` на файл в формате `key=message` (как у `Properties`).
+Есть три варианта: через `Properties`
 
 ```java
-Map<String, String> messagesMap = ...;
+Properties properties = ...;
-I18n.loadMessages(messagesMap);
+Messages.load(properties);
 ```
 
+через `Map<String, String>`
+
 ```java
-Reader reader = AssetsManager.getAsReader("messages.properties");
+Map<String, String> map = ...;
-I18n.loadMessages(reader);
+Messages.load(map);
 ```
 
-В первом параметре можно указать код языка, для которого загружаются сообщения. По-умолчанию будет "en".
+через `Reader`
 
 ```java
-Map<String, String> enMessagesMap = ...;
+Reader reader = ...;
-Map<String, String> ruMessagesMap = ...;
+Messages.load(reader);
-
-I18n.loadMessages("en", enMessagesMap);
-I18n.loadMessages("ru", ruMessagesMap);
 ```
 
-```java
+Следует учесть, про при работе через `Reader`, **Messages** ожидает там обнаружить список строк в формате `key=value`.
-Reader readerEn = AssetsManager.getAsReader("messages.properties");
-Reader readerRu = AssetsManager.getAsReader("messages.ru.properties");
-
-I18n.loadMessages("en", readerEn);
-I18n.loadMessages("ru", readerRu);
-```
 
 ### get
 
-Получение сообщения по его ключу.  
+Получение обычноего или параметизированного сообщения.
 
-```java
+Для примера, пусть у нас будут такие сообщения:
-String msg = I18n.get("player.join.msg");
+
+```properties
+simple=Простое сообщение
+welcome=Приветствуем, {player}!
 ```
 
-Если следующим сообщением указать `Map<String, Object>`, то можно будет воспользоваться шаблонизатором.
+Для получения простого сообщения, просто указываем его ключ:
 
 ```java
-Map<String, String> messagesMap = new HashMap<>();
+String message = Messages.get("simple");
-messagesMap.put("player.join.msg", "Привет, {player}!");
+// Простое сообщение
-
-I18n.loadMessages(messagesMap);
-
-Map<String, String> params = new HashMap<>();
-params.put("player", event.getPlayer().getName());
-
-String msg = I18n.get("player.join.msg", params);
 ```
 
-Однако можно создавать `Map<String, String> params` явно, а воспользоваться [paramBuilder()](#parambuilder)
+Для получения параметизированного сообщения, нужно помимо ключа передать параметры.
+Есть два способа: через `Map<String, Object>`
 
 ```java
-String msg = I18n.get("player.join.msg", I18n.paramBuilder()
+Map<String, Object> = map = new HashMap<>(1);
-        .add("player", event.getPlayer().getName())
+map.put("player", "David");
-        .build());
+
+String message = Messages.get("welcome", map);
+// Приветствуем, David!
 ```
 
-Можно первым параметром указать код языка.
+через попарное перечисление параметров
 
 ```java
-String msg = I18n.get("ru", "player.join.msg");
+String message = Messages.get("welcome", "player", "David");
+// Приветствуем, David!
 ```
 
-### paramBuilder
+Если по указанному ключу сообщение отсутствует, то **Messages** вернёт значение самого ключа
-
-Инструмент для параметизирования шаблонов сообщений.
 
 ```java
-Map<String, Object> params = I18n.paramBuilder()
+String message = Messages.get("not_exists_key");
-        .add("player", event.getPlayer().getName())
+// not_exists_key
-        .build();
+
-String msg = I18n.get("player.join.msg", params);
+message = Messages.get("not_exists_key", "player", "David");
+// not_exists_key
+```
+
+Если параметр, который указан в шаблоне не был указан/определён, то параметр останется как есть
+
+```java
+String message = Messages.get("welcome");
+// Приветствуем, {player}!
+
+message = Messages.get("welcome", "unknown_param_key", 123);
+// Приветствуем, {player}!
+```
+
+### format
+
+**Messages** можно использовать и просто для форматирования параметизированных шаблонов:
+
+```java
+Map<String, Object> = map = new HashMap<>(1);
+map.put("player", "David");
+
+String message = Messages.format("Приветствуем, {player}!", map);
+// Приветствуем, David!
+```
+
+```java
+String message = Messages.foramt("Приветствуем, {player}!", "player", "David");
+// Приветствуем, David!
 ```
 
 ## XLog
@@ -654,7 +673,7 @@ repositories {
 ```
 
 ```groovy
-implementation group: 'ghast', name: 'ghast-tools', version: '1.11-SNAPSHOT'
+implementation group: 'ghast', name: 'ghast-tools', version: '1.9'
 ```
 
 ### Maven
@@ -673,7 +692,7 @@ implementation group: 'ghast', name: 'ghast-tools', version: '1.11-SNAPSHOT'
     <dependency>
         <groupId>ghast</groupId>
         <artifactId>ghast-tools</artifactId>
-        <version>1.11-SNAPSHOT</version>
+        <version>1.9</version>
     </dependency>
 </dependencies>
 ```

build.gradle

@@ -1,35 +1,79 @@
-subprojects {
+plugins {
-    apply plugin: 'java'
+    id 'java'
-    apply plugin: LibsPlugin
+}
-    apply plugin: LogicPlugin
 
-    def publishScript = rootDir.toPath().resolve('publish.gradle').toFile()
+def publishScript = file(rootProject.getProjectDir().getPath() + '/publish.gradle')
 if (publishScript.exists()) {
-        apply from: publishScript
+    apply from: publishScript.path
 }
 
 project.group = projectGroup
-    if (project.hasProperty('moduleVersion')) {
+project.version = projectVersion
-        project.version = project.property('moduleVersion')
-    }
-    if (project.hasProperty('moduleName')) {
-        jar.archiveBaseName.set(project.property('moduleName') as String)
-    }
 
 repositories {
     mavenLocal()
     mavenCentral()
+    maven { url 'https://hub.spigotmc.org/nexus/content/groups/public' }
+    maven { url 'https://dmx-mc-project.gitlab.io/maven-repository/' }
+}
+
+ext {
+    junitVersion = '5.5.2'
+
+    libs = [
+            bukkit: [lib: 'org.bukkit:bukkit:1.12.2-R0.1-SNAPSHOT', exclude: [
+                    'com.google.code.gson:gson',
+                    'com.googlecode.json-simple:json-simple',
+                    'commons-lang:commons-lang',
+                    'org.yaml:snakeyaml'
+            ]],
+            commons_text: 'org.apache.commons:commons-text:1.9',
+            lombok: 'org.projectlombok:lombok:1.18.12',
+            reflection_object: 'ru.dmitriymx:reflection-object:1.2',
+            test: [
+                    junit5: [
+                            "org.junit.jupiter:junit-jupiter-api:$junitVersion",
+                            "org.junit.jupiter:junit-jupiter-engine:$junitVersion"
+                    ],
+                    mock: ['org.mockito:mockito-core:1.10.19'],
+                    h2db: 'com.h2database:h2:1.4.200'
+            ]
+
+    ]
+}
+
+def compileOnly2(library) {
+    dependencies.compileOnly library.lib, {
+        library.exclude.each { String excludeLibStr ->
+            String[] excludeLib = excludeLibStr.split(':')
+            exclude group: excludeLib[0], module: excludeLib[1]
+        }
+    }
+}
+
+def testImplementation2(library) {
+    dependencies.testImplementation library.lib, {
+        library.exclude.each { String excludeLibStr ->
+            String[] excludeLib = excludeLibStr.split(':')
+            exclude group: excludeLib[0], module: excludeLib[1]
+        }
+    }
 }
 
 dependencies {
     compileOnly libs.lombok
     annotationProcessor libs.lombok
 
+    compileOnly2 libs.bukkit
+    implementation libs.commons_text
+    implementation libs.reflection_object
+
     testImplementation libs.test.junit5
     testImplementation libs.test.mock
+    testImplementation2 libs.bukkit
+    testImplementation libs.test.h2db
 }
 
 test {
     useJUnitPlatform()
 }
-}

buildSrc/src/main/groovy/LibsPlugin.groovy

@@ -1,71 +0,0 @@
-import org.gradle.api.Action
-import org.gradle.api.Plugin
-import org.gradle.api.Project
-import org.gradle.api.artifacts.repositories.MavenArtifactRepository
-
-class LibsPlugin implements Plugin<Project> {
-
-    @Override
-    void apply(Project project) {
-        project.extensions.create('libs', LibsExtention)
-        project.extensions.create('repos', ReposExtention)
-    }
-}
-
-class ReposExtention {
-
-    final def mavenSpigotMC = createSimpleMavenRepo('SpigotMC repository', 'https://hub.spigotmc.org/nexus/content/groups/public')
-    final def mavenDmxMcProject = createSimpleMavenRepo('DmitriyMX MC Project repository', 'https://dmx-mc-project.gitlab.io/maven-repository/')
-
-    private static Action<MavenArtifactRepository> createSimpleMavenRepo(String name, String url) {
-        return new Action<MavenArtifactRepository>() {
-            @Override
-            void execute(MavenArtifactRepository mavenArtifactRepository) {
-                mavenArtifactRepository.setName(name)
-                mavenArtifactRepository.setUrl(url)
-            }
-        }
-    }
-}
-
-class LibsExtention {
-    private def junit_version = '5.5.2'
-
-    final def commons_text = 'org.apache.commons:commons-text:1.9'
-    final def lombok = 'org.projectlombok:lombok:1.18.12'
-
-    final def bukkit = filter([
-            lib    : 'org.bukkit:bukkit:1.12.2-R0.1-SNAPSHOT',
-            exclude: [
-                    'com.google.code.gson:gson',
-                    'com.googlecode.json-simple:json-simple',
-                    'commons-lang:commons-lang',
-                    'org.yaml:snakeyaml'
-            ]])
-
-    final def test = [
-            junit5: [
-                    "org.junit.jupiter:junit-jupiter-api:$junit_version",
-                    "org.junit.jupiter:junit-jupiter-engine:$junit_version"
-            ],
-            mock  : ['org.mockito:mockito-core:1.10.19'],
-            h2db  : 'com.h2database:h2:1.4.200'
-    ]
-
-    private static def filter(library) {
-        Object[] result = new Object[2]
-        result[0] = library.lib
-        result[1] = {
-            library.exclude.each { String excludeLibStr ->
-                String[] excludeLib = excludeLibStr.split(':', 2)
-                if (excludeLib.length == 2) {
-                    exclude group: excludeLib[0], module: excludeLib[1]
-                } else {
-                    exclude group: excludeLib[0]
-                }
-            }
-        }
-
-        return result
-    }
-}

buildSrc/src/main/groovy/LogicPlugin.groovy

@@ -1,67 +0,0 @@
-import org.gradle.api.DefaultTask
-import org.gradle.api.Plugin
-import org.gradle.api.Project
-import org.gradle.api.tasks.TaskAction
-
-import java.nio.charset.StandardCharsets
-import java.nio.file.Path
-
-class LogicPlugin implements Plugin<Project> {
-
-    @Override
-    void apply(Project project) {
-        project.tasks.register('incrementVersion', IncrementVersion)
-    }
-}
-
-class IncrementVersion extends DefaultTask {
-
-    @TaskAction
-    def incrementVersion() {
-        String nextVer
-        if (project.hasProperty('nextVersion')) {
-            nextVer = project.property('nextVersion')
-        } else {
-            nextVer = nextVersion()
-        }
-
-        incrementReadmeVersion(nextVer)
-        incrementGradlePropsVersion(nextVer)
-    }
-
-    private void incrementReadmeVersion(String nextVersion) {
-        String nextVersion2 = nextVersion.replaceAll(/-/, '--')
-
-        Reader reader = this.getClass().getResource('README.SRC.MD').toURI().toURL().newReader()
-        File readmeFile = project.file(project.getRootDir().toPath().resolve('README.MD'))
-
-        readmeFile.withWriter { wr ->
-            reader.eachLine { line ->
-                wr << line.replaceAll('@VERSION@', nextVersion)
-                        .replaceAll('@VERSION2@', nextVersion2)
-                wr << "\n"
-            }
-        }
-    }
-
-    private void incrementGradlePropsVersion(String nextVersion) {
-        Path gradlePropertiesPath = project.projectDir.toPath().resolve('gradle.properties');
-
-        Properties gradleProperties = new Properties()
-        gradleProperties.load(gradlePropertiesPath.newReader())
-        gradleProperties.setProperty('moduleVersion', nextVersion)
-
-        gradlePropertiesPath.withWriter(StandardCharsets.UTF_8.name(), { wr ->
-            gradleProperties.each {
-                wr << "${it.key}=${it.value}"
-                wr << "\n"
-            }
-        })
-    }
-
-    private String nextVersion() {
-        def matcher = project.property('moduleVersion') =~ /^(.*\d+\.)(\d+)(-.+)?$/
-        matcher.find()
-        return matcher.group(1) + (matcher.group(2).toInteger() + 1) + (matcher.group(3) == null ? '' : matcher.group(3))
-    }
-}

buildSrc/src/main/resources/README.SRC.MD

@@ -1,636 +0,0 @@
-# GHAST TOOLS
-
-![version: @VERSION@](https://img.shields.io/badge/version-@VERSION2@-0a0.svg?style=flat)
-![bukkit-api: 1.12](https://img.shields.io/badge/bukkit--api-1.12-d50.svg?style=flat)
-
-Набор вспомогательных инструментов для Bukkit API.  
-_Основан на версии Bukkit API 1.12._
-
-## Содержание
-
-1. [Перед использованием](#перед-использованием)
-2. [GhastTools](#ghasttools)
-3. [AssetsManager](#assetsmanager)
-4. [BuildHelper](#buildhelper)
-5. [CommandManager](#commandmanager)
-6. [EffectsHelper](#effectshelper)
-7. [EventContext](#eventcontext)
-8. [JdbcTemplate](#jdbctemplate)
-9. [ScheduleManager](#schedulemanager)
-10. [ScheduleTask](#scheduletask)
-11. [I18n](#i18n)
-12. [XLog](#xlog)
-13. [Подключение](#подключение)
-    1. [Gradle](#gradle)
-    2. [Maven](#maven)
-
----
-
-## Перед использованием
-
-Перед началом использования, необходимо в вашем Bukkit-плагине прописать подобный код:
-
-```java
-void onLoad() {
-    GhastTools.setPlugin(this);
-}
-```
-
-Это необходимо сделать, т.к. весь инструментарий основан на статических (static) методах.
-
-Все методы данного набора инструментов объеденены в классы, выполняющие роль группировщиков. 
-
-## GhastTools
-
-Методы общего назначения или без определённой группировки.
-
-### loadConfig
-
-Загрузка файла настроек плагина - `config.yml`.
-
-```java
-YamlConfiguration config = GhastTools.loadConfig();
-```
-
-По-умолчанию "гаст" пытается файл найти в папке плагина - `getDataFolder()`.
-Если файла там нет, то выгружает встроенный (имеющийся в `.jar` файле плагина) в эту папку и загружает его.
-
-```java
-YamlConfiguration config = GhastTools.loadConfig(false);
-```
-
-Если передать параметр `false`, то при отсутствии файла `config.yml` в папке плагина,
-будет загруден исключительно встроенный файл настроек.
-
-## AssetsManager
-
-Методы по работе с файлами плагина (_"ассетами"_).
-
-У каждой группы методов один и тот же набор входных параметров:
-
-- `resourceName` - наименование и путь к файлу в папке плагина
-- `defaultResourceName` - наименование и путь к файлу в плагине.  
-  _Опционально. По-умолчанию равнен `resourceName`_
-- `saveDefault` - необходимость скопировать содержимое файла из `defaultResourceName` в файл `resourceName`.  
-  _Опционально. По-умолчанию равен `true`_
-  
-Правила поиска файлов так же одинаков для каждой группы:
-
-- В начале файл ищется в папке плагина
-- Если файл отсутствует в папке плагина, то...
-    - если `defaultResourceName` не равен `null`...
-        - если `saveDefault` равен `true`, то файл из плагина будет выгружен в папку плагина и от туда загружен в память.
-        - если `saveDefault` равен `false`, то данные будут взяты из файлв в плагине.
-    - если `defaultResourceName` равен `null`, то будет брошено исключение `AssetsException` с описанием ошибки вида "Файл X не найден".
-
-### getAsInputStream
-
-```java
-InputStream inputStream = AssetsManager.getAsInputStream("translate.ru.yml", "translate.yml", false);
-```
-
-### getAsReader
-
-```java
-Reader reader = AssetsManager.getAsReader("translate.ru.yml", "translate.yml", false);
-```
-
-### getAsString
-
-```java
-String string = AssetsManager.getAsString("readme.txt", "readme.txt", StandardCharsets.UTF_8, false);
-```
-
-У этой группы есть дополнительный _опциональный_ параметр - `charset` - в котором указывается кодиривка получаемой строки.  
-_По-умолчанию равен `StandardCharsets.UTF_8`_
-
-## BuildHelper
-
-Набор методов облегчающих размецение объектов на карте.
-
-### placeSkull
-
-```java
-Location location = ...;
-Skull skull = BuildHelper.placeSkull(location, BlockFace.NORTH)
-```
-
-### placeSignWall
-
-```java
-Location location = ...;
-Sign signWall = BuildHelper.placeSignWall(location, BlockFace.NORTH)
-```
-
-## CommandManager
-
-Регистрация команд.
-
-Имеется два варианта использования: упрощённый
-
-```java
-CommandManager.register("start", (sender, args) -> sender.sendMessage("hello!"));
-```
-
-и подробный:
-
-```java
-CommandManager.create("start")
-        .useOnlyPlayer()
-        .executer((sender, args) -> sender.sendMessage("hello!"))
-        .register();
-```
-
-### register
-
-Упрощенная регистрация команды. Указывается лишь название команды и исполнитель.
-
-```java
-CommandManager.register("start", (sender, args) -> sender.sendMessage("hello!"));
-```
-
-### create
-
-Конструктор для подробного варианта регистрации команды.
-
-```java
-CommandManager.Builder builder = CommandManager.create("start");
-```
-
-### executer
-
-Указание исполнителя для команды
-
-```java
-CommandManager.Builder builder = CommandManager.create("start")
-        .executer((sender, args) -> sender.sendMessage("hello!"));
-```
-
-### onError
-
-Обработчик исключений
-
-```java
-CommandManager.Builder builder = CommandManager.create("start")
-        .onError((sender, commandName, args, exception) -> {
-            sender.sendMessage(ChatColor.RED + "Произошла ошибка при выполнении команды '" + commandName + "'.");
-            exception.printStackTrace();
-        });
-```
-
-### useOnlyPlayer
-
-Указание, что данную команду могут использовать только Игроки.
-Опционально можно указать сообщение, которое будет выводиться в консоль.  
-_Отменяет действие указателя `useOnlyConsole`_
-
-```java
-CommandManager.Builder builder = CommandManager.create("start")
-		.useOnlyPlayer("Команду могут использовать только игроки");
-```
-
-### useOnlyConsole
-
-Указание, что данную команду можно использовать только в консоле.
-Опционально можно указать сообщение, которое будет выводиться Игроку.  
-_Отменяет действие указателя `useOnlyPlayer`_
-
-```java
-CommandManager.Builder builder = CommandManager.create("start")
-		.useOnlyConsole(ChatColor.RED + "Команду можно использовать только в консоли");
-```
-
-### register
-
-Регистрация описанной в Конструкторе команды.
-
-```java
-CommandManager.create("start")
-        .useOnlyPlayer()
-        .executer((sender, args) -> sender.sendMessage("hello!"))
-        .register();
-```
-
-## EffectsHelper
-
-Набор методов для работы с эффектами.
-
-### playSound
-
-Воспроизвести звук.
-
-```java
-Location location = ...;
-EffectsHelper.playSound(location, Sound.AMBIENT_CAVE, 1.0f);
-```
-
-### particle
-
-Создание частиц.
-
-```java
-Location location = ...;
-EffectsHelper.particle(location, Particle.REDSTONE, 1.0d, 1.0d, 1.0d, 1.0d, 5);
-```
-
-## EventContext
-
-Регистрация группы обработчиков событий, объединённых общим условием выполнения.
-
-```java
-EventContext.create()
-        .filter(() -> Bukkit.getOnlinePlayers().size() > 10)
-        .onEvent(PlayerJoinEvent.class, event -> { event.getPlayer().kickPlayer("Max players"); });
-```
-
-### create
-
-Создание контекста событий.
-
-```java
-EventContext eventContext = EventContext.create();
-```
-
-### filter
-
-Условие, при котором будут срабатывать обработчики событий в данном контексте.
-
-```java
-EventContext.create()
-        .filter(() -> Bukkit.getOnlinePlayers().size() > 10)
-```
-
-### onEvent
-
-Указание события и его обработчика.  
-_Обработчик события регистрируется сразу же._
-
-```java
-EventContext.create()
-        .filter(() -> Bukkit.getOnlinePlayers().size() > 10)
-        .onEvent(PlayerJoinEvent.class, event -> event.getPlayer().kickPlayer("Max players"));
-```
-
-### cancelEvent
-
-Отменить событие.  
-_Обработчик события регистрируется сразу же._
-
-```java
-EventContext.create()
-        .cancelEvent(BlockPlaceEvent.class);
-```
-
-эквивалентен коду:
-
-```java
-EventContext.create()
-        .onEvent(BlockPlaceEvent.class, event -> event.setCancelled(true))
-```
-
-## JdbcTemplate
-
-Инструмент для упрощения работы с SQL базами данных, работающими через JDBC.
-
-Для начала потребуется создать объект `DataSource`
-
-```java
-// На примере MySQL
-MysqlDataSource dataSource = new MysqlDataSource();
-dataSource.setServerName("localhost");
-dataSource.setPort(3306);
-dataSource.setCharacterEncoding(StandardCharsets.UTF_8.name());
-dataSource.setDatabaseName("MyDataBase");
-dataSource.setUser("root");
-dataSource.setPassword("secret");
-```
-
-После чего создать `JdbcTemplate`
-
-```java
-JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
-```
-
-### execute
-
-Выполнение SQL запроса без последующей обработки результатов выполнения.
-
-```java
-jdbcTemplate.execute("CREATE TABLE my_table (id int, name varchar(16));");
-```
-
-### query
-
-Выполнение SQL запроса и обработка его результатов.  
-Может возвращать любой тип объектов. 
-
-```java
-String name = jdbcTemplate.query("SELECT name FROM my_table LIMIT 0,1", resultSet -> {
-        if (resultSet.next()) {
-            return resultSet.getString("name");
-        } else {
-            return null;
-        }
-});
-```
-
-```java
-List<String> names = jdbcTemplate.query("SELECT name FROM my_table", resultSet -> {
-        if (resultSet.next()) {
-            List<String> list = new ArrayList<>();
-            do {
-                list.add(resultSet.getString("name"));
-            } while (resultSet.next());
-            return list;
-        } else {
-            return Collections.emptyList();
-        }
-});
-```
-
-### queryOne
-
-Выполнение SQL запроса с расчетом, что результат будет единичным либо не будет вовсе.  
-Возвращает `Optional`.
-
-```java
-Optional<String> optName = jdbcTemplate.queryOne("SELECT name FROM my_table WHERE name LIKE 'dmitriymx'", rs -> rs.getString("name"));
-```
-
-### queryList
-
-Выполнение SQL запроса и обработка результата как списка данных.  
-Возвращает `List`.
-
-```java
-List<String> names = jdbcTemplate.queryList("SELECT name FROM my_table", (resultSet, rowNum) -> resultSet.getString("name"));
-```
-
-### queryForMap
-
-Выполнение SQL запроса с расчетом, что результат будет единичным либо не будет вовсе.  
-Возвращает `Map<String, Object>`, где ключ — это наименование колонок таблицы, а значения — это значения в ячейках таблицы.
-
-```java
-Map<String, Object> map = jdbcTemplate.queryForMap("SELECT * FROM my_table LIMIT 0,1;");
-```
-
-### queryForMapList
-
-Выполнение SQL запроса и обработка результата как списка данных.  
-Возвращает `List<Map<String, Object>>`, где ключ — это наименование колонок таблицы, а значения — это значения в ячейках таблицы.
-
-```java
-List<Map<String, Object>> mapList = jdbcTemplate.queryForMapList("SELECT * FROM my_table");
-```
-
-### update
-
-Выполнение SQL запроса где будет происходить обновление данных в таблице.
-Под "обновлением" подразумеваются любые изменения в таблице: `UPDATE`, `DELETE`, `INSERT`.  
-Возвращает число строк, которые были _по факту обновлены_ в таблице.
-
-```java
-int rows = jdbcTemplate.update("DELETE FROM my_table WHERE name LIKE 'dmitriymx';");
-```
-
-## ScheduleManager
-
-Набор методов для создания параллельных задач, выполняющихся один раз или по рассписанию.
-
-### createTask
-
-Создание конструктора задачи.
-
-```java
-ScheduleManager.Builder builder = ScheduleManager.createTask();
-```
-
-### useBukkitScheduler
-
-Если задача будет взаимодействоватьс **Bukkit API** или необходима привязка задачи к _тикам_,
-то необходимо использовать данный указатель.
-
-В ином случае, указатель не нужен.
-
-```java
-ScheduleManager.Builder builder = ScheduleManager.createTask()
-        .useBukkitScheduler();
-```
-
-### after
-
-Указание, что задачу нужно выполнить не сразу, а с некоторой задержкой перед запуском.
-
-```java
-ScheduleManager.Builder builder = ScheduleManager.createTask()
-        .after(5, TimeUnit.MINUTES);
-```
-
-### every
-
-Указание, что задачу нужно повторять через указанное время.
-
-```java
-ScheduleManager.Builder builder = ScheduleManager.createTask()
-        .every(5, TimeUnit.MINUTES);
-```
-
-### create
-
-Создание описанной задачи.
-
-```java
-ScheduleTask scheduleTask = ScheduleManager.createTask()
-        .every(1, TimeUnit.SECONDS)
-        .create(() -> Bukkit.getServer().getLogger().info("TimeMS: " + System.currentTimeMillis()));
-```
-
-_Задача будет только создана. Для её выполнения нужно вызвать `scheduleTask.start()`._
-
-### execute
-
-Создание и выполнение описанной задачи.
-
-```java
-ScheduleTask scheduleTask = ScheduleManager.createTask()
-        .every(1, TimeUnit.SECONDS)
-        .execute(() -> Bukkit.getServer().getLogger().info("TimeMS: " + System.currentTimeMillis()));
-```
-
-## ScheduleTask
-
-Вспомогательный объект, созданный через `ScheduleManager`. Позволяет управлять созданной задачей.
-
-### start
-
-Запускает задачу, если она еще не запущена.
-
-```java
-ScheduleTask scheduleTask = ...;
-scheduleTask.start();
-```
-
-### isCanceled
-
-Возвращает состояние задачи. Если `true`, значит задача была или _отменена/остоновлена_ или была завершена.
-
-```java
-ScheduleTask scheduleTask = ...;
-boolean status = scheduleTask.isCanceled();
-```
-
-### cancel
-
-Отменяет/Остонавливает выполнение задачи.
-
-```java
-ScheduleTask scheduleTask = ...;
-scheduleTask.cancel();
-```
-
-## I18n
-
-Инструмент для работы с мультиязыковыми сообщениями или просто сообщениями, которые храняться в отдельном файле.
-
-Позволяет использовать шаблонизированные сообщения вида `Привет, {player}!`.
-
-### loadMessages
-
-Загрузка сообщений в инструмент.
-
-Передать можно как "мапу" с перечислением ключ-сообщение, так и `Reader` на файл в формате `key=message` (как у `Properties`).
-
-```java
-Map<String, String> messagesMap = ...;
-I18n.loadMessages(messagesMap);
-```
-
-```java
-Reader reader = AssetsManager.getAsReader("messages.properties");
-I18n.loadMessages(reader);
-```
-
-В первом параметре можно указать код языка, для которого загружаются сообщения. По-умолчанию будет "en".
-
-```java
-Map<String, String> enMessagesMap = ...;
-Map<String, String> ruMessagesMap = ...;
-
-I18n.loadMessages("en", enMessagesMap);
-I18n.loadMessages("ru", ruMessagesMap);
-```
-
-```java
-Reader readerEn = AssetsManager.getAsReader("messages.properties");
-Reader readerRu = AssetsManager.getAsReader("messages.ru.properties");
-
-I18n.loadMessages("en", readerEn);
-I18n.loadMessages("ru", readerRu);
-```
-
-### get
-
-Получение сообщения по его ключу.  
-
-```java
-String msg = I18n.get("player.join.msg");
-```
-
-Если следующим сообщением указать `Map<String, Object>`, то можно будет воспользоваться шаблонизатором.
-
-```java
-Map<String, String> messagesMap = new HashMap<>();
-messagesMap.put("player.join.msg", "Привет, {player}!");
-
-I18n.loadMessages(messagesMap);
-
-Map<String, String> params = new HashMap<>();
-params.put("player", event.getPlayer().getName());
-
-String msg = I18n.get("player.join.msg", params);
-```
-
-Однако можно создавать `Map<String, String> params` явно, а воспользоваться [paramBuilder()](#parambuilder)
-
-```java
-String msg = I18n.get("player.join.msg", I18n.paramBuilder()
-        .add("player", event.getPlayer().getName())
-        .build());
-```
-
-Можно первым параметром указать код языка.
-
-```java
-String msg = I18n.get("ru", "player.join.msg");
-```
-
-### paramBuilder
-
-Инструмент для параметизирования шаблонов сообщений.
-
-```java
-Map<String, Object> params = I18n.paramBuilder()
-        .add("player", event.getPlayer().getName())
-        .build();
-String msg = I18n.get("player.join.msg", params);
-```
-
-## XLog
-
-Замена стандартному `getLogger()`, который использует `java.utils.Logger` и не всегда удобен для логирования.
-
-Имеет 4 уровня логирования: `debug`, `info`, `warning`, `error`.
-
-Сообщения могут быть шаблонизированными. Синтаксис шаблонов — `java.text.MessageFormat`.
-
-Примеры:
-
-```java
-XLog.info("Hello");
-XLog.info("Player {0} join game", event.getPlayer().getName());
-
-XLog.error("ERROR!", exception);
-XLog.error("ERROR: {0}", exception.getMessage());
-// Для экранирования "{" нужно перед ней поставить "'".
-// А для использования "'" нужно их дублировать.
-XLog.error("ERROR ''{0}'' in Event '{{1}'}: {2}", exception.getClass(), event.getClass(), exception.getMessage());
-XLog.error("ERROR: {0}", exception.getMessage(), exception);
-```
-
----
-
-## Подключение
-
-### Gradle
-
-```groovy
-repositories {
-    maven { url 'https://dmx-mc-project.gitlab.io/maven-repository/' }
-}
-```
-
-```groovy
-implementation group: 'ghast', name: 'ghast-tools', version: '@VERSION@'
-```
-
-### Maven
-
-```xml
-<repositories>
-    <repository>
-        <id>dmx-mc-project</id>
-        <url>https://dmx-mc-project.gitlab.io/maven-repository/</url>
-    </repository>
-</repositories>
-```
-
-```xml
-<dependencies>
-    <dependency>
-        <groupId>ghast</groupId>
-        <artifactId>ghast-tools</artifactId>
-        <version>@VERSION@</version>
-    </dependency>
-</dependencies>
-```

gradle.properties

@@ -1 +1,3 @@
 projectGroup=ghast
+projectName=ghast-tools
+projectVersion=1.4

phantom-classes/build.gradle

@@ -1,3 +0,0 @@
-dependencies {
-    compileOnly libs.bukkit
-}

phantom-classes/gradle.properties

@@ -1,2 +0,0 @@
-moduleName=phantom-classes
-moduleVersion=1.0-SNAPSHOT

phantom-classes/src/main/java/com/mojang/authlib/GameProfile.java

@@ -1,16 +0,0 @@
-package com.mojang.authlib;
-
-import com.mojang.authlib.properties.PropertyMap;
-
-import java.util.UUID;
-
-public class GameProfile {
-
-	public GameProfile(UUID id, String name) {
-
-	}
-
-	public PropertyMap getProperties() {
-		return null;
-	}
-}

phantom-classes/src/main/java/com/mojang/authlib/properties/Property.java

@@ -1,8 +0,0 @@
-package com.mojang.authlib.properties;
-
-public class Property {
-
-	public Property(String value, String name) {
-
-	}
-}

phantom-classes/src/main/java/com/mojang/authlib/properties/PropertyMap.java

@@ -1,12 +0,0 @@
-package com.mojang.authlib.properties;
-
-import com.google.common.collect.ForwardingMultimap;
-import com.google.common.collect.Multimap;
-
-public class PropertyMap extends ForwardingMultimap<String, Property> {
-
-	@Override
-	protected Multimap<String, Property> delegate() {
-		return null;
-	}
-}

phantom-classes/src/main/java/net/minecraft/server/v1_12_R1/BlockPosition.java

@@ -1,7 +0,0 @@
-package net.minecraft.server.v1_12_R1;
-
-public class BlockPosition {
-
-	public BlockPosition(double x, double y, double z) {
-	}
-}

phantom-classes/src/main/java/net/minecraft/server/v1_12_R1/TileEntity.java

@@ -1,5 +0,0 @@
-package net.minecraft.server.v1_12_R1;
-
-public class TileEntity {
-
-}

phantom-classes/src/main/java/net/minecraft/server/v1_12_R1/TileEntitySkull.java

@@ -1,10 +0,0 @@
-package net.minecraft.server.v1_12_R1;
-
-import com.mojang.authlib.GameProfile;
-
-public class TileEntitySkull extends TileEntity {
-
-	public void setGameProfile(GameProfile gameprofile) {
-
-	}
-}

phantom-classes/src/main/java/net/minecraft/server/v1_12_R1/WorldServer.java

@@ -1,8 +0,0 @@
-package net.minecraft.server.v1_12_R1;
-
-public class WorldServer {
-
-	public TileEntity getTileEntity(BlockPosition pos) {
-		return null;
-	}
-}

phantom-classes/src/main/java/org/bukkit/craftbukkit/v1_12_R1/CraftServer.java

@@ -1,10 +0,0 @@
-package org.bukkit.craftbukkit.v1_12_R1;
-
-import org.bukkit.command.SimpleCommandMap;
-
-public class CraftServer {
-
-	public SimpleCommandMap getCommandMap() {
-		return null;
-	}
-}

phantom-classes/src/main/java/org/bukkit/craftbukkit/v1_12_R1/CraftWorld.java

@@ -1,10 +0,0 @@
-package org.bukkit.craftbukkit.v1_12_R1;
-
-import net.minecraft.server.v1_12_R1.WorldServer;
-
-public class CraftWorld {
-
-	public WorldServer getHandle() {
-		return null;
-	}
-}

settings.gradle

@@ -1,2 +1,2 @@
-include 'phantom-classes'
+rootProject.name = projectName
-include 'tools'
+

src/main/java/ghast/BuildHelper.java

@@ -0,0 +1,147 @@
+package ghast;
+
+import lombok.experimental.UtilityClass;
+import org.bukkit.Location;
+import org.bukkit.Material;
+import org.bukkit.SkullType;
+import org.bukkit.block.Block;
+import org.bukkit.block.BlockFace;
+import org.bukkit.block.Sign;
+import org.bukkit.block.Skull;
+import ru.dmitriymx.reflection.ReflectionClass;
+import ru.dmitriymx.reflection.ReflectionObject;
+
+import java.nio.charset.StandardCharsets;
+import java.util.Base64;
+import java.util.UUID;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class BuildHelper {
+
+    private final Class<?> CLASS_BLOCKPOSITION = getClassForName("net.minecraft.server.v1_12_R1.BlockPosition");
+    private final Class<?> CLASS_GAMEPROFILE = getClassForName("com.mojang.authlib.GameProfile");
+
+    /**
+     * Установка черепа.
+     * <p>
+     * После установки, необходимо выполнить <code>skull.update(true);</code>
+     *
+     * @param location место установки.
+     * @param face куда будет повёрнут череп.
+     * @return Блок типа {@link Skull}
+     */
+    public Skull placeSkull(Location location, BlockFace face) {
+        Location fixedLocation = GhastTools.copyLocation(location);
+        fixedLocation.setZ(fixedLocation.getZ() - 1);
+
+        Block block = location.getWorld().getBlockAt(location);
+        block.setType(Material.SKULL);
+
+        Skull skull = (Skull) block.getState();
+        skull.setRotation(face);
+
+        org.bukkit.material.Skull skullMaterial = (org.bukkit.material.Skull) skull.getData();
+        skullMaterial.setFacingDirection(BlockFace.SELF);
+
+        return skull;
+    }
+
+    /**
+     * Установка головы игрока.
+     * <p>
+     * После установки, необходимо выполнить <code>skull.update(true);</code>
+     *
+     * @param location место установки.
+     * @param face куда будет повёрнута голова.
+     * @return Блок типа {@link Skull}
+     */
+    public static Skull placePlayerHead(Location location, BlockFace face) {
+        Location fixedLocation = GhastTools.copyLocation(location);
+        fixedLocation.setZ(fixedLocation.getZ() - 1);
+
+        Block block = fixedLocation.getWorld().getBlockAt(fixedLocation);
+        block.setType(Material.SKULL);
+
+        Skull skull = (Skull) block.getState();
+        skull.setSkullType(SkullType.PLAYER);
+        skull.setRotation(face);
+
+        org.bukkit.material.Skull skullMaterial = (org.bukkit.material.Skull) skull.getData();
+        skullMaterial.setFacingDirection(BlockFace.SELF);
+        return skull;
+    }
+
+    /**
+     * Установка текстурированной головы игрока.
+     *
+     * @param location место установки.
+     * @param face куда будет повёрнута голова.
+     * @param skinUrl URL на текстуру
+     * @return Блок типа {@link Skull}
+     */
+    public static Skull placePlayerHead(Location location, BlockFace face, String skinUrl) {
+        Skull playerHead = placePlayerHead(location, face);
+        playerHead.update(true);
+        setPlayerHeadSkin(playerHead, skinUrl);
+
+        return playerHead;
+    }
+
+    /**
+     * Установка текстуры для головы игрока.
+     *
+     * @param skull блок головы игрока
+     * @param skinUrl URL на текстуру
+     */
+    public static void setPlayerHeadSkin(Skull skull, String skinUrl) {
+        //TODO заменить рефлексию на "фантомные" классы
+        ReflectionObject refobjBlockPosition = new ReflectionClass(CLASS_BLOCKPOSITION)
+                .constructor(double.class, double.class, double.class)
+                .newInstance(skull.getX(), skull.getY(), skull.getZ());
+
+        new ReflectionObject(skull.getWorld())
+                .method("getHandle").invoke()
+                .method("getTileEntity", CLASS_BLOCKPOSITION)
+                    .invoke(refobjBlockPosition.getOriginalObject())
+                .method("setGameProfile", CLASS_GAMEPROFILE)
+                    .invoke(getRefObjPlayerProfile(skinUrl).getOriginalObject());
+    }
+
+    public Sign placeSignWall(Location location, BlockFace face) {
+        Block block = location.getWorld().getBlockAt(location);
+        block.setType(Material.WALL_SIGN);
+
+        Sign sign = (Sign) block.getState();
+        org.bukkit.material.Sign signMaterial = (org.bukkit.material.Sign) sign.getData();
+        signMaterial.setFacingDirection(face);
+
+        return sign;
+    }
+
+    private ReflectionObject getRefObjPlayerProfile(String url){
+        ReflectionObject refobjProperty = new ReflectionClass(
+                    getClassForName("com.mojang.authlib.properties.Property"))
+                .constructor(String.class, String.class)
+                .newInstance("textures", Base64.getEncoder()
+                        .encodeToString(("{textures:{SKIN:{url:\"" + url + "\"}}}").getBytes(StandardCharsets.UTF_8)));
+
+        ReflectionObject refobjGameProfile = new ReflectionClass(CLASS_GAMEPROFILE)
+                .constructor(UUID.class, String.class)
+                .newInstance(UUID.randomUUID(), null);
+        refobjGameProfile
+                .method("getProperties").invoke()
+                .method("put", Object.class, Object.class)
+                    .invoke("textures", refobjProperty.getOriginalObject());
+
+        return refobjGameProfile;
+    }
+
+    private Class<?> getClassForName(String className) {
+        try {
+            return Class.forName(className);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/ghast/EffectsHelper.java

@@ -0,0 +1,27 @@
+package ghast;
+
+import lombok.experimental.UtilityClass;
+import org.bukkit.Location;
+import org.bukkit.Particle;
+import org.bukkit.Sound;
+import org.bukkit.SoundCategory;
+import org.bukkit.util.Vector;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class EffectsHelper {
+
+    public void playSound(Location location, Sound sound, float pitch) {
+        location.getWorld().playSound(location, sound, SoundCategory.MASTER, 1.0f, pitch);
+    }
+
+    public void particle(Location location, Particle particle, double dx, double dy, double dz, double speed, int amount) {
+        location.getWorld().spawnParticle(particle, location, amount, dx, dy, dz, speed);
+    }
+
+    //TODO нужно проверить
+    public void particle(Location location, Particle particle, Vector vector, double speed, int amount) {
+        particle(location, particle, vector.getX(), vector.getY(), vector.getZ(), speed, amount);
+    }
+}
+

src/main/java/ghast/EventContext.java

@@ -0,0 +1,71 @@
+package ghast;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import org.bukkit.Bukkit;
+import org.bukkit.event.Cancellable;
+import org.bukkit.event.Event;
+import org.bukkit.event.EventPriority;
+import org.bukkit.event.Listener;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.BooleanSupplier;
+import java.util.function.Consumer;
+
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+@SuppressWarnings("unused")
+public class EventContext implements Listener {
+
+    private static final BooleanSupplier EMPTY_FILTER = () -> true;
+    private static final Consumer<Cancellable> CANCEL_EVENT = event -> event.setCancelled(true);
+
+    private final Map<Class<? extends Event>, Consumer<?>> eventMap = new HashMap<>();
+    private BooleanSupplier filter = EMPTY_FILTER;
+
+    public EventContext filter(BooleanSupplier filter) {
+        this.filter = (filter != null ? filter : EMPTY_FILTER);
+        return this;
+    }
+
+    public <T extends Event> EventContext onEvent(Class<T> eventType, EventPriority eventPriority, Consumer<T> consumer) {
+        if (consumer == null) {
+            eventMap.remove(eventType);
+        } else {
+            eventMap.put(eventType, consumer);
+            bukkitRegisterEvent(eventType, eventPriority);
+        }
+        return this;
+    }
+
+    public <T extends Event> EventContext onEvent(Class<T> eventType, Consumer<T> consumer) {
+        return onEvent(eventType, EventPriority.NORMAL, consumer);
+    }
+
+    public <T extends Event & Cancellable> EventContext cancelEvent(Class<T> eventType, EventPriority eventPriority) {
+        eventMap.put(eventType, CANCEL_EVENT);
+        bukkitRegisterEvent(eventType, eventPriority);
+        return this;
+    }
+
+    public <T extends Event & Cancellable> EventContext cancelEvent(Class<T> eventType) {
+        return cancelEvent(eventType, EventPriority.NORMAL);
+    }
+
+    private void bukkitRegisterEvent(Class<? extends Event> eventType, EventPriority eventPriority) {
+        Bukkit.getPluginManager().registerEvent(eventType, this, eventPriority,
+                this::eventExecute, GhastTools.getPlugin());
+    }
+
+    @SuppressWarnings({ "unchecked", "rawtypes" })
+    private void eventExecute(Listener listener, Event event) {
+        Consumer consumer = eventMap.get(event.getClass());
+        if (consumer != null && filter.getAsBoolean()) {
+            consumer.accept(event);
+        }
+    }
+
+    public static EventContext create() {
+        return new EventContext();
+    }
+}

src/main/java/ghast/GhastTools.java

@@ -0,0 +1,55 @@
+package ghast;
+
+import ghast.assets.AssetsManager;
+import lombok.experimental.UtilityClass;
+import org.bukkit.Location;
+import org.bukkit.configuration.file.YamlConfiguration;
+import org.bukkit.plugin.Plugin;
+
+import java.io.IOException;
+import java.io.Reader;
+import java.lang.ref.WeakReference;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class GhastTools {
+
+    private static WeakReference<Plugin> refPlugin;
+
+    public void setPlugin(Plugin plugin) {
+        refPlugin = plugin == null ? null : new WeakReference<>(plugin);
+    }
+
+    public Plugin getPlugin() {
+        if (refPlugin == null) {
+            throw new RuntimeException("Plugin not set.");
+        }
+
+        Plugin plugin = refPlugin.get();
+        if (plugin == null) {
+            throw new RuntimeException("Plugin not set.");
+        }
+
+        return plugin;
+    }
+
+    public YamlConfiguration loadConfig(boolean saveDefault) {
+        if (saveDefault) {
+            getPlugin().saveDefaultConfig();
+        }
+
+        try (Reader reader = AssetsManager.getAsReader("config.yml", saveDefault)) {
+            return YamlConfiguration.loadConfiguration(reader);
+        } catch (IOException e) {
+            throw new RuntimeException("Error load config: " + e.getMessage(), e);
+        }
+    }
+
+    public YamlConfiguration loadConfig() {
+        return loadConfig(true);
+    }
+
+    public Location copyLocation(Location location) {
+        return new Location(location.getWorld(), location.getX(), location.getY(), location.getZ());
+    }
+}

src/main/java/ghast/I18n.java

@@ -0,0 +1,94 @@
+package ghast;
+
+import com.google.common.collect.HashBasedTable;
+import com.google.common.collect.Table;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import lombok.experimental.UtilityClass;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.text.StringSubstitutor;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @deprecated use {@link Messages}
+ */
+@UtilityClass
+@SuppressWarnings("unused")
+@Deprecated
+public class I18n {
+
+    private final String DEFAULT_LANG = "en";
+    private final Table<String/*Lang*/, String/*Key*/, String/*Template|Message*/> messagesMap = HashBasedTable.create();
+
+    //region Load messages
+    public void loadMessages(String lang, Reader reader) {
+        Map<String, String> map = messagesMap.row(lang.toLowerCase());
+
+        try {
+            BufferedReader bufferedReader = new BufferedReader(reader);
+            String line;
+            while ((line = bufferedReader.readLine()) != null) {
+                String[] split = line.split("=", 2);
+                map.put(split[0].trim().toLowerCase(), split[1].trim());
+            }
+        } catch (IOException e) {
+            throw new RuntimeException("Error load messages: " + e.getMessage(), e);
+        }
+    }
+
+    public void loadMessages(String lang, Map<String, String> messages) {
+        Map<String, String> map = messagesMap.row(lang.toLowerCase());
+        messages.forEach((k, v) -> map.put(k.toLowerCase(), v));
+    }
+
+    public void loadMessages(Reader reader) {
+        loadMessages(DEFAULT_LANG, reader);
+    }
+
+    public void loadMessages(Map<String, String> messages) {
+        loadMessages(DEFAULT_LANG, messages);
+    }
+    //endregion
+
+    //region Get message
+    public String get(String lang, String key) {
+        return messagesMap.row(lang.toLowerCase()).getOrDefault(key.toLowerCase(), StringUtils.EMPTY);
+    }
+
+    public String get(String lang, String key, Map<String, Object> params) {
+        return StringSubstitutor.replace(get(lang, key.toLowerCase()), params, "{", "}");
+    }
+
+    public String get(String key) {
+        return get(DEFAULT_LANG, key);
+    }
+
+    public String get(String key, Map<String, Object> params) {
+        return get(DEFAULT_LANG, key, params);
+    }
+    //endregion
+
+    public ParamBuilder paramBuilder() {
+        return new ParamBuilder();
+    }
+
+    @NoArgsConstructor(access = AccessLevel.PRIVATE)
+    public static class ParamBuilder {
+
+        private final Map<String, Object> params = new HashMap<>();
+
+        public ParamBuilder add(String key, Object value) {
+            params.put(key, value);
+            return this;
+        }
+
+        public Map<String, Object> build() {
+            return params;
+        }
+    }
+}

src/main/java/ghast/Messages.java

@@ -0,0 +1,150 @@
+package ghast;
+
+import lombok.experimental.UtilityClass;
+import org.apache.commons.text.StringSubstitutor;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+
+@UtilityClass
+public class Messages {
+
+	private final Map<String/*Key*/, String/*Template|Message*/> MESSAGES_MAP = new HashMap<>();
+
+	//region Load messages
+
+	/**
+	 * Загрузка сообщений из {@link Properties}
+	 *
+	 * @param properties список сообщений и шаблонов
+	 */
+	public void load(Properties properties) {
+		MESSAGES_MAP.clear();
+		properties.forEach((key, value) -> MESSAGES_MAP.put(key.toString().trim().toLowerCase(), value.toString().trim()));
+	}
+
+	/**
+	 * Загрузка сообщений из {@link Reader}.
+	 * <p>
+	 * Формат строк: {@code key=value}
+	 * </p>
+	 *
+	 * @param reader {@link Reader} со списоком сообщений и шаблонов
+	 */
+	public void load(Reader reader) {
+		MESSAGES_MAP.clear();
+		try {
+			BufferedReader bufferedReader = new BufferedReader(reader);
+			String line;
+			while ((line = bufferedReader.readLine()) != null) {
+				String[] split = line.split("=", 2);
+				MESSAGES_MAP.put(split[0].trim().toLowerCase(), split[1].trim());
+			}
+		} catch (IOException e) {
+			//TODO заменить на специализированный Exception
+			throw new RuntimeException("Error load messages: " + e.getMessage(), e);
+		}
+	}
+
+	/**
+	 * Загрузка сообщений из {@link Map}<{@link String}, {@link String}>.
+	 *
+	 * @param messages список сообщений и шаблонов
+	 */
+	public void load(Map<String, String> messages) {
+		MESSAGES_MAP.clear();
+		MESSAGES_MAP.putAll(messages);
+	}
+	//endregion
+
+	//region Get messages
+	/**
+	 * Получить обычное сообщение по ключу/коду.
+	 *
+	 * @param key ключ/код
+	 * @return сообщение, если таковое задано. Иначе - ключ
+	 */
+	public String get(String key) {
+		String keyLc = key.toLowerCase();
+		return MESSAGES_MAP.getOrDefault(keyLc, keyLc);
+	}
+
+	/**
+	 * Получить параметизированное сообщение по ключу/коду.
+	 *
+	 * @param key    ключ/код
+	 * @param params список параметров
+	 * @return сообщение, если таковое задано. Иначе - ключ
+	 */
+	public String get(String key, Map<String, Object> params) {
+		String keyLc = key.toLowerCase();
+
+		if (MESSAGES_MAP.containsKey(keyLc)) {
+			return format(MESSAGES_MAP.get(keyLc), params);
+		} else {
+			return keyLc;
+		}
+	}
+
+	/**
+	 * Получить параметизированное сообщение по ключу/коду.
+	 *
+	 * @param key    ключ/код
+	 * @param params чередующийся по парный список параметров: {@link String (str)param_name}, {@link Object (obj)param_value} и т.д.
+	 * @return сообщение, если таковое задано. Иначе - ключ
+	 */
+	public String get(String key, Object... params) {
+		String keyLc = key.toLowerCase();
+
+		if (MESSAGES_MAP.containsKey(keyLc)) {
+			return format(MESSAGES_MAP.get(keyLc), params);
+		} else {
+			return keyLc;
+		}
+	}
+	//endregion
+
+	//region Format message
+	/**
+	 * Получить сообщение по формату.
+	 *
+	 * @param format параметизированное сообщение
+	 * @param params параметры
+	 * @return сообщение
+	 */
+	public String format(String format, Map<String, Object> params) {
+		return StringSubstitutor.replace(format, params, "{", "}");
+	}
+
+	/**
+	 * Получить сообщение по формату.
+	 *
+	 * @param format параметизированное сообщение
+	 * @param params параметры
+	 * @return сообщение
+	 */
+	public String format(String format, Object... params) {
+		return format(format, arrayParamsToMap(params));
+	}
+	//endregion
+
+	private Map<String, Object> arrayParamsToMap(Object... params) {
+		int len;
+		if ((params.length % 2) == 1) {
+			len = params.length - 1;
+		} else {
+			len = params.length;
+		}
+
+		Map<String, Object> map = new HashMap<>(len / 2);
+		for (int i = 0; i < len; i = i + 2) {
+			map.put((String) params[i], params[i + 1]);
+		}
+
+		return map;
+	}
+}

src/main/java/ghast/XLog.java

@@ -0,0 +1,77 @@
+package ghast;
+
+import lombok.experimental.UtilityClass;
+
+import java.util.logging.Level;
+
+import static java.text.MessageFormat.format;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class XLog {
+
+    //region Debug
+    public void debug(String pattern, Object... objects) {
+        if (objects.length > 1 && objects[objects.length - 1] instanceof Throwable) {
+            Throwable throwable = (Throwable) objects[objects.length - 1];
+            Object[] values = new Object[objects.length - 1];
+            System.arraycopy(objects, 0, values, 0, values.length);
+
+            debug(format(pattern, values), throwable);
+        } else {
+            debug(format(pattern, objects));
+        }
+    }
+
+    public void debug(String message, Throwable throwable) {
+        GhastTools.getPlugin().getLogger().log(Level.FINE, message, throwable);
+    }
+
+    public void debug(String message) {
+        GhastTools.getPlugin().getLogger().fine(message);
+    }
+    //endregion
+
+    //region Info
+    public void info(String pattern, Object... objects) {
+        info(format(pattern, objects));
+    }
+
+    public void info(String message) {
+        GhastTools.getPlugin().getLogger().info(message);
+    }
+    //endregion
+
+    //region Warning
+    public void warn(String pattern, Object... objects) {
+        warn(format(pattern, objects));
+    }
+
+    public void warn(String message) {
+        GhastTools.getPlugin().getLogger().warning(message);
+    }
+    //endregion
+
+    //region Error
+    public void error(String pattern, Object... objects) {
+        if (objects.length > 1 && objects[objects.length - 1] instanceof Throwable) {
+            Throwable throwable = (Throwable) objects[objects.length - 1];
+            Object[] values = new Object[objects.length - 1];
+            System.arraycopy(objects, 0, values, 0, values.length);
+
+            error(format(pattern, values), throwable);
+        } else {
+            error(format(pattern, objects));
+        }
+    }
+
+    public void error(String message) {
+        GhastTools.getPlugin().getLogger().severe(message);
+    }
+
+    public void error(String message, Throwable throwable) {
+        GhastTools.getPlugin().getLogger().log(Level.SEVERE, message, throwable);
+    }
+    //endregion
+
+}

src/main/java/ghast/assets/AssetsException.java

@@ -0,0 +1,13 @@
+package ghast.assets;
+
+public class AssetsException extends RuntimeException {
+
+    public AssetsException(String message) {
+        super(message);
+    }
+
+    public AssetsException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}
+

src/main/java/ghast/assets/AssetsManager.java

@@ -0,0 +1,163 @@
+package ghast.assets;
+
+import ghast.GhastTools;
+import lombok.experimental.UtilityClass;
+import org.bukkit.plugin.Plugin;
+
+import java.io.*;
+import java.net.URL;
+import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.Scanner;
+
+import static java.text.MessageFormat.format;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class AssetsManager {
+
+    private static final String ERROR_NOT_FOUND = "Asset \"{0}\" not found";
+    private static final String ERROR_OPEN = "Error open asset \"{0}\": {1}";
+
+    //region getAsInputStream methods
+    public InputStream getAsInputStream(String resourceName, String defaultResourceName, boolean saveDefault) {
+        Plugin plugin = GhastTools.getPlugin();
+        InputStream inputStream;
+
+        Path pathToResource = plugin.getDataFolder().toPath().resolve(resourceName);
+        if (Files.exists(pathToResource)) {
+            inputStream = openResource(pathToResource);
+        } else if (defaultResourceName != null) {
+            URL resourceUrl = getResourceUrl(defaultResourceName);
+
+            if (saveDefault) {
+                doSaveTo(resourceUrl, pathToResource);
+                inputStream = openResource(pathToResource);
+            } else {
+                inputStream = openResource(resourceUrl);
+            }
+        } else {
+            throw new AssetsException(format(ERROR_NOT_FOUND, resourceName));
+        }
+
+        return inputStream;
+    }
+
+    public InputStream getAsInputStream(String resourceName, String defaultResourceName) {
+        return getAsInputStream(resourceName, defaultResourceName, true);
+    }
+
+    public InputStream getAsInputStream(String resourceName, boolean saveDefault) {
+        return getAsInputStream(resourceName, resourceName, saveDefault);
+    }
+
+    public InputStream getAsInputStream(String resourceName) {
+        return getAsInputStream(resourceName, resourceName, true);
+    }
+    //endregion
+
+    //region getAsReader methods
+    public Reader getAsReader(String resourceName, String defaultResourceName, boolean saveDefault) {
+        return new InputStreamReader(getAsInputStream(resourceName, defaultResourceName, saveDefault));
+    }
+
+    public Reader getAsReader(String resourceName, String defaultResourceName) {
+        return new InputStreamReader(getAsInputStream(resourceName, defaultResourceName, true));
+    }
+
+    public Reader getAsReader(String resourceName, boolean saveDefault) {
+        return new InputStreamReader(getAsInputStream(resourceName, resourceName, saveDefault));
+    }
+
+    public Reader getAsReader(String resourceName) {
+        return new InputStreamReader(getAsInputStream(resourceName, resourceName, true));
+    }
+    //endregion
+
+    //region getAsString methods
+    public String getAsString(String resourceName, String defaultResourceName, Charset charset, boolean saveDefault) {
+        try (InputStream inputStream = getAsInputStream(resourceName, defaultResourceName, saveDefault);
+             Scanner scanner = new Scanner(inputStream, charset.name()).useDelimiter("\\A")) {
+
+            return scanner.next();
+        } catch (IOException e) {
+            throw new AssetsException(format(ERROR_OPEN, resourceName, e.getMessage()), e);
+        }
+    }
+
+    public String getAsString(String resourceName, String defaultResourceName, Charset charset) {
+        return getAsString(resourceName, defaultResourceName, charset, true);
+    }
+
+    public String getAsString(String resourceName, String defaultResourceName, boolean saveDefault) {
+        return getAsString(resourceName, defaultResourceName, StandardCharsets.UTF_8, saveDefault);
+    }
+
+    public String getAsString(String resourceName, String defaultResourceName) {
+        return getAsString(resourceName, defaultResourceName, StandardCharsets.UTF_8, true);
+    }
+
+    public String getAsString(String resourceName, Charset charset, boolean saveDefault) {
+        return getAsString(resourceName, resourceName, charset, saveDefault);
+    }
+
+    public String getAsString(String resourceName, Charset charset) {
+        return getAsString(resourceName, resourceName, charset, true);
+    }
+
+    public String getAsString(String resourceName, boolean saveDefault) {
+        return getAsString(resourceName, resourceName, StandardCharsets.UTF_8, saveDefault);
+    }
+
+    public String getAsString(String resourceName) {
+        return getAsString(resourceName, resourceName, StandardCharsets.UTF_8, true);
+    }
+    //endregion
+
+    private URL getResourceUrl(String resourceName) {
+        URL resourceUrl = AssetsManager.class.getClassLoader().getResource(resourceName);
+        if (resourceUrl == null) {
+            throw new AssetsException(format(ERROR_NOT_FOUND, resourceName));
+        }
+
+        return resourceUrl;
+    }
+
+    private void doSaveTo(URL resourceUrl, Path saveToPath) {
+        try {
+            Files.createDirectories(saveToPath.getParent());
+
+            try (InputStream inputStream = resourceUrl.openStream();
+                 OutputStream outputStream = Files.newOutputStream(saveToPath)) {
+
+                byte[] buffer = new byte[8192];
+                int count;
+                while ((count = inputStream.read(buffer)) != -1) {
+                    outputStream.write(buffer, 0, count);
+                }
+                outputStream.flush();
+            }
+        } catch (IOException e) {
+            throw new AssetsException(format("Error save asset \"{0}\" to \"{1}\": {2}",
+                    resourceUrl, saveToPath, e.getMessage()), e);
+        }
+    }
+
+    private InputStream openResource(Path pathToResource) {
+        try {
+            return Files.newInputStream(pathToResource);
+        } catch (IOException e) {
+            throw new AssetsException(format(ERROR_OPEN, pathToResource, e.getMessage()), e);
+        }
+    }
+
+    private InputStream openResource(URL resourceUrl) {
+        try {
+            return resourceUrl.openStream();
+        } catch (IOException e) {
+            throw new AssetsException(format(ERROR_OPEN, resourceUrl, e.getMessage()), e);
+        }
+    }
+}

src/main/java/ghast/command/CommandManager.java

@@ -0,0 +1,71 @@
+package ghast.command;
+
+import lombok.AccessLevel;
+import lombok.RequiredArgsConstructor;
+import lombok.experimental.UtilityClass;
+import org.bukkit.Bukkit;
+import org.bukkit.command.Command;
+import ru.dmitriymx.reflection.ReflectionObject;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class CommandManager {
+
+    public Builder create(String name) {
+        return new Builder(name);
+    }
+
+    public void register(String name, CommandExecuter executer) {
+        create(name).executer(executer).register();
+    }
+
+    @RequiredArgsConstructor(access = AccessLevel.PRIVATE)
+    public static class Builder {
+
+        private final String name;
+        private CommandExecuter executer;
+        private ErrorConsumer errorConsumer;
+        private Boolean onlyPlayer;
+        private String deniedMessage;
+
+        public Builder executer(CommandExecuter executer) {
+            this.executer = executer;
+            return this;
+        }
+
+        public Builder onError(ErrorConsumer errorConsumer) {
+            this.errorConsumer = errorConsumer;
+            return this;
+        }
+
+        public Builder useOnlyPlayer(String deniedMessage) {
+            this.onlyPlayer = true;
+            this.deniedMessage = deniedMessage;
+            return this;
+        }
+
+        public Builder useOnlyPlayer() {
+            return useOnlyPlayer(null);
+        }
+
+        public Builder useOnlyConsole(String deniedMessage) {
+            this.onlyPlayer = false;
+            this.deniedMessage = deniedMessage;
+            return this;
+        }
+
+        public Builder useOnlyConsole() {
+            return useOnlyConsole(null);
+        }
+
+        public void register() {
+            //TODO для Paper такие "извращения" не требуются. Нужно продумать.
+            new ReflectionObject(Bukkit.getServer())
+                    .method("getCommandMap").invoke()
+                    .method("register", String.class, Command.class).invoke(
+                        name, new CommandWrapper(name, this.onlyPlayer, this.deniedMessage,
+                            this.executer, this.errorConsumer)
+                    );
+        }
+    }
+}

src/main/java/ghast/command/CommandWrapper.java

@@ -0,0 +1,70 @@
+package ghast.command;
+
+import ghast.XLog;
+import org.bukkit.ChatColor;
+import org.bukkit.command.CommandSender;
+import org.bukkit.command.defaults.BukkitCommand;
+import org.bukkit.entity.Player;
+
+class CommandWrapper extends BukkitCommand {
+
+    private static final String DEFAULT_DENIED_MESSAGE_PLAYERS = ChatColor.RED + "This command use only players";
+    private static final String DEFAULT_DENIED_MESSAGE_CONSOLE = ChatColor.RED + "This command use only in console";
+
+    private static final ErrorConsumer DEFAULT_ERROR_CONSUMER =
+            (sender, commandName, args, exception) -> {
+                sender.sendMessage(String.format("%sError execute command '%s'!", ChatColor.RED, commandName));
+                XLog.error("Error execute command ''{0}'' with args ''{1}''",
+                        commandName, String.join(" ", args), exception);
+            };
+
+    private final CommandExecuter executer;
+    private final ErrorConsumer errorConsumer;
+    private final Boolean onlyPlayer;
+    private String deniedMessage;
+
+    protected CommandWrapper(String name, Boolean onlyPlayer, String deniedMessage,
+            CommandExecuter executer, ErrorConsumer errorConsumer) {
+        super(name);
+        this.onlyPlayer = onlyPlayer;
+        this.executer = executer;
+
+        if (onlyPlayer != null) {
+            if (deniedMessage == null) {
+                this.deniedMessage = Boolean.TRUE.equals(onlyPlayer) ? DEFAULT_DENIED_MESSAGE_PLAYERS
+                        : DEFAULT_DENIED_MESSAGE_CONSOLE;
+            } else {
+                this.deniedMessage = deniedMessage;
+            }
+        }
+
+        if(errorConsumer == null) {
+            this.errorConsumer = DEFAULT_ERROR_CONSUMER;
+        } else {
+            this.errorConsumer = errorConsumer;
+        }
+    }
+
+    @Override
+    public boolean execute(CommandSender commandSender, String commandName, String[] args) {
+        if (Boolean.TRUE.equals(onlyPlayer)) {
+            if (!(commandSender instanceof Player)) {
+                commandSender.sendMessage(deniedMessage);
+                return true;
+            }
+        } else if (Boolean.FALSE.equals(onlyPlayer)) { // use console only
+            if (commandSender instanceof Player) {
+                commandSender.sendMessage(deniedMessage);
+                return true;
+            }
+        }
+
+        try {
+            executer.execute(commandSender, args);
+            return true;
+        } catch (Exception e) {
+            errorConsumer.accept(commandSender, commandName, args, e);
+            return false;
+        }
+    }
+}

src/main/java/ghast/database/DataAccessException.java

@@ -0,0 +1,18 @@
+package ghast.database;
+
+import lombok.Getter;
+
+@Getter
+public class DataAccessException extends RuntimeException {
+
+    private String sql;
+
+    public DataAccessException(String msg, Throwable cause) {
+        super(msg, cause);
+    }
+
+    public DataAccessException(String msg, String sql, Throwable cause) {
+        this(msg, cause);
+        this.sql = sql;
+    }
+}

src/main/java/ghast/database/JdbcOperations.java

@@ -0,0 +1,22 @@
+package ghast.database;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+public interface JdbcOperations {
+
+    void execute(String sql) throws DataAccessException;
+
+    <T> T query(String sql, ResultSetExtractor<T> rse) throws DataAccessException;
+
+    <T> Optional<T> queryOne(String sql, ResultSetExtractor<T> rse) throws DataAccessException;
+
+    <T> List<T> queryList(String sql, RowMapper<T> rowMapper) throws DataAccessException;
+
+    Map<String, Object> queryForMap(String sql) throws DataAccessException;
+
+    List<Map<String, Object>> queryForMapList(String sql) throws DataAccessException;
+
+    int update(String sql) throws DataAccessException;
+}

src/main/java/ghast/database/JdbcTemplate.java

@@ -0,0 +1,244 @@
+package ghast.database;
+
+import ghast.XLog;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import javax.sql.DataSource;
+import java.sql.Date;
+import java.sql.*;
+import java.util.*;
+
+@NoArgsConstructor
+@Getter
+@Setter
+public class JdbcTemplate implements JdbcOperations {
+
+    private static final String DBG_SQL_INFO = "Execute SQL: {0}";
+    private DataSource dataSource;
+
+    public JdbcTemplate(DataSource dataSource) {
+        setDataSource(dataSource);
+    }
+
+    @Override
+    public void execute(String sql) throws DataAccessException {
+        XLog.debug(DBG_SQL_INFO, sql);
+
+        Connection connection = openConnection();
+        Statement statement = null;
+        try {
+            statement = connection.createStatement();
+            statement.execute(sql);
+        } catch (SQLException e) {
+            throw new DataAccessException("Error execute SQL", sql, e);
+        } finally {
+            closeStatement(statement);
+            closeConnection(connection);
+        }
+    }
+
+    @Override
+    public <T> T query(String sql, ResultSetExtractor<T> rse) throws DataAccessException {
+        XLog.debug(DBG_SQL_INFO, sql);
+
+        Connection connection = openConnection();
+        Statement statement = null;
+        ResultSet resultSet = null;
+        try {
+            statement = connection.createStatement();
+            resultSet = statement.executeQuery(sql);
+            return rse.extractData(resultSet);
+        } catch (SQLException e) {
+            throw new DataAccessException("Error execute SQL", sql, e);
+        } finally {
+            closeResultSet(resultSet);
+            closeStatement(statement);
+            closeConnection(connection);
+        }
+    }
+
+    @Override
+    public <T> Optional<T> queryOne(String sql, ResultSetExtractor<T> rse) throws DataAccessException {
+        return query(sql, rs -> {
+            if (rs.next()) {
+                return Optional.ofNullable(rse.extractData(rs));
+            } else {
+                return Optional.empty();
+            }
+        });
+    }
+
+    @Override
+    public <T> List<T> queryList(String sql, final RowMapper<T> rowMapper) throws DataAccessException {
+        return query(sql, rs -> {
+            List<T> resultList;
+            int rowNum = 0;
+            if (rs.next()) {
+                resultList = new ArrayList<>();
+
+                do {
+                    resultList.add(rowMapper.mapRow(rs, rowNum++));
+                } while (rs.next());
+            } else {
+                resultList = Collections.emptyList();
+            }
+
+            return resultList;
+        });
+    }
+
+    @Override
+    public Map<String, Object> queryForMap(String sql) throws DataAccessException {
+        return query(sql, rs -> {
+            if (rs.next()) {
+                ResultSetMetaData metaData = rs.getMetaData();
+                int columnCount = metaData.getColumnCount();
+
+                return rowToMap(columnCount, metaData, rs);
+            } else {
+                return Collections.emptyMap();
+            }
+        });
+    }
+
+    @Override
+    public List<Map<String, Object>> queryForMapList(String sql) throws DataAccessException {
+        return query(sql, rs -> {
+            List<Map<String, Object>> resultList;
+
+            if (rs.next()) {
+                resultList = new ArrayList<>();
+
+                ResultSetMetaData metaData = rs.getMetaData();
+                int columnCount = metaData.getColumnCount();
+
+                do {
+                    resultList.add(rowToMap(columnCount, metaData, rs));
+                } while (rs.next());
+            } else {
+                resultList = Collections.emptyList();
+            }
+
+            return resultList;
+        });
+    }
+
+    @Override
+    public int update(String sql) throws DataAccessException {
+        XLog.debug(DBG_SQL_INFO, sql);
+
+        Connection connection = openConnection();
+        Statement statement = null;
+        try {
+            statement = connection.createStatement();
+            int rows = statement.executeUpdate(sql);
+            XLog.debug("Affected {0} rows", rows);
+            return rows;
+        } catch (SQLException e) {
+            XLog.error("Error execute SQL: {0}", e.getMessage(), e);
+            return 0;
+        } finally {
+            closeStatement(statement);
+            closeConnection(connection);
+        }
+    }
+
+    private Connection openConnection() {
+        try {
+            return getDataSource().getConnection();
+        } catch (SQLException ex) {
+            throw new CannotGetJdbcConnectionException("Could not get JDBC Connection", ex);
+        }
+    }
+
+    private String lookupColumnName(ResultSetMetaData resultSetMetaData, int columnIndex) throws SQLException {
+        String name = resultSetMetaData.getColumnLabel(columnIndex);
+        if (name == null || name.isEmpty()) {
+            name = resultSetMetaData.getColumnName(columnIndex);
+        }
+        return name;
+    }
+
+    private Map<String, Object> rowToMap(int columnCount, ResultSetMetaData metaData, ResultSet rs) throws SQLException {
+        Map<String, Object> rowMap = new LinkedHashMap<>(columnCount);
+
+        for (int i = 1; i <= columnCount; i++) {
+            String key = lookupColumnName(metaData, i);
+            Object value = getResultSetRawValue(rs, i);
+            rowMap.put(key, value);
+        }
+
+        return rowMap;
+    }
+
+    private Object getResultSetRawValue(ResultSet resultSet, int index) throws SQLException {
+        Object obj = resultSet.getObject(index);
+        if (obj == null) {
+            return null;
+        }
+
+        String className = obj.getClass().getName();
+
+        if (obj instanceof Blob) {
+            Blob blob = (Blob) obj;
+            obj = blob.getBytes(1, (int) blob.length());
+        } else if (obj instanceof Clob) {
+            Clob clob = (Clob) obj;
+            obj = clob.getSubString(1, (int) clob.length());
+        } else if ("oracle.sql.TIMESTAMP".equals(className) || "oracle.sql.TIMESTAMPTZ".equals(className)) {
+            obj = resultSet.getTimestamp(index);
+        } else if (className.startsWith("oracle.sql.DATE")) {
+            String metaDataClassName = resultSet.getMetaData().getColumnClassName(index);
+            if ("java.sql.Timestamp".equals(metaDataClassName) || "oracle.sql.TIMESTAMP".equals(metaDataClassName)) {
+                obj = resultSet.getTimestamp(index);
+            } else {
+                obj = resultSet.getDate(index);
+            }
+        } else if (obj instanceof Date
+                && "java.sql.Timestamp".equals(resultSet.getMetaData().getColumnClassName(index))) {
+            obj = resultSet.getTimestamp(index);
+        }
+
+        return obj;
+    }
+
+    private void closeResultSet(ResultSet resultSet) {
+        if (resultSet != null) {
+            try {
+                resultSet.close();
+            } catch (SQLException e) {
+                XLog.debug("Could not close JDBC ResultSet", e);
+            } catch (Exception e) {
+                XLog.debug("Unexpected exception on closing JDBC ResultSet", e);
+            }
+        }
+    }
+
+    private void closeStatement(Statement statement) {
+        if (statement != null) {
+            try {
+                statement.close();
+            } catch (SQLException e) {
+                XLog.debug("Could not close JDBC Statement", e);
+            } catch (Exception e) {
+                XLog.debug("Unexpected exception on closing JDBC Statement", e);
+            }
+        }
+    }
+
+    private void closeConnection(Connection con) {
+        if (con == null) {
+            return;
+        }
+
+        try {
+            con.close();
+        } catch (SQLException e) {
+            XLog.debug("Could not close JDBC Connection", e);
+        } catch (Exception e) {
+            XLog.debug("Unexpected exception on closing JDBC Connection", e);
+        }
+    }
+}

src/main/java/ghast/scheduler/BukkitScheduleTask.java

@@ -0,0 +1,33 @@
+package ghast.scheduler;
+
+import lombok.RequiredArgsConstructor;
+import org.bukkit.scheduler.BukkitTask;
+
+import java.util.function.Supplier;
+
+@RequiredArgsConstructor
+public class BukkitScheduleTask implements ScheduleTask {
+
+    private final Supplier<BukkitTask> generator;
+    private BukkitTask bukkitTask;
+
+    @Override
+    public void start() {
+        if (isCanceled()) {
+            bukkitTask = generator.get();
+        }
+    }
+
+    @Override
+    public boolean isCanceled() {
+        return bukkitTask == null || bukkitTask.isCancelled();
+    }
+
+    @Override
+    public void cancel() {
+        if (bukkitTask != null) {
+            bukkitTask.cancel();
+            bukkitTask = null;
+        }
+    }
+}

src/main/java/ghast/scheduler/JavaScheduleTask.java

@@ -0,0 +1,33 @@
+package ghast.scheduler;
+
+import lombok.RequiredArgsConstructor;
+
+import java.util.concurrent.Future;
+import java.util.function.Supplier;
+
+@RequiredArgsConstructor
+public class JavaScheduleTask implements ScheduleTask {
+
+    private final Supplier<Future<?>> generator;
+    private Future<?> future;
+
+    @Override
+    public void start() {
+        if (future == null || future.isDone()) {
+            future = generator.get();
+        }
+    }
+
+    @Override
+    public boolean isCanceled() {
+        return future == null || future.isCancelled();
+    }
+
+    @Override
+    public void cancel() {
+        if (future != null) {
+            future.cancel(true);
+            future = null;
+        }
+    }
+}

src/main/java/ghast/scheduler/ScheduleManager.java

@@ -0,0 +1,113 @@
+package ghast.scheduler;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import ghast.GhastTools;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import lombok.experimental.UtilityClass;
+import org.bukkit.Bukkit;
+import org.bukkit.scheduler.BukkitScheduler;
+
+import java.util.concurrent.*;
+
+@UtilityClass
+@SuppressWarnings("unused")
+public class ScheduleManager {
+
+    private static final ThreadFactory THREAD_FACTORY = new ThreadFactoryBuilder()
+            .setNameFormat("ScheduleManager-Thread-%d")
+            .setDaemon(true)
+            .build();
+
+    public Builder createTask() {
+        return new Builder();
+    }
+
+    @NoArgsConstructor(access = AccessLevel.PRIVATE)
+    public static class Builder {
+
+        private static final long MS_PER_ONE_TICK = 1000L/*one second by ms*/ / 20L/*tick per second*/;
+        private boolean useBukkitScheduler = false;
+        private Long afterMs;
+        private Long everyMs;
+
+        public Builder useBukkitScheduler() {
+            this.useBukkitScheduler = true;
+            return this;
+        }
+
+        public Builder after(long value, TimeUnit unit) {
+            this.afterMs = unit.toMillis(value);
+            return this;
+        }
+
+        public Builder every(long value, TimeUnit unit) {
+            this.everyMs = unit.toMillis(value);
+            return this;
+        }
+
+        public ScheduleTask create(Runnable runnable) {
+            if (useBukkitScheduler) {
+                return createBukkitSchedule(runnable);
+            } else {
+                return createSchedule(runnable);
+            }
+        }
+
+        public ScheduleTask execute(Runnable runnable) {
+            ScheduleTask scheduleTask = create(runnable);
+            scheduleTask.start();
+            return scheduleTask;
+        }
+
+        private ScheduleTask createBukkitSchedule(Runnable runnable) {
+            BukkitScheduler bukkitScheduler = Bukkit.getScheduler();
+            BukkitScheduleTask resultTask;
+
+            if (this.afterMs == null && this.everyMs == null) {
+                resultTask = new BukkitScheduleTask(() -> bukkitScheduler.runTask(GhastTools.getPlugin(), runnable));
+            } else if (this.everyMs != null) {
+                long everyTicks = this.everyMs / MS_PER_ONE_TICK;
+                long afterTicks = this.afterMs != null ? this.afterMs / MS_PER_ONE_TICK : 0;
+                resultTask = new BukkitScheduleTask(() ->
+                        bukkitScheduler.runTaskTimer(GhastTools.getPlugin(), runnable, afterTicks, everyTicks));
+            } else {
+                long ticks = this.afterMs / MS_PER_ONE_TICK;
+                resultTask = new BukkitScheduleTask(() ->
+                        bukkitScheduler.runTaskLater(GhastTools.getPlugin(), runnable, ticks));
+            }
+
+            return resultTask;
+        }
+
+        private ScheduleTask createSchedule(Runnable runnable) {
+            ExecutorService executorService;
+            JavaScheduleTask resultTask;
+
+            if (this.afterMs == null && this.everyMs == null) {
+                executorService = Executors.newSingleThreadExecutor(THREAD_FACTORY);
+                resultTask = new JavaScheduleTask(() -> executorService.submit(runnable));
+            } else if (this.everyMs != null) {
+                ScheduledExecutorService scheduledExecutorService
+                        = Executors.newScheduledThreadPool(1, THREAD_FACTORY);
+
+                resultTask = new JavaScheduleTask(() ->
+                        scheduledExecutorService.scheduleAtFixedRate(runnable,
+                                this.afterMs != null ? this.afterMs : 0,
+                                everyMs, TimeUnit.MILLISECONDS));
+
+                executorService = scheduledExecutorService;
+            } else {
+                ScheduledExecutorService scheduledExecutorService
+                        = Executors.newScheduledThreadPool(1, THREAD_FACTORY);
+
+                resultTask = new JavaScheduleTask(() ->
+                        scheduledExecutorService.schedule(runnable, afterMs, TimeUnit.MILLISECONDS));
+                executorService = scheduledExecutorService;
+            }
+
+            executorService.shutdown();
+            return resultTask;
+        }
+    }
+}

src/test/java/ghast/database/JdbcTemplateTest.java

@@ -0,0 +1,289 @@
+package ghast.database;
+
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.Lists;
+import ghast.GhastTools;
+import org.apache.commons.lang3.builder.EqualsBuilder;
+import org.apache.commons.lang3.builder.HashCodeBuilder;
+import org.bukkit.plugin.Plugin;
+import org.h2.jdbcx.JdbcDataSource;
+import org.junit.jupiter.api.*;
+
+import javax.sql.DataSource;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.text.MessageFormat;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.StringJoiner;
+import java.util.logging.Logger;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+class JdbcTemplateTest {
+
+    static final String JDBC_USER = "sa";
+    static final String JDBC_PASSWORD = "";
+    static final String JDBC_DB_NAME = "in_mem_db";
+    static final String JDBC_URL = "jdbc:h2:mem:" + JDBC_DB_NAME + ";DB_CLOSE_DELAY=-1";
+
+    static final String TABLE_NAME = "TEST_TABLE";
+    static final String COLUMN_ID = "ID";
+    static final String COLUMN_NAME = "C_NAME";
+    static final String COLUMN_VALUE = "C_VALUE";
+
+    static final Object[][] DATA = new Object[][]{
+            { "Player 1", 100 }, { "Player 2", 250 },
+            { "Player 3", 0 }, { "Player 4", 780 }
+    };
+
+    static DataSource dataSource;
+    JdbcTemplate jdbcTemplate;
+
+    @BeforeAll
+    static void beforeAll() {
+        Logger logger = Logger.getLogger(JdbcTemplateTest.class.getName());
+
+        Plugin mockPlugin = mock(Plugin.class);
+        when(mockPlugin.getLogger()).thenReturn(logger);
+
+        GhastTools.setPlugin(mockPlugin);
+
+        JdbcDataSource jdbcDataSource = new JdbcDataSource();
+        jdbcDataSource.setUser(JDBC_USER);
+        jdbcDataSource.setPassword(JDBC_PASSWORD);
+        jdbcDataSource.setURL(JDBC_URL);
+
+        dataSource = jdbcDataSource;
+    }
+
+    @BeforeEach
+    void before() {
+        jdbcTemplate = new JdbcTemplate(dataSource);
+        createTable();
+
+        String sql_head = MessageFormat.format("INSERT INTO {0} ({1}, {2}) VALUES ",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE);
+        StringJoiner sql_sj = new StringJoiner(", ");
+        for (Object[] datum : DATA) {
+            sql_sj.add(MessageFormat.format("( ''{0}'', {1} )", datum[0], datum[1]));
+        }
+
+        jdbcTemplate.execute(sql_head + sql_sj.toString());
+    }
+
+    @AfterEach
+    void after() {
+        dropTable();
+    }
+
+    @Test
+    void testQuery_Simple_Single() {
+        String sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}''",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
+
+        Integer value = jdbcTemplate.query(sql, rs -> {
+            if (rs.next()) {
+                return rs.getInt(1);
+            } else {
+                return null;
+            }
+        });
+
+        assertEquals(DATA[0][1], value);
+    }
+
+    @Test
+    void testQuery_Simple_Optional() {
+        String sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}''",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
+
+        Optional<Integer> optValue = jdbcTemplate.queryOne(sql, rs -> rs.getInt(1));
+
+        assertTrue(optValue.isPresent());
+        assertEquals(DATA[0][1], optValue.get());
+    }
+
+    @Test
+    void testQuery_Simple_List() {
+        String sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}'' OR {1} LIKE ''{4}''",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0], DATA[1][0]);
+
+        List<Integer> listValues = jdbcTemplate.queryList(sql, (rs, rowNum) -> rs.getInt(1));
+
+        assertIterableEquals(Lists.newArrayList(DATA[0][1], DATA[1][1]), listValues);
+    }
+
+    @Test
+    void testQuery_Object_Single() {
+        String sql = MessageFormat.format("SELECT {1}, {2} FROM {0} WHERE {1} LIKE ''{3}''",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
+
+        Player actualPlayer = jdbcTemplate.query(sql, rs -> {
+            if (rs.next()) {
+                Player player0 = new Player();
+                player0.name = rs.getString(COLUMN_NAME);
+                player0.value = rs.getInt(COLUMN_VALUE);
+
+                return player0;
+            } else {
+                return null;
+            }
+        });
+
+        Player expectedPlayer = new Player();
+        expectedPlayer.name = (String) DATA[0][0];
+        expectedPlayer.value = (int) DATA[0][1];
+
+        assertEquals(expectedPlayer, actualPlayer);
+    }
+
+    @Test
+    void testQuery_Object_List() {
+        String sql = MessageFormat.format("SELECT {1}, {2} FROM {0}",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE);
+
+        List<Player> actualPlayers = jdbcTemplate.queryList(sql, (rs, num) -> {
+            Player player0 = new Player();
+            player0.name = rs.getString(COLUMN_NAME);
+            player0.value = rs.getInt(COLUMN_VALUE);
+
+            return player0;
+        });
+
+
+        List<Player> expectedPlayers = Stream.of(DATA)
+                .map(datum -> {
+                    Player player1 = new Player();
+                    player1.name = (String) datum[0];
+                    player1.value = (int) datum[1];
+
+                    return player1;
+                })
+                .collect(Collectors.toList());
+
+
+        assertIterableEquals(expectedPlayers, actualPlayers);
+    }
+
+    @Test
+    void testQueryForMap() {
+        String sql = MessageFormat.format("SELECT {1}, {2} FROM {0} WHERE {1} LIKE ''{3}''",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
+
+        Map<String, Object> actualMap = jdbcTemplate.queryForMap(sql);
+
+        Map<String, Object> expectedMap = ImmutableMap.of(
+                COLUMN_NAME, DATA[0][0],
+                COLUMN_VALUE, DATA[0][1]);
+
+        assertIterableEquals(expectedMap.entrySet(), actualMap.entrySet());
+    }
+
+    @Test
+    void testQueryForMapList() {
+        String sql = MessageFormat.format("SELECT {1}, {2} FROM {0}",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE);
+
+        List<Map<String, Object>> actualMapList = jdbcTemplate.queryForMapList(sql);
+
+        List<Map<String, Object>> expectedMapList = Stream.of(DATA)
+                .map(datum -> ImmutableMap.of(COLUMN_NAME, datum[0], COLUMN_VALUE, datum[1]))
+                .collect(Collectors.toList());
+
+        assertIterableEquals(expectedMapList, actualMapList);
+
+    }
+
+    @Test
+    void testUpdate() {
+        String newName = "Player X";
+        String sql = MessageFormat.format("UPDATE {0} SET {1} = ''{3}'' WHERE {1} LIKE ''{2}''",
+                TABLE_NAME, COLUMN_NAME, DATA[0][0], newName);
+
+        int rows = jdbcTemplate.update(sql);
+
+        assertEquals(1, rows);
+
+        sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}''",
+                TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, newName);
+
+        Integer value = jdbcTemplate.query(sql, rs -> {
+            if (rs.next()) {
+                return rs.getInt(1);
+            } else {
+                return null;
+            }
+        });
+
+        assertEquals(DATA[0][1], value);
+    }
+
+    private void createTable() {
+        jdbcTemplate.execute("CREATE TABLE " + TABLE_NAME + " (" +
+                COLUMN_ID + " bigint auto_increment," +
+                COLUMN_NAME + " varchar(16)," +
+                COLUMN_VALUE + " integer)");
+    }
+
+    private void dropTable() {
+        jdbcTemplate.execute("DROP TABLE IF EXISTS " + TABLE_NAME);
+    }
+
+    class Player {
+        String name;
+        int value;
+
+        @Override
+        public boolean equals(Object o) {
+            if (this == o) return true;
+            if (!(o instanceof Player)) return false;
+            Player player = (Player) o;
+            return new EqualsBuilder().append(value, player.value).append(name, player.name).isEquals();
+        }
+
+        @Override
+        public int hashCode() {
+            return new HashCodeBuilder(17, 37).append(name).append(value).toHashCode();
+        }
+    }
+
+    @Nested
+    class JdbcTemplateTest_ExecuteTestCase {
+
+        @BeforeEach
+        void before() {
+            jdbcTemplate = new JdbcTemplate(dataSource);
+            dropTable();
+        }
+
+        @AfterEach
+        void after() {
+            dropTable();
+        }
+
+        @Test
+        void test() throws ClassNotFoundException, IllegalAccessException, InstantiationException, SQLException {
+            createTable();
+
+            //region Check result
+            Class.forName("org.h2.Driver").newInstance();
+            Connection connection = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD);
+            ResultSet resultSet = connection.getMetaData().getTables(JDBC_DB_NAME.toUpperCase(), "PUBLIC",
+                    TABLE_NAME.toUpperCase(), new String[]{"TABLE"});
+
+            assertTrue(resultSet.next());
+
+            resultSet.close();
+            connection.close();
+            //endregion
+        }
+    }
+}

tools/build.gradle

@@ -1,13 +0,0 @@
-repositories {
-    maven repos.mavenSpigotMC
-    maven repos.mavenDmxMcProject
-}
-
-dependencies {
-    compileOnly project(':phantom-classes')
-    compileOnly libs.bukkit
-    implementation libs.commons_text
-
-    testImplementation libs.bukkit
-    testImplementation libs.test.h2db
-}

tools/gradle.properties

@@ -1,2 +0,0 @@
-moduleName=ghast-tools
-moduleVersion=1.11-SNAPSHOT

tools/src/main/java/ghast/BuildHelper.java

@@ -1,123 +0,0 @@
-package ghast;
-
-import com.mojang.authlib.GameProfile;
-import com.mojang.authlib.properties.Property;
-import lombok.experimental.UtilityClass;
-import net.minecraft.server.v1_12_R1.BlockPosition;
-import net.minecraft.server.v1_12_R1.TileEntitySkull;
-import org.bukkit.Location;
-import org.bukkit.Material;
-import org.bukkit.SkullType;
-import org.bukkit.block.Block;
-import org.bukkit.block.BlockFace;
-import org.bukkit.block.Sign;
-import org.bukkit.block.Skull;
-import org.bukkit.craftbukkit.v1_12_R1.CraftWorld;
-
-import java.nio.charset.StandardCharsets;
-import java.util.Base64;
-import java.util.UUID;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class BuildHelper {
-
-	/**
-	 * Установка черепа.
-	 * <p>
-	 * После установки, необходимо выполнить <code>skull.update(true);</code>
-	 *
-	 * @param location место установки.
-	 * @param face куда будет повёрнут череп.
-	 * @return Блок типа {@link Skull}
-	 */
-	public Skull placeSkull(Location location, BlockFace face) {
-		Location fixedLocation = GhastTools.copyLocation(location);
-		fixedLocation.setZ(fixedLocation.getZ() - 1);
-
-		Block block = location.getWorld().getBlockAt(location);
-		block.setType(Material.SKULL);
-
-		Skull skull = (Skull) block.getState();
-		skull.setRotation(face);
-
-		org.bukkit.material.Skull skullMaterial = (org.bukkit.material.Skull) skull.getData();
-		skullMaterial.setFacingDirection(BlockFace.SELF);
-
-		return skull;
-	}
-
-	/**
-	 * Установка головы игрока.
-	 * <p>
-	 * После установки, необходимо выполнить <code>skull.update(true);</code>
-	 *
-	 * @param location место установки.
-	 * @param face куда будет повёрнута голова.
-	 * @return Блок типа {@link Skull}
-	 */
-	public static Skull placePlayerHead(Location location, BlockFace face) {
-		Location fixedLocation = GhastTools.copyLocation(location);
-		fixedLocation.setZ(fixedLocation.getZ() - 1);
-
-		Block block = fixedLocation.getWorld().getBlockAt(fixedLocation);
-		block.setType(Material.SKULL);
-
-		Skull skull = (Skull) block.getState();
-		skull.setSkullType(SkullType.PLAYER);
-		skull.setRotation(face);
-
-		org.bukkit.material.Skull skullMaterial = (org.bukkit.material.Skull) skull.getData();
-		skullMaterial.setFacingDirection(BlockFace.SELF);
-		return skull;
-	}
-
-	/**
-	 * Установка текстурированной головы игрока.
-	 *
-	 * @param location место установки.
-	 * @param face куда будет повёрнута голова.
-	 * @param skinUrl URL на текстуру
-	 * @return Блок типа {@link Skull}
-	 */
-	public static Skull placePlayerHead(Location location, BlockFace face, String skinUrl) {
-		Skull playerHead = placePlayerHead(location, face);
-		playerHead.update(true);
-		setPlayerHeadSkin(playerHead, skinUrl);
-
-		return playerHead;
-	}
-
-	/**
-	 * Установка текстуры для головы игрока.
-	 *
-	 * @param skull блок головы игрока
-	 * @param skinUrl URL на текстуру
-	 */
-	public static void setPlayerHeadSkin(Skull skull, String skinUrl) {
-		((TileEntitySkull) (((CraftWorld) skull.getWorld())
-				.getHandle()
-				.getTileEntity(new BlockPosition(skull.getX(), skull.getY(), skull.getZ()))))
-				.setGameProfile(generateTexturedPlayerProfile(skinUrl));
-	}
-
-	public Sign placeSignWall(Location location, BlockFace face) {
-		Block block = location.getWorld().getBlockAt(location);
-		block.setType(Material.WALL_SIGN);
-
-		Sign sign = (Sign) block.getState();
-		org.bukkit.material.Sign signMaterial = (org.bukkit.material.Sign) sign.getData();
-		signMaterial.setFacingDirection(face);
-
-		return sign;
-	}
-
-	private GameProfile generateTexturedPlayerProfile(String skinUrl) {
-		GameProfile gameProfile = new GameProfile(UUID.randomUUID(), null);
-
-		gameProfile.getProperties().put("textures",
-				new Property("textures", Base64.getEncoder().encodeToString(
-						("{textures:{SKIN:{url:\"" + skinUrl + "\"}}}").getBytes(StandardCharsets.UTF_8))));
-		return gameProfile;
-	}
-}

tools/src/main/java/ghast/EffectsHelper.java

@@ -1,27 +0,0 @@
-package ghast;
-
-import lombok.experimental.UtilityClass;
-import org.bukkit.Location;
-import org.bukkit.Particle;
-import org.bukkit.Sound;
-import org.bukkit.SoundCategory;
-import org.bukkit.util.Vector;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class EffectsHelper {
-
-	public void playSound(Location location, Sound sound, float pitch) {
-		location.getWorld().playSound(location, sound, SoundCategory.MASTER, 1.0f, pitch);
-	}
-
-	public void particle(Location location, Particle particle, double dx, double dy, double dz, double speed, int amount) {
-		location.getWorld().spawnParticle(particle, location, amount, dx, dy, dz, speed);
-	}
-
-	//TODO нужно проверить
-	public void particle(Location location, Particle particle, Vector vector, double speed, int amount) {
-		particle(location, particle, vector.getX(), vector.getY(), vector.getZ(), speed, amount);
-	}
-}
-

tools/src/main/java/ghast/EventContext.java

@@ -1,71 +0,0 @@
-package ghast;
-
-import lombok.AccessLevel;
-import lombok.NoArgsConstructor;
-import org.bukkit.Bukkit;
-import org.bukkit.event.Cancellable;
-import org.bukkit.event.Event;
-import org.bukkit.event.EventPriority;
-import org.bukkit.event.Listener;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.function.BooleanSupplier;
-import java.util.function.Consumer;
-
-@NoArgsConstructor(access = AccessLevel.PRIVATE)
-@SuppressWarnings("unused")
-public class EventContext implements Listener {
-
-	private static final BooleanSupplier EMPTY_FILTER = () -> true;
-	private static final Consumer<Cancellable> CANCEL_EVENT = event -> event.setCancelled(true);
-
-	private final Map<Class<? extends Event>, Consumer<?>> eventMap = new HashMap<>();
-	private BooleanSupplier filter = EMPTY_FILTER;
-
-	public EventContext filter(BooleanSupplier filter) {
-		this.filter = (filter != null ? filter : EMPTY_FILTER);
-		return this;
-	}
-
-	public <T extends Event> EventContext onEvent(Class<T> eventType, EventPriority eventPriority, Consumer<T> consumer) {
-		if (consumer == null) {
-			eventMap.remove(eventType);
-		} else {
-			eventMap.put(eventType, consumer);
-			bukkitRegisterEvent(eventType, eventPriority);
-		}
-		return this;
-	}
-
-	public <T extends Event> EventContext onEvent(Class<T> eventType, Consumer<T> consumer) {
-		return onEvent(eventType, EventPriority.NORMAL, consumer);
-	}
-
-	public <T extends Event & Cancellable> EventContext cancelEvent(Class<T> eventType, EventPriority eventPriority) {
-		eventMap.put(eventType, CANCEL_EVENT);
-		bukkitRegisterEvent(eventType, eventPriority);
-		return this;
-	}
-
-	public <T extends Event & Cancellable> EventContext cancelEvent(Class<T> eventType) {
-		return cancelEvent(eventType, EventPriority.NORMAL);
-	}
-
-	private void bukkitRegisterEvent(Class<? extends Event> eventType, EventPriority eventPriority) {
-		Bukkit.getPluginManager().registerEvent(eventType, this, eventPriority,
-				this::eventExecute, GhastTools.getPlugin());
-	}
-
-	@SuppressWarnings({ "unchecked", "rawtypes" })
-	private void eventExecute(Listener listener, Event event) {
-		Consumer consumer = eventMap.get(event.getClass());
-		if (consumer != null && filter.getAsBoolean()) {
-			consumer.accept(event);
-		}
-	}
-
-	public static EventContext create() {
-		return new EventContext();
-	}
-}

tools/src/main/java/ghast/GhastTools.java

@@ -1,62 +0,0 @@
-package ghast;
-
-import ghast.assets.AssetsManager;
-import lombok.experimental.UtilityClass;
-import org.bukkit.Location;
-import org.bukkit.configuration.file.YamlConfiguration;
-import org.bukkit.plugin.Plugin;
-
-import java.io.IOException;
-import java.io.Reader;
-import java.lang.ref.WeakReference;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class GhastTools {
-
-	private static WeakReference<Plugin> refPlugin;
-
-	@SuppressWarnings("java:S2696")
-	public void setPlugin(Plugin plugin) {
-		if (plugin == null) {
-			refPlugin = null;
-		} else {
-			refPlugin = new WeakReference<>(plugin);
-		}
-	}
-
-	@SuppressWarnings("java:S112")
-	public Plugin getPlugin() {
-		if (refPlugin == null) {
-			throw new RuntimeException("Plugin not set.");
-		}
-
-		Plugin plugin = refPlugin.get();
-		if (plugin == null) {
-			throw new RuntimeException("Plugin not set.");
-		}
-
-		return plugin;
-	}
-
-	@SuppressWarnings("java:S112")
-	public YamlConfiguration loadConfig(boolean saveDefault) {
-		if (saveDefault) {
-			getPlugin().saveDefaultConfig();
-		}
-
-		try (Reader reader = AssetsManager.getAsReader("config.yml", saveDefault)) {
-			return YamlConfiguration.loadConfiguration(reader);
-		} catch (IOException e) {
-			throw new RuntimeException("Error load config: " + e.getMessage(), e);
-		}
-	}
-
-	public YamlConfiguration loadConfig() {
-		return loadConfig(true);
-	}
-
-	public Location copyLocation(Location location) {
-		return new Location(location.getWorld(), location.getX(), location.getY(), location.getZ());
-	}
-}

tools/src/main/java/ghast/I18n.java

@@ -1,91 +0,0 @@
-package ghast;
-
-import com.google.common.collect.HashBasedTable;
-import com.google.common.collect.Table;
-import lombok.AccessLevel;
-import lombok.NoArgsConstructor;
-import lombok.experimental.UtilityClass;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.commons.text.StringSubstitutor;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.Reader;
-import java.util.HashMap;
-import java.util.Map;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class I18n {
-
-	private final String DEFAULT_LANG = "en";
-	private final Table<String/*Lang*/, String/*Key*/, String/*Template|Message*/> messagesMap = HashBasedTable.create();
-
-	//region Load messages
-	@SuppressWarnings("java:S112")
-	public void loadMessages(String lang, Reader reader) {
-		Map<String, String> map = messagesMap.row(lang.toLowerCase());
-
-		try {
-			BufferedReader bufferedReader = new BufferedReader(reader);
-			String line;
-			while ((line = bufferedReader.readLine()) != null) {
-				String[] split = line.split("=", 2);
-				map.put(split[0].trim().toLowerCase(), split[1].trim());
-			}
-		} catch (IOException e) {
-			throw new RuntimeException("Error load messages: " + e.getMessage(), e);
-		}
-	}
-
-	public void loadMessages(String lang, Map<String, String> messages) {
-		Map<String, String> map = messagesMap.row(lang.toLowerCase());
-		messages.forEach((k, v) -> map.put(k.toLowerCase(), v));
-	}
-
-	public void loadMessages(Reader reader) {
-		loadMessages(DEFAULT_LANG, reader);
-	}
-
-	public void loadMessages(Map<String, String> messages) {
-		loadMessages(DEFAULT_LANG, messages);
-	}
-	//endregion
-
-	//region Get message
-	public String get(String lang, String key) {
-		return messagesMap.row(lang.toLowerCase()).getOrDefault(key.toLowerCase(), StringUtils.EMPTY);
-	}
-
-	public String get(String lang, String key, Map<String, Object> params) {
-		return StringSubstitutor.replace(get(lang, key.toLowerCase()), params, "{", "}");
-	}
-
-	public String get(String key) {
-		return get(DEFAULT_LANG, key);
-	}
-
-	public String get(String key, Map<String, Object> params) {
-		return get(DEFAULT_LANG, key, params);
-	}
-	//endregion
-
-	public ParamBuilder paramBuilder() {
-		return new ParamBuilder();
-	}
-
-	@NoArgsConstructor(access = AccessLevel.PRIVATE)
-	public static class ParamBuilder {
-
-		private final Map<String, Object> params = new HashMap<>();
-
-		public ParamBuilder add(String key, Object value) {
-			params.put(key, value);
-			return this;
-		}
-
-		public Map<String, Object> build() {
-			return params;
-		}
-	}
-}

tools/src/main/java/ghast/XLog.java

@@ -1,77 +0,0 @@
-package ghast;
-
-import lombok.experimental.UtilityClass;
-
-import java.util.logging.Level;
-
-import static java.text.MessageFormat.format;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class XLog {
-
-	//region Debug
-	public void debug(String pattern, Object... objects) {
-		if (objects.length > 1 && objects[objects.length - 1] instanceof Throwable) {
-			Throwable throwable = (Throwable) objects[objects.length - 1];
-			Object[] values = new Object[objects.length - 1];
-			System.arraycopy(objects, 0, values, 0, values.length);
-
-			debug(format(pattern, values), throwable);
-		} else {
-			debug(format(pattern, objects));
-		}
-	}
-
-	public void debug(String message, Throwable throwable) {
-		GhastTools.getPlugin().getLogger().log(Level.FINE, message, throwable);
-	}
-
-	public void debug(String message) {
-		GhastTools.getPlugin().getLogger().fine(message);
-	}
-	//endregion
-
-	//region Info
-	public void info(String pattern, Object... objects) {
-		info(format(pattern, objects));
-	}
-
-	public void info(String message) {
-		GhastTools.getPlugin().getLogger().info(message);
-	}
-	//endregion
-
-	//region Warning
-	public void warn(String pattern, Object... objects) {
-		warn(format(pattern, objects));
-	}
-
-	public void warn(String message) {
-		GhastTools.getPlugin().getLogger().warning(message);
-	}
-	//endregion
-
-	//region Error
-	public void error(String pattern, Object... objects) {
-		if (objects.length > 1 && objects[objects.length - 1] instanceof Throwable) {
-			Throwable throwable = (Throwable) objects[objects.length - 1];
-			Object[] values = new Object[objects.length - 1];
-			System.arraycopy(objects, 0, values, 0, values.length);
-
-			error(format(pattern, values), throwable);
-		} else {
-			error(format(pattern, objects));
-		}
-	}
-
-	public void error(String message) {
-		GhastTools.getPlugin().getLogger().severe(message);
-	}
-
-	public void error(String message, Throwable throwable) {
-		GhastTools.getPlugin().getLogger().log(Level.SEVERE, message, throwable);
-	}
-	//endregion
-
-}

tools/src/main/java/ghast/assets/AssetsException.java

@@ -1,13 +0,0 @@
-package ghast.assets;
-
-public class AssetsException extends RuntimeException {
-
-	public AssetsException(String message) {
-		super(message);
-	}
-
-	public AssetsException(String message, Throwable cause) {
-		super(message, cause);
-	}
-}
-

tools/src/main/java/ghast/assets/AssetsManager.java

@@ -1,163 +0,0 @@
-package ghast.assets;
-
-import ghast.GhastTools;
-import lombok.experimental.UtilityClass;
-import org.bukkit.plugin.Plugin;
-
-import java.io.*;
-import java.net.URL;
-import java.nio.charset.Charset;
-import java.nio.charset.StandardCharsets;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.util.Scanner;
-
-import static java.text.MessageFormat.format;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class AssetsManager {
-
-	private static final String ERROR_NOT_FOUND = "Asset \"{0}\" not found";
-	private static final String ERROR_OPEN = "Error open asset \"{0}\": {1}";
-
-	//region getAsInputStream methods
-	public InputStream getAsInputStream(String resourceName, String defaultResourceName, boolean saveDefault) {
-		Plugin plugin = GhastTools.getPlugin();
-		InputStream inputStream;
-
-		Path pathToResource = plugin.getDataFolder().toPath().resolve(resourceName);
-		if (Files.exists(pathToResource)) {
-			inputStream = openResource(pathToResource);
-		} else if (defaultResourceName != null) {
-			URL resourceUrl = getResourceUrl(defaultResourceName);
-
-			if (saveDefault) {
-				doSaveTo(resourceUrl, pathToResource);
-				inputStream = openResource(pathToResource);
-			} else {
-				inputStream = openResource(resourceUrl);
-			}
-		} else {
-			throw new AssetsException(format(ERROR_NOT_FOUND, resourceName));
-		}
-
-		return inputStream;
-	}
-
-	public InputStream getAsInputStream(String resourceName, String defaultResourceName) {
-		return getAsInputStream(resourceName, defaultResourceName, true);
-	}
-
-	public InputStream getAsInputStream(String resourceName, boolean saveDefault) {
-		return getAsInputStream(resourceName, resourceName, saveDefault);
-	}
-
-	public InputStream getAsInputStream(String resourceName) {
-		return getAsInputStream(resourceName, resourceName, true);
-	}
-	//endregion
-
-	//region getAsReader methods
-	public Reader getAsReader(String resourceName, String defaultResourceName, boolean saveDefault) {
-		return new InputStreamReader(getAsInputStream(resourceName, defaultResourceName, saveDefault));
-	}
-
-	public Reader getAsReader(String resourceName, String defaultResourceName) {
-		return new InputStreamReader(getAsInputStream(resourceName, defaultResourceName, true));
-	}
-
-	public Reader getAsReader(String resourceName, boolean saveDefault) {
-		return new InputStreamReader(getAsInputStream(resourceName, resourceName, saveDefault));
-	}
-
-	public Reader getAsReader(String resourceName) {
-		return new InputStreamReader(getAsInputStream(resourceName, resourceName, true));
-	}
-	//endregion
-
-	//region getAsString methods
-	public String getAsString(String resourceName, String defaultResourceName, Charset charset, boolean saveDefault) {
-		try (InputStream inputStream = getAsInputStream(resourceName, defaultResourceName, saveDefault);
-			 Scanner scanner = new Scanner(inputStream, charset.name()).useDelimiter("\\A")) {
-
-			return scanner.next();
-		} catch (IOException e) {
-			throw new AssetsException(format(ERROR_OPEN, resourceName, e.getMessage()), e);
-		}
-	}
-
-	public String getAsString(String resourceName, String defaultResourceName, Charset charset) {
-		return getAsString(resourceName, defaultResourceName, charset, true);
-	}
-
-	public String getAsString(String resourceName, String defaultResourceName, boolean saveDefault) {
-		return getAsString(resourceName, defaultResourceName, StandardCharsets.UTF_8, saveDefault);
-	}
-
-	public String getAsString(String resourceName, String defaultResourceName) {
-		return getAsString(resourceName, defaultResourceName, StandardCharsets.UTF_8, true);
-	}
-
-	public String getAsString(String resourceName, Charset charset, boolean saveDefault) {
-		return getAsString(resourceName, resourceName, charset, saveDefault);
-	}
-
-	public String getAsString(String resourceName, Charset charset) {
-		return getAsString(resourceName, resourceName, charset, true);
-	}
-
-	public String getAsString(String resourceName, boolean saveDefault) {
-		return getAsString(resourceName, resourceName, StandardCharsets.UTF_8, saveDefault);
-	}
-
-	public String getAsString(String resourceName) {
-		return getAsString(resourceName, resourceName, StandardCharsets.UTF_8, true);
-	}
-	//endregion
-	
-	private URL getResourceUrl(String resourceName) {
-		URL resourceUrl = AssetsManager.class.getClassLoader().getResource(resourceName);
-		if (resourceUrl == null) {
-			throw new AssetsException(format(ERROR_NOT_FOUND, resourceName));
-		}
-
-		return resourceUrl;
-	}
-
-	private void doSaveTo(URL resourceUrl, Path saveToPath) {
-		try {
-			Files.createDirectories(saveToPath.getParent());
-
-			try (InputStream inputStream = resourceUrl.openStream();
-				 OutputStream outputStream = Files.newOutputStream(saveToPath)) {
-
-				byte[] buffer = new byte[8192];
-				int count;
-				while ((count = inputStream.read(buffer)) != -1) {
-					outputStream.write(buffer, 0, count);
-				}
-				outputStream.flush();
-			}
-		} catch (IOException e) {
-			throw new AssetsException(format("Error save asset \"{0}\" to \"{1}\": {2}",
-					resourceUrl, saveToPath, e.getMessage()), e);
-		}
-	}
-
-	private InputStream openResource(Path pathToResource) {
-		try {
-			return Files.newInputStream(pathToResource);
-		} catch (IOException e) {
-			throw new AssetsException(format(ERROR_OPEN, pathToResource, e.getMessage()), e);
-		}
-	}
-
-	private InputStream openResource(URL resourceUrl) {
-		try {
-			return resourceUrl.openStream();
-		} catch (IOException e) {
-			throw new AssetsException(format(ERROR_OPEN, resourceUrl, e.getMessage()), e);
-		}
-	}
-}

tools/src/main/java/ghast/command/CommandManager.java

@@ -1,67 +0,0 @@
-package ghast.command;
-
-import lombok.AccessLevel;
-import lombok.RequiredArgsConstructor;
-import lombok.experimental.UtilityClass;
-import org.bukkit.Bukkit;
-import org.bukkit.craftbukkit.v1_12_R1.CraftServer;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class CommandManager {
-
-	public Builder create(String name) {
-		return new Builder(name);
-	}
-
-	public void register(String name, CommandExecuter executer) {
-		create(name).executer(executer).register();
-	}
-
-	@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
-	public static class Builder {
-
-		private final String name;
-		private CommandExecuter executer;
-		private ErrorConsumer errorConsumer;
-		private Boolean onlyPlayer;
-		private String deniedMessage;
-
-		public Builder executer(CommandExecuter executer) {
-			this.executer = executer;
-			return this;
-		}
-
-		public Builder onError(ErrorConsumer errorConsumer) {
-			this.errorConsumer = errorConsumer;
-			return this;
-		}
-
-		public Builder useOnlyPlayer(String deniedMessage) {
-			this.onlyPlayer = true;
-			this.deniedMessage = deniedMessage;
-			return this;
-		}
-
-		public Builder useOnlyPlayer() {
-			return useOnlyPlayer(null);
-		}
-
-		public Builder useOnlyConsole(String deniedMessage) {
-			this.onlyPlayer = false;
-			this.deniedMessage = deniedMessage;
-			return this;
-		}
-
-		public Builder useOnlyConsole() {
-			return useOnlyConsole(null);
-		}
-
-		public void register() {
-			((CraftServer) Bukkit.getServer()).getCommandMap().register(
-					name,
-					new CommandWrapper(name, this.onlyPlayer, this.deniedMessage, this.executer, this.errorConsumer)
-			);
-		}
-	}
-}

tools/src/main/java/ghast/command/CommandWrapper.java

@@ -1,71 +0,0 @@
-package ghast.command;
-
-import ghast.XLog;
-import org.bukkit.ChatColor;
-import org.bukkit.command.CommandSender;
-import org.bukkit.command.defaults.BukkitCommand;
-import org.bukkit.entity.Player;
-
-class CommandWrapper extends BukkitCommand {
-
-	private static final String DEFAULT_DENIED_MESSAGE_PLAYERS = ChatColor.RED + "This command use only players";
-	private static final String DEFAULT_DENIED_MESSAGE_CONSOLE = ChatColor.RED + "This command use only in console";
-
-	private static final ErrorConsumer DEFAULT_ERROR_CONSUMER =
-			(sender, commandName, args, exception) -> {
-				sender.sendMessage(String.format("%sError execute command '%s'!", ChatColor.RED, commandName));
-				XLog.error("Error execute command ''{0}'' with args ''{1}''",
-						commandName, String.join(" ", args), exception);
-			};
-
-	private final CommandExecuter executer;
-	private final ErrorConsumer errorConsumer;
-	private final Boolean onlyPlayer;
-	private String deniedMessage;
-
-	protected CommandWrapper(String name, Boolean onlyPlayer, String deniedMessage,
-			CommandExecuter executer, ErrorConsumer errorConsumer) {
-		super(name);
-		this.onlyPlayer = onlyPlayer;
-		this.executer = executer;
-
-		if (onlyPlayer != null) {
-			if (deniedMessage == null) {
-				this.deniedMessage = Boolean.TRUE.equals(onlyPlayer) ? DEFAULT_DENIED_MESSAGE_PLAYERS
-						: DEFAULT_DENIED_MESSAGE_CONSOLE;
-			} else {
-				this.deniedMessage = deniedMessage;
-			}
-		}
-
-		if(errorConsumer == null) {
-			this.errorConsumer = DEFAULT_ERROR_CONSUMER;
-		} else {
-			this.errorConsumer = errorConsumer;
-		}
-	}
-
-	@Override
-	@SuppressWarnings("java:S1066")
-	public boolean execute(CommandSender commandSender, String commandName, String[] args) {
-		if (Boolean.TRUE.equals(onlyPlayer)) {
-			if (!(commandSender instanceof Player)) {
-				commandSender.sendMessage(deniedMessage);
-				return true;
-			}
-		} else if (Boolean.FALSE.equals(onlyPlayer)) { // use console only
-			if (commandSender instanceof Player) {
-				commandSender.sendMessage(deniedMessage);
-				return true;
-			}
-		}
-
-		try {
-			executer.execute(commandSender, args);
-			return true;
-		} catch (Exception e) {
-			errorConsumer.accept(commandSender, commandName, args, e);
-			return false;
-		}
-	}
-}

tools/src/main/java/ghast/database/DataAccessException.java

@@ -1,19 +0,0 @@
-package ghast.database;
-
-import lombok.Getter;
-
-@SuppressWarnings("java:S1165")
-@Getter
-public class DataAccessException extends RuntimeException {
-
-	private String sql;
-
-	public DataAccessException(String msg, Throwable cause) {
-		super(msg, cause);
-	}
-
-	public DataAccessException(String msg, String sql, Throwable cause) {
-		this(msg, cause);
-		this.sql = sql;
-	}
-}

tools/src/main/java/ghast/database/JdbcOperations.java

@@ -1,22 +0,0 @@
-package ghast.database;
-
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-
-public interface JdbcOperations {
-
-	void execute(String sql) throws DataAccessException;
-
-	<T> T query(String sql, ResultSetExtractor<T> rse) throws DataAccessException;
-
-	<T> Optional<T> queryOne(String sql, ResultSetExtractor<T> rse) throws DataAccessException;
-
-	<T> List<T> queryList(String sql, RowMapper<T> rowMapper) throws DataAccessException;
-
-	Map<String, Object> queryForMap(String sql) throws DataAccessException;
-
-	List<Map<String, Object>> queryForMapList(String sql) throws DataAccessException;
-
-	int update(String sql) throws DataAccessException;
-}

tools/src/main/java/ghast/database/JdbcTemplate.java

@@ -1,244 +0,0 @@
-package ghast.database;
-
-import ghast.XLog;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import lombok.Setter;
-
-import javax.sql.DataSource;
-import java.sql.Date;
-import java.sql.*;
-import java.util.*;
-
-@NoArgsConstructor
-@Getter
-@Setter
-public class JdbcTemplate implements JdbcOperations {
-
-	private static final String DBG_SQL_INFO = "Execute SQL: {0}";
-	private DataSource dataSource;
-
-	public JdbcTemplate(DataSource dataSource) {
-		setDataSource(dataSource);
-	}
-
-	@Override
-	public void execute(String sql) throws DataAccessException {
-		XLog.debug(DBG_SQL_INFO, sql);
-
-		Connection connection = openConnection();
-		Statement statement = null;
-		try {
-			statement = connection.createStatement();
-			statement.execute(sql);
-		} catch (SQLException e) {
-			throw new DataAccessException("Error execute SQL", sql, e);
-		} finally {
-			closeStatement(statement);
-			closeConnection(connection);
-		}
-	}
-
-	@Override
-	public <T> T query(String sql, ResultSetExtractor<T> rse) throws DataAccessException {
-		XLog.debug(DBG_SQL_INFO, sql);
-
-		Connection connection = openConnection();
-		Statement statement = null;
-		ResultSet resultSet = null;
-		try {
-			statement = connection.createStatement();
-			resultSet = statement.executeQuery(sql);
-			return rse.extractData(resultSet);
-		} catch (SQLException e) {
-			throw new DataAccessException("Error execute SQL", sql, e);
-		} finally {
-			closeResultSet(resultSet);
-			closeStatement(statement);
-			closeConnection(connection);
-		}
-	}
-
-	@Override
-	public <T> Optional<T> queryOne(String sql, ResultSetExtractor<T> rse) throws DataAccessException {
-		return query(sql, rs -> {
-			if (rs.next()) {
-				return Optional.ofNullable(rse.extractData(rs));
-			} else {
-				return Optional.empty();
-			}
-		});
-	}
-
-	@Override
-	public <T> List<T> queryList(String sql, final RowMapper<T> rowMapper) throws DataAccessException {
-		return query(sql, rs -> {
-			List<T> resultList;
-			int rowNum = 0;
-			if (rs.next()) {
-				resultList = new ArrayList<>();
-
-				do {
-					resultList.add(rowMapper.mapRow(rs, rowNum++));
-				} while (rs.next());
-			} else {
-				resultList = Collections.emptyList();
-			}
-
-			return resultList;
-		});
-	}
-
-	@Override
-	public Map<String, Object> queryForMap(String sql) throws DataAccessException {
-		return query(sql, rs -> {
-			if (rs.next()) {
-				ResultSetMetaData metaData = rs.getMetaData();
-				int columnCount = metaData.getColumnCount();
-
-				return rowToMap(columnCount, metaData, rs);
-			} else {
-				return Collections.emptyMap();
-			}
-		});
-	}
-
-	@Override
-	public List<Map<String, Object>> queryForMapList(String sql) throws DataAccessException {
-		return query(sql, rs -> {
-			List<Map<String, Object>> resultList;
-
-			if (rs.next()) {
-				resultList = new ArrayList<>();
-
-				ResultSetMetaData metaData = rs.getMetaData();
-				int columnCount = metaData.getColumnCount();
-
-				do {
-					resultList.add(rowToMap(columnCount, metaData, rs));
-				} while (rs.next());
-			} else {
-				resultList = Collections.emptyList();
-			}
-
-			return resultList;
-		});
-	}
-
-	@Override
-	public int update(String sql) throws DataAccessException {
-		XLog.debug(DBG_SQL_INFO, sql);
-
-		Connection connection = openConnection();
-		Statement statement = null;
-		try {
-			statement = connection.createStatement();
-			int rows = statement.executeUpdate(sql);
-			XLog.debug("Affected {0} rows", rows);
-			return rows;
-		} catch (SQLException e) {
-			XLog.error("Error execute SQL: {0}", e.getMessage(), e);
-			return 0;
-		} finally {
-			closeStatement(statement);
-			closeConnection(connection);
-		}
-	}
-
-	private Connection openConnection() {
-		try {
-			return getDataSource().getConnection();
-		} catch (SQLException ex) {
-			throw new CannotGetJdbcConnectionException("Could not get JDBC Connection", ex);
-		}
-	}
-
-	private String lookupColumnName(ResultSetMetaData resultSetMetaData, int columnIndex) throws SQLException {
-		String name = resultSetMetaData.getColumnLabel(columnIndex);
-		if (name == null || name.isEmpty()) {
-			name = resultSetMetaData.getColumnName(columnIndex);
-		}
-		return name;
-	}
-
-	private Map<String, Object> rowToMap(int columnCount, ResultSetMetaData metaData, ResultSet rs) throws SQLException {
-		Map<String, Object> rowMap = new LinkedHashMap<>(columnCount);
-
-		for (int i = 1; i <= columnCount; i++) {
-			String key = lookupColumnName(metaData, i);
-			Object value = getResultSetRawValue(rs, i);
-			rowMap.put(key, value);
-		}
-
-		return rowMap;
-	}
-
-	private Object getResultSetRawValue(ResultSet resultSet, int index) throws SQLException {
-		Object obj = resultSet.getObject(index);
-		if (obj == null) {
-			return null;
-		}
-
-		String className = obj.getClass().getName();
-
-		if (obj instanceof Blob) {
-			Blob blob = (Blob) obj;
-			obj = blob.getBytes(1, (int) blob.length());
-		} else if (obj instanceof Clob) {
-			Clob clob = (Clob) obj;
-			obj = clob.getSubString(1, (int) clob.length());
-		} else if ("oracle.sql.TIMESTAMP".equals(className) || "oracle.sql.TIMESTAMPTZ".equals(className)) {
-			obj = resultSet.getTimestamp(index);
-		} else if (className.startsWith("oracle.sql.DATE")) {
-			String metaDataClassName = resultSet.getMetaData().getColumnClassName(index);
-			if ("java.sql.Timestamp".equals(metaDataClassName) || "oracle.sql.TIMESTAMP".equals(metaDataClassName)) {
-				obj = resultSet.getTimestamp(index);
-			} else {
-				obj = resultSet.getDate(index);
-			}
-		} else if (obj instanceof Date
-				&& "java.sql.Timestamp".equals(resultSet.getMetaData().getColumnClassName(index))) {
-			obj = resultSet.getTimestamp(index);
-		}
-
-		return obj;
-	}
-
-	private void closeResultSet(ResultSet resultSet) {
-		if (resultSet != null) {
-			try {
-				resultSet.close();
-			} catch (SQLException e) {
-				XLog.debug("Could not close JDBC ResultSet", e);
-			} catch (Exception e) {
-				XLog.debug("Unexpected exception on closing JDBC ResultSet", e);
-			}
-		}
-	}
-
-	private void closeStatement(Statement statement) {
-		if (statement != null) {
-			try {
-				statement.close();
-			} catch (SQLException e) {
-				XLog.debug("Could not close JDBC Statement", e);
-			} catch (Exception e) {
-				XLog.debug("Unexpected exception on closing JDBC Statement", e);
-			}
-		}
-	}
-
-	private void closeConnection(Connection con) {
-		if (con == null) {
-			return;
-		}
-
-		try {
-			con.close();
-		} catch (SQLException e) {
-			XLog.debug("Could not close JDBC Connection", e);
-		} catch (Exception e) {
-			XLog.debug("Unexpected exception on closing JDBC Connection", e);
-		}
-	}
-}

tools/src/main/java/ghast/scheduler/BukkitScheduleTask.java

@@ -1,33 +0,0 @@
-package ghast.scheduler;
-
-import lombok.RequiredArgsConstructor;
-import org.bukkit.scheduler.BukkitTask;
-
-import java.util.function.Supplier;
-
-@RequiredArgsConstructor
-public class BukkitScheduleTask implements ScheduleTask {
-
-	private final Supplier<BukkitTask> generator;
-	private BukkitTask bukkitTask;
-
-	@Override
-	public void start() {
-		if (isCanceled()) {
-			bukkitTask = generator.get();
-		}
-	}
-
-	@Override
-	public boolean isCanceled() {
-		return bukkitTask == null || bukkitTask.isCancelled();
-	}
-
-	@Override
-	public void cancel() {
-		if (bukkitTask != null) {
-			bukkitTask.cancel();
-			bukkitTask = null;
-		}
-	}
-}

tools/src/main/java/ghast/scheduler/JavaScheduleTask.java

@@ -1,33 +0,0 @@
-package ghast.scheduler;
-
-import lombok.RequiredArgsConstructor;
-
-import java.util.concurrent.Future;
-import java.util.function.Supplier;
-
-@RequiredArgsConstructor
-public class JavaScheduleTask implements ScheduleTask {
-
-	private final Supplier<Future<?>> generator;
-	private Future<?> future;
-
-	@Override
-	public void start() {
-		if (future == null || future.isDone()) {
-			future = generator.get();
-		}
-	}
-
-	@Override
-	public boolean isCanceled() {
-		return future == null || future.isCancelled();
-	}
-
-	@Override
-	public void cancel() {
-		if (future != null) {
-			future.cancel(true);
-			future = null;
-		}
-	}
-}

tools/src/main/java/ghast/scheduler/ScheduleManager.java

@@ -1,113 +0,0 @@
-package ghast.scheduler;
-
-import com.google.common.util.concurrent.ThreadFactoryBuilder;
-import ghast.GhastTools;
-import lombok.AccessLevel;
-import lombok.NoArgsConstructor;
-import lombok.experimental.UtilityClass;
-import org.bukkit.Bukkit;
-import org.bukkit.scheduler.BukkitScheduler;
-
-import java.util.concurrent.*;
-
-@UtilityClass
-@SuppressWarnings("unused")
-public class ScheduleManager {
-
-	private static final ThreadFactory THREAD_FACTORY = new ThreadFactoryBuilder()
-			.setNameFormat("ScheduleManager-Thread-%d")
-			.setDaemon(true)
-			.build();
-
-	public Builder createTask() {
-		return new Builder();
-	}
-
-	@NoArgsConstructor(access = AccessLevel.PRIVATE)
-	public static class Builder {
-
-		private static final long MS_PER_ONE_TICK = 1000L/*one second by ms*/ / 20L/*tick per second*/;
-		private boolean useBukkitScheduler = false;
-		private Long afterMs;
-		private Long everyMs;
-
-		public Builder useBukkitScheduler() {
-			this.useBukkitScheduler = true;
-			return this;
-		}
-
-		public Builder after(long value, TimeUnit unit) {
-			this.afterMs = unit.toMillis(value);
-			return this;
-		}
-
-		public Builder every(long value, TimeUnit unit) {
-			this.everyMs = unit.toMillis(value);
-			return this;
-		}
-
-		public ScheduleTask create(Runnable runnable) {
-			if (useBukkitScheduler) {
-				return createBukkitSchedule(runnable);
-			} else {
-				return createSchedule(runnable);
-			}
-		}
-
-		public ScheduleTask execute(Runnable runnable) {
-			ScheduleTask scheduleTask = create(runnable);
-			scheduleTask.start();
-			return scheduleTask;
-		}
-
-		private ScheduleTask createBukkitSchedule(Runnable runnable) {
-			BukkitScheduler bukkitScheduler = Bukkit.getScheduler();
-			BukkitScheduleTask resultTask;
-
-			if (this.afterMs == null && this.everyMs == null) {
-				resultTask = new BukkitScheduleTask(() -> bukkitScheduler.runTask(GhastTools.getPlugin(), runnable));
-			} else if (this.everyMs != null) {
-				long everyTicks = this.everyMs / MS_PER_ONE_TICK;
-				long afterTicks = this.afterMs != null ? this.afterMs / MS_PER_ONE_TICK : 0;
-				resultTask = new BukkitScheduleTask(() ->
-						bukkitScheduler.runTaskTimer(GhastTools.getPlugin(), runnable, afterTicks, everyTicks));
-			} else {
-				long ticks = this.afterMs / MS_PER_ONE_TICK;
-				resultTask = new BukkitScheduleTask(() ->
-						bukkitScheduler.runTaskLater(GhastTools.getPlugin(), runnable, ticks));
-			}
-
-			return resultTask;
-		}
-
-		private ScheduleTask createSchedule(Runnable runnable) {
-			ExecutorService executorService;
-			JavaScheduleTask resultTask;
-
-			if (this.afterMs == null && this.everyMs == null) {
-				executorService = Executors.newSingleThreadExecutor(THREAD_FACTORY);
-				resultTask = new JavaScheduleTask(() -> executorService.submit(runnable));
-			} else if (this.everyMs != null) {
-				ScheduledExecutorService scheduledExecutorService
-						= Executors.newScheduledThreadPool(1, THREAD_FACTORY);
-
-				resultTask = new JavaScheduleTask(() ->
-						scheduledExecutorService.scheduleAtFixedRate(runnable,
-								this.afterMs != null ? this.afterMs : 0,
-								everyMs, TimeUnit.MILLISECONDS));
-
-				executorService = scheduledExecutorService;
-			} else {
-				ScheduledExecutorService scheduledExecutorService
-						= Executors.newScheduledThreadPool(1, THREAD_FACTORY);
-
-				resultTask = new JavaScheduleTask(() ->
-						scheduledExecutorService.schedule(runnable, afterMs, TimeUnit.MILLISECONDS));
-				executorService = scheduledExecutorService;
-			}
-
-			executorService.shutdown();
-			return resultTask;
-		}
-	}
-}

tools/src/test/java/ghast/database/JdbcTemplateTest.java

@@ -1,289 +0,0 @@
-package ghast.database;
-
-import com.google.common.collect.ImmutableMap;
-import com.google.common.collect.Lists;
-import ghast.GhastTools;
-import org.apache.commons.lang3.builder.EqualsBuilder;
-import org.apache.commons.lang3.builder.HashCodeBuilder;
-import org.bukkit.plugin.Plugin;
-import org.h2.jdbcx.JdbcDataSource;
-import org.junit.jupiter.api.*;
-
-import javax.sql.DataSource;
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.text.MessageFormat;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.StringJoiner;
-import java.util.logging.Logger;
-import java.util.stream.Collectors;
-import java.util.stream.Stream;
-
-import static org.junit.jupiter.api.Assertions.*;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-class JdbcTemplateTest {
-
-	static final String JDBC_USER = "sa";
-	static final String JDBC_PASSWORD = "";
-	static final String JDBC_DB_NAME = "in_mem_db";
-	static final String JDBC_URL = "jdbc:h2:mem:" + JDBC_DB_NAME + ";DB_CLOSE_DELAY=-1";
-
-	static final String TABLE_NAME = "TEST_TABLE";
-	static final String COLUMN_ID = "ID";
-	static final String COLUMN_NAME = "C_NAME";
-	static final String COLUMN_VALUE = "C_VALUE";
-
-	static final Object[][] DATA = new Object[][]{
-			{ "Player 1", 100 }, { "Player 2", 250 },
-			{ "Player 3", 0 }, { "Player 4", 780 }
-	};
-
-	static DataSource dataSource;
-	JdbcTemplate jdbcTemplate;
-
-	@BeforeAll
-	static void beforeAll() {
-		Logger logger = Logger.getLogger(JdbcTemplateTest.class.getName());
-
-		Plugin mockPlugin = mock(Plugin.class);
-		when(mockPlugin.getLogger()).thenReturn(logger);
-
-		GhastTools.setPlugin(mockPlugin);
-
-		JdbcDataSource jdbcDataSource = new JdbcDataSource();
-		jdbcDataSource.setUser(JDBC_USER);
-		jdbcDataSource.setPassword(JDBC_PASSWORD);
-		jdbcDataSource.setURL(JDBC_URL);
-
-		dataSource = jdbcDataSource;
-	}
-
-	@BeforeEach
-	void before() {
-		jdbcTemplate = new JdbcTemplate(dataSource);
-		createTable();
-
-		String sql_head = MessageFormat.format("INSERT INTO {0} ({1}, {2}) VALUES ",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE);
-		StringJoiner sql_sj = new StringJoiner(", ");
-		for (Object[] datum : DATA) {
-			sql_sj.add(MessageFormat.format("( ''{0}'', {1} )", datum[0], datum[1]));
-		}
-
-		jdbcTemplate.execute(sql_head + sql_sj.toString());
-	}
-
-	@AfterEach
-	void after() {
-		dropTable();
-	}
-
-	@Test
-	void testQuery_Simple_Single() {
-		String sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}''",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
-
-		Integer value = jdbcTemplate.query(sql, rs -> {
-			if (rs.next()) {
-				return rs.getInt(1);
-			} else {
-				return null;
-			}
-		});
-
-		assertEquals(DATA[0][1], value);
-	}
-
-	@Test
-	void testQuery_Simple_Optional() {
-		String sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}''",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
-
-		Optional<Integer> optValue = jdbcTemplate.queryOne(sql, rs -> rs.getInt(1));
-
-		assertTrue(optValue.isPresent());
-		assertEquals(DATA[0][1], optValue.get());
-	}
-
-	@Test
-	void testQuery_Simple_List() {
-		String sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}'' OR {1} LIKE ''{4}''",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0], DATA[1][0]);
-
-		List<Integer> listValues = jdbcTemplate.queryList(sql, (rs, rowNum) -> rs.getInt(1));
-
-		assertIterableEquals(Lists.newArrayList(DATA[0][1], DATA[1][1]), listValues);
-	}
-
-	@Test
-	void testQuery_Object_Single() {
-		String sql = MessageFormat.format("SELECT {1}, {2} FROM {0} WHERE {1} LIKE ''{3}''",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
-
-		Player actualPlayer = jdbcTemplate.query(sql, rs -> {
-			if (rs.next()) {
-				Player player0 = new Player();
-				player0.name = rs.getString(COLUMN_NAME);
-				player0.value = rs.getInt(COLUMN_VALUE);
-
-				return player0;
-			} else {
-				return null;
-			}
-		});
-
-		Player expectedPlayer = new Player();
-		expectedPlayer.name = (String) DATA[0][0];
-		expectedPlayer.value = (int) DATA[0][1];
-
-		assertEquals(expectedPlayer, actualPlayer);
-	}
-
-	@Test
-	void testQuery_Object_List() {
-		String sql = MessageFormat.format("SELECT {1}, {2} FROM {0}",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE);
-
-		List<Player> actualPlayers = jdbcTemplate.queryList(sql, (rs, num) -> {
-			Player player0 = new Player();
-			player0.name = rs.getString(COLUMN_NAME);
-			player0.value = rs.getInt(COLUMN_VALUE);
-
-			return player0;
-		});
-
-
-		List<Player> expectedPlayers = Stream.of(DATA)
-				.map(datum -> {
-					Player player1 = new Player();
-					player1.name = (String) datum[0];
-					player1.value = (int) datum[1];
-
-					return player1;
-				})
-				.collect(Collectors.toList());
-
-
-		assertIterableEquals(expectedPlayers, actualPlayers);
-	}
-
-	@Test
-	void testQueryForMap() {
-		String sql = MessageFormat.format("SELECT {1}, {2} FROM {0} WHERE {1} LIKE ''{3}''",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, DATA[0][0]);
-
-		Map<String, Object> actualMap = jdbcTemplate.queryForMap(sql);
-
-		Map<String, Object> expectedMap = ImmutableMap.of(
-				COLUMN_NAME, DATA[0][0],
-				COLUMN_VALUE, DATA[0][1]);
-
-		assertIterableEquals(expectedMap.entrySet(), actualMap.entrySet());
-	}
-
-	@Test
-	void testQueryForMapList() {
-		String sql = MessageFormat.format("SELECT {1}, {2} FROM {0}",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE);
-
-		List<Map<String, Object>> actualMapList = jdbcTemplate.queryForMapList(sql);
-
-		List<Map<String, Object>> expectedMapList = Stream.of(DATA)
-				.map(datum -> ImmutableMap.of(COLUMN_NAME, datum[0], COLUMN_VALUE, datum[1]))
-				.collect(Collectors.toList());
-
-		assertIterableEquals(expectedMapList, actualMapList);
-
-	}
-
-	@Test
-	void testUpdate() {
-		String newName = "Player X";
-		String sql = MessageFormat.format("UPDATE {0} SET {1} = ''{3}'' WHERE {1} LIKE ''{2}''",
-				TABLE_NAME, COLUMN_NAME, DATA[0][0], newName);
-
-		int rows = jdbcTemplate.update(sql);
-
-		assertEquals(1, rows);
-
-		sql = MessageFormat.format("SELECT {2} FROM {0} WHERE {1} LIKE ''{3}''",
-				TABLE_NAME, COLUMN_NAME, COLUMN_VALUE, newName);
-
-		Integer value = jdbcTemplate.query(sql, rs -> {
-			if (rs.next()) {
-				return rs.getInt(1);
-			} else {
-				return null;
-			}
-		});
-
-		assertEquals(DATA[0][1], value);
-	}
-
-	private void createTable() {
-		jdbcTemplate.execute("CREATE TABLE " + TABLE_NAME + " (" +
-				COLUMN_ID + " bigint auto_increment," +
-				COLUMN_NAME + " varchar(16)," +
-				COLUMN_VALUE + " integer)");
-	}
-
-	private void dropTable() {
-		jdbcTemplate.execute("DROP TABLE IF EXISTS " + TABLE_NAME);
-	}
-
-	class Player {
-		String name;
-		int value;
-
-		@Override
-		public boolean equals(Object o) {
-			if (this == o) return true;
-			if (!(o instanceof Player)) return false;
-			Player player = (Player) o;
-			return new EqualsBuilder().append(value, player.value).append(name, player.name).isEquals();
-		}
-
-		@Override
-		public int hashCode() {
-			return new HashCodeBuilder(17, 37).append(name).append(value).toHashCode();
-		}
-	}
-
-	@Nested
-	class JdbcTemplateTest_ExecuteTestCase {
-
-		@BeforeEach
-		void before() {
-			jdbcTemplate = new JdbcTemplate(dataSource);
-			dropTable();
-		}
-
-		@AfterEach
-		void after() {
-			dropTable();
-		}
-
-		@Test
-		void test() throws ClassNotFoundException, IllegalAccessException, InstantiationException, SQLException {
-			createTable();
-
-			//region Check result
-			Class.forName("org.h2.Driver").newInstance();
-			Connection connection = DriverManager.getConnection(JDBC_URL, JDBC_USER, JDBC_PASSWORD);
-			ResultSet resultSet = connection.getMetaData().getTables(JDBC_DB_NAME.toUpperCase(), "PUBLIC",
-					TABLE_NAME.toUpperCase(), new String[]{"TABLE"});
-
-			assertTrue(resultSet.next());
-
-			resultSet.close();
-			connection.close();
-			//endregion
-		}
-	}
-}