misc/chomens-bot-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove greplog

Browse Source 
rip.,,.,.
This commit is contained in:
ChomeNS
2023-07-06 20:02:23 +07:00
parent 1a274e281b
commit 364203aa80
4 changed files with 0 additions and 260 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/land/chipmunk/chayapak/chomens_bot/Bot.java
View File

@@ -62,7 +62,6 @@ public class Bot {
public EvalPlugin eval;
public TrustedPlugin trusted;
public BruhifyPlugin bruhify;
public GrepLogPlugin grepLog;
public CloopPlugin cloop;
public MazePlugin maze;
public ExploitsPlugin exploits;
@@ -108,7 +107,6 @@ public class Bot {
this.eval = new EvalPlugin(this);
this.trusted = new TrustedPlugin(this);
this.bruhify = new BruhifyPlugin(this);
this.grepLog = new GrepLogPlugin(this);
this.cloop = new CloopPlugin(this);
this.maze = new MazePlugin(this);
this.exploits = new ExploitsPlugin(this);

68
src/main/java/land/chipmunk/chayapak/chomens_bot/commands/GrepLogCommand.java
View File

@@ -1,68 +0,0 @@
package land.chipmunk.chayapak.chomens_bot.commands;
import land.chipmunk.chayapak.chomens_bot.Bot;
import land.chipmunk.chayapak.chomens_bot.command.Command;
import land.chipmunk.chayapak.chomens_bot.command.CommandContext;
import land.chipmunk.chayapak.chomens_bot.command.TrustLevel;
import net.kyori.adventure.text.Component;
import net.kyori.adventure.text.format.NamedTextColor;
import java.util.Arrays;
public class GrepLogCommand extends Command {
public GrepLogCommand () {
super(
"greplog",
"Queries the bots log files",
new String[] {
"<{input}>",
"-ignorecase <{input}>",
"-regex <{input}>",
"-ignorecase -regex <{input}>",
"stop"
},
new String[] { "logquery", "greplogs" },
TrustLevel.PUBLIC
);
}
@Override
public Component execute(CommandContext context, String[] _args, String[] fullArgs) {
final Bot bot = context.bot;
String[] args = _args;
boolean ignoreCase = false;
boolean regex = false;
if (_args[0].equals("stop")) {
bot.grepLog.thread.interrupt();
bot.grepLog.thread = null;
return Component.text("Log query stopped");
}
if (bot.grepLog.thread != null) return Component.text("Another query is already running").color(NamedTextColor.RED);
// this is a mess
if (_args[0].equals("-ignorecase")) {
ignoreCase = true;
args = Arrays.copyOfRange(_args, 1, _args.length);
} else if (_args[0].equals("-regex")) {
regex = true;
args = Arrays.copyOfRange(_args, 1, _args.length);
}
if (_args.length > 1 && _args[1].equals("-ignorecase")) {
ignoreCase = true;
args = Arrays.copyOfRange(_args, 2, _args.length);
} else if (_args.length > 1 && _args[1].equals("-regex")) {
regex = true;
args = Arrays.copyOfRange(_args, 2, _args.length);
}
bot.grepLog.query(String.join(" ", args), regex, ignoreCase);
return null;
}
}

1
src/main/java/land/chipmunk/chayapak/chomens_bot/plugins/CommandHandlerPlugin.java
View File

@@ -50,7 +50,6 @@ public class CommandHandlerPlugin {
registerCommand(new UUIDCommand());
registerCommand(new TimeCommand());
registerCommand(new BruhifyCommand());
registerCommand(new GrepLogCommand());
registerCommand(new SudoAllCommand());
registerCommand(new EndCommand());
registerCommand(new CloopCommand());

189
src/main/java/land/chipmunk/chayapak/chomens_bot/plugins/GrepLogPlugin.java
View File

@@ -1,189 +0,0 @@
package land.chipmunk.chayapak.chomens_bot.plugins;
import land.chipmunk.chayapak.chomens_bot.Bot;
import land.chipmunk.chayapak.chomens_bot.util.ColorUtilities;
import land.chipmunk.chayapak.chomens_bot.util.FileLoggerUtilities;
import net.dv8tion.jda.api.entities.TextChannel;
import net.kyori.adventure.text.Component;
import net.kyori.adventure.text.format.NamedTextColor;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.Arrays;
import java.util.Comparator;
import java.util.regex.Pattern;
import java.util.zip.GZIPInputStream;
public class GrepLogPlugin {
private final Bot bot;
public Thread thread = null;
public GrepLogPlugin (Bot bot) {
this.bot = bot;
}
public void query (String query, boolean regex, boolean ignoreCase) {
thread = new GrepLogThread(query, regex, ignoreCase);
}
// should i move this to another file or keep it here
public class GrepLogThread extends Thread {
private String query;
private final boolean regex;
private final boolean ignoreCase;
private Pattern pattern;
private boolean queryStopped = false;
private int matches = 0;
private final StringBuilder results = new StringBuilder();
public GrepLogThread(String query, boolean regex, boolean ignoreCase) {
this.regex = regex;
this.ignoreCase = ignoreCase;
this.query = query;
if (regex) {
if (ignoreCase) {
pattern = Pattern.compile(query, Pattern.CASE_INSENSITIVE);
}
else {
try {
pattern = Pattern.compile(query);
} catch (Exception e) {
bot.chat.tellraw(Component.text(e.toString()).color(NamedTextColor.RED));
}
}
} else {
if (ignoreCase) {
this.query = query.toLowerCase();
}
}
}
@Override
public void run() {
bot.chat.tellraw(
Component.translatable(
"Collecting %s in logs...",
Component.text(query).color(ColorUtilities.getColorByString(bot.config.colorPalette.secondary))
).color(ColorUtilities.getColorByString(bot.config.colorPalette.defaultColor))
);
final File[] fileList = FileLoggerUtilities.logDir.listFiles();
Arrays.sort(fileList, Comparator.comparing(File::getName)); // VERY IMPORTANT
for (File file : fileList) {
final String fileName = file.getName();
if (fileName.matches(".*\\.txt\\.gz")) {
try (
FileInputStream fin = new FileInputStream(file);
GZIPInputStream gzin = new GZIPInputStream(fin, 65536);
BufferedReader br = new BufferedReader(new InputStreamReader(gzin, StandardCharsets.UTF_8))
) {
br.readLine();
readFile(br);
} catch (Exception e) {
e.printStackTrace();
}
} else {
try (
FileInputStream fin = new FileInputStream(file);
BufferedReader br = new BufferedReader(new InputStreamReader(fin, StandardCharsets.UTF_8))
) {
br.readLine();
readFile(br);
} catch (Exception e) {
e.printStackTrace();
}
}
if (queryStopped) break;
}
finish();
}
private void readFile(BufferedReader br) {
String line;
try {
while ((line = br.readLine()) != null) {
if (line.length() == 0) continue;
String[] tokens = line.split("\\s+");
if (tokens.length < 3) continue; // not a valid log message
processLine(line);
}
} catch (IOException ignored) {}
}
private void processLine(String _line) {
// [day/month/year hh:mm:ss] [server:port] message
String[] tokens = _line.split("\\s+");
final String line = String.join(" ", Arrays.copyOfRange(tokens, 3, tokens.length)); // very 1 liner
if (regex) {
if (pattern.matcher(line).find()) {
match(_line);
}
} else {
if (ignoreCase) {
if (line.toLowerCase().contains(query)) {
match(_line);
}
} else {
if (line.contains(query)) {
match(_line);
}
}
}
}
private void match (String line) {
results.append(line);
results.append("\n");
matches++;
int resultsLimit = 1_000_000;
if (results.length() > resultsLimit) {
queryStopped = true;
}
}
private void finish () {
if (results.toString().split("\n").length < 100) { // ig lazy fix for removing \n lol
bot.chat.tellraw(
Component.empty()
.append(Component.text("Log query output for \""))
.append(Component.text(query))
.append(Component.text("\":"))
.append(Component.newline())
.append(Component.text(results.toString()))
);
} else if (bot.config.discord.enabled) {
bot.chat.tellraw(
Component.translatable(
"Log query for \"%s\" finished, found %s matches. Results were sent in Discord",
Component.text(query).color(ColorUtilities.getColorByString(bot.config.colorPalette.string)),
Component.text(matches).color(ColorUtilities.getColorByString(bot.config.colorPalette.number))
)
);
final String channelId = bot.discord.servers.get(bot.host + ":" + bot.port);
final TextChannel logChannel = bot.discord.jda.getTextChannelById(channelId);
if (logChannel == null) return;
logChannel.sendMessage("Log query output").addFile(results.toString().getBytes(), "report.txt").queue();
}
thread = null;
}
}
}