fix #36
|
@ -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,30 @@ 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<>();
|
||||||
|
|
||||||
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("Number Name State");
|
||||||
|
names.add(elements.get(0) + ", "
|
||||||
|
+ elements.get(6) + ", "
|
||||||
|
+ elements.get(4) + " "
|
||||||
|
+ elements.get(5));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return names;
|
return names;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue