X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/fc8b6d0fcbedd6a4c9ae394a0640e79690e28337..7b0744ec758b1ccbe3c9ce5a1e6dea5d7e2313da:/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 801a2640..f1b8ef5b 100644 --- a/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java +++ b/src/main/java/org/asamk/signal/commands/QuitGroupCommand.java @@ -8,24 +8,22 @@ import org.asamk.signal.commands.exceptions.CommandException; import org.asamk.signal.commands.exceptions.IOErrorException; import org.asamk.signal.commands.exceptions.UserErrorException; import org.asamk.signal.manager.Manager; -import org.asamk.signal.manager.groups.GroupNotFoundException; -import org.asamk.signal.manager.groups.LastGroupAdminException; -import org.asamk.signal.manager.groups.NotAGroupMemberException; -import org.asamk.signal.output.JsonWriter; +import org.asamk.signal.manager.api.GroupNotFoundException; +import org.asamk.signal.manager.api.LastGroupAdminException; +import org.asamk.signal.manager.api.NotAGroupMemberException; +import org.asamk.signal.manager.api.UnregisteredRecipientException; import org.asamk.signal.output.OutputWriter; -import org.asamk.signal.output.PlainTextWriter; import org.asamk.signal.util.CommandUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.IOException; -import java.util.Map; -import static org.asamk.signal.util.ErrorUtils.handleSendMessageResults; +import static org.asamk.signal.util.SendMessageResultUtils.outputResult; public class QuitGroupCommand implements JsonRpcLocalCommand { - private final static Logger logger = LoggerFactory.getLogger(QuitGroupCommand.class); + private static final Logger logger = LoggerFactory.getLogger(QuitGroupCommand.class); @Override public String getName() { @@ -55,9 +53,7 @@ public class QuitGroupCommand implements JsonRpcLocalCommand { try { try { final var results = m.quitGroup(groupId, groupAdmins); - final var timestamp = results.timestamp(); - outputResult(outputWriter, timestamp); - handleSendMessageResults(results.results()); + outputResult(outputWriter, results); } catch (NotAGroupMemberException e) { logger.info("User is not a group member"); } @@ -75,15 +71,8 @@ public class QuitGroupCommand implements JsonRpcLocalCommand { throw new UserErrorException("Failed to send to group: " + e.getMessage()); } catch (LastGroupAdminException e) { throw new UserErrorException("You need to specify a new admin with --admin: " + e.getMessage()); - } - } - - private void outputResult(final OutputWriter outputWriter, final long timestamp) { - if (outputWriter instanceof PlainTextWriter writer) { - writer.println("{}", timestamp); - } else { - final var writer = (JsonWriter) outputWriter; - writer.write(Map.of("timestamp", timestamp)); + } catch (UnregisteredRecipientException e) { + throw new UserErrorException("The user " + e.getSender().getIdentifier() + " is not registered."); } } }