X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/d4b4bd86038025ec69e95c9994e30077d1c9d241..f4ed9a01b728272f2a3ba1790ec784fc4f4d7796:/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 447cbb03..4bc209cd 100644 --- a/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java +++ b/src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java @@ -1,12 +1,10 @@ package org.asamk.signal.commands; -import com.fasterxml.jackson.core.JsonGenerator; -import com.fasterxml.jackson.databind.ObjectMapper; - import net.sourceforge.argparse4j.impl.Arguments; import net.sourceforge.argparse4j.inf.Namespace; import net.sourceforge.argparse4j.inf.Subparser; +import org.asamk.signal.JsonWriter; import org.asamk.signal.OutputType; import org.asamk.signal.manager.Manager; import org.slf4j.Logger; @@ -16,11 +14,11 @@ 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; public class GetUserStatusCommand implements LocalCommand { - // TODO delete later when "json" variable is removed private final static Logger logger = LoggerFactory.getLogger(GetUserStatusCommand.class); @Override @@ -32,12 +30,14 @@ public class GetUserStatusCommand implements LocalCommand { .action(Arguments.storeTrue()); } + @Override + public Set getSupportedOutputTypes() { + return Set.of(OutputType.PLAIN_TEXT, OutputType.JSON); + } + @Override public int handleCommand(final Namespace ns, final Manager m) { // Setup the json object mapper - ObjectMapper jsonProcessor = new ObjectMapper(); - jsonProcessor.disable(JsonGenerator.Feature.AUTO_CLOSE_TARGET); - boolean inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json"); // TODO delete later when "json" variable is removed @@ -56,16 +56,18 @@ public class GetUserStatusCommand implements LocalCommand { // Output if (inJson) { - List objects = registered.entrySet() + final JsonWriter jsonWriter = new JsonWriter(System.out); + + List jsonUserStatuses = registered.entrySet() .stream() - .map(entry -> new JsonIsRegistered(entry.getKey(), entry.getValue())) + .map(entry -> new JsonUserStatus(entry.getKey(), entry.getValue())) .collect(Collectors.toList()); try { - jsonProcessor.writeValue(System.out, objects); - System.out.println(); + jsonWriter.write(jsonUserStatuses); } catch (IOException e) { - System.err.println(e.getMessage()); + logger.error("Failed to write json object: {}", e.getMessage()); + return 3; } } else { for (Map.Entry entry : registered.entrySet()) { @@ -76,13 +78,13 @@ public class GetUserStatusCommand implements LocalCommand { return 0; } - private static final class JsonIsRegistered { + private static final class JsonUserStatus { public String name; public boolean isRegistered; - public JsonIsRegistered(String name, boolean isRegistered) { + public JsonUserStatus(String name, boolean isRegistered) { this.name = name; this.isRegistered = isRegistered; }