nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/json/JsonDataMessage.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
   7 import java.util.List;
   8 import java.util.stream.Collectors;
   9
  10 record JsonDataMessage(
  11         long timestamp,
  12         String message,
  13         Integer expiresInSeconds,
  14         @JsonInclude(JsonInclude.Include.NON_NULL) Boolean viewOnce,
  15         @JsonInclude(JsonInclude.Include.NON_NULL) JsonReaction reaction,
  16         @JsonInclude(JsonInclude.Include.NON_NULL) JsonQuote quote,
  17         @JsonInclude(JsonInclude.Include.NON_NULL) JsonPayment payment,
  18         @JsonInclude(JsonInclude.Include.NON_NULL) List<JsonMention> mentions,
  19         @JsonInclude(JsonInclude.Include.NON_NULL) List<JsonAttachment> attachments,
  20         @JsonInclude(JsonInclude.Include.NON_NULL) JsonSticker sticker,
  21         @JsonInclude(JsonInclude.Include.NON_NULL) JsonRemoteDelete remoteDelete,
  22         @JsonInclude(JsonInclude.Include.NON_NULL) List<JsonSharedContact> contacts,
  23         @JsonInclude(JsonInclude.Include.NON_NULL) JsonGroupInfo groupInfo
  24 ) {
  25
  26     static JsonDataMessage from(MessageEnvelope.Data dataMessage) {
  27         final var timestamp = dataMessage.timestamp();
  28         final var groupInfo = dataMessage.groupContext().isPresent() ? JsonGroupInfo.from(dataMessage.groupContext()
  29                 .get()) : null;
  30         final var message = dataMessage.body().orElse(null);
  31         final var expiresInSeconds = dataMessage.expiresInSeconds();
  32         final var viewOnce = dataMessage.isViewOnce();
  33         final var reaction = dataMessage.reaction().map(JsonReaction::from).orElse(null);
  34         final var quote = dataMessage.quote().isPresent() ? JsonQuote.from(dataMessage.quote().get()) : null;
  35         final var payment = dataMessage.payment().isPresent() ? JsonPayment.from(dataMessage.payment().get()) : null;
  36         final var mentions = dataMessage.mentions().size() > 0 ? dataMessage.mentions()
  37                 .stream()
  38                 .map(JsonMention::from)
  39                 .collect(Collectors.toList()) : null;
  40         final var remoteDelete = dataMessage.remoteDeleteId().isPresent()
  41                 ? new JsonRemoteDelete(dataMessage.remoteDeleteId().get())
  42                 : null;
  43         final var attachments = dataMessage.attachments().size() > 0 ? dataMessage.attachments()
  44                 .stream()
  45                 .map(JsonAttachment::from)
  46                 .collect(Collectors.toList()) : null;
  47         final var sticker = dataMessage.sticker().isPresent() ? JsonSticker.from(dataMessage.sticker().get()) : null;
  48
  49         final var contacts = dataMessage.sharedContacts().size() > 0 ? dataMessage.sharedContacts()
  50                 .stream()
  51                 .map(JsonSharedContact::from)
  52                 .collect(Collectors.toList()) : null;
  53         return new JsonDataMessage(timestamp,
  54                 message,
  55                 expiresInSeconds,
  56                 viewOnce,
  57                 reaction,
  58                 quote,
  59                 payment,
  60                 mentions,
  61                 attachments,
  62                 sticker,
  63                 remoteDelete,
  64                 contacts,
  65                 groupInfo);
  66     }
  67 }