nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/json/JsonSyncMessage.java

   1 package org.asamk.signal.json;
   2
   3 import com.fasterxml.jackson.annotation.JsonInclude;
   4
   5 import org.asamk.signal.manager.api.MessageEnvelope;
   6 import org.asamk.signal.manager.groups.GroupId;
   7 import org.asamk.signal.manager.storage.recipients.RecipientAddress;
   8
   9 import java.util.List;
  10 import java.util.stream.Collectors;
  11
  12 enum JsonSyncMessageType {
  13     CONTACTS_SYNC,
  14     GROUPS_SYNC,
  15     REQUEST_SYNC
  16 }
  17
  18 record JsonSyncMessage(
  19         @JsonInclude(JsonInclude.Include.NON_NULL) JsonSyncDataMessage sentMessage,
  20         @JsonInclude(JsonInclude.Include.NON_NULL) List<String> blockedNumbers,
  21         @JsonInclude(JsonInclude.Include.NON_NULL) List<String> blockedGroupIds,
  22         @JsonInclude(JsonInclude.Include.NON_NULL) List<JsonSyncReadMessage> readMessages,
  23         @JsonInclude(JsonInclude.Include.NON_NULL) JsonSyncMessageType type
  24 ) {
  25
  26     JsonSyncMessage(
  27             final JsonSyncDataMessage sentMessage,
  28             final List<String> blockedNumbers,
  29             final List<String> blockedGroupIds,
  30             final List<JsonSyncReadMessage> readMessages,
  31             final JsonSyncMessageType type
  32     ) {
  33         this.sentMessage = sentMessage;
  34         this.blockedNumbers = blockedNumbers;
  35         this.blockedGroupIds = blockedGroupIds;
  36         this.readMessages = readMessages;
  37         this.type = type;
  38     }
  39
  40     static JsonSyncMessage from(MessageEnvelope.Sync syncMessage) {
  41         final var sentMessage = syncMessage.sent().isPresent()
  42                 ? JsonSyncDataMessage.from(syncMessage.sent().get())
  43                 : null;
  44         final List<String> blockedNumbers;
  45         final List<String> blockedGroupIds;
  46         if (syncMessage.blocked().isPresent()) {
  47             blockedNumbers = syncMessage.blocked()
  48                     .get()
  49                     .recipients()
  50                     .stream()
  51                     .map(RecipientAddress::getLegacyIdentifier)
  52                     .collect(Collectors.toList());
  53             blockedGroupIds = syncMessage.blocked()
  54                     .get()
  55                     .groupIds()
  56                     .stream()
  57                     .map(GroupId::toBase64)
  58                     .collect(Collectors.toList());
  59         } else {
  60             blockedNumbers = null;
  61             blockedGroupIds = null;
  62         }
  63
  64         final var readMessages = syncMessage.read().size() > 0 ? syncMessage.read()
  65                 .stream()
  66                 .map(JsonSyncReadMessage::from)
  67                 .collect(Collectors.toList()) : null;
  68
  69         final JsonSyncMessageType type;
  70         if (syncMessage.contacts().isPresent()) {
  71             type = JsonSyncMessageType.CONTACTS_SYNC;
  72         } else if (syncMessage.groups().isPresent()) {
  73             type = JsonSyncMessageType.GROUPS_SYNC;
  74         } else {
  75             type = null;
  76         }
  77         return new JsonSyncMessage(sentMessage, blockedNumbers, blockedGroupIds, readMessages, type);
  78     }
  79 }