2 Commits

Author SHA1 Message Date
62a473000a fix
Some checks are pending
Hedgehog_server_CI/ServerMonitorBot/pipeline/pr-master Build queued...
2023-11-22 20:48:51 +03:00
187e20ad9d fix
Some checks are pending
Hedgehog_server_CI/ServerMonitorBot/pipeline/pr-master Build queued...
2023-11-22 20:42:47 +03:00
2 changed files with 34 additions and 18 deletions

View File

@@ -15,6 +15,7 @@ import ru.ldeloff.servermonitorbot.utils.SshServerUtils;
import java.util.*; import java.util.*;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; import java.util.regex.Pattern;
import java.util.stream.Collectors;
@Service @Service
@Slf4j @Slf4j
@@ -55,7 +56,7 @@ public class MdadmStatusCommand extends CommandTemplate {
.findFirst(); .findFirst();
if (server.isPresent()) { if (server.isPresent()) {
// узнаю скок рейдов // узнаю скок рейдов
Command commandRaid = sshService.execute(new Command("mdadm --monitor", 500, server.get())); Command commandRaid = sshService.execute(new Command("mdadm --detail --scan", 500, server.get()));
List<String> raidNames = parseRaidNames(commandRaid); List<String> raidNames = parseRaidNames(commandRaid);
// Для каждого рейда надо выяснить статус // Для каждого рейда надо выяснить статус
StringBuilder result = new StringBuilder(); StringBuilder result = new StringBuilder();
@@ -72,9 +73,8 @@ public class MdadmStatusCommand extends CommandTemplate {
} }
} }
private List<String> parseRaidNames(Command result) { private List<String> parseRaidNames(Command result) {
String raidInfo = result.getResponse();
List<String> names = new ArrayList<>(); List<String> names = new ArrayList<>();
Arrays.stream(raidInfo.split("\n")) Arrays.stream(result.getResponse().split("\n"))
.map(line -> line.split(" ")) .map(line -> line.split(" "))
.filter(lineArray -> lineArray.length >= 2) .filter(lineArray -> lineArray.length >= 2)
.map(lineArray -> lineArray[1]) .map(lineArray -> lineArray[1])
@@ -83,18 +83,31 @@ public class MdadmStatusCommand extends CommandTemplate {
} }
private List<String> parseHddState(Command result) { private List<String> parseHddState(Command result) {
String raidInfo = result.getResponse();
List<String> names = new ArrayList<>(); List<String> names = new ArrayList<>();
names.add("Number Name State");
Pattern pattern = Pattern.compile("^\\s*(\\d+)\\s+\\d+\\s+\\d+\\s+\\d+\\s+\\w+\\s+(.+)$"); String[] lines = result.getResponse().split("\n");
Matcher matcher = pattern.matcher(raidInfo);
while (matcher.find()) { boolean foundHeader = false;
String number = matcher.group(1);
String state = matcher.group(2); for (String line : lines) {
names.add("Number: " + number + ", State: " + state); if (!foundHeader) {
if ( line.contains("Number") &&
line.contains("Major") &&
line.contains("Minor") &&
line.contains("RaidDevice") ) {
foundHeader = true;
}
} else {
List<String> elements = Arrays.stream(line.split(" "))
.filter(x -> !Objects.equals(x, "")).toList();
names.add(elements.get(0) + ", "
+ elements.get(6) + ", "
+ elements.get(4) + " "
+ elements.get(5));
}
} }
return names; return names;
} }
} }

View File

@@ -26,14 +26,17 @@ public class TelegramBotKeyboard implements UiFormer {
ArrayList<KeyboardRow> keyboardRows = new ArrayList<>(); ArrayList<KeyboardRow> keyboardRows = new ArrayList<>();
KeyboardRow keyboardRow = new KeyboardRow(); KeyboardRow keyboardRow1 = new KeyboardRow();
keyboardRows.add(keyboardRow); keyboardRows.add(keyboardRow1);
keyboardRow.add(new KeyboardButton(STATUS)); keyboardRow1.add(new KeyboardButton(STATUS));
keyboardRow.add(new KeyboardButton(UNAME)); keyboardRow1.add(new KeyboardButton(UNAME));
keyboardRow.add(new KeyboardButton(CPU_TEMP)); keyboardRow1.add(new KeyboardButton(CPU_TEMP));
keyboardRow.add(new KeyboardButton(HDD_TEMP)); keyboardRow1.add(new KeyboardButton(HDD_TEMP));
keyboardRow.add(new KeyboardButton(MDADM));
KeyboardRow keyboardRow2 = new KeyboardRow();
keyboardRows.add(keyboardRow2);
keyboardRow2.add(new KeyboardButton(MDADM));
replyKeyboardMarkup.setKeyboard(keyboardRows); replyKeyboardMarkup.setKeyboard(keyboardRows);
message.setReplyMarkup(replyKeyboardMarkup); message.setReplyMarkup(replyKeyboardMarkup);