Implement tasks 1-6: project setup, config, database, webhook, commands

This commit is contained in:
Loki 2025-12-19 12:18:59 +01:00
parent 0a7b382cdb
commit 5af08efdad
22 changed files with 2018 additions and 19 deletions

BIN
.jqwik-database Normal file

Binary file not shown.

View file

@ -1,6 +1,7 @@
# Implementation Plan
- [-] 1. Настройка проекта и Git
- [x] 1. Настройка проекта и Git
- [x] 1.1 Создать структуру Gradle проекта
@ -10,40 +11,59 @@
- Настроить Java 21 и shadowJar для сборки
- _Requirements: 7.1_
- [ ] 1.2 Настроить Git и .gitignore
- [x] 1.2 Настроить Git и .gitignore
- Создать .gitignore для Java/Gradle проекта
- Инициализировать git репозиторий
- Добавить remote https://git.lokili.xyz/loki/lorep.git
- Сделать initial commit и push
- _Requirements: N/A_
- [ ] 1.3 Создать plugin.yml и основной класс
- [x] 1.3 Создать plugin.yml и основной класс
- Создать plugin.yml с командами и правами
- Создать LorepPlugin.java с onEnable/onDisable
- _Requirements: 6.1, 6.2, 6.3_
- [ ] 2. Реализация конфигурации
- [ ] 2.1 Создать ConfigManager и config.yml
- [x] 2. Реализация конфигурации
- [x] 2.1 Создать ConfigManager и config.yml
- Создать default config.yml с настройками БД и webhook
- Реализовать ConfigManager для чтения конфигурации
- _Requirements: 7.1, 7.2, 7.3, 7.4_
- [ ] 2.2 Написать property test для парсинга конфигурации
- [x] 2.2 Написать property test для парсинга конфигурации
- **Property 9: Configuration Parsing**
- **Validates: Requirements 7.1, 7.3, 7.4**
- [ ] 3. Реализация базы данных
- [ ] 3.1 Создать модель Report и интерфейс DatabaseManager
- [x] 3. Реализация базы данных
- [x] 3.1 Создать модель Report и интерфейс DatabaseManager
- Создать Report record
- Создать интерфейс DatabaseManager
- _Requirements: 2.1_
- [ ] 3.2 Реализовать SQLiteDatabaseManager
- [x] 3.2 Реализовать SQLiteDatabaseManager
- Реализовать все методы интерфейса для SQLite
- Создать таблицу и индексы
- _Requirements: 2.1, 2.2, 2.3_
- [ ] 3.3 Реализовать PostgreSQLDatabaseManager
- [x] 3.3 Реализовать PostgreSQLDatabaseManager
- Реализовать все методы с HikariCP connection pool
- Создать таблицу и индексы для PostgreSQL
- _Requirements: 2.1, 2.2, 2.3_
- [ ] 3.4 Написать property tests для DatabaseManager
- [x] 3.4 Написать property tests для DatabaseManager
- **Property 1: Report Creation Integrity**
- **Property 2: Duplicate Report Prevention**
- **Property 3: Report Persistence Round-Trip**
@ -51,31 +71,47 @@
- **Property 7: Report Count Accuracy**
- **Validates: Requirements 1.1, 1.2, 2.1, 2.2, 2.3, 5.1**
- [ ] 4. Checkpoint - Проверка тестов БД
- [x] 4. Checkpoint - Проверка тестов БД
- Ensure all tests pass, ask the user if questions arise.
- [ ] 5. Реализация Discord Webhook
- [ ] 5.1 Создать DiscordWebhook сервис
- [x] 5. Реализация Discord Webhook
- [x] 5.1 Создать DiscordWebhook сервис
- Реализовать отправку embed сообщений через OkHttp
- Обработать ошибки и отсутствие URL
- _Requirements: 3.1, 3.2, 3.3_
- [ ] 5.2 Написать property test для webhook payload
- [x] 5.2 Написать property test для webhook payload
- **Property 5: Webhook Payload Completeness**
- **Validates: Requirements 3.1**
- [ ] 6. Реализация команд
- [ ] 6.1 Создать ReportCommand (/report [ник] [причина])
- [x] 6. Реализация команд
- [x] 6.1 Создать ReportCommand (/report [ник] [причина])
- Валидация аргументов и прав
- Проверка на самого себя и существование игрока
- Проверка на дубликат репорта
- Сохранение в БД и отправка в webhook
- _Requirements: 1.1, 1.2, 1.3, 1.4, 1.5, 6.1_
- [ ] 6.2 Создать ReportStatsCommand (/report stats [ник])
- [x] 6.2 Создать ReportStatsCommand (/report stats [ник])
- Показ количества репортов
- Показ последнего онлайна
- Список последних репортов
- _Requirements: 5.1, 5.2, 5.3, 5.4, 6.3_
- [ ] 6.3 Написать property test для проверки прав
- [x] 6.3 Написать property test для проверки прав
- **Property 8: Permission Enforcement**
- **Validates: Requirements 6.1, 6.2, 6.3**

View file

@ -26,6 +26,8 @@ dependencies {
testImplementation("org.junit.jupiter:junit-jupiter:5.10.2")
testImplementation("net.jqwik:jqwik:1.8.4")
testImplementation("org.yaml:snakeyaml:2.2")
testImplementation("org.xerial:sqlite-jdbc:3.45.1.0")
testRuntimeOnly("org.junit.platform:junit-platform-launcher")
}

View file

@ -0,0 +1,7 @@
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-9.1.0-bin.zip
networkTimeout=10000
validateDistributionUrl=true
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists

248
gradlew vendored Normal file
View file

@ -0,0 +1,248 @@
#!/bin/sh
#
# Copyright © 2015 the original authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# SPDX-License-Identifier: Apache-2.0
#
##############################################################################
#
# Gradle start up script for POSIX generated by Gradle.
#
# Important for running:
#
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
# noncompliant, but you have some other compliant shell such as ksh or
# bash, then to run this script, type that shell name before the whole
# command line, like:
#
# ksh Gradle
#
# Busybox and similar reduced shells will NOT work, because this script
# requires all of these POSIX shell features:
# * functions;
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
# «${var#prefix}», «${var%suffix}», and «$( cmd )»;
# * compound commands having a testable exit status, especially «case»;
# * various built-in commands including «command», «set», and «ulimit».
#
# Important for patching:
#
# (2) This script targets any POSIX shell, so it avoids extensions provided
# by Bash, Ksh, etc; in particular arrays are avoided.
#
# The "traditional" practice of packing multiple parameters into a
# space-separated string is a well documented source of bugs and security
# problems, so this is (mostly) avoided, by progressively accumulating
# options in "$@", and eventually passing that to Java.
#
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
# see the in-line comments for details.
#
# There are tweaks for specific operating systems such as AIX, CygWin,
# Darwin, MinGW, and NonStop.
#
# (3) This script is generated from the Groovy template
# https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
# within the Gradle project.
#
# You can find Gradle at https://github.com/gradle/gradle/.
#
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
app_path=$0
# Need this for daisy-chained symlinks.
while
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
[ -h "$app_path" ]
do
ls=$( ls -ld "$app_path" )
link=${ls#*' -> '}
case $link in #(
/*) app_path=$link ;; #(
*) app_path=$APP_HOME$link ;;
esac
done
# This is normally unused
# shellcheck disable=SC2034
APP_BASE_NAME=${0##*/}
# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s\n' "$PWD" ) || exit
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD=maximum
warn () {
echo "$*"
} >&2
die () {
echo
echo "$*"
echo
exit 1
} >&2
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "$( uname )" in #(
CYGWIN* ) cygwin=true ;; #(
Darwin* ) darwin=true ;; #(
MSYS* | MINGW* ) msys=true ;; #(
NONSTOP* ) nonstop=true ;;
esac
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD=$JAVA_HOME/jre/sh/java
else
JAVACMD=$JAVA_HOME/bin/java
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD=java
if ! command -v java >/dev/null 2>&1
then
die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
fi
# Increase the maximum file descriptors if we can.
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
case $MAX_FD in #(
max*)
# In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
# shellcheck disable=SC2039,SC3045
MAX_FD=$( ulimit -H -n ) ||
warn "Could not query maximum file descriptor limit"
esac
case $MAX_FD in #(
'' | soft) :;; #(
*)
# In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
# shellcheck disable=SC2039,SC3045
ulimit -n "$MAX_FD" ||
warn "Could not set maximum file descriptor limit to $MAX_FD"
esac
fi
# Collect all arguments for the java command, stacking in reverse order:
# * args from the command line
# * the main class name
# * -classpath
# * -D...appname settings
# * --module-path (only if needed)
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
# For Cygwin or MSYS, switch paths to Windows format before running java
if "$cygwin" || "$msys" ; then
APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
JAVACMD=$( cygpath --unix "$JAVACMD" )
# Now convert the arguments - kludge to limit ourselves to /bin/sh
for arg do
if
case $arg in #(
-*) false ;; # don't mess with options #(
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
[ -e "$t" ] ;; #(
*) false ;;
esac
then
arg=$( cygpath --path --ignore --mixed "$arg" )
fi
# Roll the args list around exactly as many times as the number of
# args, so each arg winds up back in the position where it started, but
# possibly modified.
#
# NB: a `for` loop captures its iteration list before it begins, so
# changing the positional parameters here affects neither the number of
# iterations, nor the values presented in `arg`.
shift # remove old arg
set -- "$@" "$arg" # push replacement arg
done
fi
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
# Collect all arguments for the java command:
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
# and any embedded shellness will be escaped.
# * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
# treated as '${Hostname}' itself on the command line.
set -- \
"-Dorg.gradle.appname=$APP_BASE_NAME" \
-jar "$APP_HOME/gradle/wrapper/gradle-wrapper.jar" \
"$@"
# Stop when "xargs" is not available.
if ! command -v xargs >/dev/null 2>&1
then
die "xargs is not available"
fi
# Use "xargs" to parse quoted args.
#
# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
#
# In Bash we could simply go:
#
# readarray ARGS < <( xargs -n1 <<<"$var" ) &&
# set -- "${ARGS[@]}" "$@"
#
# but POSIX shell has neither arrays nor command substitution, so instead we
# post-process each arg (as a line of input to sed) to backslash-escape any
# character that might be a shell metacharacter, then use eval to reverse
# that process (while maintaining the separation between arguments), and wrap
# the whole thing up as a single "set" statement.
#
# This will of course break if any of these variables contains a newline or
# an unmatched quote.
#
eval "set -- $(
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
xargs -n1 |
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
tr '\n' ' '
)" '"$@"'
exec "$JAVACMD" "$@"

93
gradlew.bat vendored Normal file
View file

@ -0,0 +1,93 @@
@rem
@rem Copyright 2015 the original author or authors.
@rem
@rem Licensed under the Apache License, Version 2.0 (the "License");
@rem you may not use this file except in compliance with the License.
@rem You may obtain a copy of the License at
@rem
@rem https://www.apache.org/licenses/LICENSE-2.0
@rem
@rem Unless required by applicable law or agreed to in writing, software
@rem distributed under the License is distributed on an "AS IS" BASIS,
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@rem See the License for the specific language governing permissions and
@rem limitations under the License.
@rem
@rem SPDX-License-Identifier: Apache-2.0
@rem
@if "%DEBUG%"=="" @echo off
@rem ##########################################################################
@rem
@rem Gradle startup script for Windows
@rem
@rem ##########################################################################
@rem Set local scope for the variables with windows NT shell
if "%OS%"=="Windows_NT" setlocal
set DIRNAME=%~dp0
if "%DIRNAME%"=="" set DIRNAME=.
@rem This is normally unused
set APP_BASE_NAME=%~n0
set APP_HOME=%DIRNAME%
@rem Resolve any "." and ".." in APP_HOME to make it shorter.
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
@rem Find java.exe
if defined JAVA_HOME goto findJavaFromJavaHome
set JAVA_EXE=java.exe
%JAVA_EXE% -version >NUL 2>&1
if %ERRORLEVEL% equ 0 goto execute
echo. 1>&2
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
echo. 1>&2
echo Please set the JAVA_HOME variable in your environment to match the 1>&2
echo location of your Java installation. 1>&2
goto fail
:findJavaFromJavaHome
set JAVA_HOME=%JAVA_HOME:"=%
set JAVA_EXE=%JAVA_HOME%/bin/java.exe
if exist "%JAVA_EXE%" goto execute
echo. 1>&2
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
echo. 1>&2
echo Please set the JAVA_HOME variable in your environment to match the 1>&2
echo location of your Java installation. 1>&2
goto fail
:execute
@rem Setup the command line
@rem Execute Gradle
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -jar "%APP_HOME%\gradle\wrapper\gradle-wrapper.jar" %*
:end
@rem End local scope for the variables with windows NT shell
if %ERRORLEVEL% equ 0 goto mainEnd
:fail
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
rem the _cmd.exe /c_ return code!
set EXIT_CODE=%ERRORLEVEL%
if %EXIT_CODE% equ 0 set EXIT_CODE=1
if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
exit /b %EXIT_CODE%
:mainEnd
if "%OS%"=="Windows_NT" endlocal
:omega

View file

@ -0,0 +1,60 @@
package dev.loki.lorep;
import dev.loki.lorep.config.ConfigManager;
import dev.loki.lorep.database.DatabaseManager;
import dev.loki.lorep.webhook.DiscordWebhook;
import org.bukkit.plugin.java.JavaPlugin;
public final class LorepPlugin extends JavaPlugin {
private static LorepPlugin instance;
private ConfigManager configManager;
private DatabaseManager databaseManager;
private DiscordWebhook discordWebhook;
@Override
public void onEnable() {
instance = this;
getLogger().info("lorep plugin enabling...");
// Initialize managers (will be implemented later)
getLogger().info("lorep plugin enabled!");
}
@Override
public void onDisable() {
if (databaseManager != null) {
databaseManager.close();
}
getLogger().info("lorep plugin disabled!");
}
public static LorepPlugin getInstance() {
return instance;
}
public ConfigManager getConfigManager() {
return configManager;
}
public DatabaseManager getDatabaseManager() {
return databaseManager;
}
public DiscordWebhook getDiscordWebhook() {
return discordWebhook;
}
public void setConfigManager(ConfigManager configManager) {
this.configManager = configManager;
}
public void setDatabaseManager(DatabaseManager databaseManager) {
this.databaseManager = databaseManager;
}
public void setDiscordWebhook(DiscordWebhook discordWebhook) {
this.discordWebhook = discordWebhook;
}
}

View file

@ -0,0 +1,155 @@
package dev.loki.lorep.command;
import dev.loki.lorep.LorepPlugin;
import dev.loki.lorep.database.Report;
import org.bukkit.Bukkit;
import org.bukkit.OfflinePlayer;
import org.bukkit.command.Command;
import org.bukkit.command.CommandExecutor;
import org.bukkit.command.CommandSender;
import org.bukkit.command.TabCompleter;
import org.bukkit.entity.Player;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class ReportCommand implements CommandExecutor, TabCompleter {
private final LorepPlugin plugin;
public ReportCommand(LorepPlugin plugin) {
this.plugin = plugin;
}
@Override
public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {
if (!(sender instanceof Player player)) {
sender.sendMessage("§cЭта команда только для игроков!");
return true;
}
if (args.length == 0) {
player.sendMessage(plugin.getConfigManager().getMessage("usage"));
return true;
}
// Handle subcommands for admins
if (args[0].equalsIgnoreCase("gui")) {
return handleGui(player);
}
if (args[0].equalsIgnoreCase("stats") && args.length >= 2) {
return handleStats(player, args[1]);
}
// Regular report command
if (!player.hasPermission("lorep.report")) {
player.sendMessage(plugin.getConfigManager().getMessage("no-permission"));
return true;
}
if (args.length < 2) {
player.sendMessage(plugin.getConfigManager().getMessage("usage"));
return true;
}
String targetName = args[0];
String reason = String.join(" ", Arrays.copyOfRange(args, 1, args.length));
return handleReport(player, targetName, reason);
}
private boolean handleReport(Player reporter, String targetName, String reason) {
// Check if target exists
@SuppressWarnings("deprecation")
OfflinePlayer target = Bukkit.getOfflinePlayer(targetName);
if (!target.hasPlayedBefore() && !target.isOnline()) {
reporter.sendMessage(plugin.getConfigManager().getMessage("player-not-found"));
return true;
}
// Check self-report
if (target.getUniqueId().equals(reporter.getUniqueId())) {
reporter.sendMessage(plugin.getConfigManager().getMessage("self-report"));
return true;
}
// Check duplicate report
if (plugin.getDatabaseManager().hasReported(reporter.getUniqueId(), target.getUniqueId())) {
reporter.sendMessage(plugin.getConfigManager().getMessage("already-reported"));
return true;
}
// Create and save report
Report report = new Report(
reporter.getUniqueId(),
reporter.getName(),
target.getUniqueId(),
target.getName() != null ? target.getName() : targetName,
reason
);
plugin.getDatabaseManager().saveReport(report);
// Send to Discord webhook
if (plugin.getDiscordWebhook() != null) {
plugin.getDiscordWebhook().sendReport(report);
}
reporter.sendMessage(plugin.getConfigManager().getMessage("report-sent"));
return true;
}
private boolean handleGui(Player player) {
if (!player.hasPermission("lorep.admin")) {
player.sendMessage(plugin.getConfigManager().getMessage("no-permission"));
return true;
}
// GUI will be implemented in task 7
player.sendMessage("§eGUI будет реализован позже");
return true;
}
private boolean handleStats(Player player, String targetName) {
new ReportStatsCommand(plugin).execute(player, targetName);
return true;
}
@Override
public List<String> onTabComplete(CommandSender sender, Command command, String alias, String[] args) {
List<String> completions = new ArrayList<>();
if (args.length == 1) {
// First argument: player names or subcommands
String input = args[0].toLowerCase();
if (sender.hasPermission("lorep.admin")) {
if ("gui".startsWith(input)) completions.add("gui");
if ("stats".startsWith(input)) completions.add("stats");
}
// Add online player names
completions.addAll(
Bukkit.getOnlinePlayers().stream()
.map(Player::getName)
.filter(name -> name.toLowerCase().startsWith(input))
.collect(Collectors.toList())
);
} else if (args.length == 2 && args[0].equalsIgnoreCase("stats")) {
// Second argument for stats: player names
String input = args[1].toLowerCase();
completions.addAll(
Bukkit.getOnlinePlayers().stream()
.map(Player::getName)
.filter(name -> name.toLowerCase().startsWith(input))
.collect(Collectors.toList())
);
}
return completions;
}
}

View file

@ -0,0 +1,71 @@
package dev.loki.lorep.command;
import dev.loki.lorep.LorepPlugin;
import dev.loki.lorep.database.Report;
import dev.loki.lorep.util.TimeUtil;
import org.bukkit.Bukkit;
import org.bukkit.OfflinePlayer;
import org.bukkit.entity.Player;
import java.util.List;
public class ReportStatsCommand {
private final LorepPlugin plugin;
public ReportStatsCommand(LorepPlugin plugin) {
this.plugin = plugin;
}
public void execute(Player player, String targetName) {
if (!player.hasPermission("lorep.admin")) {
player.sendMessage(plugin.getConfigManager().getMessage("no-permission"));
return;
}
@SuppressWarnings("deprecation")
OfflinePlayer target = Bukkit.getOfflinePlayer(targetName);
if (!target.hasPlayedBefore() && !target.isOnline()) {
player.sendMessage(plugin.getConfigManager().getMessage("player-not-found"));
return;
}
List<Report> reports = plugin.getDatabaseManager().getReportsForTarget(target.getUniqueId());
int reportCount = reports.size();
if (reportCount == 0) {
player.sendMessage(plugin.getConfigManager().getMessage("no-reports"));
return;
}
// Header
player.sendMessage(plugin.getConfigManager().getMessage("stats-header",
"%player%", target.getName() != null ? target.getName() : targetName));
// Report count
player.sendMessage(plugin.getConfigManager().getMessage("stats-count",
"%count%", String.valueOf(reportCount)));
// Last online
String lastOnline = target.isOnline() ? "Сейчас онлайн" :
TimeUtil.formatTimeAgo(target.getLastPlayed());
player.sendMessage(plugin.getConfigManager().getMessage("stats-last-online",
"%time%", lastOnline));
// Recent reports (max 5)
player.sendMessage("§7Последние репорты:");
int shown = Math.min(5, reports.size());
for (int i = 0; i < shown; i++) {
Report report = reports.get(i);
String timeAgo = TimeUtil.formatTimeAgo(report.createdAt().toEpochMilli());
player.sendMessage(plugin.getConfigManager().getMessage("stats-report-entry",
"%reason%", report.reason(),
"%time%", timeAgo));
}
if (reports.size() > 5) {
player.sendMessage("§7... и ещё " + (reports.size() - 5) + " репортов");
}
}
}

View file

@ -0,0 +1,71 @@
package dev.loki.lorep.config;
import dev.loki.lorep.LorepPlugin;
import org.bukkit.ChatColor;
import org.bukkit.configuration.file.FileConfiguration;
public class ConfigManager {
private final LorepPlugin plugin;
private FileConfiguration config;
public ConfigManager(LorepPlugin plugin) {
this.plugin = plugin;
reload();
}
public void reload() {
plugin.saveDefaultConfig();
plugin.reloadConfig();
this.config = plugin.getConfig();
}
public String getWebhookUrl() {
return config.getString("webhook-url", "");
}
public String getDatabaseType() {
return config.getString("database.type", "sqlite");
}
public String getSqliteFile() {
return config.getString("database.sqlite.file", "reports.db");
}
public String getPostgresHost() {
return config.getString("database.postgresql.host", "localhost");
}
public int getPostgresPort() {
return config.getInt("database.postgresql.port", 5432);
}
public String getPostgresDatabase() {
return config.getString("database.postgresql.database", "lorep");
}
public String getPostgresUsername() {
return config.getString("database.postgresql.username", "lorep");
}
public String getPostgresPassword() {
return config.getString("database.postgresql.password", "password");
}
public int getPostgresPoolSize() {
return config.getInt("database.postgresql.pool-size", 10);
}
public String getMessage(String key) {
String message = config.getString("messages." + key, "&cMessage not found: " + key);
return ChatColor.translateAlternateColorCodes('&', message);
}
public String getMessage(String key, String... replacements) {
String message = getMessage(key);
for (int i = 0; i < replacements.length - 1; i += 2) {
message = message.replace(replacements[i], replacements[i + 1]);
}
return message;
}
}

View file

@ -0,0 +1,25 @@
package dev.loki.lorep.database;
import java.util.List;
import java.util.UUID;
public interface DatabaseManager {
void initialize();
void close();
void saveReport(Report report);
List<Report> getReportsForTarget(UUID targetUuid);
List<Report> getAllReports();
int getReportCount(UUID targetUuid);
boolean hasReported(UUID reporterUuid, UUID targetUuid);
List<Report> getReportsPaginated(int page, int pageSize);
int getTotalReportCount();
}

View file

@ -0,0 +1,229 @@
package dev.loki.lorep.database;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import java.sql.*;
import java.time.Instant;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import java.util.logging.Level;
import java.util.logging.Logger;
public class PostgreSQLDatabaseManager implements DatabaseManager {
private final String host;
private final int port;
private final String database;
private final String username;
private final String password;
private final int poolSize;
private final Logger logger;
private HikariDataSource dataSource;
public PostgreSQLDatabaseManager(String host, int port, String database,
String username, String password, int poolSize, Logger logger) {
this.host = host;
this.port = port;
this.database = database;
this.username = username;
this.password = password;
this.poolSize = poolSize;
this.logger = logger;
}
@Override
public void initialize() {
try {
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:postgresql://" + host + ":" + port + "/" + database);
config.setUsername(username);
config.setPassword(password);
config.setMaximumPoolSize(poolSize);
config.setMinimumIdle(2);
config.setIdleTimeout(30000);
config.setConnectionTimeout(10000);
config.setPoolName("lorep-pool");
dataSource = new HikariDataSource(config);
createTables();
logger.info("PostgreSQL database initialized: " + host + ":" + port + "/" + database);
} catch (Exception e) {
logger.log(Level.SEVERE, "Failed to initialize PostgreSQL database", e);
}
}
private void createTables() throws SQLException {
String createTable = """
CREATE TABLE IF NOT EXISTS reports (
id SERIAL PRIMARY KEY,
reporter_uuid TEXT NOT NULL,
reporter_name TEXT NOT NULL,
target_uuid TEXT NOT NULL,
target_name TEXT NOT NULL,
reason TEXT NOT NULL,
created_at BIGINT NOT NULL
)
""";
String createTargetIndex = "CREATE INDEX IF NOT EXISTS idx_target_uuid ON reports(target_uuid)";
String createReporterTargetIndex = "CREATE INDEX IF NOT EXISTS idx_reporter_target ON reports(reporter_uuid, target_uuid)";
try (Connection conn = dataSource.getConnection();
Statement stmt = conn.createStatement()) {
stmt.execute(createTable);
stmt.execute(createTargetIndex);
stmt.execute(createReporterTargetIndex);
}
}
@Override
public void close() {
if (dataSource != null && !dataSource.isClosed()) {
dataSource.close();
logger.info("PostgreSQL connection pool closed");
}
}
@Override
public void saveReport(Report report) {
String sql = "INSERT INTO reports (reporter_uuid, reporter_name, target_uuid, target_name, reason, created_at) VALUES (?, ?, ?, ?, ?, ?)";
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, report.reporterUuid().toString());
stmt.setString(2, report.reporterName());
stmt.setString(3, report.targetUuid().toString());
stmt.setString(4, report.targetName());
stmt.setString(5, report.reason());
stmt.setLong(6, report.createdAt().toEpochMilli());
stmt.executeUpdate();
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to save report", e);
}
}
@Override
public List<Report> getReportsForTarget(UUID targetUuid) {
String sql = "SELECT * FROM reports WHERE target_uuid = ? ORDER BY created_at DESC";
List<Report> reports = new ArrayList<>();
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, targetUuid.toString());
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
reports.add(mapReport(rs));
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get reports for target", e);
}
return reports;
}
@Override
public List<Report> getAllReports() {
String sql = "SELECT * FROM reports ORDER BY created_at DESC";
List<Report> reports = new ArrayList<>();
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
reports.add(mapReport(rs));
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get all reports", e);
}
return reports;
}
@Override
public int getReportCount(UUID targetUuid) {
String sql = "SELECT COUNT(*) FROM reports WHERE target_uuid = ?";
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, targetUuid.toString());
ResultSet rs = stmt.executeQuery();
if (rs.next()) {
return rs.getInt(1);
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get report count", e);
}
return 0;
}
@Override
public boolean hasReported(UUID reporterUuid, UUID targetUuid) {
String sql = "SELECT COUNT(*) FROM reports WHERE reporter_uuid = ? AND target_uuid = ?";
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, reporterUuid.toString());
stmt.setString(2, targetUuid.toString());
ResultSet rs = stmt.executeQuery();
if (rs.next()) {
return rs.getInt(1) > 0;
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to check if reported", e);
}
return false;
}
@Override
public List<Report> getReportsPaginated(int page, int pageSize) {
String sql = "SELECT * FROM reports ORDER BY created_at DESC LIMIT ? OFFSET ?";
List<Report> reports = new ArrayList<>();
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setInt(1, pageSize);
stmt.setInt(2, page * pageSize);
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
reports.add(mapReport(rs));
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get paginated reports", e);
}
return reports;
}
@Override
public int getTotalReportCount() {
String sql = "SELECT COUNT(*) FROM reports";
try (Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement(sql)) {
ResultSet rs = stmt.executeQuery();
if (rs.next()) {
return rs.getInt(1);
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get total report count", e);
}
return 0;
}
private Report mapReport(ResultSet rs) throws SQLException {
return new Report(
rs.getInt("id"),
UUID.fromString(rs.getString("reporter_uuid")),
rs.getString("reporter_name"),
UUID.fromString(rs.getString("target_uuid")),
rs.getString("target_name"),
rs.getString("reason"),
Instant.ofEpochMilli(rs.getLong("created_at"))
);
}
}

View file

@ -0,0 +1,18 @@
package dev.loki.lorep.database;
import java.time.Instant;
import java.util.UUID;
public record Report(
int id,
UUID reporterUuid,
String reporterName,
UUID targetUuid,
String targetName,
String reason,
Instant createdAt
) {
public Report(UUID reporterUuid, String reporterName, UUID targetUuid, String targetName, String reason) {
this(0, reporterUuid, reporterName, targetUuid, targetName, reason, Instant.now());
}
}

View file

@ -0,0 +1,211 @@
package dev.loki.lorep.database;
import java.io.File;
import java.sql.*;
import java.time.Instant;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import java.util.logging.Level;
import java.util.logging.Logger;
public class SQLiteDatabaseManager implements DatabaseManager {
private final File dataFolder;
private final String fileName;
private final Logger logger;
private Connection connection;
public SQLiteDatabaseManager(File dataFolder, String fileName, Logger logger) {
this.dataFolder = dataFolder;
this.fileName = fileName;
this.logger = logger;
}
@Override
public void initialize() {
try {
if (!dataFolder.exists()) {
dataFolder.mkdirs();
}
File dbFile = new File(dataFolder, fileName);
String url = "jdbc:sqlite:" + dbFile.getAbsolutePath();
connection = DriverManager.getConnection(url);
createTables();
logger.info("SQLite database initialized: " + dbFile.getAbsolutePath());
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to initialize SQLite database", e);
}
}
private void createTables() throws SQLException {
String createTable = """
CREATE TABLE IF NOT EXISTS reports (
id INTEGER PRIMARY KEY AUTOINCREMENT,
reporter_uuid TEXT NOT NULL,
reporter_name TEXT NOT NULL,
target_uuid TEXT NOT NULL,
target_name TEXT NOT NULL,
reason TEXT NOT NULL,
created_at INTEGER NOT NULL
)
""";
String createTargetIndex = "CREATE INDEX IF NOT EXISTS idx_target_uuid ON reports(target_uuid)";
String createReporterTargetIndex = "CREATE INDEX IF NOT EXISTS idx_reporter_target ON reports(reporter_uuid, target_uuid)";
try (Statement stmt = connection.createStatement()) {
stmt.execute(createTable);
stmt.execute(createTargetIndex);
stmt.execute(createReporterTargetIndex);
}
}
@Override
public void close() {
try {
if (connection != null && !connection.isClosed()) {
connection.close();
logger.info("SQLite database connection closed");
}
} catch (SQLException e) {
logger.log(Level.WARNING, "Failed to close SQLite connection", e);
}
}
@Override
public void saveReport(Report report) {
String sql = "INSERT INTO reports (reporter_uuid, reporter_name, target_uuid, target_name, reason, created_at) VALUES (?, ?, ?, ?, ?, ?)";
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
stmt.setString(1, report.reporterUuid().toString());
stmt.setString(2, report.reporterName());
stmt.setString(3, report.targetUuid().toString());
stmt.setString(4, report.targetName());
stmt.setString(5, report.reason());
stmt.setLong(6, report.createdAt().toEpochMilli());
stmt.executeUpdate();
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to save report", e);
}
}
@Override
public List<Report> getReportsForTarget(UUID targetUuid) {
String sql = "SELECT * FROM reports WHERE target_uuid = ? ORDER BY created_at DESC";
List<Report> reports = new ArrayList<>();
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
stmt.setString(1, targetUuid.toString());
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
reports.add(mapReport(rs));
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get reports for target", e);
}
return reports;
}
@Override
public List<Report> getAllReports() {
String sql = "SELECT * FROM reports ORDER BY created_at DESC";
List<Report> reports = new ArrayList<>();
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
reports.add(mapReport(rs));
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get all reports", e);
}
return reports;
}
@Override
public int getReportCount(UUID targetUuid) {
String sql = "SELECT COUNT(*) FROM reports WHERE target_uuid = ?";
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
stmt.setString(1, targetUuid.toString());
ResultSet rs = stmt.executeQuery();
if (rs.next()) {
return rs.getInt(1);
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get report count", e);
}
return 0;
}
@Override
public boolean hasReported(UUID reporterUuid, UUID targetUuid) {
String sql = "SELECT COUNT(*) FROM reports WHERE reporter_uuid = ? AND target_uuid = ?";
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
stmt.setString(1, reporterUuid.toString());
stmt.setString(2, targetUuid.toString());
ResultSet rs = stmt.executeQuery();
if (rs.next()) {
return rs.getInt(1) > 0;
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to check if reported", e);
}
return false;
}
@Override
public List<Report> getReportsPaginated(int page, int pageSize) {
String sql = "SELECT * FROM reports ORDER BY created_at DESC LIMIT ? OFFSET ?";
List<Report> reports = new ArrayList<>();
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
stmt.setInt(1, pageSize);
stmt.setInt(2, page * pageSize);
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
reports.add(mapReport(rs));
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get paginated reports", e);
}
return reports;
}
@Override
public int getTotalReportCount() {
String sql = "SELECT COUNT(*) FROM reports";
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
ResultSet rs = stmt.executeQuery();
if (rs.next()) {
return rs.getInt(1);
}
} catch (SQLException e) {
logger.log(Level.SEVERE, "Failed to get total report count", e);
}
return 0;
}
private Report mapReport(ResultSet rs) throws SQLException {
return new Report(
rs.getInt("id"),
UUID.fromString(rs.getString("reporter_uuid")),
rs.getString("reporter_name"),
UUID.fromString(rs.getString("target_uuid")),
rs.getString("target_name"),
rs.getString("reason"),
Instant.ofEpochMilli(rs.getLong("created_at"))
);
}
}

View file

@ -0,0 +1,65 @@
package dev.loki.lorep.util;
import java.time.Duration;
import java.time.Instant;
public class TimeUtil {
public static String formatTimeAgo(long epochMillis) {
return formatTimeAgo(Instant.ofEpochMilli(epochMillis));
}
public static String formatTimeAgo(Instant instant) {
Duration duration = Duration.between(instant, Instant.now());
long seconds = duration.getSeconds();
if (seconds < 60) {
return seconds + " сек. назад";
}
long minutes = seconds / 60;
if (minutes < 60) {
return minutes + " мин. назад";
}
long hours = minutes / 60;
if (hours < 24) {
return hours + " ч. назад";
}
long days = hours / 24;
if (days < 30) {
return days + " дн. назад";
}
long months = days / 30;
if (months < 12) {
return months + " мес. назад";
}
long years = months / 12;
return years + " г. назад";
}
public static String formatDuration(Duration duration) {
long seconds = duration.getSeconds();
if (seconds < 60) {
return seconds + " секунд";
}
long minutes = seconds / 60;
if (minutes < 60) {
return minutes + " минут";
}
long hours = minutes / 60;
if (hours < 24) {
return hours + " часов";
}
long days = hours / 24;
return days + " дней";
}
}

View file

@ -0,0 +1,92 @@
package dev.loki.lorep.webhook;
import dev.loki.lorep.database.Report;
import okhttp3.*;
import java.io.IOException;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.logging.Level;
import java.util.logging.Logger;
public class DiscordWebhook {
private static final MediaType JSON = MediaType.get("application/json; charset=utf-8");
private static final DateTimeFormatter FORMATTER = DateTimeFormatter
.ofPattern("dd.MM.yyyy HH:mm:ss")
.withZone(ZoneId.systemDefault());
private final String webhookUrl;
private final Logger logger;
private final OkHttpClient client;
public DiscordWebhook(String webhookUrl, Logger logger) {
this.webhookUrl = webhookUrl;
this.logger = logger;
this.client = new OkHttpClient();
}
public void sendReport(Report report) {
if (webhookUrl == null || webhookUrl.isEmpty()) {
logger.warning("Discord webhook URL is not configured");
return;
}
String json = buildPayload(report);
RequestBody body = RequestBody.create(json, JSON);
Request request = new Request.Builder()
.url(webhookUrl)
.post(body)
.build();
client.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
logger.log(Level.WARNING, "Failed to send Discord webhook", e);
}
@Override
public void onResponse(Call call, Response response) {
if (!response.isSuccessful()) {
logger.warning("Discord webhook returned: " + response.code());
}
response.close();
}
});
}
public String buildPayload(Report report) {
String timestamp = FORMATTER.format(report.createdAt());
return String.format("""
{
"embeds": [{
"title": "📢 Новый репорт",
"color": 16711680,
"fields": [
{"name": "👤 Нарушитель", "value": "%s", "inline": true},
{"name": "📝 Отправитель", "value": "%s", "inline": true},
{"name": "📋 Причина", "value": "%s", "inline": false},
{"name": "🕐 Время", "value": "%s", "inline": false}
]
}]
}
""",
escapeJson(report.targetName()),
escapeJson(report.reporterName()),
escapeJson(report.reason()),
timestamp
);
}
private String escapeJson(String text) {
if (text == null) return "";
return text
.replace("\\", "\\\\")
.replace("\"", "\\\"")
.replace("\n", "\\n")
.replace("\r", "\\r")
.replace("\t", "\\t");
}
}

View file

@ -0,0 +1,35 @@
# Discord Webhook URL
webhook-url: ""
# Database settings
database:
# Type: sqlite or postgresql
type: "sqlite"
# SQLite settings
sqlite:
file: "reports.db"
# PostgreSQL settings
postgresql:
host: "localhost"
port: 5432
database: "lorep"
username: "lorep"
password: "password"
pool-size: 10
# Messages
messages:
report-sent: "&aРепорт успешно отправлен!"
already-reported: "&cВы уже отправляли репорт на этого игрока!"
self-report: "&cВы не можете отправить репорт на себя!"
player-not-found: "&cИгрок не найден!"
no-permission: "&cУ вас нет прав на эту команду!"
usage: "&eИспользование: /report <ник> <причина>"
no-reports: "&eУ этого игрока нет репортов."
stats-header: "&6=== Статистика репортов: %player% ==="
stats-count: "&eВсего репортов: &f%count%"
stats-last-online: "&eПоследний онлайн: &f%time%"
stats-report-entry: "&7- %reason% &8(%time% назад)"
gui-title: "Репорты - Страница %page%"

View file

@ -0,0 +1,20 @@
name: lorep
version: ${version}
main: dev.loki.lorep.LorepPlugin
api-version: '1.21'
author: loki
description: Player report system with Discord integration
commands:
report:
description: Report a player or manage reports
usage: /report <player> <reason> | /report gui | /report stats <player>
permission: lorep.report
permissions:
lorep.report:
description: Allows players to report other players
default: true
lorep.admin:
description: Allows access to admin commands (gui, stats)
default: op

View file

@ -0,0 +1,95 @@
package dev.loki.lorep.command;
import net.jqwik.api.*;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
/**
* **Feature: lorep-report-plugin, Property 8: Permission Enforcement**
* **Validates: Requirements 6.1, 6.2, 6.3**
*
* Note: Full permission testing requires Bukkit mocking which is complex.
* These tests verify the permission logic structure.
*/
public class PermissionTest {
// Permission constants
private static final String REPORT_PERMISSION = "lorep.report";
private static final String ADMIN_PERMISSION = "lorep.admin";
/**
* **Property 8: Permission Enforcement**
* For any command execution, if the player lacks the required permission,
* the command SHALL be denied.
* **Validates: Requirements 6.1, 6.2, 6.3**
*/
@Property(tries = 100)
void permissionEnforcementLogic(
@ForAll("commands") String command,
@ForAll boolean hasReportPerm,
@ForAll boolean hasAdminPerm
) {
boolean shouldAllow = checkPermission(command, hasReportPerm, hasAdminPerm);
switch (command) {
case "report" -> {
// /report <player> <reason> requires lorep.report
assertEquals(hasReportPerm, shouldAllow,
"Report command should require lorep.report permission");
}
case "gui" -> {
// /report gui requires lorep.admin
assertEquals(hasAdminPerm, shouldAllow,
"GUI command should require lorep.admin permission");
}
case "stats" -> {
// /report stats requires lorep.admin
assertEquals(hasAdminPerm, shouldAllow,
"Stats command should require lorep.admin permission");
}
}
}
private boolean checkPermission(String command, boolean hasReportPerm, boolean hasAdminPerm) {
return switch (command) {
case "report" -> hasReportPerm;
case "gui", "stats" -> hasAdminPerm;
default -> false;
};
}
@Provide
Arbitrary<String> commands() {
return Arbitraries.of("report", "gui", "stats");
}
@Test
void permissionStringsAreCorrect() {
assertEquals("lorep.report", REPORT_PERMISSION);
assertEquals("lorep.admin", ADMIN_PERMISSION);
}
@Test
void reportCommandRequiresReportPermission() {
assertTrue(checkPermission("report", true, false));
assertFalse(checkPermission("report", false, true));
assertFalse(checkPermission("report", false, false));
}
@Test
void guiCommandRequiresAdminPermission() {
assertTrue(checkPermission("gui", false, true));
assertTrue(checkPermission("gui", true, true));
assertFalse(checkPermission("gui", true, false));
assertFalse(checkPermission("gui", false, false));
}
@Test
void statsCommandRequiresAdminPermission() {
assertTrue(checkPermission("stats", false, true));
assertTrue(checkPermission("stats", true, true));
assertFalse(checkPermission("stats", true, false));
assertFalse(checkPermission("stats", false, false));
}
}

View file

@ -0,0 +1,133 @@
package dev.loki.lorep.config;
import net.jqwik.api.*;
import org.junit.jupiter.api.Test;
import org.yaml.snakeyaml.Yaml;
import java.util.Map;
import static org.junit.jupiter.api.Assertions.*;
/**
* **Feature: lorep-report-plugin, Property 9: Configuration Parsing**
* **Validates: Requirements 7.1, 7.3, 7.4**
*/
public class ConfigParsingTest {
private final Yaml yaml = new Yaml();
/**
* Property 9: Configuration Parsing
* For any valid config.yml content, parsing SHALL correctly extract webhook URL and database settings.
*/
@Property(tries = 100)
void configurationParsingExtractsValues(
@ForAll("webhookUrls") String webhookUrl,
@ForAll("databaseTypes") String dbType,
@ForAll("sqliteFiles") String sqliteFile,
@ForAll("hosts") String pgHost,
@ForAll("ports") int pgPort
) {
String configYaml = buildConfigYaml(webhookUrl, dbType, sqliteFile, pgHost, pgPort);
@SuppressWarnings("unchecked")
Map<String, Object> config = yaml.load(configYaml);
// Verify webhook URL is correctly parsed
assertEquals(webhookUrl, config.get("webhook-url"));
// Verify database settings
@SuppressWarnings("unchecked")
Map<String, Object> database = (Map<String, Object>) config.get("database");
assertNotNull(database);
assertEquals(dbType, database.get("type"));
// Verify SQLite settings
@SuppressWarnings("unchecked")
Map<String, Object> sqlite = (Map<String, Object>) database.get("sqlite");
assertNotNull(sqlite);
assertEquals(sqliteFile, sqlite.get("file"));
// Verify PostgreSQL settings
@SuppressWarnings("unchecked")
Map<String, Object> postgresql = (Map<String, Object>) database.get("postgresql");
assertNotNull(postgresql);
assertEquals(pgHost, postgresql.get("host"));
assertEquals(pgPort, postgresql.get("port"));
}
@Provide
Arbitrary<String> webhookUrls() {
return Arbitraries.of(
"",
"https://discord.com/api/webhooks/123/abc",
"https://discord.com/api/webhooks/999999/xyz123"
);
}
@Provide
Arbitrary<String> databaseTypes() {
return Arbitraries.of("sqlite", "postgresql");
}
@Provide
Arbitrary<String> sqliteFiles() {
return Arbitraries.of("reports.db", "data.db", "lorep.sqlite");
}
@Provide
Arbitrary<String> hosts() {
return Arbitraries.of("localhost", "127.0.0.1", "db.example.com");
}
@Provide
Arbitrary<Integer> ports() {
return Arbitraries.integers().between(1, 65535);
}
private String buildConfigYaml(String webhookUrl, String dbType, String sqliteFile, String pgHost, int pgPort) {
return String.format("""
webhook-url: "%s"
database:
type: "%s"
sqlite:
file: "%s"
postgresql:
host: "%s"
port: %d
database: "lorep"
username: "lorep"
password: "password"
pool-size: 10
messages:
report-sent: "Report sent!"
""", webhookUrl, dbType, sqliteFile, pgHost, pgPort);
}
@Test
void defaultConfigHasValidStructure() {
String defaultConfig = """
webhook-url: ""
database:
type: "sqlite"
sqlite:
file: "reports.db"
postgresql:
host: "localhost"
port: 5432
database: "lorep"
username: "lorep"
password: "password"
pool-size: 10
messages:
report-sent: "&aРепорт успешно отправлен!"
""";
@SuppressWarnings("unchecked")
Map<String, Object> config = yaml.load(defaultConfig);
assertNotNull(config.get("webhook-url"));
assertNotNull(config.get("database"));
assertNotNull(config.get("messages"));
}
}

View file

@ -0,0 +1,222 @@
package dev.loki.lorep.database;
import net.jqwik.api.*;
import net.jqwik.api.lifecycle.AfterProperty;
import net.jqwik.api.lifecycle.BeforeProperty;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import java.io.File;
import java.time.Instant;
import java.util.List;
import java.util.UUID;
import java.util.logging.Logger;
import static org.junit.jupiter.api.Assertions.*;
/**
* Property-based tests for DatabaseManager
* **Feature: lorep-report-plugin**
* **Validates: Requirements 1.1, 1.2, 2.1, 2.2, 2.3, 5.1**
*/
public class DatabaseManagerTest {
private SQLiteDatabaseManager dbManager;
private File tempDir;
private static final Logger logger = Logger.getLogger("TestLogger");
@BeforeEach
@BeforeProperty
void setUp() {
tempDir = new File(System.getProperty("java.io.tmpdir"), "lorep-test-" + System.currentTimeMillis());
tempDir.mkdirs();
dbManager = new SQLiteDatabaseManager(tempDir, "test.db", logger);
dbManager.initialize();
}
@AfterEach
@AfterProperty
void tearDown() {
if (dbManager != null) {
dbManager.close();
}
if (tempDir != null && tempDir.exists()) {
for (File file : tempDir.listFiles()) {
file.delete();
}
tempDir.delete();
}
}
/**
* **Property 1: Report Creation Integrity**
* For any valid reporter UUID, target UUID, and reason string, creating a report
* and then querying reports for that target SHALL return a list containing the
* created report with matching fields.
* **Validates: Requirements 1.1, 2.1**
*/
@Property(tries = 100)
void reportCreationIntegrity(
@ForAll("uuids") UUID reporterUuid,
@ForAll("uuids") UUID targetUuid,
@ForAll("reasons") String reason
) {
Assume.that(!reporterUuid.equals(targetUuid));
Report report = new Report(
0, reporterUuid, "Reporter", targetUuid, "Target", reason, Instant.now()
);
dbManager.saveReport(report);
List<Report> reports = dbManager.getReportsForTarget(targetUuid);
assertTrue(reports.stream().anyMatch(r ->
r.reporterUuid().equals(reporterUuid) &&
r.targetUuid().equals(targetUuid) &&
r.reason().equals(reason)
), "Created report should be retrievable by target UUID");
}
/**
* **Property 2: Duplicate Report Prevention**
* For any reporter-target pair, if a report already exists from that reporter
* to that target, hasReported SHALL return true.
* **Validates: Requirements 1.2**
*/
@Property(tries = 100)
void duplicateReportPrevention(
@ForAll("uuids") UUID reporterUuid,
@ForAll("uuids") UUID targetUuid
) {
Assume.that(!reporterUuid.equals(targetUuid));
assertFalse(dbManager.hasReported(reporterUuid, targetUuid),
"Should not have reported before creating report");
Report report = new Report(
0, reporterUuid, "Reporter", targetUuid, "Target", "Test reason", Instant.now()
);
dbManager.saveReport(report);
assertTrue(dbManager.hasReported(reporterUuid, targetUuid),
"Should detect existing report from same reporter to same target");
}
/**
* **Property 3: Report Persistence Round-Trip**
* For any set of reports saved to the database, reloading the database
* SHALL return the same reports with identical data.
* **Validates: Requirements 2.2**
*/
@Property(tries = 50)
void reportPersistenceRoundTrip(
@ForAll("uuids") UUID reporterUuid,
@ForAll("uuids") UUID targetUuid,
@ForAll("reasons") String reason
) {
Assume.that(!reporterUuid.equals(targetUuid));
String reporterName = "Reporter_" + reporterUuid.toString().substring(0, 8);
String targetName = "Target_" + targetUuid.toString().substring(0, 8);
Instant createdAt = Instant.now();
Report original = new Report(0, reporterUuid, reporterName, targetUuid, targetName, reason, createdAt);
dbManager.saveReport(original);
// Close and reopen database
dbManager.close();
dbManager = new SQLiteDatabaseManager(tempDir, "test.db", logger);
dbManager.initialize();
List<Report> loaded = dbManager.getReportsForTarget(targetUuid);
assertTrue(loaded.stream().anyMatch(r ->
r.reporterUuid().equals(reporterUuid) &&
r.reporterName().equals(reporterName) &&
r.targetUuid().equals(targetUuid) &&
r.targetName().equals(targetName) &&
r.reason().equals(reason)
), "Report should persist across database reload");
}
/**
* **Property 4: Report Ordering**
* For any collection of reports with different timestamps, querying all reports
* SHALL return them sorted by creation timestamp in descending order (newest first).
* **Validates: Requirements 2.3**
*/
@Property(tries = 50)
void reportOrdering(@ForAll("reportCounts") int count) {
UUID targetUuid = UUID.randomUUID();
for (int i = 0; i < count; i++) {
Report report = new Report(
0, UUID.randomUUID(), "Reporter" + i, targetUuid, "Target",
"Reason " + i, Instant.now().minusSeconds(count - i)
);
dbManager.saveReport(report);
}
List<Report> reports = dbManager.getAllReports();
for (int i = 0; i < reports.size() - 1; i++) {
assertTrue(
reports.get(i).createdAt().compareTo(reports.get(i + 1).createdAt()) >= 0,
"Reports should be sorted by timestamp descending"
);
}
}
/**
* **Property 7: Report Count Accuracy**
* For any target UUID, the report count returned by getReportCount SHALL equal
* the actual number of reports in the database for that target.
* **Validates: Requirements 5.1**
*/
@Property(tries = 100)
void reportCountAccuracy(@ForAll("reportCounts") int count) {
UUID targetUuid = UUID.randomUUID();
for (int i = 0; i < count; i++) {
Report report = new Report(
0, UUID.randomUUID(), "Reporter" + i, targetUuid, "Target",
"Reason " + i, Instant.now()
);
dbManager.saveReport(report);
}
int reportedCount = dbManager.getReportCount(targetUuid);
List<Report> actualReports = dbManager.getReportsForTarget(targetUuid);
assertEquals(count, reportedCount, "getReportCount should match actual count");
assertEquals(count, actualReports.size(), "List size should match count");
}
@Provide
Arbitrary<UUID> uuids() {
return Arbitraries.create(UUID::randomUUID);
}
@Provide
Arbitrary<String> reasons() {
return Arbitraries.strings()
.withCharRange('a', 'z')
.ofMinLength(1)
.ofMaxLength(100);
}
@Provide
Arbitrary<Integer> reportCounts() {
return Arbitraries.integers().between(1, 10);
}
@Test
void testEmptyDatabase() {
UUID randomUuid = UUID.randomUUID();
assertEquals(0, dbManager.getReportCount(randomUuid));
assertTrue(dbManager.getReportsForTarget(randomUuid).isEmpty());
assertFalse(dbManager.hasReported(randomUuid, UUID.randomUUID()));
}
}

View file

@ -0,0 +1,111 @@
package dev.loki.lorep.webhook;
import dev.loki.lorep.database.Report;
import net.jqwik.api.*;
import org.junit.jupiter.api.Test;
import java.time.Instant;
import java.util.UUID;
import java.util.logging.Logger;
import static org.junit.jupiter.api.Assertions.*;
/**
* **Feature: lorep-report-plugin, Property 5: Webhook Payload Completeness**
* **Validates: Requirements 3.1**
*/
public class DiscordWebhookTest {
private static final Logger logger = Logger.getLogger("TestLogger");
/**
* **Property 5: Webhook Payload Completeness**
* For any report sent to the webhook, the payload SHALL contain reporter name,
* target name, reason, and formatted timestamp.
* **Validates: Requirements 3.1**
*/
@Property(tries = 100)
void webhookPayloadContainsAllRequiredFields(
@ForAll("playerNames") String reporterName,
@ForAll("playerNames") String targetName,
@ForAll("reasons") String reason
) {
DiscordWebhook webhook = new DiscordWebhook("https://example.com/webhook", logger);
Report report = new Report(
1,
UUID.randomUUID(),
reporterName,
UUID.randomUUID(),
targetName,
reason,
Instant.now()
);
String payload = webhook.buildPayload(report);
// Verify all required fields are present in payload
assertTrue(payload.contains(escapeForCheck(reporterName)),
"Payload should contain reporter name: " + reporterName);
assertTrue(payload.contains(escapeForCheck(targetName)),
"Payload should contain target name: " + targetName);
assertTrue(payload.contains(escapeForCheck(reason)),
"Payload should contain reason: " + reason);
// Verify timestamp format (dd.MM.yyyy HH:mm:ss) - using Pattern.DOTALL for multiline
assertTrue(java.util.regex.Pattern.compile("\\d{2}\\.\\d{2}\\.\\d{4} \\d{2}:\\d{2}:\\d{2}",
java.util.regex.Pattern.DOTALL).matcher(payload).find(),
"Payload should contain formatted timestamp");
// Verify it's valid JSON structure
assertTrue(payload.contains("\"embeds\""), "Payload should have embeds array");
assertTrue(payload.contains("\"fields\""), "Payload should have fields array");
}
@Provide
Arbitrary<String> playerNames() {
return Arbitraries.strings()
.withCharRange('a', 'z')
.withCharRange('A', 'Z')
.withCharRange('0', '9')
.withChars('_')
.ofMinLength(3)
.ofMaxLength(16);
}
@Provide
Arbitrary<String> reasons() {
return Arbitraries.strings()
.withCharRange('a', 'z')
.withCharRange('A', 'Z')
.withCharRange('0', '9')
.withChars(' ', '.', ',', '!')
.ofMinLength(1)
.ofMaxLength(100);
}
private String escapeForCheck(String text) {
return text
.replace("\\", "\\\\")
.replace("\"", "\\\"");
}
@Test
void payloadHasCorrectStructure() {
DiscordWebhook webhook = new DiscordWebhook("https://example.com/webhook", logger);
Report report = new Report(
1, UUID.randomUUID(), "TestReporter",
UUID.randomUUID(), "TestTarget",
"Test reason", Instant.now()
);
String payload = webhook.buildPayload(report);
assertTrue(payload.contains("Новый репорт"));
assertTrue(payload.contains("Нарушитель"));
assertTrue(payload.contains("Отправитель"));
assertTrue(payload.contains("Причина"));
assertTrue(payload.contains("Время"));
}
}