1 package org
.asamk
.signal
;
3 import org
.asamk
.signal
.manager
.Manager
;
4 import org
.asamk
.signal
.manager
.UntrustedIdentityException
;
5 import org
.asamk
.signal
.manager
.api
.RecipientIdentifier
;
6 import org
.asamk
.signal
.manager
.groups
.GroupId
;
7 import org
.asamk
.signal
.manager
.groups
.GroupUtils
;
8 import org
.asamk
.signal
.util
.DateUtils
;
9 import org
.asamk
.signal
.util
.Util
;
10 import org
.slf4j
.helpers
.MessageFormatter
;
11 import org
.whispersystems
.libsignal
.protocol
.DecryptionErrorMessage
;
12 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachment
;
13 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceContent
;
14 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceDataMessage
;
15 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceEnvelope
;
16 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupContext
;
17 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceReceiptMessage
;
18 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceTypingMessage
;
19 import org
.whispersystems
.signalservice
.api
.messages
.calls
.SignalServiceCallMessage
;
20 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SignalServiceSyncMessage
;
21 import org
.whispersystems
.signalservice
.api
.messages
.shared
.SharedContact
;
22 import org
.whispersystems
.signalservice
.api
.push
.SignalServiceAddress
;
24 import java
.util
.ArrayList
;
25 import java
.util
.Base64
;
26 import java
.util
.stream
.Collectors
;
28 import static org
.asamk
.signal
.util
.Util
.getLegacyIdentifier
;
30 public class ReceiveMessageHandler
implements Manager
.ReceiveMessageHandler
{
33 final PlainTextWriter writer
;
35 public ReceiveMessageHandler(Manager m
, final PlainTextWriter writer
) {
41 public void handleMessage(SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
) {
42 if (envelope
.hasSourceUuid()) {
43 var source
= envelope
.getSourceAddress();
44 writer
.println("Envelope from: {} (device: {})", formatContact(source
), envelope
.getSourceDevice());
46 writer
.println("Envelope from: unknown source");
48 writer
.println("Timestamp: {}", DateUtils
.formatTimestamp(envelope
.getTimestamp()));
49 if (envelope
.isUnidentifiedSender()) {
50 writer
.println("Sent by unidentified/sealed sender");
53 if (envelope
.isReceipt()) {
54 writer
.println("Got receipt.");
55 } else if (envelope
.isSignalMessage() || envelope
.isPreKeySignalMessage() || envelope
.isUnidentifiedSender()) {
56 if (exception
!= null) {
57 if (exception
instanceof UntrustedIdentityException
) {
58 var e
= (UntrustedIdentityException
) exception
;
60 "The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
61 final var recipientName
= getLegacyIdentifier(m
.resolveSignalServiceAddress(e
.getSender()));
63 "Use 'signal-cli -u {} listIdentities -n {}', verify the key and run 'signal-cli -u {} trust -v \"FINGER_PRINT\" {}' to mark it as trusted",
69 "If you don't care about security, use 'signal-cli -u {} trust -a {}' to trust it without verification",
73 writer
.println("Exception: {} ({})", exception
.getMessage(), exception
.getClass().getSimpleName());
76 if (content
== null) {
77 writer
.println("No message content");
79 writer
.println("Sender: {} (device: {})",
80 formatContact(content
.getSender()),
81 content
.getSenderDevice());
82 writer
.println("Server timestamps: received: {} delivered: {}",
83 DateUtils
.formatTimestamp(content
.getServerReceivedTimestamp()),
84 DateUtils
.formatTimestamp(content
.getServerDeliveredTimestamp()));
86 if (content
.getSenderKeyDistributionMessage().isPresent()) {
87 final var message
= content
.getSenderKeyDistributionMessage().get();
88 writer
.println("Received a sender key distribution message for distributionId {}",
89 message
.getDistributionId());
92 if (content
.getDataMessage().isPresent()) {
93 var message
= content
.getDataMessage().get();
94 printDataMessage(writer
, message
);
96 if (content
.getSyncMessage().isPresent()) {
97 writer
.println("Received a sync message");
98 var syncMessage
= content
.getSyncMessage().get();
99 printSyncMessage(writer
, syncMessage
);
102 if (content
.getCallMessage().isPresent()) {
103 writer
.println("Received a call message");
104 var callMessage
= content
.getCallMessage().get();
105 printCallMessage(writer
.indentedWriter(), callMessage
);
107 if (content
.getReceiptMessage().isPresent()) {
108 writer
.println("Received a receipt message");
109 var receiptMessage
= content
.getReceiptMessage().get();
110 printReceiptMessage(writer
.indentedWriter(), receiptMessage
);
112 if (content
.getTypingMessage().isPresent()) {
113 writer
.println("Received a typing message");
114 var typingMessage
= content
.getTypingMessage().get();
115 printTypingMessage(writer
.indentedWriter(), typingMessage
);
117 if (content
.getDecryptionErrorMessage().isPresent()) {
118 writer
.println("Received a decryption error message (resend request)");
119 var decryptionErrorMessage
= content
.getDecryptionErrorMessage().get();
120 printDecryptionErrorMessage(writer
.indentedWriter(), decryptionErrorMessage
);
124 writer
.println("Unknown message received.");
129 private void printDataMessage(
130 PlainTextWriter writer
, SignalServiceDataMessage message
132 writer
.println("Message timestamp: {}", DateUtils
.formatTimestamp(message
.getTimestamp()));
133 if (message
.isViewOnce()) {
134 writer
.println("=VIEW ONCE=");
137 if (message
.getBody().isPresent()) {
138 writer
.println("Body: {}", message
.getBody().get());
140 if (message
.getGroupContext().isPresent()) {
141 writer
.println("Group info:");
142 final var groupContext
= message
.getGroupContext().get();
143 printGroupContext(writer
.indentedWriter(), groupContext
);
145 if (message
.getGroupCallUpdate().isPresent()) {
146 writer
.println("Group call update:");
147 final var groupCallUpdate
= message
.getGroupCallUpdate().get();
148 writer
.indentedWriter().println("Era id: {}", groupCallUpdate
.getEraId());
150 if (message
.getPreviews().isPresent()) {
151 writer
.println("Previews:");
152 final var previews
= message
.getPreviews().get();
153 for (var preview
: previews
) {
154 writer
.println("- Preview");
155 printPreview(writer
.indentedWriter(), preview
);
158 if (message
.getSharedContacts().isPresent()) {
159 final var sharedContacts
= message
.getSharedContacts().get();
160 writer
.println("Contacts:");
161 for (var contact
: sharedContacts
) {
162 writer
.println("- Contact:");
163 printSharedContact(writer
.indentedWriter(), contact
);
166 if (message
.getSticker().isPresent()) {
167 final var sticker
= message
.getSticker().get();
168 writer
.println("Sticker:");
169 printSticker(writer
.indentedWriter(), sticker
);
171 if (message
.isEndSession()) {
172 writer
.println("Is end session");
174 if (message
.isExpirationUpdate()) {
175 writer
.println("Is Expiration update: {}", message
.isExpirationUpdate());
177 if (message
.getExpiresInSeconds() > 0) {
178 writer
.println("Expires in: {} seconds", message
.getExpiresInSeconds());
180 if (message
.getProfileKey().isPresent()) {
181 writer
.println("Profile key update, key length: {}", message
.getProfileKey().get().length
);
183 if (message
.getReaction().isPresent()) {
184 writer
.println("Reaction:");
185 final var reaction
= message
.getReaction().get();
186 printReaction(writer
.indentedWriter(), reaction
);
188 if (message
.getQuote().isPresent()) {
189 writer
.println("Quote:");
190 var quote
= message
.getQuote().get();
191 printQuote(writer
.indentedWriter(), quote
);
193 if (message
.getRemoteDelete().isPresent()) {
194 final var remoteDelete
= message
.getRemoteDelete().get();
195 writer
.println("Remote delete message: timestamp = {}", remoteDelete
.getTargetSentTimestamp());
197 if (message
.getMentions().isPresent()) {
198 writer
.println("Mentions:");
199 for (var mention
: message
.getMentions().get()) {
200 printMention(writer
, mention
);
203 if (message
.getAttachments().isPresent()) {
204 writer
.println("Attachments:");
205 for (var attachment
: message
.getAttachments().get()) {
206 writer
.println("- Attachment:");
207 printAttachment(writer
.indentedWriter(), attachment
);
212 private void printTypingMessage(
213 final PlainTextWriter writer
, final SignalServiceTypingMessage typingMessage
215 writer
.println("Action: {}", typingMessage
.getAction());
216 writer
.println("Timestamp: {}", DateUtils
.formatTimestamp(typingMessage
.getTimestamp()));
217 if (typingMessage
.getGroupId().isPresent()) {
218 writer
.println("Group Info:");
219 final var groupId
= GroupId
.unknownVersion(typingMessage
.getGroupId().get());
220 printGroupInfo(writer
.indentedWriter(), groupId
);
224 private void printDecryptionErrorMessage(
225 final PlainTextWriter writer
, final DecryptionErrorMessage decryptionErrorMessage
227 writer
.println("Device id: {}", decryptionErrorMessage
.getDeviceId());
228 writer
.println("Timestamp: {}", DateUtils
.formatTimestamp(decryptionErrorMessage
.getTimestamp()));
229 writer
.println("Ratchet key: {}",
230 decryptionErrorMessage
.getRatchetKey().isPresent() ?
"is present" : "not present");
233 private void printReceiptMessage(
234 final PlainTextWriter writer
, final SignalServiceReceiptMessage receiptMessage
236 writer
.println("When: {}", DateUtils
.formatTimestamp(receiptMessage
.getWhen()));
237 if (receiptMessage
.isDeliveryReceipt()) {
238 writer
.println("Is delivery receipt");
240 if (receiptMessage
.isReadReceipt()) {
241 writer
.println("Is read receipt");
243 if (receiptMessage
.isViewedReceipt()) {
244 writer
.println("Is viewed receipt");
246 writer
.println("Timestamps:");
247 for (long timestamp
: receiptMessage
.getTimestamps()) {
248 writer
.println("- {}", DateUtils
.formatTimestamp(timestamp
));
252 private void printCallMessage(
253 final PlainTextWriter writer
, final SignalServiceCallMessage callMessage
255 if (callMessage
.getDestinationDeviceId().isPresent()) {
256 final var deviceId
= callMessage
.getDestinationDeviceId().get();
257 writer
.println("Destination device id: {}", deviceId
);
259 if (callMessage
.getGroupId().isPresent()) {
260 final var groupId
= GroupId
.unknownVersion(callMessage
.getGroupId().get());
261 writer
.println("Destination group id: {}", groupId
);
263 if (callMessage
.getTimestamp().isPresent()) {
264 writer
.println("Timestamp: {}", DateUtils
.formatTimestamp(callMessage
.getTimestamp().get()));
266 if (callMessage
.getAnswerMessage().isPresent()) {
267 var answerMessage
= callMessage
.getAnswerMessage().get();
268 writer
.println("Answer message: {}, sdp: {})", answerMessage
.getId(), answerMessage
.getSdp());
270 if (callMessage
.getBusyMessage().isPresent()) {
271 var busyMessage
= callMessage
.getBusyMessage().get();
272 writer
.println("Busy message: {}", busyMessage
.getId());
274 if (callMessage
.getHangupMessage().isPresent()) {
275 var hangupMessage
= callMessage
.getHangupMessage().get();
276 writer
.println("Hangup message: {}", hangupMessage
.getId());
278 if (callMessage
.getIceUpdateMessages().isPresent()) {
279 writer
.println("Ice update messages:");
280 var iceUpdateMessages
= callMessage
.getIceUpdateMessages().get();
281 for (var iceUpdateMessage
: iceUpdateMessages
) {
282 writer
.println("- {}, sdp: {}", iceUpdateMessage
.getId(), iceUpdateMessage
.getSdp());
285 if (callMessage
.getOfferMessage().isPresent()) {
286 var offerMessage
= callMessage
.getOfferMessage().get();
287 writer
.println("Offer message: {}, sdp: {}", offerMessage
.getId(), offerMessage
.getSdp());
289 if (callMessage
.getOpaqueMessage().isPresent()) {
290 final var opaqueMessage
= callMessage
.getOpaqueMessage().get();
291 writer
.println("Opaque message: size {}, urgency: {}",
292 opaqueMessage
.getOpaque().length
,
293 opaqueMessage
.getUrgency().name());
297 private void printSyncMessage(
298 final PlainTextWriter writer
, final SignalServiceSyncMessage syncMessage
300 if (syncMessage
.getContacts().isPresent()) {
301 final var contactsMessage
= syncMessage
.getContacts().get();
302 var type
= contactsMessage
.isComplete() ?
"complete" : "partial";
303 writer
.println("Received {} sync contacts:", type
);
304 printAttachment(writer
.indentedWriter(), contactsMessage
.getContactsStream());
306 if (syncMessage
.getGroups().isPresent()) {
307 writer
.println("Received sync groups:");
308 printAttachment(writer
.indentedWriter(), syncMessage
.getGroups().get());
310 if (syncMessage
.getRead().isPresent()) {
311 writer
.println("Received sync read messages list");
312 for (var rm
: syncMessage
.getRead().get()) {
313 writer
.println("- From: {} Message timestamp: {}",
314 formatContact(rm
.getSender()),
315 DateUtils
.formatTimestamp(rm
.getTimestamp()));
318 if (syncMessage
.getViewed().isPresent()) {
319 writer
.println("Received sync viewed messages list");
320 for (var vm
: syncMessage
.getViewed().get()) {
321 writer
.println("- From: {} Message timestamp: {}",
322 formatContact(vm
.getSender()),
323 DateUtils
.formatTimestamp(vm
.getTimestamp()));
326 if (syncMessage
.getRequest().isPresent()) {
328 if (syncMessage
.getRequest().get().isContactsRequest()) {
330 } else if (syncMessage
.getRequest().get().isGroupsRequest()) {
332 } else if (syncMessage
.getRequest().get().isBlockedListRequest()) {
333 type
= "blocked list";
334 } else if (syncMessage
.getRequest().get().isConfigurationRequest()) {
335 type
= "configuration";
336 } else if (syncMessage
.getRequest().get().isKeysRequest()) {
341 writer
.println("Received sync request for: {}", type
);
343 if (syncMessage
.getSent().isPresent()) {
344 writer
.println("Received sync sent message");
345 final var sentTranscriptMessage
= syncMessage
.getSent().get();
347 if (sentTranscriptMessage
.getDestination().isPresent()) {
348 to = formatContact(sentTranscriptMessage
.getDestination().get());
349 } else if (sentTranscriptMessage
.getRecipients().size() > 0) {
350 to = sentTranscriptMessage
.getRecipients()
352 .map(this::formatContact
)
353 .collect(Collectors
.joining(", "));
357 writer
.indentedWriter().println("To: {}", to);
358 writer
.indentedWriter()
359 .println("Timestamp: {}", DateUtils
.formatTimestamp(sentTranscriptMessage
.getTimestamp()));
360 if (sentTranscriptMessage
.getExpirationStartTimestamp() > 0) {
361 writer
.indentedWriter()
362 .println("Expiration started at: {}",
363 DateUtils
.formatTimestamp(sentTranscriptMessage
.getExpirationStartTimestamp()));
365 var message
= sentTranscriptMessage
.getMessage();
366 printDataMessage(writer
.indentedWriter(), message
);
368 if (syncMessage
.getBlockedList().isPresent()) {
369 writer
.println("Received sync message with block list");
370 writer
.println("Blocked numbers:");
371 final var blockedList
= syncMessage
.getBlockedList().get();
372 for (var address
: blockedList
.getAddresses()) {
373 writer
.println("- {}", getLegacyIdentifier(address
));
376 if (syncMessage
.getVerified().isPresent()) {
377 writer
.println("Received sync message with verified identities:");
378 final var verifiedMessage
= syncMessage
.getVerified().get();
379 writer
.println("- {}: {}", formatContact(verifiedMessage
.getDestination()), verifiedMessage
.getVerified());
380 var safetyNumber
= Util
.formatSafetyNumber(m
.computeSafetyNumber(verifiedMessage
.getDestination(),
381 verifiedMessage
.getIdentityKey()));
382 writer
.indentedWriter().println(safetyNumber
);
384 if (syncMessage
.getConfiguration().isPresent()) {
385 writer
.println("Received sync message with configuration:");
386 final var configurationMessage
= syncMessage
.getConfiguration().get();
387 if (configurationMessage
.getReadReceipts().isPresent()) {
388 writer
.println("- Read receipts: {}",
389 configurationMessage
.getReadReceipts().get() ?
"enabled" : "disabled");
391 if (configurationMessage
.getLinkPreviews().isPresent()) {
392 writer
.println("- Link previews: {}",
393 configurationMessage
.getLinkPreviews().get() ?
"enabled" : "disabled");
395 if (configurationMessage
.getTypingIndicators().isPresent()) {
396 writer
.println("- Typing indicators: {}",
397 configurationMessage
.getTypingIndicators().get() ?
"enabled" : "disabled");
399 if (configurationMessage
.getUnidentifiedDeliveryIndicators().isPresent()) {
400 writer
.println("- Unidentified Delivery Indicators: {}",
401 configurationMessage
.getUnidentifiedDeliveryIndicators().get() ?
"enabled" : "disabled");
404 if (syncMessage
.getFetchType().isPresent()) {
405 final var fetchType
= syncMessage
.getFetchType().get();
406 writer
.println("Received sync message with fetch type: {}", fetchType
);
408 if (syncMessage
.getViewOnceOpen().isPresent()) {
409 final var viewOnceOpenMessage
= syncMessage
.getViewOnceOpen().get();
410 writer
.println("Received sync message with view once open message:");
411 writer
.indentedWriter().println("Sender: {}", formatContact(viewOnceOpenMessage
.getSender()));
412 writer
.indentedWriter()
413 .println("Timestamp: {}", DateUtils
.formatTimestamp(viewOnceOpenMessage
.getTimestamp()));
415 if (syncMessage
.getStickerPackOperations().isPresent()) {
416 final var stickerPackOperationMessages
= syncMessage
.getStickerPackOperations().get();
417 writer
.println("Received sync message with sticker pack operations:");
418 for (var m
: stickerPackOperationMessages
) {
419 writer
.println("- {}", m
.getType().isPresent() ? m
.getType().get() : "<unknown>");
420 if (m
.getPackId().isPresent()) {
421 writer
.indentedWriter()
422 .println("packId: {}", Base64
.getEncoder().encodeToString(m
.getPackId().get()));
424 if (m
.getPackKey().isPresent()) {
425 writer
.indentedWriter()
426 .println("packKey: {}", Base64
.getEncoder().encodeToString(m
.getPackKey().get()));
430 if (syncMessage
.getMessageRequestResponse().isPresent()) {
431 final var requestResponseMessage
= syncMessage
.getMessageRequestResponse().get();
432 writer
.println("Received message request response:");
433 writer
.indentedWriter().println("Type: {}", requestResponseMessage
.getType());
434 if (requestResponseMessage
.getGroupId().isPresent()) {
435 writer
.println("For group:");
436 printGroupInfo(writer
.indentedWriter(),
437 GroupId
.unknownVersion(requestResponseMessage
.getGroupId().get()));
439 if (requestResponseMessage
.getPerson().isPresent()) {
440 writer
.indentedWriter()
441 .println("For Person: {}", formatContact(requestResponseMessage
.getPerson().get()));
444 if (syncMessage
.getKeys().isPresent()) {
445 final var keysMessage
= syncMessage
.getKeys().get();
446 writer
.println("Received sync message with keys:");
447 if (keysMessage
.getStorageService().isPresent()) {
448 writer
.println("- storage key: length: {}", keysMessage
.getStorageService().get().serialize().length
);
453 private void printPreview(
454 final PlainTextWriter writer
, final SignalServiceDataMessage
.Preview preview
456 writer
.println("Title: {}", preview
.getTitle());
457 writer
.println("Description: {}", preview
.getDescription());
458 writer
.println("Date: {}", DateUtils
.formatTimestamp(preview
.getDate()));
459 writer
.println("Url: {}", preview
.getUrl());
460 if (preview
.getImage().isPresent()) {
461 writer
.println("Image:");
462 printAttachment(writer
.indentedWriter(), preview
.getImage().get());
466 private void printSticker(
467 final PlainTextWriter writer
, final SignalServiceDataMessage
.Sticker sticker
469 writer
.println("Pack id: {}", Base64
.getEncoder().encodeToString(sticker
.getPackId()));
470 writer
.println("Pack key: {}", Base64
.getEncoder().encodeToString(sticker
.getPackKey()));
471 writer
.println("Sticker id: {}", sticker
.getStickerId());
472 writer
.println("Image:");
473 printAttachment(writer
.indentedWriter(), sticker
.getAttachment());
476 private void printReaction(
477 final PlainTextWriter writer
, final SignalServiceDataMessage
.Reaction reaction
479 writer
.println("Emoji: {}", reaction
.getEmoji());
480 writer
.println("Target author: {}", formatContact(reaction
.getTargetAuthor()));
481 writer
.println("Target timestamp: {}", DateUtils
.formatTimestamp(reaction
.getTargetSentTimestamp()));
482 writer
.println("Is remove: {}", reaction
.isRemove());
485 private void printQuote(
486 final PlainTextWriter writer
, final SignalServiceDataMessage
.Quote quote
488 writer
.println("Id: {}", quote
.getId());
489 writer
.println("Author: {}", formatContact(quote
.getAuthor()));
490 writer
.println("Text: {}", quote
.getText());
491 if (quote
.getMentions() != null && quote
.getMentions().size() > 0) {
492 writer
.println("Mentions:");
493 for (var mention
: quote
.getMentions()) {
494 printMention(writer
, mention
);
497 if (quote
.getAttachments().size() > 0) {
498 writer
.println("Attachments:");
499 for (var attachment
: quote
.getAttachments()) {
500 writer
.println("- Filename: {}", attachment
.getFileName());
502 w
.println("Type: {}", attachment
.getContentType());
503 w
.println("Thumbnail:");
504 if (attachment
.getThumbnail() != null) {
505 printAttachment(w
, attachment
.getThumbnail());
512 private void printSharedContact(final PlainTextWriter writer
, final SharedContact contact
) {
513 writer
.println("Name:");
514 var name
= contact
.getName();
516 if (name
.getDisplay().isPresent() && !name
.getDisplay().get().isBlank()) {
517 w
.println("Display name: {}", name
.getDisplay().get());
519 if (name
.getGiven().isPresent() && !name
.getGiven().get().isBlank()) {
520 w
.println("First name: {}", name
.getGiven().get());
522 if (name
.getMiddle().isPresent() && !name
.getMiddle().get().isBlank()) {
523 w
.println("Middle name: {}", name
.getMiddle().get());
525 if (name
.getFamily().isPresent() && !name
.getFamily().get().isBlank()) {
526 w
.println("Family name: {}", name
.getFamily().get());
528 if (name
.getPrefix().isPresent() && !name
.getPrefix().get().isBlank()) {
529 w
.println("Prefix name: {}", name
.getPrefix().get());
531 if (name
.getSuffix().isPresent() && !name
.getSuffix().get().isBlank()) {
532 w
.println("Suffix name: {}", name
.getSuffix().get());
536 if (contact
.getAvatar().isPresent()) {
537 var avatar
= contact
.getAvatar().get();
538 writer
.println("Avatar: (profile: {})", avatar
.isProfile());
539 printAttachment(writer
.indentedWriter(), avatar
.getAttachment());
542 if (contact
.getOrganization().isPresent()) {
543 writer
.println("Organisation: {}", contact
.getOrganization().get());
546 if (contact
.getPhone().isPresent()) {
547 writer
.println("Phone details:");
548 for (var phone
: contact
.getPhone().get()) {
549 writer
.println("- Phone:");
551 if (phone
.getValue() != null) {
552 w
.println("Number: {}", phone
.getValue());
554 if (phone
.getType() != null) {
555 w
.println("Type: {}", phone
.getType());
557 if (phone
.getLabel().isPresent() && !phone
.getLabel().get().isBlank()) {
558 w
.println("Label: {}", phone
.getLabel().get());
564 if (contact
.getEmail().isPresent()) {
565 writer
.println("Email details:");
566 for (var email
: contact
.getEmail().get()) {
567 writer
.println("- Email:");
569 if (email
.getValue() != null) {
570 w
.println("Address: {}", email
.getValue());
572 if (email
.getType() != null) {
573 w
.println("Type: {}", email
.getType());
575 if (email
.getLabel().isPresent() && !email
.getLabel().get().isBlank()) {
576 w
.println("Label: {}", email
.getLabel().get());
582 if (contact
.getAddress().isPresent()) {
583 writer
.println("Address details:");
584 for (var address
: contact
.getAddress().get()) {
585 writer
.println("- Address:");
587 if (address
.getType() != null) {
588 w
.println("Type: {}", address
.getType());
590 if (address
.getLabel().isPresent() && !address
.getLabel().get().isBlank()) {
591 w
.println("Label: {}", address
.getLabel().get());
593 if (address
.getStreet().isPresent() && !address
.getStreet().get().isBlank()) {
594 w
.println("Street: {}", address
.getStreet().get());
596 if (address
.getPobox().isPresent() && !address
.getPobox().get().isBlank()) {
597 w
.println("Pobox: {}", address
.getPobox().get());
599 if (address
.getNeighborhood().isPresent() && !address
.getNeighborhood().get().isBlank()) {
600 w
.println("Neighbourhood: {}", address
.getNeighborhood().get());
602 if (address
.getCity().isPresent() && !address
.getCity().get().isBlank()) {
603 w
.println("City: {}", address
.getCity().get());
605 if (address
.getRegion().isPresent() && !address
.getRegion().get().isBlank()) {
606 w
.println("Region: {}", address
.getRegion().get());
608 if (address
.getPostcode().isPresent() && !address
.getPostcode().get().isBlank()) {
609 w
.println("Postcode: {}", address
.getPostcode().get());
611 if (address
.getCountry().isPresent() && !address
.getCountry().get().isBlank()) {
612 w
.println("Country: {}", address
.getCountry().get());
619 private void printGroupContext(
620 final PlainTextWriter writer
, final SignalServiceGroupContext groupContext
622 final var groupId
= GroupUtils
.getGroupId(groupContext
);
623 if (groupContext
.getGroupV1().isPresent()) {
624 var groupInfo
= groupContext
.getGroupV1().get();
625 printGroupInfo(writer
, groupId
);
626 writer
.println("Type: {}", groupInfo
.getType());
627 if (groupInfo
.getMembers().isPresent()) {
628 writer
.println("Members:");
629 for (var member
: groupInfo
.getMembers().get()) {
630 writer
.println("- {}", formatContact(member
));
633 if (groupInfo
.getAvatar().isPresent()) {
634 writer
.println("Avatar:");
635 printAttachment(writer
.indentedWriter(), groupInfo
.getAvatar().get());
637 } else if (groupContext
.getGroupV2().isPresent()) {
638 final var groupInfo
= groupContext
.getGroupV2().get();
639 printGroupInfo(writer
, groupId
);
640 writer
.println("Revision: {}", groupInfo
.getRevision());
641 writer
.println("Master key length: {}", groupInfo
.getMasterKey().serialize().length
);
642 writer
.println("Has signed group change: {}", groupInfo
.hasSignedGroupChange());
646 private void printGroupInfo(final PlainTextWriter writer
, final GroupId groupId
) {
647 writer
.println("Id: {}", groupId
.toBase64());
649 var group
= m
.getGroup(groupId
);
651 writer
.println("Name: {}", group
.getTitle());
653 writer
.println("Name: <Unknown group>");
657 private void printMention(
658 PlainTextWriter writer
, SignalServiceDataMessage
.Mention mention
660 final var address
= m
.resolveSignalServiceAddress(mention
.getUuid());
661 writer
.println("- {}: {} (length: {})", formatContact(address
), mention
.getStart(), mention
.getLength());
664 private void printAttachment(PlainTextWriter writer
, SignalServiceAttachment attachment
) {
665 writer
.println("Content-Type: {}", attachment
.getContentType());
666 writer
.println("Type: {}", attachment
.isPointer() ?
"Pointer" : attachment
.isStream() ?
"Stream" : "<unknown>");
667 if (attachment
.isPointer()) {
668 final var pointer
= attachment
.asPointer();
669 writer
.println("Id: {} Key length: {}", pointer
.getRemoteId(), pointer
.getKey().length
);
670 if (pointer
.getUploadTimestamp() > 0) {
671 writer
.println("Upload timestamp: {}", DateUtils
.formatTimestamp(pointer
.getUploadTimestamp()));
673 if (pointer
.getCaption().isPresent()) {
674 writer
.println("Caption: {}", pointer
.getCaption().get());
676 if (pointer
.getFileName().isPresent()) {
677 writer
.println("Filename: {}", pointer
.getFileName().get());
679 writer
.println("Size: {}{}",
680 pointer
.getSize().isPresent() ? pointer
.getSize().get() + " bytes" : "<unavailable>",
681 pointer
.getPreview().isPresent() ?
" (Preview is available: "
682 + pointer
.getPreview().get().length
684 final var flags
= new ArrayList
<String
>();
685 if (pointer
.getVoiceNote()) {
686 flags
.add("voice note");
688 if (pointer
.isBorderless()) {
689 flags
.add("borderless");
691 if (pointer
.isGif()) {
692 flags
.add("video gif");
694 if (flags
.size() > 0) {
695 writer
.println("Flags: {}", String
.join(", ", flags
));
697 if (pointer
.getWidth() > 0 || pointer
.getHeight() > 0) {
698 writer
.println("Dimensions: {}x{}", pointer
.getWidth(), pointer
.getHeight());
700 var file
= m
.getAttachmentFile(pointer
.getRemoteId());
702 writer
.println("Stored plaintext in: {}", file
);
707 private String
formatContact(SignalServiceAddress address
) {
708 address
= m
.resolveSignalServiceAddress(address
);
709 final var number
= getLegacyIdentifier(address
);
710 final var name
= m
.getContactOrProfileName(RecipientIdentifier
.Single
.fromAddress(address
));
711 if (name
== null || name
.isEmpty()) {
714 return MessageFormatter
.arrayFormat("“{}” {}", new Object
[]{name
, number
}).getMessage();