iTakinn/TKNLogs
1
0
Fork 0
mirror of https://github.com/IdalecioSch/TKNLogs.git synced 2026-07-27 16:25:50 -03:00
Code Issues Packages Projects Releases Wiki Activity

ae porra

Browse Source
This commit is contained in:
iTakinn
2025-03-16 19:56:21 -03:00
parent 4de0018c7d
commit 0ddc4ef324
2 changed files with 51 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/org/itakinn/tknlogs/LoggerReader.java
+48 -36
View File
@@ -13,69 +13,81 @@ import static java.nio.file.StandardWatchEventKinds.*;
public class LoggerReader {
private final JavaPlugin plugin;
private Path logDir;
private final TKNLogs plugin;
private long lastPosition = 0;
private Path logFilePath;
private WatchService watchService;
private long lastReadPosition;
public LoggerReader(TKNLogs pl) {
this.plugin = pl;
Path logDir = Paths.get(Bukkit.getServer().getWorldContainer().getAbsolutePath(), "logs");
this.lastReadPosition = 0;
public LoggerReader(TKNLogs plugin) {
this.plugin = plugin;
File serverDir = Bukkit.getServer().getWorldContainer();
this.logFilePath = Paths.get(serverDir.getAbsolutePath(), "logs", "latest.log");
}
public void start() {
try {
if (!Files.exists(logFilePath)) {
plugin.getLogger().severe("Arquivo latest.log não encontrado!");
return;
}
try {
watchService = FileSystems.getDefault().newWatchService();
logDir.register(watchService, ENTRY_MODIFY);
Path logDir = logFilePath.getParent();
logDir.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);
Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
while (!Thread.currentThread().isInterrupted()) {
WatchKey key;
try {
key = watchService.take();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return;
}
for (WatchEvent<?> event : key.pollEvents()) {
if (event.kind() == ENTRY_MODIFY) {
Path changedFile = logDir.resolve((Path) event.context());
if (changedFile.endsWith("latest.log")) {
processLogChanges(changedFile.toFile());
try {
while (!Thread.currentThread().isInterrupted()) {
WatchKey key = watchService.take();
for (WatchEvent<?> event : key.pollEvents()) {
if (event.context().toString().equals("latest.log")) {
readNewLines();
}
}
key.reset();
}
key.reset();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
} catch (IOException e) {
plugin.getLogger().severe("Erro ao iniciar monitor de logs: " + e.getMessage());
plugin.getLogger().severe("Erro ao iniciar monitor: " + e.getMessage());
}
}
private void processLogChanges(File logFile) {
try (RandomAccessFile raf = new RandomAccessFile(logFile, "r")) {
if (raf.length() < lastReadPosition) {
lastReadPosition = 0;
private void readNewLines() {
try (RandomAccessFile raf = new RandomAccessFile(logFilePath.toFile(), "r")) {
if (raf.length() < lastPosition) {
lastPosition = 0;
}
raf.seek(lastReadPosition);
raf.seek(lastPosition);
String line;
while ((line = raf.readLine()) != null) {
line = new String(line.getBytes(StandardCharsets.ISO_8859_1), StandardCharsets.UTF_8);
TKNLogs.getDiscord().sendMessage(line);
String utf8Line = new String(line.getBytes(StandardCharsets.ISO_8859_1), StandardCharsets.UTF_8);
sendToDiscord(utf8Line);
}
lastReadPosition = raf.getFilePointer();
lastPosition = raf.getFilePointer();
} catch (IOException e) {
plugin.getLogger().severe("Erro ao ler latest.log: " + e.getMessage());
}
}
private void sendToDiscord(String message) {
if (TKNLogs.getDiscord() != null) {
TKNLogs.getDiscord().sendMessage("```" + message + "```");
}
}
public void stop() {
try {
if (watchService != null) {
watchService.close();
}
} catch (IOException e) {
plugin.getLogger().severe("Erro ao parar monitor: " + e.getMessage());
}
}
}
src/main/java/org/itakinn/tknlogs/TKNLogs.java
+2 -1
View File
@@ -12,15 +12,16 @@ public final class TKNLogs extends JavaPlugin {
public void onEnable() {
saveDefaultConfig();
reloadConfig();
discord = new DiscordNotifier();
Bukkit.getPluginManager().registerEvents(new ChatListener(), this);
Bukkit.getPluginManager().registerEvents(new CommandListener(), this);
Bukkit.getPluginManager().registerEvents(new JoinQuitListener(), this);
logMonitor = new LoggerReader(this);
logMonitor.start();
plugin = this;
Logger logger = Bukkit.getLogger();
logger.addHandler(new ErrorCatcher());
ErrorCatcher.register();
discord = new DiscordNotifier();
getLogger().info("PLUGIN STARTED");
}
public static JavaPlugin getPlugin(){