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
.PlainTextWriterImpl
;
7 import org
.asamk
.signal
.commands
.exceptions
.CommandException
;
8 import org
.asamk
.signal
.commands
.exceptions
.IOErrorException
;
9 import org
.asamk
.signal
.commands
.exceptions
.UnexpectedErrorException
;
10 import org
.asamk
.signal
.commands
.exceptions
.UserErrorException
;
11 import org
.asamk
.signal
.manager
.Manager
;
12 import org
.asamk
.signal
.manager
.groups
.GroupInviteLinkUrl
;
13 import org
.freedesktop
.dbus
.exceptions
.DBusExecutionException
;
14 import org
.whispersystems
.signalservice
.api
.groupsv2
.GroupLinkNotActiveException
;
15 import org
.whispersystems
.signalservice
.internal
.push
.exceptions
.GroupPatchNotAcceptedException
;
17 import java
.io
.IOException
;
19 import static org
.asamk
.signal
.util
.ErrorUtils
.handleTimestampAndSendMessageResults
;
21 public class JoinGroupCommand
implements LocalCommand
{
24 public void attachToSubparser(final Subparser subparser
) {
25 subparser
.addArgument("--uri").required(true).help("Specify the uri with the group invitation link.");
29 public void handleCommand(final Namespace ns
, final Manager m
) throws CommandException
{
30 final GroupInviteLinkUrl linkUrl
;
31 var uri
= ns
.getString("uri");
33 linkUrl
= GroupInviteLinkUrl
.fromUri(uri
);
34 } catch (GroupInviteLinkUrl
.InvalidGroupLinkException e
) {
35 throw new UserErrorException("Group link is invalid: " + e
.getMessage());
36 } catch (GroupInviteLinkUrl
.UnknownGroupLinkVersionException e
) {
37 throw new UserErrorException("Group link was created with an incompatible version: " + e
.getMessage());
40 if (linkUrl
== null) {
41 throw new UserErrorException("Link is not a signal group invitation link");
45 final var writer
= new PlainTextWriterImpl(System
.out
);
47 final var results
= m
.joinGroup(linkUrl
);
48 var newGroupId
= results
.first();
49 if (!m
.getGroup(newGroupId
).isMember(m
.getSelfAddress())) {
50 writer
.println("Requested to join group \"{}\"", newGroupId
.toBase64());
52 writer
.println("Joined group \"{}\"", newGroupId
.toBase64());
54 handleTimestampAndSendMessageResults(writer
, 0, results
.second());
55 } catch (GroupPatchNotAcceptedException e
) {
56 throw new UserErrorException("Failed to join group, maybe already a member");
57 } catch (IOException e
) {
58 throw new IOErrorException("Failed to send message: " + e
.getMessage());
59 } catch (DBusExecutionException e
) {
60 throw new UnexpectedErrorException("Failed to send message: " + e
.getMessage());
61 } catch (GroupLinkNotActiveException e
) {
62 throw new UserErrorException("Group link is not valid: " + e
.getMessage());