1 package org
.asamk
.signal
.commands
;
3 import net
.sourceforge
.argparse4j
.inf
.Namespace
;
4 import net
.sourceforge
.argparse4j
.inf
.Subparser
;
6 import org
.asamk
.signal
.commands
.exceptions
.CommandException
;
7 import org
.asamk
.signal
.commands
.exceptions
.IOErrorException
;
8 import org
.asamk
.signal
.commands
.exceptions
.UserErrorException
;
9 import org
.asamk
.signal
.manager
.Manager
;
10 import org
.asamk
.signal
.manager
.api
.GroupInviteLinkUrl
;
11 import org
.asamk
.signal
.manager
.api
.InactiveGroupLinkException
;
12 import org
.asamk
.signal
.manager
.api
.PendingAdminApprovalException
;
13 import org
.asamk
.signal
.output
.JsonWriter
;
14 import org
.asamk
.signal
.output
.OutputWriter
;
15 import org
.asamk
.signal
.output
.PlainTextWriter
;
16 import org
.asamk
.signal
.util
.SendMessageResultUtils
;
18 import java
.io
.IOException
;
21 public class JoinGroupCommand
implements JsonRpcLocalCommand
{
24 public String
getName() {
29 public void attachToSubparser(final Subparser subparser
) {
30 subparser
.help("Join a group via an invitation link.");
31 subparser
.addArgument("--uri").required(true).help("Specify the uri with the group invitation link.");
35 public void handleCommand(
36 final Namespace ns
, final Manager m
, final OutputWriter outputWriter
37 ) throws CommandException
{
38 final GroupInviteLinkUrl linkUrl
;
39 var uri
= ns
.getString("uri");
41 linkUrl
= GroupInviteLinkUrl
.fromUri(uri
);
42 } catch (GroupInviteLinkUrl
.InvalidGroupLinkException e
) {
43 throw new UserErrorException("Group link is invalid: " + e
.getMessage());
44 } catch (GroupInviteLinkUrl
.UnknownGroupLinkVersionException e
) {
45 throw new UserErrorException("Group link was created with an incompatible version: " + e
.getMessage());
48 if (linkUrl
== null) {
49 throw new UserErrorException("Link is not a signal group invitation link");
53 final var results
= m
.joinGroup(linkUrl
);
54 var newGroupId
= results
.first();
55 switch (outputWriter
) {
56 case JsonWriter writer
-> {
57 var jsonResults
= SendMessageResultUtils
.getJsonSendMessageResults(results
.second().results());
58 if (!m
.getGroup(newGroupId
).isMember()) {
59 writer
.write(Map
.of("timestamp",
60 results
.second().timestamp(),
64 newGroupId
.toBase64(),
68 writer
.write(Map
.of("timestamp",
69 results
.second().timestamp(),
73 newGroupId
.toBase64()));
76 case PlainTextWriter writer
-> {
77 if (!m
.getGroup(newGroupId
).isMember()) {
78 writer
.println("Requested to join group \"{}\"", newGroupId
.toBase64());
80 writer
.println("Joined group \"{}\"", newGroupId
.toBase64());
82 var errors
= SendMessageResultUtils
.getErrorMessagesFromSendMessageResults(results
.second()
84 SendMessageResultUtils
.printSendMessageResultErrors(writer
, errors
);
85 writer
.println("{}", results
.second().timestamp());
88 } catch (IOException e
) {
89 throw new IOErrorException("Failed to send message: "
92 + e
.getClass().getSimpleName()
94 } catch (InactiveGroupLinkException e
) {
95 throw new UserErrorException("Group link is not valid: " + e
.getMessage());
96 } catch (PendingAdminApprovalException e
) {
97 throw new UserErrorException("Pending admin approval: " + e
.getMessage());