X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/a8bbdb54d006f157a009ece0cae5bf72fb636ced..593cd7d8ca6e8e0ab654accfd7e3c9d2ee01b001:/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 91e6e47c..be94fb36 100644 --- a/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java +++ b/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java @@ -11,64 +11,76 @@ import org.asamk.signal.commands.exceptions.IOErrorException; import org.asamk.signal.manager.Manager; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.whispersystems.libsignal.util.Pair; import java.io.IOException; import java.util.HashSet; import java.util.Map; +import java.util.UUID; import java.util.stream.Collectors; public class GetUserStatusCommand implements JsonRpcLocalCommand { private final static Logger logger = LoggerFactory.getLogger(GetUserStatusCommand.class); - private final OutputWriter outputWriter; - public static void attachToSubparser(final Subparser subparser) { - subparser.help("Check if the specified phone number/s have been registered"); - subparser.addArgument("number").help("Phone number").nargs("+"); + @Override + public String getName() { + return "getUserStatus"; } - public GetUserStatusCommand(final OutputWriter outputWriter) { - this.outputWriter = outputWriter; + @Override + public void attachToSubparser(final Subparser subparser) { + subparser.help("Check if the specified phone number/s have been registered"); + subparser.addArgument("recipient").help("Phone number").nargs("+"); } @Override - public void handleCommand(final Namespace ns, final Manager m) throws CommandException { + public void handleCommand( + final Namespace ns, final Manager m, final OutputWriter outputWriter + ) throws CommandException { // Get a map of registration statuses - Map registered; + 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; - var jsonUserStatuses = registered.entrySet() - .stream() - .map(entry -> new JsonUserStatus(entry.getKey(), entry.getValue())) - .collect(Collectors.toList()); + var jsonUserStatuses = registered.entrySet().stream().map(entry -> { + final var number = entry.getValue().first(); + final var uuid = entry.getValue().second(); + return new JsonUserStatus(entry.getKey(), number, uuid == null ? null : uuid.toString(), uuid != null); + }).collect(Collectors.toList()); jsonWriter.write(jsonUserStatuses); } else { 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 String name; + public final String recipient; + + public final String number; + + public final String uuid; - public boolean isRegistered; + public final boolean isRegistered; - public JsonUserStatus(String name, boolean isRegistered) { - this.name = name; + public JsonUserStatus(String recipient, String number, String uuid, boolean isRegistered) { + this.recipient = recipient; + this.number = number; + this.uuid = uuid; this.isRegistered = isRegistered; } }