import org.asamk.signal.commands.exceptions.IOErrorException;
import org.asamk.signal.commands.exceptions.UserErrorException;
import org.asamk.signal.manager.Manager;
-import org.asamk.signal.manager.groups.GroupId;
-import org.asamk.signal.manager.groups.GroupIdFormatException;
import org.asamk.signal.manager.groups.GroupNotFoundException;
import org.asamk.signal.manager.groups.LastGroupAdminException;
import org.asamk.signal.manager.groups.NotAGroupMemberException;
-import org.asamk.signal.util.Util;
+import org.asamk.signal.util.CommandUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.whispersystems.signalservice.api.util.InvalidNumberException;
import java.io.IOException;
-import java.util.HashSet;
import java.util.Map;
-import java.util.Set;
import static org.asamk.signal.util.ErrorUtils.handleSendMessageResults;
public void handleCommand(
final Namespace ns, final Manager m, final OutputWriter outputWriter
) throws CommandException {
- final GroupId groupId;
- try {
- groupId = Util.decodeGroupId(ns.getString("group-id"));
- } catch (GroupIdFormatException e) {
- throw new UserErrorException("Invalid group id: " + e.getMessage());
- }
+ final var groupId = CommandUtil.getGroupId(ns.getString("group-id"));
- var groupAdmins = ns.<String>getList("admin");
+ var groupAdmins = CommandUtil.getSingleRecipientIdentifiers(ns.getList("admin"), m.getSelfNumber());
try {
try {
- final var results = m.sendQuitGroupMessage(groupId,
- groupAdmins == null ? Set.of() : new HashSet<>(groupAdmins));
- final var timestamp = results.first();
+ final var results = m.quitGroup(groupId, groupAdmins);
+ final var timestamp = results.getTimestamp();
outputResult(outputWriter, timestamp);
- handleSendMessageResults(results.second());
+ handleSendMessageResults(results.getResults());
} catch (NotAGroupMemberException e) {
logger.info("User is not a group member");
}
- if (ns.getBoolean("delete")) {
+ if (Boolean.TRUE.equals(ns.getBoolean("delete"))) {
logger.debug("Deleting group {}", groupId);
m.deleteGroup(groupId);
}
} catch (IOException e) {
- throw new IOErrorException("Failed to send message: " + e.getMessage());
+ throw new IOErrorException("Failed to send message: "
+ + e.getMessage()
+ + " ("
+ + e.getClass().getSimpleName()
+ + ")", e);
} catch (GroupNotFoundException e) {
throw new UserErrorException("Failed to send to group: " + e.getMessage());
- } catch (InvalidNumberException e) {
- throw new UserErrorException("Failed to parse admin number: " + e.getMessage());
} catch (LastGroupAdminException e) {
throw new UserErrorException("You need to specify a new admin with --admin: " + e.getMessage());
}
}
private void outputResult(final OutputWriter outputWriter, final long timestamp) {
- if (outputWriter instanceof PlainTextWriter) {
- final var writer = (PlainTextWriter) outputWriter;
+ if (outputWriter instanceof PlainTextWriter writer) {
writer.println("{}", timestamp);
} else {
final var writer = (JsonWriter) outputWriter;