import org.asamk.signal.JsonWriter;
import org.asamk.signal.OutputType;
+import org.asamk.signal.PlainTextWriterImpl;
+import org.asamk.signal.commands.exceptions.CommandException;
+import org.asamk.signal.commands.exceptions.IOErrorException;
import org.asamk.signal.manager.Manager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.HashSet;
-import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
@Override
public void attachToSubparser(final Subparser subparser) {
- subparser.addArgument("number").help("Phone number").nargs("+");
subparser.help("Check if the specified phone number/s have been registered");
+ subparser.addArgument("number").help("Phone number").nargs("+");
subparser.addArgument("--json")
.help("WARNING: This parameter is now deprecated! Please use the global \"--output=json\" option instead.\n\nOutput received messages in json format, one json object per line.")
.action(Arguments.storeTrue());
}
@Override
- public int handleCommand(final Namespace ns, final Manager m) {
+ public void handleCommand(final Namespace ns, final Manager m) throws CommandException {
// Setup the json object mapper
- boolean inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json");
+ var inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json");
// TODO delete later when "json" variable is removed
if (ns.getBoolean("json")) {
try {
registered = m.areUsersRegistered(new HashSet<>(ns.getList("number")));
} catch (IOException e) {
- System.err.println("Unable to check if users are registered");
- return 3;
+ logger.debug("Failed to check registered users", e);
+ throw new IOErrorException("Unable to check if users are registered");
}
// Output
if (inJson) {
- final JsonWriter jsonWriter = new JsonWriter(System.out);
+ final var jsonWriter = new JsonWriter(System.out);
- List<JsonUserStatus> jsonUserStatuses = registered.entrySet()
+ var jsonUserStatuses = registered.entrySet()
.stream()
.map(entry -> new JsonUserStatus(entry.getKey(), entry.getValue()))
.collect(Collectors.toList());
- try {
- jsonWriter.write(jsonUserStatuses);
- } catch (IOException e) {
- logger.error("Failed to write json object: {}", e.getMessage());
- return 3;
- }
+ jsonWriter.write(jsonUserStatuses);
} else {
- for (Map.Entry<String, Boolean> entry : registered.entrySet()) {
- System.out.println(entry.getKey() + ": " + entry.getValue());
+ final var writer = new PlainTextWriterImpl(System.out);
+
+ for (var entry : registered.entrySet()) {
+ writer.println("{}: {}", entry.getKey(), entry.getValue());
}
}
-
- return 0;
}
private static final class JsonUserStatus {