1 package org
.asamk
.signal
.json
;
3 import com
.fasterxml
.jackson
.annotation
.JsonInclude
;
5 import org
.asamk
.signal
.manager
.api
.GroupId
;
6 import org
.asamk
.signal
.manager
.api
.MessageEnvelope
;
7 import org
.asamk
.signal
.manager
.api
.RecipientAddress
;
11 enum JsonSyncMessageType
{
17 record JsonSyncMessage(
18 @JsonInclude(JsonInclude
.Include
.NON_NULL
) JsonSyncDataMessage sentMessage
,
19 @JsonInclude(JsonInclude
.Include
.NON_NULL
) JsonSyncStoryMessage sentStoryMessage
,
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
26 static JsonSyncMessage
from(MessageEnvelope
.Sync syncMessage
) {
27 final var sentMessage
= syncMessage
.sent().isPresent() && syncMessage
.sent().get().story().isEmpty()
28 ? JsonSyncDataMessage
.from(syncMessage
.sent().get())
30 final var sentStoryMessage
= syncMessage
.sent().isPresent() && syncMessage
.sent().get().story().isPresent()
31 ? JsonSyncStoryMessage
.from(syncMessage
.sent().get())
33 final List
<String
> blockedNumbers
;
34 final List
<String
> blockedGroupIds
;
35 if (syncMessage
.blocked().isPresent()) {
36 blockedNumbers
= syncMessage
.blocked()
40 .map(RecipientAddress
::getLegacyIdentifier
)
42 blockedGroupIds
= syncMessage
.blocked().get().groupIds().stream().map(GroupId
::toBase64
).toList();
44 blockedNumbers
= null;
45 blockedGroupIds
= null;
48 final var readMessages
= syncMessage
.read().size() > 0 ? syncMessage
.read()
50 .map(JsonSyncReadMessage
::from
)
53 final JsonSyncMessageType type
;
54 if (syncMessage
.contacts().isPresent()) {
55 type
= JsonSyncMessageType
.CONTACTS_SYNC
;
56 } else if (syncMessage
.groups().isPresent()) {
57 type
= JsonSyncMessageType
.GROUPS_SYNC
;
61 return new JsonSyncMessage(sentMessage
, sentStoryMessage
, blockedNumbers
, blockedGroupIds
, readMessages
, type
);