package org.asamk.signal.json;
-import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonUnwrapped;
import org.asamk.Signal;
import org.asamk.signal.manager.Manager;
import org.whispersystems.signalservice.api.messages.multidevice.SentTranscriptMessage;
-import org.whispersystems.signalservice.api.push.SignalServiceAddress;
-class JsonSyncDataMessage extends JsonDataMessage {
+import static org.asamk.signal.util.Util.getLegacyIdentifier;
- @JsonProperty
- final String destination;
+record JsonSyncDataMessage(
+ @Deprecated String destination,
+ String destinationNumber,
+ String destinationUuid,
+ @JsonUnwrapped JsonDataMessage dataMessage
+) {
- JsonSyncDataMessage(SentTranscriptMessage transcriptMessage, Manager m) {
- super(transcriptMessage.getMessage(), m);
+ static JsonSyncDataMessage from(SentTranscriptMessage transcriptMessage, Manager m) {
+ if (transcriptMessage.getDestination().isPresent()) {
+ final var address = transcriptMessage.getDestination().get();
+ return new JsonSyncDataMessage(getLegacyIdentifier(address),
+ address.getNumber().orNull(),
+ address.getUuid().toString(),
+ JsonDataMessage.from(transcriptMessage.getMessage(), m));
- this.destination = transcriptMessage.getDestination()
- .transform(SignalServiceAddress::getLegacyIdentifier)
- .orNull();
+ } else {
+ return new JsonSyncDataMessage(null, null, null, JsonDataMessage.from(transcriptMessage.getMessage(), m));
+ }
}
- JsonSyncDataMessage(Signal.SyncMessageReceived messageReceived) {
- super(messageReceived);
- destination = messageReceived.getDestination();
+ static JsonSyncDataMessage from(Signal.SyncMessageReceived messageReceived) {
+ return new JsonSyncDataMessage(messageReceived.getDestination(),
+ null,
+ null,
+ JsonDataMessage.from(messageReceived));
}
}