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