]> nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/commands/QuitGroupCommand.java
Implement JsonRpc command for quitGroup
[signal-cli] / src / main / java / org / asamk / signal / commands / QuitGroupCommand.java
1 package org.asamk.signal.commands;
2
3 import net.sourceforge.argparse4j.impl.Arguments;
4 import net.sourceforge.argparse4j.inf.Namespace;
5 import net.sourceforge.argparse4j.inf.Subparser;
6
7 import org.asamk.signal.JsonWriter;
8 import org.asamk.signal.OutputWriter;
9 import org.asamk.signal.PlainTextWriter;
10 import org.asamk.signal.commands.exceptions.CommandException;
11 import org.asamk.signal.commands.exceptions.IOErrorException;
12 import org.asamk.signal.commands.exceptions.UserErrorException;
13 import org.asamk.signal.manager.Manager;
14 import org.asamk.signal.manager.groups.GroupId;
15 import org.asamk.signal.manager.groups.GroupIdFormatException;
16 import org.asamk.signal.manager.groups.GroupNotFoundException;
17 import org.asamk.signal.manager.groups.LastGroupAdminException;
18 import org.asamk.signal.manager.groups.NotAGroupMemberException;
19 import org.asamk.signal.util.Util;
20 import org.slf4j.Logger;
21 import org.slf4j.LoggerFactory;
22 import org.whispersystems.signalservice.api.util.InvalidNumberException;
23
24 import java.io.IOException;
25 import java.util.HashSet;
26 import java.util.Map;
27 import java.util.Set;
28
29 import static org.asamk.signal.util.ErrorUtils.handleSendMessageResults;
30
31 public class QuitGroupCommand implements JsonRpcLocalCommand {
32
33 private final static Logger logger = LoggerFactory.getLogger(QuitGroupCommand.class);
34 private final OutputWriter outputWriter;
35
36 public QuitGroupCommand(final OutputWriter outputWriter) {
37 this.outputWriter = outputWriter;
38 }
39
40 public static void attachToSubparser(final Subparser subparser) {
41 subparser.help("Send a quit group message to all group members and remove self from member list.");
42 subparser.addArgument("-g", "--group-id", "--group").required(true).help("Specify the recipient group ID.");
43 subparser.addArgument("--delete")
44 .action(Arguments.storeTrue())
45 .help("Delete local group data completely after quitting group.");
46 subparser.addArgument("--admin")
47 .nargs("*")
48 .help("Specify one or more members to make a group admin, required if you're currently the only admin.");
49 }
50
51 @Override
52 public void handleCommand(final Namespace ns, final Manager m) throws CommandException {
53 final GroupId groupId;
54 try {
55 groupId = Util.decodeGroupId(ns.getString("group-id"));
56 } catch (GroupIdFormatException e) {
57 throw new UserErrorException("Invalid group id: " + e.getMessage());
58 }
59
60 var groupAdmins = ns.<String>getList("admin");
61
62 try {
63 try {
64 final var results = m.sendQuitGroupMessage(groupId,
65 groupAdmins == null ? Set.of() : new HashSet<>(groupAdmins));
66 final var timestamp = results.first();
67 outputResult(timestamp);
68 handleSendMessageResults(results.second());
69 } catch (NotAGroupMemberException e) {
70 logger.info("User is not a group member");
71 }
72 if (ns.getBoolean("delete")) {
73 logger.debug("Deleting group {}", groupId);
74 m.deleteGroup(groupId);
75 }
76 } catch (IOException e) {
77 throw new IOErrorException("Failed to send message: " + e.getMessage());
78 } catch (GroupNotFoundException e) {
79 throw new UserErrorException("Failed to send to group: " + e.getMessage());
80 } catch (InvalidNumberException e) {
81 throw new UserErrorException("Failed to parse admin number: " + e.getMessage());
82 } catch (LastGroupAdminException e) {
83 throw new UserErrorException("You need to specify a new admin with --admin: " + e.getMessage());
84 }
85 }
86
87 private void outputResult(final long timestamp) {
88 if (outputWriter instanceof PlainTextWriter) {
89 final var writer = (PlainTextWriter) outputWriter;
90 writer.println("{}", timestamp);
91 } else {
92 final var writer = (JsonWriter) outputWriter;
93 writer.write(Map.of("timestamp", timestamp));
94 }
95 }
96 }