X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/fc8b6d0fcbedd6a4c9ae394a0640e79690e28337..175057e781623d5e61128ccbb13f2eb47ae8bf94:/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 e04fca06..5e3461b7 100644 --- a/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java +++ b/src/main/java/org/asamk/signal/commands/JoinGroupCommand.java @@ -9,17 +9,17 @@ import org.asamk.signal.commands.exceptions.UnexpectedErrorException; 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.api.PendingAdminApprovalException; 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 java.io.IOException; import java.util.Map; -import static org.asamk.signal.util.ErrorUtils.handleSendMessageResults; - public class JoinGroupCommand implements JsonRpcLocalCommand { @Override @@ -55,10 +55,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; @@ -67,8 +80,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 (IOException e) { throw new IOErrorException("Failed to send message: " + e.getMessage() @@ -80,6 +95,8 @@ public class JoinGroupCommand implements JsonRpcLocalCommand { .getSimpleName() + ")", e); } catch (InactiveGroupLinkException e) { throw new UserErrorException("Group link is not valid: " + e.getMessage()); + } catch (PendingAdminApprovalException e) { + throw new UserErrorException("Pending admin approval: " + e.getMessage()); } } }