X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/5bbfd3259891e18a11cb878e14a9c17990b13d79..8867a7b9eeb3353d059613544899b262f4f47579:/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java diff --git a/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java b/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java index 055dac9f..97e4af34 100644 --- a/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java +++ b/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java @@ -3,15 +3,15 @@ package org.asamk.signal.commands; import net.sourceforge.argparse4j.inf.Namespace; import net.sourceforge.argparse4j.inf.Subparser; -import org.asamk.signal.JsonWriter; -import org.asamk.signal.OutputWriter; -import org.asamk.signal.PlainTextWriter; import org.asamk.signal.commands.exceptions.CommandException; import org.asamk.signal.commands.exceptions.IOErrorException; import org.asamk.signal.manager.Manager; +import org.asamk.signal.manager.api.Pair; +import org.asamk.signal.output.JsonWriter; +import org.asamk.signal.output.OutputWriter; +import org.asamk.signal.output.PlainTextWriter; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.whispersystems.libsignal.util.Pair; import java.io.IOException; import java.util.HashSet; @@ -31,7 +31,7 @@ public class GetUserStatusCommand implements JsonRpcLocalCommand { @Override public void attachToSubparser(final Subparser subparser) { subparser.help("Check if the specified phone number/s have been registered"); - subparser.addArgument("number").help("Phone number").nargs("+"); + subparser.addArgument("recipient").help("Phone number").nargs("+"); } @Override @@ -41,15 +41,13 @@ public class GetUserStatusCommand implements JsonRpcLocalCommand { // Get a map of registration statuses Map> registered; try { - registered = m.areUsersRegistered(new HashSet<>(ns.getList("number"))); + registered = m.areUsersRegistered(new HashSet<>(ns.getList("recipient"))); } catch (IOException e) { - logger.debug("Failed to check registered users", e); - throw new IOErrorException("Unable to check if users are registered"); + throw new IOErrorException("Unable to check if users are registered", e); } // Output - if (outputWriter instanceof JsonWriter) { - final var jsonWriter = (JsonWriter) outputWriter; + if (outputWriter instanceof JsonWriter jsonWriter) { var jsonUserStatuses = registered.entrySet().stream().map(entry -> { final var number = entry.getValue().first(); @@ -62,26 +60,11 @@ public class GetUserStatusCommand implements JsonRpcLocalCommand { final var writer = (PlainTextWriter) outputWriter; for (var entry : registered.entrySet()) { - writer.println("{}: {}", entry.getKey(), entry.getValue()); + final var uuid = entry.getValue().second(); + writer.println("{}: {}", entry.getKey(), uuid != null); } } } - private static final class JsonUserStatus { - - public final String name; - - public final String number; - - public final String uuid; - - public final boolean isRegistered; - - public JsonUserStatus(String name, String number, String uuid, boolean isRegistered) { - this.name = name; - this.number = number; - this.uuid = uuid; - this.isRegistered = isRegistered; - } - } + private record JsonUserStatus(String recipient, String number, String uuid, boolean isRegistered) {} }