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
  11 enum JsonSyncMessageType {
  12     CONTACTS_SYNC,
  13     GROUPS_SYNC,
  14     REQUEST_SYNC
  15 }
  16
  17 record JsonSyncMessage(
  18         @JsonInclude(JsonInclude.Include.NON_NULL) JsonSyncDataMessage sentMessage,
  19         @JsonInclude(JsonInclude.Include.NON_NULL) List<String> blockedNumbers,
  20         @JsonInclude(JsonInclude.Include.NON_NULL) List<String> blockedGroupIds,
  21         @JsonInclude(JsonInclude.Include.NON_NULL) List<JsonSyncReadMessage> readMessages,
  22         @JsonInclude(JsonInclude.Include.NON_NULL) JsonSyncMessageType type
  23 ) {
  24
  25     JsonSyncMessage(
  26             final JsonSyncDataMessage sentMessage,
  27             final List<String> blockedNumbers,
  28             final List<String> blockedGroupIds,
  29             final List<JsonSyncReadMessage> readMessages,
  30             final JsonSyncMessageType type
  31     ) {
  32         this.sentMessage = sentMessage;
  33         this.blockedNumbers = blockedNumbers;
  34         this.blockedGroupIds = blockedGroupIds;
  35         this.readMessages = readMessages;
  36         this.type = type;
  37     }
  38
  39     static JsonSyncMessage from(MessageEnvelope.Sync syncMessage) {
  40         final var sentMessage = syncMessage.sent().isPresent()
  41                 ? JsonSyncDataMessage.from(syncMessage.sent().get())
  42                 : null;
  43         final List<String> blockedNumbers;
  44         final List<String> blockedGroupIds;
  45         if (syncMessage.blocked().isPresent()) {
  46             blockedNumbers = syncMessage.blocked()
  47                     .get()
  48                     .recipients()
  49                     .stream()
  50                     .map(RecipientAddress::getLegacyIdentifier)
  51                     .toList();
  52             blockedGroupIds = syncMessage.blocked().get().groupIds().stream().map(GroupId::toBase64).toList();
  53         } else {
  54             blockedNumbers = null;
  55             blockedGroupIds = null;
  56         }
  57
  58         final var readMessages = syncMessage.read().size() > 0 ? syncMessage.read()
  59                 .stream()
  60                 .map(JsonSyncReadMessage::from)
  61                 .toList() : null;
  62
  63         final JsonSyncMessageType type;
  64         if (syncMessage.contacts().isPresent()) {
  65             type = JsonSyncMessageType.CONTACTS_SYNC;
  66         } else if (syncMessage.groups().isPresent()) {
  67             type = JsonSyncMessageType.GROUPS_SYNC;
  68         } else {
  69             type = null;
  70         }
  71         return new JsonSyncMessage(sentMessage, blockedNumbers, blockedGroupIds, readMessages, type);
  72     }
  73 }