X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/659761f00688523970bdc3d99aea2d7f7806a3af..06e93b84da2718c31111e820cd35a3354f22bae2:/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java diff --git a/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java b/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java index c7b8b040..31fc4caf 100644 --- a/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java +++ b/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java @@ -3,9 +3,6 @@ package org.asamk.signal.commands; import net.sourceforge.argparse4j.inf.Namespace; import net.sourceforge.argparse4j.inf.Subparser; -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.UnexpectedErrorException; @@ -13,14 +10,15 @@ import org.asamk.signal.commands.exceptions.UserErrorException; import org.asamk.signal.manager.Manager; import org.asamk.signal.manager.api.InactiveGroupLinkException; import org.asamk.signal.manager.groups.GroupInviteLinkUrl; +import org.asamk.signal.output.JsonWriter; +import org.asamk.signal.output.OutputWriter; +import org.asamk.signal.output.PlainTextWriter; +import org.asamk.signal.util.SendMessageResultUtils; import org.freedesktop.dbus.exceptions.DBusExecutionException; -import org.whispersystems.signalservice.internal.push.exceptions.GroupPatchNotAcceptedException; import java.io.IOException; import java.util.Map; -import static org.asamk.signal.util.ErrorUtils.handleSendMessageResults; - public class JoinGroupCommand implements JsonRpcLocalCommand { @Override @@ -56,10 +54,23 @@ public class JoinGroupCommand implements JsonRpcLocalCommand { final var results = m.joinGroup(linkUrl); var newGroupId = results.first(); if (outputWriter instanceof JsonWriter writer) { + var jsonResults = SendMessageResultUtils.getJsonSendMessageResults(results.second().results()); if (!m.getGroup(newGroupId).isMember()) { - writer.write(Map.of("groupId", newGroupId.toBase64(), "onlyRequested", true)); + writer.write(Map.of("timestamp", + results.second().timestamp(), + "results", + jsonResults, + "groupId", + newGroupId.toBase64(), + "onlyRequested", + true)); } else { - writer.write(Map.of("groupId", newGroupId.toBase64())); + writer.write(Map.of("timestamp", + results.second().timestamp(), + "results", + jsonResults, + "groupId", + newGroupId.toBase64())); } } else { final var writer = (PlainTextWriter) outputWriter; @@ -68,10 +79,10 @@ public class JoinGroupCommand implements JsonRpcLocalCommand { } else { writer.println("Joined group \"{}\"", newGroupId.toBase64()); } + var errors = SendMessageResultUtils.getErrorMessagesFromSendMessageResults(results.second().results()); + SendMessageResultUtils.printSendMessageResultErrors(writer, errors); + writer.println("{}", results.second().timestamp()); } - handleSendMessageResults(results.second().results()); - } catch (GroupPatchNotAcceptedException e) { - throw new UserErrorException("Failed to join group, maybe already a member"); } catch (IOException e) { throw new IOErrorException("Failed to send message: " + e.getMessage()