import org.asamk.signal.commands.exceptions.CommandException;
import org.asamk.signal.manager.Manager;
import org.asamk.signal.manager.api.Group;
-import org.asamk.signal.manager.storage.recipients.RecipientAddress;
+import org.asamk.signal.manager.api.RecipientAddress;
import org.asamk.signal.output.JsonWriter;
import org.asamk.signal.output.OutputWriter;
import org.asamk.signal.output.PlainTextWriter;
+import org.asamk.signal.util.CommandUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class ListGroupsCommand implements JsonRpcLocalCommand {
- private final static Logger logger = LoggerFactory.getLogger(ListGroupsCommand.class);
+ private static final Logger logger = LoggerFactory.getLogger(ListGroupsCommand.class);
@Override
public String getName() {
subparser.addArgument("-d", "--detailed")
.action(Arguments.storeTrue())
.help("List the members and group invite links of each group. If output=json, then this is always set");
+ subparser.addArgument("-g", "--group-id").help("Specify one or more group IDs to show.").nargs("*");
}
private static Set<String> resolveMembers(Set<RecipientAddress> addresses) {
.collect(Collectors.toSet());
}
- private static void printGroupPlainText(
- PlainTextWriter writer, Group group, boolean detailed
- ) {
+ private static void printGroupPlainText(PlainTextWriter writer, Group group, boolean detailed) {
if (detailed) {
final var groupInviteLink = group.groupInviteLinkUrl();
@Override
public void handleCommand(
- final Namespace ns, final Manager m, final OutputWriter outputWriter
+ final Namespace ns,
+ final Manager m,
+ final OutputWriter outputWriter
) throws CommandException {
- final var groups = m.getGroups();
-
- if (outputWriter instanceof JsonWriter jsonWriter) {
-
- var jsonGroups = groups.stream().map(group -> {
- final var groupInviteLink = group.groupInviteLinkUrl();
-
- return new JsonGroup(group.groupId().toBase64(),
- group.title(),
- group.description(),
- group.isMember(),
- group.isBlocked(),
- group.messageExpirationTimer(),
- resolveJsonMembers(group.members()),
- resolveJsonMembers(group.pendingMembers()),
- resolveJsonMembers(group.requestingMembers()),
- resolveJsonMembers(group.adminMembers()),
- resolveJsonMembers(group.bannedMembers()),
- group.permissionAddMember().name(),
- group.permissionEditDetails().name(),
- group.permissionSendMessage().name(),
- groupInviteLink == null ? null : groupInviteLink.getUrl());
- }).toList();
-
- jsonWriter.write(jsonGroups);
- } else {
- final var writer = (PlainTextWriter) outputWriter;
- boolean detailed = Boolean.TRUE.equals(ns.getBoolean("detailed"));
- for (var group : groups) {
- printGroupPlainText(writer, group, detailed);
+ var groups = m.getGroups();
+
+ final var groupIdStrings = ns.<String>getList("group-id");
+ final var groupIds = CommandUtil.getGroupIds(groupIdStrings);
+ if (!groupIds.isEmpty()) {
+ groups = groups.stream().filter(g -> groupIds.contains(g.groupId())).toList();
+ }
+
+ switch (outputWriter) {
+ case JsonWriter jsonWriter -> {
+ var jsonGroups = groups.stream().map(group -> {
+ final var groupInviteLink = group.groupInviteLinkUrl();
+
+ return new JsonGroup(group.groupId().toBase64(),
+ group.title(),
+ group.description(),
+ group.isMember(),
+ group.isBlocked(),
+ group.messageExpirationTimer(),
+ resolveJsonMembers(group.members()),
+ resolveJsonMembers(group.pendingMembers()),
+ resolveJsonMembers(group.requestingMembers()),
+ resolveJsonMembers(group.adminMembers()),
+ resolveJsonMembers(group.bannedMembers()),
+ group.permissionAddMember().name(),
+ group.permissionEditDetails().name(),
+ group.permissionSendMessage().name(),
+ groupInviteLink == null ? null : groupInviteLink.getUrl());
+ }).toList();
+ jsonWriter.write(jsonGroups);
+ }
+ case PlainTextWriter writer -> {
+ boolean detailed = Boolean.TRUE.equals(ns.getBoolean("detailed"));
+ for (var group : groups) {
+ printGroupPlainText(writer, group, detailed);
+ }
}
}
}