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
.slf4j
.helpers
.MessageFormatter
;
10 import org
.whispersystems
.libsignal
.UntrustedIdentityException
;
11 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachment
;
12 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachmentPointer
;
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
.SignalServiceGroup
;
17 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupContext
;
18 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupV2
;
19 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceReceiptMessage
;
20 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceTypingMessage
;
21 import org
.whispersystems
.signalservice
.api
.messages
.calls
.AnswerMessage
;
22 import org
.whispersystems
.signalservice
.api
.messages
.calls
.BusyMessage
;
23 import org
.whispersystems
.signalservice
.api
.messages
.calls
.HangupMessage
;
24 import org
.whispersystems
.signalservice
.api
.messages
.calls
.IceUpdateMessage
;
25 import org
.whispersystems
.signalservice
.api
.messages
.calls
.OfferMessage
;
26 import org
.whispersystems
.signalservice
.api
.messages
.calls
.OpaqueMessage
;
27 import org
.whispersystems
.signalservice
.api
.messages
.calls
.SignalServiceCallMessage
;
28 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.BlockedListMessage
;
29 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ConfigurationMessage
;
30 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ContactsMessage
;
31 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.KeysMessage
;
32 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.MessageRequestResponseMessage
;
33 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ReadMessage
;
34 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SentTranscriptMessage
;
35 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SignalServiceSyncMessage
;
36 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.StickerPackOperationMessage
;
37 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.VerifiedMessage
;
38 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ViewOnceOpenMessage
;
39 import org
.whispersystems
.signalservice
.api
.messages
.shared
.SharedContact
;
40 import org
.whispersystems
.signalservice
.api
.push
.SignalServiceAddress
;
43 import java
.io
.IOException
;
44 import java
.util
.Base64
;
45 import java
.util
.List
;
46 import java
.util
.stream
.Collectors
;
48 public class ReceiveMessageHandler
implements Manager
.ReceiveMessageHandler
{
52 public ReceiveMessageHandler(Manager m
) {
57 public void handleMessage(SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
) {
59 printMessage(envelope
, content
, exception
);
60 } catch (IOException e
) {
65 private void printMessage(
66 SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
67 ) throws IOException
{
68 PlainTextWriter writer
= new PlainTextWriterImpl(System
.out
);
70 if (envelope
.hasSource()) {
71 SignalServiceAddress source
= envelope
.getSourceAddress();
72 writer
.println("Envelope from: {} (device: {})", formatContact(source
), envelope
.getSourceDevice());
73 if (source
.getRelay().isPresent()) {
74 writer
.println("Relayed by: {}", source
.getRelay().get());
77 writer
.println("Envelope from: unknown source");
79 writer
.println("Timestamp: {}", DateUtils
.formatTimestamp(envelope
.getTimestamp()));
80 if (envelope
.isUnidentifiedSender()) {
81 writer
.println("Sent by unidentified/sealed sender");
84 if (envelope
.isReceipt()) {
85 writer
.println("Got receipt.");
86 } else if (envelope
.isSignalMessage() || envelope
.isPreKeySignalMessage() || envelope
.isUnidentifiedSender()) {
87 if (exception
!= null) {
88 if (exception
instanceof UntrustedIdentityException
) {
89 UntrustedIdentityException e
= (UntrustedIdentityException
) exception
;
91 "The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
93 "Use 'signal-cli -u {0} listIdentities -n {1}', verify the key and run 'signal-cli -u {0} trust -v \"FINGER_PRINT\" {1}' to mark it as trusted",
97 "If you don't care about security, use 'signal-cli -u {} trust -a {}' to trust it without verification",
101 writer
.println("Exception: {} ({})", exception
.getMessage(), exception
.getClass().getSimpleName());
104 if (content
== null) {
105 writer
.println("Failed to decrypt message.");
107 writer
.println("Sender: {} (device: {})",
108 formatContact(content
.getSender()),
109 content
.getSenderDevice());
110 writer
.println("Server timestamps: received: {} delivered: {}",
111 DateUtils
.formatTimestamp(content
.getServerReceivedTimestamp()),
112 DateUtils
.formatTimestamp(content
.getServerDeliveredTimestamp()));
114 if (content
.getDataMessage().isPresent()) {
115 SignalServiceDataMessage message
= content
.getDataMessage().get();
116 printDataMessage(writer
, message
);
118 if (content
.getSyncMessage().isPresent()) {
119 writer
.println("Received a sync message");
120 SignalServiceSyncMessage syncMessage
= content
.getSyncMessage().get();
121 printSyncMessage(writer
, syncMessage
);
124 if (content
.getCallMessage().isPresent()) {
125 writer
.println("Received a call message");
126 SignalServiceCallMessage callMessage
= content
.getCallMessage().get();
127 printCallMessage(writer
.indentedWriter(), callMessage
);
129 if (content
.getReceiptMessage().isPresent()) {
130 writer
.println("Received a receipt message");
131 SignalServiceReceiptMessage receiptMessage
= content
.getReceiptMessage().get();
132 printReceiptMessage(writer
.indentedWriter(), receiptMessage
);
134 if (content
.getTypingMessage().isPresent()) {
135 writer
.println("Received a typing message");
136 SignalServiceTypingMessage typingMessage
= content
.getTypingMessage().get();
137 printTypingMessage(writer
.indentedWriter(), typingMessage
);
141 writer
.println("Unknown message received.");
146 private void printDataMessage(
147 PlainTextWriter writer
, SignalServiceDataMessage message
148 ) throws IOException
{
149 writer
.println("Message timestamp: {}", DateUtils
.formatTimestamp(message
.getTimestamp()));
150 if (message
.isViewOnce()) {
151 writer
.println("=VIEW ONCE=");
154 if (message
.getBody().isPresent()) {
155 writer
.println("Body: {}", message
.getBody().get());
157 if (message
.getGroupContext().isPresent()) {
158 writer
.println("Group info:");
159 final SignalServiceGroupContext groupContext
= message
.getGroupContext().get();
160 printGroupContext(writer
.indentedWriter(), groupContext
);
162 if (message
.getGroupCallUpdate().isPresent()) {
163 writer
.println("Group call update:");
164 final SignalServiceDataMessage
.GroupCallUpdate groupCallUpdate
= message
.getGroupCallUpdate().get();
165 writer
.indentedWriter().println("Era id: {}", groupCallUpdate
.getEraId());
167 if (message
.getPreviews().isPresent()) {
168 writer
.println("Previews:");
169 final List
<SignalServiceDataMessage
.Preview
> previews
= message
.getPreviews().get();
170 for (SignalServiceDataMessage
.Preview preview
: previews
) {
171 writer
.println("- Preview");
172 printPreview(writer
.indentedWriter(), preview
);
175 if (message
.getSharedContacts().isPresent()) {
176 final List
<SharedContact
> sharedContacts
= message
.getSharedContacts().get();
177 writer
.println("Contacts:");
178 for (SharedContact contact
: sharedContacts
) {
179 writer
.println("- Contact:");
180 printSharedContact(writer
.indentedWriter(), contact
);
183 if (message
.getSticker().isPresent()) {
184 final SignalServiceDataMessage
.Sticker sticker
= message
.getSticker().get();
185 writer
.println("Sticker:");
186 printSticker(writer
.indentedWriter(), sticker
);
188 if (message
.isEndSession()) {
189 writer
.println("Is end session");
191 if (message
.isExpirationUpdate()) {
192 writer
.println("Is Expiration update: {}", message
.isExpirationUpdate());
194 if (message
.getExpiresInSeconds() > 0) {
195 writer
.println("Expires in: {} seconds", message
.getExpiresInSeconds());
197 if (message
.getProfileKey().isPresent()) {
198 writer
.println("Profile key update, key length: {}", message
.getProfileKey().get().length
);
200 if (message
.getReaction().isPresent()) {
201 writer
.println("Reaction:");
202 final SignalServiceDataMessage
.Reaction reaction
= message
.getReaction().get();
203 printReaction(writer
.indentedWriter(), reaction
);
205 if (message
.getQuote().isPresent()) {
206 writer
.println("Quote:");
207 SignalServiceDataMessage
.Quote quote
= message
.getQuote().get();
208 printQuote(writer
.indentedWriter(), quote
);
210 if (message
.getRemoteDelete().isPresent()) {
211 final SignalServiceDataMessage
.RemoteDelete remoteDelete
= message
.getRemoteDelete().get();
212 writer
.println("Remote delete message: timestamp = {}", remoteDelete
.getTargetSentTimestamp());
214 if (message
.getMentions().isPresent()) {
215 writer
.println("Mentions:");
216 for (SignalServiceDataMessage
.Mention mention
: message
.getMentions().get()) {
217 printMention(writer
, mention
);
220 if (message
.getAttachments().isPresent()) {
221 writer
.println("Attachments:");
222 for (SignalServiceAttachment attachment
: message
.getAttachments().get()) {
223 writer
.println("- Attachment:");
224 printAttachment(writer
.indentedWriter(), attachment
);
229 private void printTypingMessage(
230 final PlainTextWriter writer
, final SignalServiceTypingMessage typingMessage
231 ) throws IOException
{
232 writer
.println("Action: {}", typingMessage
.getAction());
233 writer
.println("Timestamp: {}", DateUtils
.formatTimestamp(typingMessage
.getTimestamp()));
234 if (typingMessage
.getGroupId().isPresent()) {
235 writer
.println("Group Info:");
236 final GroupId groupId
= GroupId
.unknownVersion(typingMessage
.getGroupId().get());
237 printGroupInfo(writer
.indentedWriter(), groupId
);
241 private void printReceiptMessage(
242 final PlainTextWriter writer
, final SignalServiceReceiptMessage receiptMessage
243 ) throws IOException
{
244 writer
.println("When: {}", DateUtils
.formatTimestamp(receiptMessage
.getWhen()));
245 if (receiptMessage
.isDeliveryReceipt()) {
246 writer
.println("Is delivery receipt");
248 if (receiptMessage
.isReadReceipt()) {
249 writer
.println("Is read receipt");
251 if (receiptMessage
.isViewedReceipt()) {
252 writer
.println("Is viewed receipt");
254 writer
.println("Timestamps:");
255 for (long timestamp
: receiptMessage
.getTimestamps()) {
256 writer
.println("- {}", DateUtils
.formatTimestamp(timestamp
));
260 private void printCallMessage(
261 final PlainTextWriter writer
, final SignalServiceCallMessage callMessage
262 ) throws IOException
{
263 if (callMessage
.getDestinationDeviceId().isPresent()) {
264 final Integer deviceId
= callMessage
.getDestinationDeviceId().get();
265 writer
.println("Destination device id: {}", deviceId
);
267 if (callMessage
.getAnswerMessage().isPresent()) {
268 AnswerMessage answerMessage
= callMessage
.getAnswerMessage().get();
269 writer
.println("Answer message: {}, sdp: {})", answerMessage
.getId(), answerMessage
.getSdp());
271 if (callMessage
.getBusyMessage().isPresent()) {
272 BusyMessage busyMessage
= callMessage
.getBusyMessage().get();
273 writer
.println("Busy message: {}", busyMessage
.getId());
275 if (callMessage
.getHangupMessage().isPresent()) {
276 HangupMessage hangupMessage
= callMessage
.getHangupMessage().get();
277 writer
.println("Hangup message: {}", hangupMessage
.getId());
279 if (callMessage
.getIceUpdateMessages().isPresent()) {
280 writer
.println("Ice update messages:");
281 List
<IceUpdateMessage
> iceUpdateMessages
= callMessage
.getIceUpdateMessages().get();
282 for (IceUpdateMessage iceUpdateMessage
: iceUpdateMessages
) {
283 writer
.println("- {}, sdp: {}", iceUpdateMessage
.getId(), iceUpdateMessage
.getSdp());
286 if (callMessage
.getOfferMessage().isPresent()) {
287 OfferMessage offerMessage
= callMessage
.getOfferMessage().get();
288 writer
.println("Offer message: {}, sdp: {}", offerMessage
.getId(), offerMessage
.getSdp());
290 if (callMessage
.getOpaqueMessage().isPresent()) {
291 final OpaqueMessage opaqueMessage
= callMessage
.getOpaqueMessage().get();
292 writer
.println("Opaque message: size {}", opaqueMessage
.getOpaque().length
);
296 private void printSyncMessage(
297 final PlainTextWriter writer
, final SignalServiceSyncMessage syncMessage
298 ) throws IOException
{
299 if (syncMessage
.getContacts().isPresent()) {
300 final ContactsMessage contactsMessage
= syncMessage
.getContacts().get();
301 String type
= contactsMessage
.isComplete() ?
"complete" : "partial";
302 writer
.println("Received {} sync contacts:", type
);
303 printAttachment(writer
.indentedWriter(), contactsMessage
.getContactsStream());
305 if (syncMessage
.getGroups().isPresent()) {
306 writer
.println("Received sync groups:");
307 printAttachment(writer
.indentedWriter(), syncMessage
.getGroups().get());
309 if (syncMessage
.getRead().isPresent()) {
310 writer
.println("Received sync read messages list");
311 for (ReadMessage rm
: syncMessage
.getRead().get()) {
312 writer
.println("- From: {} Message timestamp: {}",
313 formatContact(rm
.getSender()),
314 DateUtils
.formatTimestamp(rm
.getTimestamp()));
317 if (syncMessage
.getRequest().isPresent()) {
319 if (syncMessage
.getRequest().get().isContactsRequest()) {
321 } else if (syncMessage
.getRequest().get().isGroupsRequest()) {
323 } else if (syncMessage
.getRequest().get().isBlockedListRequest()) {
324 type
= "blocked list";
325 } else if (syncMessage
.getRequest().get().isConfigurationRequest()) {
326 type
= "configuration";
327 } else if (syncMessage
.getRequest().get().isKeysRequest()) {
332 writer
.println("Received sync request for: {}", type
);
334 if (syncMessage
.getSent().isPresent()) {
335 writer
.println("Received sync sent message");
336 final SentTranscriptMessage sentTranscriptMessage
= syncMessage
.getSent().get();
338 if (sentTranscriptMessage
.getDestination().isPresent()) {
339 to = formatContact(sentTranscriptMessage
.getDestination().get());
340 } else if (sentTranscriptMessage
.getRecipients().size() > 0) {
341 to = sentTranscriptMessage
.getRecipients()
343 .map(this::formatContact
)
344 .collect(Collectors
.joining(", "));
348 writer
.indentedWriter().println("To: {}", to);
349 writer
.indentedWriter()
350 .println("Timestamp: {}", DateUtils
.formatTimestamp(sentTranscriptMessage
.getTimestamp()));
351 if (sentTranscriptMessage
.getExpirationStartTimestamp() > 0) {
352 writer
.indentedWriter()
353 .println("Expiration started at: {}",
354 DateUtils
.formatTimestamp(sentTranscriptMessage
.getExpirationStartTimestamp()));
356 SignalServiceDataMessage message
= sentTranscriptMessage
.getMessage();
357 printDataMessage(writer
.indentedWriter(), message
);
359 if (syncMessage
.getBlockedList().isPresent()) {
360 writer
.println("Received sync message with block list");
361 writer
.println("Blocked numbers:");
362 final BlockedListMessage blockedList
= syncMessage
.getBlockedList().get();
363 for (SignalServiceAddress address
: blockedList
.getAddresses()) {
364 writer
.println("- {}", address
.getLegacyIdentifier());
367 if (syncMessage
.getVerified().isPresent()) {
368 writer
.println("Received sync message with verified identities:");
369 final VerifiedMessage verifiedMessage
= syncMessage
.getVerified().get();
370 writer
.println("- {}: {}", formatContact(verifiedMessage
.getDestination()), verifiedMessage
.getVerified());
371 String safetyNumber
= Util
.formatSafetyNumber(m
.computeSafetyNumber(verifiedMessage
.getDestination(),
372 verifiedMessage
.getIdentityKey()));
373 writer
.indentedWriter().println(safetyNumber
);
375 if (syncMessage
.getConfiguration().isPresent()) {
376 writer
.println("Received sync message with configuration:");
377 final ConfigurationMessage configurationMessage
= syncMessage
.getConfiguration().get();
378 if (configurationMessage
.getReadReceipts().isPresent()) {
379 writer
.println("- Read receipts: {}",
380 configurationMessage
.getReadReceipts().get() ?
"enabled" : "disabled");
382 if (configurationMessage
.getLinkPreviews().isPresent()) {
383 writer
.println("- Link previews: {}",
384 configurationMessage
.getLinkPreviews().get() ?
"enabled" : "disabled");
386 if (configurationMessage
.getTypingIndicators().isPresent()) {
387 writer
.println("- Typing indicators: {}",
388 configurationMessage
.getTypingIndicators().get() ?
"enabled" : "disabled");
390 if (configurationMessage
.getUnidentifiedDeliveryIndicators().isPresent()) {
391 writer
.println("- Unidentified Delivery Indicators: {}",
392 configurationMessage
.getUnidentifiedDeliveryIndicators().get() ?
"enabled" : "disabled");
395 if (syncMessage
.getFetchType().isPresent()) {
396 final SignalServiceSyncMessage
.FetchType fetchType
= syncMessage
.getFetchType().get();
397 writer
.println("Received sync message with fetch type: {}", fetchType
);
399 if (syncMessage
.getViewOnceOpen().isPresent()) {
400 final ViewOnceOpenMessage viewOnceOpenMessage
= syncMessage
.getViewOnceOpen().get();
401 writer
.println("Received sync message with view once open message:");
402 writer
.indentedWriter().println("Sender: {}", formatContact(viewOnceOpenMessage
.getSender()));
403 writer
.indentedWriter()
404 .println("Timestamp: {}", DateUtils
.formatTimestamp(viewOnceOpenMessage
.getTimestamp()));
406 if (syncMessage
.getStickerPackOperations().isPresent()) {
407 final List
<StickerPackOperationMessage
> stickerPackOperationMessages
= syncMessage
.getStickerPackOperations()
409 writer
.println("Received sync message with sticker pack operations:");
410 for (StickerPackOperationMessage m
: stickerPackOperationMessages
) {
411 writer
.println("- {}", m
.getType().isPresent() ? m
.getType().get() : "<unknown>");
412 if (m
.getPackId().isPresent()) {
413 writer
.indentedWriter()
414 .println("packId: {}", Base64
.getEncoder().encodeToString(m
.getPackId().get()));
416 if (m
.getPackKey().isPresent()) {
417 writer
.indentedWriter()
418 .println("packKey: {}", Base64
.getEncoder().encodeToString(m
.getPackKey().get()));
422 if (syncMessage
.getMessageRequestResponse().isPresent()) {
423 final MessageRequestResponseMessage requestResponseMessage
= syncMessage
.getMessageRequestResponse().get();
424 writer
.println("Received message request response:");
425 writer
.indentedWriter().println("Type: {}", requestResponseMessage
.getType());
426 if (requestResponseMessage
.getGroupId().isPresent()) {
427 writer
.println("For group:");
428 printGroupInfo(writer
.indentedWriter(),
429 GroupId
.unknownVersion(requestResponseMessage
.getGroupId().get()));
431 if (requestResponseMessage
.getPerson().isPresent()) {
432 writer
.indentedWriter()
433 .println("For Person: {}", formatContact(requestResponseMessage
.getPerson().get()));
436 if (syncMessage
.getKeys().isPresent()) {
437 final KeysMessage keysMessage
= syncMessage
.getKeys().get();
438 writer
.println("Received sync message with keys:");
439 if (keysMessage
.getStorageService().isPresent()) {
440 writer
.println("- storage key: length: {}", keysMessage
.getStorageService().get().serialize().length
);
445 private void printPreview(
446 final PlainTextWriter writer
, final SignalServiceDataMessage
.Preview preview
447 ) throws IOException
{
448 writer
.println("Title: {}", preview
.getTitle());
449 writer
.println("Description: {}", preview
.getDescription());
450 writer
.println("Date: {}", DateUtils
.formatTimestamp(preview
.getDate()));
451 writer
.println("Url: {}", preview
.getUrl());
452 if (preview
.getImage().isPresent()) {
453 writer
.println("Image:");
454 printAttachment(writer
.indentedWriter(), preview
.getImage().get());
458 private void printSticker(
459 final PlainTextWriter writer
, final SignalServiceDataMessage
.Sticker sticker
460 ) throws IOException
{
461 writer
.println("Pack id: {}", Base64
.getEncoder().encodeToString(sticker
.getPackId()));
462 writer
.println("Pack key: {}", Base64
.getEncoder().encodeToString(sticker
.getPackKey()));
463 writer
.println("Sticker id: {}", sticker
.getStickerId());
464 writer
.println("Image:");
465 printAttachment(writer
.indentedWriter(), sticker
.getAttachment());
468 private void printReaction(
469 final PlainTextWriter writer
, final SignalServiceDataMessage
.Reaction reaction
470 ) throws IOException
{
471 writer
.println("Emoji: {}", reaction
.getEmoji());
472 writer
.println("Target author: {}", formatContact(m
.resolveSignalServiceAddress(reaction
.getTargetAuthor())));
473 writer
.println("Target timestamp: {}", DateUtils
.formatTimestamp(reaction
.getTargetSentTimestamp()));
474 writer
.println("Is remove: {}", reaction
.isRemove());
477 private void printQuote(
478 final PlainTextWriter writer
, final SignalServiceDataMessage
.Quote quote
479 ) throws IOException
{
480 writer
.println("Id: {}", quote
.getId());
481 writer
.println("Author: {}", m
.resolveSignalServiceAddress(quote
.getAuthor()).getLegacyIdentifier());
482 writer
.println("Text: {}", quote
.getText());
483 if (quote
.getMentions() != null && quote
.getMentions().size() > 0) {
484 writer
.println("Mentions:");
485 for (SignalServiceDataMessage
.Mention mention
: quote
.getMentions()) {
486 printMention(writer
, mention
);
489 if (quote
.getAttachments().size() > 0) {
490 writer
.println("Attachments:");
491 for (SignalServiceDataMessage
.Quote
.QuotedAttachment attachment
: quote
.getAttachments()) {
492 writer
.println("- Filename: {}", attachment
.getFileName());
494 w
.println("Type: {}", attachment
.getContentType());
495 w
.println("Thumbnail:");
496 if (attachment
.getThumbnail() != null) {
497 printAttachment(w
, attachment
.getThumbnail());
504 private void printSharedContact(final PlainTextWriter writer
, final SharedContact contact
) throws IOException
{
505 writer
.println("Name:");
506 SharedContact
.Name name
= contact
.getName();
508 if (name
.getDisplay().isPresent() && !name
.getDisplay().get().isBlank()) {
509 w
.println("Display name: {}", name
.getDisplay().get());
511 if (name
.getGiven().isPresent() && !name
.getGiven().get().isBlank()) {
512 w
.println("First name: {}", name
.getGiven().get());
514 if (name
.getMiddle().isPresent() && !name
.getMiddle().get().isBlank()) {
515 w
.println("Middle name: {}", name
.getMiddle().get());
517 if (name
.getFamily().isPresent() && !name
.getFamily().get().isBlank()) {
518 w
.println("Family name: {}", name
.getFamily().get());
520 if (name
.getPrefix().isPresent() && !name
.getPrefix().get().isBlank()) {
521 w
.println("Prefix name: {}", name
.getPrefix().get());
523 if (name
.getSuffix().isPresent() && !name
.getSuffix().get().isBlank()) {
524 w
.println("Suffix name: {}", name
.getSuffix().get());
528 if (contact
.getAvatar().isPresent()) {
529 SharedContact
.Avatar avatar
= contact
.getAvatar().get();
530 writer
.println("Avatar: (profile: {})", avatar
.isProfile());
531 printAttachment(writer
.indentedWriter(), avatar
.getAttachment());
534 if (contact
.getOrganization().isPresent()) {
535 writer
.println("Organisation: {}", contact
.getOrganization().get());
538 if (contact
.getPhone().isPresent()) {
539 writer
.println("Phone details:");
540 for (SharedContact
.Phone phone
: contact
.getPhone().get()) {
541 writer
.println("- Phone:");
543 if (phone
.getValue() != null) {
544 w
.println("Number: {}", phone
.getValue());
546 if (phone
.getType() != null) {
547 w
.println("Type: {}", phone
.getType());
549 if (phone
.getLabel().isPresent() && !phone
.getLabel().get().isBlank()) {
550 w
.println("Label: {}", phone
.getLabel().get());
556 if (contact
.getEmail().isPresent()) {
557 writer
.println("Email details:");
558 for (SharedContact
.Email email
: contact
.getEmail().get()) {
559 writer
.println("- Email:");
561 if (email
.getValue() != null) {
562 w
.println("Address: {}", email
.getValue());
564 if (email
.getType() != null) {
565 w
.println("Type: {}", email
.getType());
567 if (email
.getLabel().isPresent() && !email
.getLabel().get().isBlank()) {
568 w
.println("Label: {}", email
.getLabel().get());
574 if (contact
.getAddress().isPresent()) {
575 writer
.println("Address details:");
576 for (SharedContact
.PostalAddress address
: contact
.getAddress().get()) {
577 writer
.println("- Address:");
579 if (address
.getType() != null) {
580 w
.println("Type: {}", address
.getType());
582 if (address
.getLabel().isPresent() && !address
.getLabel().get().isBlank()) {
583 w
.println("Label: {}", address
.getLabel().get());
585 if (address
.getStreet().isPresent() && !address
.getStreet().get().isBlank()) {
586 w
.println("Street: {}", address
.getStreet().get());
588 if (address
.getPobox().isPresent() && !address
.getPobox().get().isBlank()) {
589 w
.println("Pobox: {}", address
.getPobox().get());
591 if (address
.getNeighborhood().isPresent() && !address
.getNeighborhood().get().isBlank()) {
592 w
.println("Neighbourhood: {}", address
.getNeighborhood().get());
594 if (address
.getCity().isPresent() && !address
.getCity().get().isBlank()) {
595 w
.println("City: {}", address
.getCity().get());
597 if (address
.getRegion().isPresent() && !address
.getRegion().get().isBlank()) {
598 w
.println("Region: {}", address
.getRegion().get());
600 if (address
.getPostcode().isPresent() && !address
.getPostcode().get().isBlank()) {
601 w
.println("Postcode: {}", address
.getPostcode().get());
603 if (address
.getCountry().isPresent() && !address
.getCountry().get().isBlank()) {
604 w
.println("Country: {}", address
.getCountry().get());
611 private void printGroupContext(
612 final PlainTextWriter writer
, final SignalServiceGroupContext groupContext
613 ) throws IOException
{
614 final GroupId groupId
= GroupUtils
.getGroupId(groupContext
);
615 if (groupContext
.getGroupV1().isPresent()) {
616 SignalServiceGroup groupInfo
= groupContext
.getGroupV1().get();
617 printGroupInfo(writer
, groupId
);
618 writer
.println("Type: {}", groupInfo
.getType());
619 if (groupInfo
.getMembers().isPresent()) {
620 writer
.println("Members:");
621 for (SignalServiceAddress member
: groupInfo
.getMembers().get()) {
622 writer
.println("- {}", formatContact(member
));
625 if (groupInfo
.getAvatar().isPresent()) {
626 writer
.println("Avatar:");
627 printAttachment(writer
.indentedWriter(), groupInfo
.getAvatar().get());
629 } else if (groupContext
.getGroupV2().isPresent()) {
630 final SignalServiceGroupV2 groupInfo
= groupContext
.getGroupV2().get();
631 printGroupInfo(writer
, groupId
);
632 writer
.println("Revision: {}", groupInfo
.getRevision());
633 writer
.println("Master key length: {}", groupInfo
.getMasterKey().serialize().length
);
634 writer
.println("Has signed group change: {}", groupInfo
.hasSignedGroupChange());
638 private void printGroupInfo(final PlainTextWriter writer
, final GroupId groupId
) throws IOException
{
639 writer
.println("Id: {}", groupId
.toBase64());
641 GroupInfo group
= m
.getGroup(groupId
);
643 writer
.println("Name: {}", group
.getTitle());
645 writer
.println("Name: <Unknown group>");
649 private void printMention(
650 PlainTextWriter writer
, SignalServiceDataMessage
.Mention mention
651 ) throws IOException
{
652 final SignalServiceAddress address
= m
.resolveSignalServiceAddress(new SignalServiceAddress(mention
.getUuid(),
654 writer
.println("- {}: {} (length: {})", formatContact(address
), mention
.getStart(), mention
.getLength());
657 private void printAttachment(PlainTextWriter writer
, SignalServiceAttachment attachment
) throws IOException
{
658 writer
.println("Content-Type: {}", attachment
.getContentType());
659 writer
.println("Type: {}", attachment
.isPointer() ?
"Pointer" : attachment
.isStream() ?
"Stream" : "<unknown>");
660 if (attachment
.isPointer()) {
661 final SignalServiceAttachmentPointer pointer
= attachment
.asPointer();
662 writer
.println("Id: {} Key length: {}", pointer
.getRemoteId(), pointer
.getKey().length
);
663 if (pointer
.getUploadTimestamp() > 0) {
664 writer
.println("Upload timestamp: {}", DateUtils
.formatTimestamp(pointer
.getUploadTimestamp()));
666 if (pointer
.getCaption().isPresent()) {
667 writer
.println("Caption: {}", pointer
.getCaption().get());
669 if (pointer
.getFileName().isPresent()) {
670 writer
.println("Filename: {}", pointer
.getFileName().get());
672 writer
.println("Size: {}{}",
673 pointer
.getSize().isPresent() ? pointer
.getSize().get() + " bytes" : "<unavailable>",
674 pointer
.getPreview().isPresent() ?
" (Preview is available: "
675 + pointer
.getPreview().get().length
677 writer
.println("Voice note: {}", pointer
.getVoiceNote() ?
"yes" : "no");
678 writer
.println("Borderless: {}", pointer
.isBorderless() ?
"yes" : "no");
679 if (pointer
.getWidth() > 0 || pointer
.getHeight() > 0) {
680 writer
.println("Dimensions: {}x{}", pointer
.getWidth(), pointer
.getHeight());
682 File file
= m
.getAttachmentFile(pointer
.getRemoteId());
684 writer
.println("Stored plaintext in: {}", file
);
689 private String
formatContact(SignalServiceAddress address
) {
690 final String number
= address
.getLegacyIdentifier();
691 String name
= m
.getContactOrProfileName(number
);
695 return MessageFormatter
.arrayFormat("“{}” {}", new Object
[]{name
, number
}).getMessage();