nmode's Git Repositories - signal-cli/blob - lib/src/main/java/org/asamk/signal/manager/storage/groups/GroupInfo.java

   1 package org.asamk.signal.manager.storage.groups;
   2
   3 import org.asamk.signal.manager.groups.GroupId;
   4 import org.asamk.signal.manager.groups.GroupInviteLinkUrl;
   5 import org.asamk.signal.manager.storage.recipients.RecipientId;
   6
   7 import java.util.Set;
   8 import java.util.stream.Collectors;
   9 import java.util.stream.Stream;
  10
  11 public abstract class GroupInfo {
  12
  13     public abstract GroupId getGroupId();
  14
  15     public abstract String getTitle();
  16
  17     public abstract GroupInviteLinkUrl getGroupInviteLink();
  18
  19     public abstract Set<RecipientId> getMembers();
  20
  21     public Set<RecipientId> getPendingMembers() {
  22         return Set.of();
  23     }
  24
  25     public Set<RecipientId> getRequestingMembers() {
  26         return Set.of();
  27     }
  28
  29     public abstract boolean isBlocked();
  30
  31     public abstract void setBlocked(boolean blocked);
  32
  33     public abstract int getMessageExpirationTime();
  34
  35     public Set<RecipientId> getMembersWithout(RecipientId recipientId) {
  36         return getMembers().stream().filter(member -> !member.equals(recipientId)).collect(Collectors.toSet());
  37     }
  38
  39     public Set<RecipientId> getMembersIncludingPendingWithout(RecipientId recipientId) {
  40         return Stream.concat(getMembers().stream(), getPendingMembers().stream())
  41                 .filter(member -> !member.equals(recipientId))
  42                 .collect(Collectors.toSet());
  43     }
  44
  45     public boolean isMember(RecipientId recipientId) {
  46         return getMembers().contains(recipientId);
  47     }
  48
  49     public boolean isPendingMember(RecipientId recipientId) {
  50         return getPendingMembers().contains(recipientId);
  51     }
  52 }