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 String getDescription() {
  18         return null;
  19     }
  20
  21     public abstract GroupInviteLinkUrl getGroupInviteLink();
  22
  23     public abstract Set<RecipientId> getMembers();
  24
  25     public Set<RecipientId> getPendingMembers() {
  26         return Set.of();
  27     }
  28
  29     public Set<RecipientId> getRequestingMembers() {
  30         return Set.of();
  31     }
  32
  33     public abstract boolean isBlocked();
  34
  35     public abstract void setBlocked(boolean blocked);
  36
  37     public abstract int getMessageExpirationTime();
  38
  39     public Set<RecipientId> getMembersWithout(RecipientId recipientId) {
  40         return getMembers().stream().filter(member -> !member.equals(recipientId)).collect(Collectors.toSet());
  41     }
  42
  43     public Set<RecipientId> getMembersIncludingPendingWithout(RecipientId recipientId) {
  44         return Stream.concat(getMembers().stream(), getPendingMembers().stream())
  45                 .filter(member -> !member.equals(recipientId))
  46                 .collect(Collectors.toSet());
  47     }
  48
  49     public boolean isMember(RecipientId recipientId) {
  50         return getMembers().contains(recipientId);
  51     }
  52
  53     public boolean isPendingMember(RecipientId recipientId) {
  54         return getPendingMembers().contains(recipientId);
  55     }
  56 }