]> nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/commands/JoinGroupCommand.java
Implement dbus support for listIdentities
[signal-cli] / src / main / java / org / asamk / signal / commands / JoinGroupCommand.java
1 package org.asamk.signal.commands;
2
3 import net.sourceforge.argparse4j.inf.Namespace;
4 import net.sourceforge.argparse4j.inf.Subparser;
5
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;
17
18 import java.io.IOException;
19 import java.util.Map;
20
21 public class JoinGroupCommand implements JsonRpcLocalCommand {
22
23 @Override
24 public String getName() {
25 return "joinGroup";
26 }
27
28 @Override
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.");
32 }
33
34 @Override
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");
40 try {
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());
46 }
47
48 if (linkUrl == null) {
49 throw new UserErrorException("Link is not a signal group invitation link");
50 }
51
52 try {
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(),
61 "results",
62 jsonResults,
63 "groupId",
64 newGroupId.toBase64(),
65 "onlyRequested",
66 true));
67 } else {
68 writer.write(Map.of("timestamp",
69 results.second().timestamp(),
70 "results",
71 jsonResults,
72 "groupId",
73 newGroupId.toBase64()));
74 }
75 }
76 case PlainTextWriter writer -> {
77 if (!m.getGroup(newGroupId).isMember()) {
78 writer.println("Requested to join group \"{}\"", newGroupId.toBase64());
79 } else {
80 writer.println("Joined group \"{}\"", newGroupId.toBase64());
81 }
82 var errors = SendMessageResultUtils.getErrorMessagesFromSendMessageResults(results.second()
83 .results());
84 SendMessageResultUtils.printSendMessageResultErrors(writer, errors);
85 writer.println("{}", results.second().timestamp());
86 }
87 }
88 } catch (IOException e) {
89 throw new IOErrorException("Failed to send message: "
90 + e.getMessage()
91 + " ("
92 + e.getClass().getSimpleName()
93 + ")", e);
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());
98 }
99 }
100 }