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