X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/d356d92b5eb24f7340055f766455b943c274bc50..ca33249170118be0d2fe3e9deed4ad23b34ac875:/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 1691fac8..eab4155c 100644 --- a/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java +++ b/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java @@ -22,6 +22,7 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.util.HashSet; import java.util.Map; +import java.util.Set; import java.util.stream.Stream; public class GetUserStatusCommand implements JsonRpcLocalCommand { @@ -42,12 +43,15 @@ public class GetUserStatusCommand implements JsonRpcLocalCommand { @Override public void handleCommand( - final Namespace ns, final Manager m, final OutputWriter outputWriter + final Namespace ns, + final Manager m, + final OutputWriter outputWriter ) throws CommandException { // Get a map of registration statuses Map registered; try { - registered = m.getUserStatus(new HashSet<>(ns.getList("recipient"))); + final var recipient = ns.getList("recipient"); + registered = m.getUserStatus(recipient == null ? Set.of() : new HashSet<>(recipient)); } catch (RateLimitException e) { final var message = CommandUtil.getRateLimitMessage(e); throw new RateLimitErrorException(message, e); @@ -60,9 +64,16 @@ public class GetUserStatusCommand implements JsonRpcLocalCommand { } final var usernames = ns.getList("username"); - final var registeredUsernames = usernames == null - ? Map.of() - : m.getUsernameStatus(new HashSet<>(usernames)); + final Map registeredUsernames; + try { + registeredUsernames = usernames == null ? Map.of() : m.getUsernameStatus(new HashSet<>(usernames)); + } catch (IOException e) { + throw new IOErrorException("Unable to check if users are registered: " + + e.getMessage() + + " (" + + e.getClass().getSimpleName() + + ")", e); + } // Output switch (outputWriter) {