1 package org
.asamk
.signal
;
3 import org
.asamk
.signal
.manager
.Manager
;
4 import org
.asamk
.signal
.manager
.groups
.GroupId
;
5 import org
.asamk
.signal
.manager
.groups
.GroupUtils
;
6 import org
.asamk
.signal
.manager
.storage
.groups
.GroupInfo
;
7 import org
.asamk
.signal
.util
.DateUtils
;
8 import org
.asamk
.signal
.util
.Util
;
9 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachment
;
10 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachmentPointer
;
11 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceContent
;
12 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceDataMessage
;
13 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceEnvelope
;
14 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroup
;
15 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupContext
;
16 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupV2
;
17 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceReceiptMessage
;
18 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceTypingMessage
;
19 import org
.whispersystems
.signalservice
.api
.messages
.calls
.AnswerMessage
;
20 import org
.whispersystems
.signalservice
.api
.messages
.calls
.BusyMessage
;
21 import org
.whispersystems
.signalservice
.api
.messages
.calls
.HangupMessage
;
22 import org
.whispersystems
.signalservice
.api
.messages
.calls
.IceUpdateMessage
;
23 import org
.whispersystems
.signalservice
.api
.messages
.calls
.OfferMessage
;
24 import org
.whispersystems
.signalservice
.api
.messages
.calls
.OpaqueMessage
;
25 import org
.whispersystems
.signalservice
.api
.messages
.calls
.SignalServiceCallMessage
;
26 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.BlockedListMessage
;
27 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ConfigurationMessage
;
28 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ContactsMessage
;
29 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.KeysMessage
;
30 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.MessageRequestResponseMessage
;
31 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ReadMessage
;
32 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SentTranscriptMessage
;
33 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SignalServiceSyncMessage
;
34 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.StickerPackOperationMessage
;
35 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.VerifiedMessage
;
36 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ViewOnceOpenMessage
;
37 import org
.whispersystems
.signalservice
.api
.messages
.shared
.SharedContact
;
38 import org
.whispersystems
.signalservice
.api
.push
.SignalServiceAddress
;
41 import java
.util
.Base64
;
42 import java
.util
.List
;
44 public class ReceiveMessageHandler
implements Manager
.ReceiveMessageHandler
{
48 public ReceiveMessageHandler(Manager m
) {
53 public void handleMessage(SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
) {
54 if (!envelope
.isUnidentifiedSender() && envelope
.hasSource()) {
55 SignalServiceAddress source
= envelope
.getSourceAddress();
56 String name
= m
.getContactOrProfileName(source
.getLegacyIdentifier());
57 System
.out
.println(String
.format("Envelope from: %s (device: %d)",
58 (name
== null ?
"" : "“" + name
+ "” ") + source
.getLegacyIdentifier(),
59 envelope
.getSourceDevice()));
60 if (source
.getRelay().isPresent()) {
61 System
.out
.println("Relayed by: " + source
.getRelay().get());
64 System
.out
.println("Envelope from: unknown source");
66 System
.out
.println("Timestamp: " + DateUtils
.formatTimestamp(envelope
.getTimestamp()));
67 if (envelope
.isUnidentifiedSender()) {
68 System
.out
.println("Sent by unidentified/sealed sender");
71 if (envelope
.isReceipt()) {
72 System
.out
.println("Got receipt.");
73 } else if (envelope
.isSignalMessage() || envelope
.isPreKeySignalMessage() || envelope
.isUnidentifiedSender()) {
74 if (exception
!= null) {
75 if (exception
instanceof org
.whispersystems
.libsignal
.UntrustedIdentityException
) {
76 org
.whispersystems
.libsignal
.UntrustedIdentityException e
= (org
.whispersystems
.libsignal
.UntrustedIdentityException
) exception
;
78 "The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
79 System
.out
.println("Use 'signal-cli -u "
81 + " listIdentities -n "
83 + "', verify the key and run 'signal-cli -u "
85 + " trust -v \"FINGER_PRINT\" "
87 + "' to mark it as trusted");
88 System
.out
.println("If you don't care about security, use 'signal-cli -u "
92 + "' to trust it without verification");
94 System
.out
.println("Exception: " + exception
.getMessage() + " (" + exception
.getClass()
95 .getSimpleName() + ")");
98 if (content
== null) {
99 System
.out
.println("Failed to decrypt message.");
101 String senderName
= m
.getContactOrProfileName(content
.getSender().getLegacyIdentifier());
102 System
.out
.println(String
.format("Sender: %s (device: %d)",
103 (senderName
== null ?
"" : "“" + senderName
+ "” ") + content
.getSender().getLegacyIdentifier(),
104 content
.getSenderDevice()));
105 if (content
.getDataMessage().isPresent()) {
106 SignalServiceDataMessage message
= content
.getDataMessage().get();
107 handleSignalServiceDataMessage(message
);
109 if (content
.getSyncMessage().isPresent()) {
110 System
.out
.println("Received a sync message");
111 SignalServiceSyncMessage syncMessage
= content
.getSyncMessage().get();
113 if (syncMessage
.getContacts().isPresent()) {
114 final ContactsMessage contactsMessage
= syncMessage
.getContacts().get();
115 if (contactsMessage
.isComplete()) {
116 System
.out
.println("Received complete sync contacts");
118 System
.out
.println("Received sync contacts");
120 printAttachment(contactsMessage
.getContactsStream(), 0);
122 if (syncMessage
.getGroups().isPresent()) {
123 System
.out
.println("Received sync groups");
124 printAttachment(syncMessage
.getGroups().get(), 0);
126 if (syncMessage
.getRead().isPresent()) {
127 System
.out
.println("Received sync read messages list");
128 for (ReadMessage rm
: syncMessage
.getRead().get()) {
129 String name
= m
.getContactOrProfileName(rm
.getSender().getLegacyIdentifier());
130 System
.out
.println("From: "
131 + (name
== null ?
"" : "“" + name
+ "” ")
133 .getLegacyIdentifier()
134 + " Message timestamp: "
135 + DateUtils
.formatTimestamp(rm
.getTimestamp()));
138 if (syncMessage
.getRequest().isPresent()) {
139 System
.out
.println("Received sync request");
140 if (syncMessage
.getRequest().get().isContactsRequest()) {
141 System
.out
.println(" - contacts request");
143 if (syncMessage
.getRequest().get().isGroupsRequest()) {
144 System
.out
.println(" - groups request");
146 if (syncMessage
.getRequest().get().isBlockedListRequest()) {
147 System
.out
.println(" - blocked list request");
149 if (syncMessage
.getRequest().get().isConfigurationRequest()) {
150 System
.out
.println(" - configuration request");
152 if (syncMessage
.getRequest().get().isKeysRequest()) {
153 System
.out
.println(" - keys request");
156 if (syncMessage
.getSent().isPresent()) {
157 System
.out
.println("Received sync sent message");
158 final SentTranscriptMessage sentTranscriptMessage
= syncMessage
.getSent().get();
160 if (sentTranscriptMessage
.getDestination().isPresent()) {
161 String dest
= sentTranscriptMessage
.getDestination().get().getLegacyIdentifier();
162 String name
= m
.getContactOrProfileName(dest
);
163 to = (name
== null ?
"" : "“" + name
+ "” ") + dest
;
164 } else if (sentTranscriptMessage
.getRecipients().size() > 0) {
165 StringBuilder toBuilder
= new StringBuilder();
166 for (SignalServiceAddress dest
: sentTranscriptMessage
.getRecipients()) {
167 String name
= m
.getContactOrProfileName(dest
.getLegacyIdentifier());
168 toBuilder
.append(name
== null ?
"" : "“" + name
+ "” ")
169 .append(dest
.getLegacyIdentifier())
172 to = toBuilder
.toString();
176 System
.out
.println("To: " + to + " , Message timestamp: " + DateUtils
.formatTimestamp(
177 sentTranscriptMessage
.getTimestamp()));
178 if (sentTranscriptMessage
.getExpirationStartTimestamp() > 0) {
179 System
.out
.println("Expiration started at: " + DateUtils
.formatTimestamp(
180 sentTranscriptMessage
.getExpirationStartTimestamp()));
182 SignalServiceDataMessage message
= sentTranscriptMessage
.getMessage();
183 handleSignalServiceDataMessage(message
);
185 if (syncMessage
.getBlockedList().isPresent()) {
186 System
.out
.println("Received sync message with block list");
187 System
.out
.println("Blocked numbers:");
188 final BlockedListMessage blockedList
= syncMessage
.getBlockedList().get();
189 for (SignalServiceAddress address
: blockedList
.getAddresses()) {
190 System
.out
.println(" - " + address
.getLegacyIdentifier());
193 if (syncMessage
.getVerified().isPresent()) {
194 System
.out
.println("Received sync message with verified identities:");
195 final VerifiedMessage verifiedMessage
= syncMessage
.getVerified().get();
196 System
.out
.println(" - "
197 + verifiedMessage
.getDestination()
199 + verifiedMessage
.getVerified());
200 String safetyNumber
= Util
.formatSafetyNumber(m
.computeSafetyNumber(verifiedMessage
.getDestination(),
201 verifiedMessage
.getIdentityKey()));
202 System
.out
.println(" " + safetyNumber
);
204 if (syncMessage
.getConfiguration().isPresent()) {
205 System
.out
.println("Received sync message with configuration:");
206 final ConfigurationMessage configurationMessage
= syncMessage
.getConfiguration().get();
207 if (configurationMessage
.getReadReceipts().isPresent()) {
208 System
.out
.println(" - Read receipts: " + (
209 configurationMessage
.getReadReceipts().get() ?
"enabled" : "disabled"
212 if (configurationMessage
.getLinkPreviews().isPresent()) {
213 System
.out
.println(" - Link previews: " + (
214 configurationMessage
.getLinkPreviews().get() ?
"enabled" : "disabled"
217 if (configurationMessage
.getTypingIndicators().isPresent()) {
218 System
.out
.println(" - Typing indicators: " + (
219 configurationMessage
.getTypingIndicators().get() ?
"enabled" : "disabled"
222 if (configurationMessage
.getUnidentifiedDeliveryIndicators().isPresent()) {
223 System
.out
.println(" - Unidentified Delivery Indicators: " + (
224 configurationMessage
.getUnidentifiedDeliveryIndicators().get()
230 if (syncMessage
.getFetchType().isPresent()) {
231 final SignalServiceSyncMessage
.FetchType fetchType
= syncMessage
.getFetchType().get();
232 System
.out
.println("Received sync message with fetch type: " + fetchType
.toString());
234 if (syncMessage
.getViewOnceOpen().isPresent()) {
235 final ViewOnceOpenMessage viewOnceOpenMessage
= syncMessage
.getViewOnceOpen().get();
236 System
.out
.println("Received sync message with view once open message:");
237 System
.out
.println(" - Sender:" + viewOnceOpenMessage
.getSender().getLegacyIdentifier());
238 System
.out
.println(" - Timestamp:" + viewOnceOpenMessage
.getTimestamp());
240 if (syncMessage
.getStickerPackOperations().isPresent()) {
241 final List
<StickerPackOperationMessage
> stickerPackOperationMessages
= syncMessage
.getStickerPackOperations()
243 System
.out
.println("Received sync message with sticker pack operations:");
244 for (StickerPackOperationMessage m
: stickerPackOperationMessages
) {
245 System
.out
.println(" - " + m
.getType().toString());
246 if (m
.getPackId().isPresent()) {
247 System
.out
.println(" packId: " + Base64
.getEncoder()
248 .encodeToString(m
.getPackId().get()));
250 if (m
.getPackKey().isPresent()) {
251 System
.out
.println(" packKey: " + Base64
.getEncoder()
252 .encodeToString(m
.getPackKey().get()));
256 if (syncMessage
.getMessageRequestResponse().isPresent()) {
257 final MessageRequestResponseMessage requestResponseMessage
= syncMessage
.getMessageRequestResponse()
259 System
.out
.println("Received message request response:");
260 System
.out
.println(" Type: " + requestResponseMessage
.getType());
261 if (requestResponseMessage
.getGroupId().isPresent()) {
262 System
.out
.println(" Group id: " + Base64
.getEncoder()
263 .encodeToString(requestResponseMessage
.getGroupId().get()));
265 if (requestResponseMessage
.getPerson().isPresent()) {
266 System
.out
.println(" Person: " + requestResponseMessage
.getPerson()
268 .getLegacyIdentifier());
271 if (syncMessage
.getKeys().isPresent()) {
272 final KeysMessage keysMessage
= syncMessage
.getKeys().get();
273 System
.out
.println("Received sync message with keys:");
274 if (keysMessage
.getStorageService().isPresent()) {
275 System
.out
.println(" With storage key length: " + keysMessage
.getStorageService()
277 .serialize().length
);
279 System
.out
.println(" With empty storage key");
283 if (content
.getCallMessage().isPresent()) {
284 System
.out
.println("Received a call message");
285 SignalServiceCallMessage callMessage
= content
.getCallMessage().get();
286 if (callMessage
.getDestinationDeviceId().isPresent()) {
287 final Integer deviceId
= callMessage
.getDestinationDeviceId().get();
288 System
.out
.println("Destination device id: " + deviceId
);
290 if (callMessage
.getAnswerMessage().isPresent()) {
291 AnswerMessage answerMessage
= callMessage
.getAnswerMessage().get();
292 System
.out
.println("Answer message: " + answerMessage
.getId() + ": " + answerMessage
.getSdp());
294 if (callMessage
.getBusyMessage().isPresent()) {
295 BusyMessage busyMessage
= callMessage
.getBusyMessage().get();
296 System
.out
.println("Busy message: " + busyMessage
.getId());
298 if (callMessage
.getHangupMessage().isPresent()) {
299 HangupMessage hangupMessage
= callMessage
.getHangupMessage().get();
300 System
.out
.println("Hangup message: " + hangupMessage
.getId());
302 if (callMessage
.getIceUpdateMessages().isPresent()) {
303 List
<IceUpdateMessage
> iceUpdateMessages
= callMessage
.getIceUpdateMessages().get();
304 for (IceUpdateMessage iceUpdateMessage
: iceUpdateMessages
) {
305 System
.out
.println("Ice update message: "
306 + iceUpdateMessage
.getId()
308 + iceUpdateMessage
.getSdp());
311 if (callMessage
.getOfferMessage().isPresent()) {
312 OfferMessage offerMessage
= callMessage
.getOfferMessage().get();
313 System
.out
.println("Offer message: " + offerMessage
.getId() + ": " + offerMessage
.getSdp());
315 if (callMessage
.getOpaqueMessage().isPresent()) {
316 final OpaqueMessage opaqueMessage
= callMessage
.getOpaqueMessage().get();
317 System
.out
.println("Opaque message: size " + opaqueMessage
.getOpaque().length
);
320 if (content
.getReceiptMessage().isPresent()) {
321 System
.out
.println("Received a receipt message");
322 SignalServiceReceiptMessage receiptMessage
= content
.getReceiptMessage().get();
323 System
.out
.println(" - When: " + DateUtils
.formatTimestamp(receiptMessage
.getWhen()));
324 if (receiptMessage
.isDeliveryReceipt()) {
325 System
.out
.println(" - Is delivery receipt");
327 if (receiptMessage
.isReadReceipt()) {
328 System
.out
.println(" - Is read receipt");
330 if (receiptMessage
.isViewedReceipt()) {
331 System
.out
.println(" - Is viewed receipt");
333 System
.out
.println(" - Timestamps:");
334 for (long timestamp
: receiptMessage
.getTimestamps()) {
335 System
.out
.println(" " + DateUtils
.formatTimestamp(timestamp
));
338 if (content
.getTypingMessage().isPresent()) {
339 System
.out
.println("Received a typing message");
340 SignalServiceTypingMessage typingMessage
= content
.getTypingMessage().get();
341 System
.out
.println(" - Action: " + typingMessage
.getAction());
342 System
.out
.println(" - Timestamp: " + DateUtils
.formatTimestamp(typingMessage
.getTimestamp()));
343 if (typingMessage
.getGroupId().isPresent()) {
344 System
.out
.println(" - Group Info:");
345 final GroupId groupId
= GroupId
.unknownVersion(typingMessage
.getGroupId().get());
346 System
.out
.println(" Id: " + groupId
.toBase64());
347 GroupInfo group
= m
.getGroup(groupId
);
349 System
.out
.println(" Name: " + group
.getTitle());
351 System
.out
.println(" Name: <Unknown group>");
357 System
.out
.println("Unknown message received.");
359 System
.out
.println();
362 private void handleSignalServiceDataMessage(SignalServiceDataMessage message
) {
363 System
.out
.println("Message timestamp: " + DateUtils
.formatTimestamp(message
.getTimestamp()));
364 if (message
.isViewOnce()) {
365 System
.out
.println("=VIEW ONCE=");
368 if (message
.getBody().isPresent()) {
369 System
.out
.println("Body: " + message
.getBody().get());
371 if (message
.getGroupContext().isPresent()) {
372 System
.out
.println("Group info:");
373 final SignalServiceGroupContext groupContext
= message
.getGroupContext().get();
374 final GroupId groupId
= GroupUtils
.getGroupId(groupContext
);
375 if (groupContext
.getGroupV1().isPresent()) {
376 SignalServiceGroup groupInfo
= groupContext
.getGroupV1().get();
377 System
.out
.println(" Id: " + groupId
.toBase64());
378 if (groupInfo
.getType() == SignalServiceGroup
.Type
.UPDATE
&& groupInfo
.getName().isPresent()) {
379 System
.out
.println(" Name: " + groupInfo
.getName().get());
381 GroupInfo group
= m
.getGroup(groupId
);
383 System
.out
.println(" Name: " + group
.getTitle());
385 System
.out
.println(" Name: <Unknown group>");
388 System
.out
.println(" Type: " + groupInfo
.getType());
389 if (groupInfo
.getMembers().isPresent()) {
390 for (SignalServiceAddress member
: groupInfo
.getMembers().get()) {
391 System
.out
.println(" Member: " + member
.getLegacyIdentifier());
394 if (groupInfo
.getAvatar().isPresent()) {
395 System
.out
.println(" Avatar:");
396 printAttachment(groupInfo
.getAvatar().get(), 2);
398 } else if (groupContext
.getGroupV2().isPresent()) {
399 final SignalServiceGroupV2 groupInfo
= groupContext
.getGroupV2().get();
400 System
.out
.println(" Id: " + groupId
.toBase64());
401 GroupInfo group
= m
.getGroup(groupId
);
403 System
.out
.println(" Name: " + group
.getTitle());
405 System
.out
.println(" Name: <Unknown group>");
407 System
.out
.println(" Revision: " + groupInfo
.getRevision());
408 System
.out
.println(" Master key length: " + groupInfo
.getMasterKey().serialize().length
);
409 System
.out
.println(" Has signed group change: " + groupInfo
.hasSignedGroupChange());
412 if (message
.getGroupCallUpdate().isPresent()) {
413 final SignalServiceDataMessage
.GroupCallUpdate groupCallUpdate
= message
.getGroupCallUpdate().get();
414 System
.out
.println("Group call update:");
415 System
.out
.println(" - Era id: " + groupCallUpdate
.getEraId());
417 if (message
.getPreviews().isPresent()) {
418 final List
<SignalServiceDataMessage
.Preview
> previews
= message
.getPreviews().get();
419 System
.out
.println("Previews:");
420 for (SignalServiceDataMessage
.Preview preview
: previews
) {
421 System
.out
.println(" - Title: " + preview
.getTitle());
422 System
.out
.println(" - Url: " + preview
.getUrl());
423 if (preview
.getImage().isPresent()) {
424 printAttachment(preview
.getImage().get(), 1);
428 if (message
.getSharedContacts().isPresent()) {
429 final List
<SharedContact
> sharedContacts
= message
.getSharedContacts().get();
430 System
.out
.println("Contacts:");
431 for (SharedContact contact
: sharedContacts
) {
432 System
.out
.println(" - Name:");
433 SharedContact
.Name name
= contact
.getName();
434 if (name
.getDisplay().isPresent() && !name
.getDisplay().get().isBlank()) {
435 System
.out
.println(" - Display name: " + name
.getDisplay().get());
437 if (name
.getGiven().isPresent() && !name
.getGiven().get().isBlank()) {
438 System
.out
.println(" - First name: " + name
.getGiven().get());
440 if (name
.getMiddle().isPresent() && !name
.getMiddle().get().isBlank()) {
441 System
.out
.println(" - Middle name: " + name
.getMiddle().get());
443 if (name
.getFamily().isPresent() && !name
.getFamily().get().isBlank()) {
444 System
.out
.println(" - Family name: " + name
.getFamily().get());
446 if (name
.getPrefix().isPresent() && !name
.getPrefix().get().isBlank()) {
447 System
.out
.println(" - Prefix name: " + name
.getPrefix().get());
449 if (name
.getSuffix().isPresent() && !name
.getSuffix().get().isBlank()) {
450 System
.out
.println(" - Suffix name: " + name
.getSuffix().get());
453 if (contact
.getAvatar().isPresent()) {
454 SharedContact
.Avatar avatar
= contact
.getAvatar().get();
455 System
.out
.println(" - Avatar:");
456 printAttachment(avatar
.getAttachment(), 3);
457 if (avatar
.isProfile()) {
458 System
.out
.println(" - Is profile");
460 System
.out
.println(" - Is not a profile");
464 if (contact
.getPhone().isPresent()) {
465 System
.out
.println(" - Phone details:");
466 for (SharedContact
.Phone phone
: contact
.getPhone().get()) {
467 System
.out
.println(" - Phone:");
468 if (phone
.getValue() != null) {
469 System
.out
.println(" - Number: " + phone
.getValue());
471 if (phone
.getType() != null) {
472 System
.out
.println(" - Type: " + phone
.getType());
474 if (phone
.getLabel().isPresent() && !phone
.getLabel().get().isBlank()) {
475 System
.out
.println(" - Label: " + phone
.getLabel().get());
480 if (contact
.getEmail().isPresent()) {
481 System
.out
.println(" - Email details:");
482 for (SharedContact
.Email email
: contact
.getEmail().get()) {
483 System
.out
.println(" - Email:");
484 if (email
.getValue() != null) {
485 System
.out
.println(" - Value: " + email
.getValue());
487 if (email
.getType() != null) {
488 System
.out
.println(" - Type: " + email
.getType());
490 if (email
.getLabel().isPresent() && !email
.getLabel().get().isBlank()) {
491 System
.out
.println(" - Label: " + email
.getLabel().get());
496 if (contact
.getAddress().isPresent()) {
497 System
.out
.println(" - Address details:");
498 for (SharedContact
.PostalAddress address
: contact
.getAddress().get()) {
499 System
.out
.println(" - Address:");
500 if (address
.getType() != null) {
501 System
.out
.println(" - Type: " + address
.getType());
503 if (address
.getLabel().isPresent() && !address
.getLabel().get().isBlank()) {
504 System
.out
.println(" - Label: " + address
.getLabel().get());
506 if (address
.getStreet().isPresent() && !address
.getStreet().get().isBlank()) {
507 System
.out
.println(" - Street: " + address
.getStreet().get());
509 if (address
.getPobox().isPresent() && !address
.getPobox().get().isBlank()) {
510 System
.out
.println(" - Pobox: " + address
.getPobox().get());
512 if (address
.getNeighborhood().isPresent() && !address
.getNeighborhood().get().isBlank()) {
513 System
.out
.println(" - Neighbourhood: " + address
.getNeighborhood().get());
515 if (address
.getCity().isPresent() && !address
.getCity().get().isBlank()) {
516 System
.out
.println(" - City: " + address
.getCity().get());
518 if (address
.getRegion().isPresent() && !address
.getRegion().get().isBlank()) {
519 System
.out
.println(" - Region: " + address
.getRegion().get());
521 if (address
.getPostcode().isPresent() && !address
.getPostcode().get().isBlank()) {
522 System
.out
.println(" - Postcode: " + address
.getPostcode().get());
524 if (address
.getCountry().isPresent() && !address
.getCountry().get().isBlank()) {
525 System
.out
.println(" - Country: " + address
.getCountry().get());
530 System
.out
.println(" - Organisation: " +
531 (contact
.getOrganization().isPresent() ? contact
.getOrganization().get() : "-"));
534 if (message
.getSticker().isPresent()) {
535 final SignalServiceDataMessage
.Sticker sticker
= message
.getSticker().get();
536 System
.out
.println("Sticker:");
537 System
.out
.println(" - Pack id: " + Base64
.getEncoder().encodeToString(sticker
.getPackId()));
538 System
.out
.println(" - Pack key: " + Base64
.getEncoder().encodeToString(sticker
.getPackKey()));
539 System
.out
.println(" - Sticker id: " + sticker
.getStickerId());
540 // TODO also download sticker image ??
542 if (message
.isEndSession()) {
543 System
.out
.println("Is end session");
545 if (message
.isExpirationUpdate()) {
546 System
.out
.println("Is Expiration update: " + message
.isExpirationUpdate());
548 if (message
.getExpiresInSeconds() > 0) {
549 System
.out
.println("Expires in: " + message
.getExpiresInSeconds() + " seconds");
551 if (message
.getProfileKey().isPresent()) {
552 System
.out
.println("Profile key update, key length:" + message
.getProfileKey().get().length
);
555 if (message
.getReaction().isPresent()) {
556 final SignalServiceDataMessage
.Reaction reaction
= message
.getReaction().get();
557 System
.out
.println("Reaction:");
558 System
.out
.println(" - Emoji: " + reaction
.getEmoji());
559 System
.out
.println(" - Target author: " + m
.resolveSignalServiceAddress(reaction
.getTargetAuthor())
560 .getLegacyIdentifier());
561 System
.out
.println(" - Target timestamp: " + reaction
.getTargetSentTimestamp());
562 System
.out
.println(" - Is remove: " + reaction
.isRemove());
565 if (message
.getQuote().isPresent()) {
566 SignalServiceDataMessage
.Quote quote
= message
.getQuote().get();
567 System
.out
.println("Quote: (" + quote
.getId() + ")");
568 System
.out
.println(" Author: " + m
.resolveSignalServiceAddress(quote
.getAuthor()).getLegacyIdentifier());
569 System
.out
.println(" Text: " + quote
.getText());
570 if (quote
.getMentions() != null && quote
.getMentions().size() > 0) {
571 System
.out
.println(" Mentions: ");
572 for (SignalServiceDataMessage
.Mention mention
: quote
.getMentions()) {
573 printMention(mention
, m
, 1);
576 if (quote
.getAttachments().size() > 0) {
577 System
.out
.println(" Attachments: ");
578 for (SignalServiceDataMessage
.Quote
.QuotedAttachment attachment
: quote
.getAttachments()) {
579 System
.out
.println(" - Filename: " + attachment
.getFileName());
580 System
.out
.println(" Type: " + attachment
.getContentType());
581 System
.out
.println(" Thumbnail:");
582 if (attachment
.getThumbnail() != null) {
583 printAttachment(attachment
.getThumbnail(), 3);
589 if (message
.getRemoteDelete().isPresent()) {
590 final SignalServiceDataMessage
.RemoteDelete remoteDelete
= message
.getRemoteDelete().get();
591 System
.out
.println("Remote delete message: timestamp = " + remoteDelete
.getTargetSentTimestamp());
593 if (message
.getMentions().isPresent()) {
594 System
.out
.println("Mentions: ");
595 for (SignalServiceDataMessage
.Mention mention
: message
.getMentions().get()) {
596 printMention(mention
, m
, 0);
600 if (message
.getAttachments().isPresent()) {
601 System
.out
.println("Attachments: ");
602 for (SignalServiceAttachment attachment
: message
.getAttachments().get()) {
603 printAttachment(attachment
, 0);
609 * Prints the Signal mention information
611 * @param mention is the Signal mention to print
612 * @param m is the Manager. used to resolve UUIDs into phone numbers if possible
613 * @param leadingSpaces is the number of spaces you want the message to be indented by
615 private void printMention(SignalServiceDataMessage
.Mention mention
, Manager m
, int leadingSpaces
) {
616 String spaces
= " ".repeat(leadingSpaces
);
617 System
.out
.println(spaces
+ "- " + m
.resolveSignalServiceAddress(new SignalServiceAddress(mention
.getUuid(), null))
618 .getLegacyIdentifier() + ": " + mention
.getStart() + " (length: " + mention
.getLength() + ")");
622 * Prints the Signal attachment information
624 * @param attachment is the Signal attachment to print
625 * @param leadingSpaces is the number of spaces you want the message to be indented by
627 private void printAttachment(SignalServiceAttachment attachment
, int leadingSpaces
) {
628 String spaces
= " ".repeat(leadingSpaces
);
629 System
.out
.println(spaces
+ "- " + attachment
.getContentType() + " (" + (attachment
.isPointer() ?
"Pointer" : "") + (
630 attachment
.isStream() ?
"Stream" : ""
632 if (attachment
.isPointer()) {
633 final SignalServiceAttachmentPointer pointer
= attachment
.asPointer();
634 System
.out
.println(spaces
+ " Id: " + pointer
.getRemoteId() + " Key length: " + pointer
.getKey().length
);
635 System
.out
.println(spaces
+ " Filename: " + (
636 pointer
.getFileName().isPresent() ? pointer
.getFileName().get() : "-"
638 System
.out
.println(spaces
+ " Size: " + (
639 pointer
.getSize().isPresent() ? pointer
.getSize().get() + " bytes" : "<unavailable>"
641 pointer
.getPreview().isPresent() ?
" (Preview is available: "
642 + pointer
.getPreview().get().length
645 System
.out
.println(spaces
+ " Voice note: " + (pointer
.getVoiceNote() ?
"yes" : "no"));
646 System
.out
.println(spaces
+ " Dimensions: " + pointer
.getWidth() + "x" + pointer
.getHeight());
647 File file
= m
.getAttachmentFile(pointer
.getRemoteId());
649 System
.out
.println(spaces
+ " Stored plaintext in: " + file
);