X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/87406e2cdb4cb65a50202792350657457801c235..b810e303ec9d0fcc3ba948b7e65d57f85bffe437:/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java diff --git a/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java b/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java index 0a53c638..af5d600c 100644 --- a/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java +++ b/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java @@ -4,7 +4,9 @@ import net.sourceforge.argparse4j.impl.Arguments; import net.sourceforge.argparse4j.inf.Namespace; import net.sourceforge.argparse4j.inf.Subparser; -import org.asamk.signal.PlainTextWriterImpl; +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.commands.exceptions.UserErrorException; @@ -21,18 +23,23 @@ import org.whispersystems.signalservice.api.util.InvalidNumberException; import java.io.IOException; import java.util.HashSet; +import java.util.Map; import java.util.Set; -import static org.asamk.signal.util.ErrorUtils.handleTimestampAndSendMessageResults; +import static org.asamk.signal.util.ErrorUtils.handleSendMessageResults; -public class QuitGroupCommand implements LocalCommand { +public class QuitGroupCommand implements JsonRpcLocalCommand { private final static Logger logger = LoggerFactory.getLogger(QuitGroupCommand.class); + private final OutputWriter outputWriter; - @Override - public void attachToSubparser(final Subparser subparser) { + public QuitGroupCommand(final OutputWriter outputWriter) { + this.outputWriter = outputWriter; + } + + public static void attachToSubparser(final Subparser subparser) { subparser.help("Send a quit group message to all group members and remove self from member list."); - subparser.addArgument("-g", "--group").required(true).help("Specify the recipient group ID."); + subparser.addArgument("-g", "--group-id", "--group").required(true).help("Specify the recipient group ID."); subparser.addArgument("--delete") .action(Arguments.storeTrue()) .help("Delete local group data completely after quitting group."); @@ -43,11 +50,9 @@ public class QuitGroupCommand implements LocalCommand { @Override public void handleCommand(final Namespace ns, final Manager m) throws CommandException { - final var writer = new PlainTextWriterImpl(System.out); - final GroupId groupId; try { - groupId = Util.decodeGroupId(ns.getString("group")); + groupId = Util.decodeGroupId(ns.getString("group-id")); } catch (GroupIdFormatException e) { throw new UserErrorException("Invalid group id: " + e.getMessage()); } @@ -58,7 +63,9 @@ public class QuitGroupCommand implements LocalCommand { try { final var results = m.sendQuitGroupMessage(groupId, groupAdmins == null ? Set.of() : new HashSet<>(groupAdmins)); - handleTimestampAndSendMessageResults(writer, results.first(), results.second()); + final var timestamp = results.first(); + outputResult(timestamp); + handleSendMessageResults(results.second()); } catch (NotAGroupMemberException e) { logger.info("User is not a group member"); } @@ -76,4 +83,14 @@ public class QuitGroupCommand implements LocalCommand { throw new UserErrorException("You need to specify a new admin with --admin: " + e.getMessage()); } } + + private void outputResult(final long timestamp) { + if (outputWriter instanceof PlainTextWriter) { + final var writer = (PlainTextWriter) outputWriter; + writer.println("{}", timestamp); + } else { + final var writer = (JsonWriter) outputWriter; + writer.write(Map.of("timestamp", timestamp)); + } + } }