]> nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/ReceiveMessageHandler.java
Reformat code
[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.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;
23
24 import java.util.ArrayList;
25 import java.util.Base64;
26 import java.util.stream.Collectors;
27
28 import static org.asamk.signal.util.Util.getLegacyIdentifier;
29
30 public class ReceiveMessageHandler implements Manager.ReceiveMessageHandler {
31
32 final Manager m;
33 final PlainTextWriter writer;
34
35 public ReceiveMessageHandler(Manager m, final PlainTextWriter writer) {
36 this.m = m;
37 this.writer = writer;
38 }
39
40 @Override
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());
45 } else {
46 writer.println("Envelope from: unknown source");
47 }
48 writer.println("Timestamp: {}", DateUtils.formatTimestamp(envelope.getTimestamp()));
49 if (envelope.isUnidentifiedSender()) {
50 writer.println("Sent by unidentified/sealed sender");
51 }
52
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;
59 writer.println(
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()));
62 writer.println(
63 "Use 'signal-cli -u {} listIdentities -n {}', verify the key and run 'signal-cli -u {} trust -v \"FINGER_PRINT\" {}' to mark it as trusted",
64 m.getUsername(),
65 recipientName,
66 m.getUsername(),
67 recipientName);
68 writer.println(
69 "If you don't care about security, use 'signal-cli -u {} trust -a {}' to trust it without verification",
70 m.getUsername(),
71 recipientName);
72 } else {
73 writer.println("Exception: {} ({})", exception.getMessage(), exception.getClass().getSimpleName());
74 }
75 }
76 if (content == null) {
77 writer.println("No message content");
78 } else {
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()));
85
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());
90 }
91
92 if (content.getDataMessage().isPresent()) {
93 var message = content.getDataMessage().get();
94 printDataMessage(writer, message);
95 }
96 if (content.getSyncMessage().isPresent()) {
97 writer.println("Received a sync message");
98 var syncMessage = content.getSyncMessage().get();
99 printSyncMessage(writer, syncMessage);
100 }
101
102 if (content.getCallMessage().isPresent()) {
103 writer.println("Received a call message");
104 var callMessage = content.getCallMessage().get();
105 printCallMessage(writer.indentedWriter(), callMessage);
106 }
107 if (content.getReceiptMessage().isPresent()) {
108 writer.println("Received a receipt message");
109 var receiptMessage = content.getReceiptMessage().get();
110 printReceiptMessage(writer.indentedWriter(), receiptMessage);
111 }
112 if (content.getTypingMessage().isPresent()) {
113 writer.println("Received a typing message");
114 var typingMessage = content.getTypingMessage().get();
115 printTypingMessage(writer.indentedWriter(), typingMessage);
116 }
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);
121 }
122 }
123 } else {
124 writer.println("Unknown message received.");
125 }
126 writer.println();
127 }
128
129 private void printDataMessage(
130 PlainTextWriter writer, SignalServiceDataMessage message
131 ) {
132 writer.println("Message timestamp: {}", DateUtils.formatTimestamp(message.getTimestamp()));
133 if (message.isViewOnce()) {
134 writer.println("=VIEW ONCE=");
135 }
136
137 if (message.getBody().isPresent()) {
138 writer.println("Body: {}", message.getBody().get());
139 }
140 if (message.getGroupContext().isPresent()) {
141 writer.println("Group info:");
142 final var groupContext = message.getGroupContext().get();
143 printGroupContext(writer.indentedWriter(), groupContext);
144 }
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());
149 }
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);
156 }
157 }
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);
164 }
165 }
166 if (message.getSticker().isPresent()) {
167 final var sticker = message.getSticker().get();
168 writer.println("Sticker:");
169 printSticker(writer.indentedWriter(), sticker);
170 }
171 if (message.isEndSession()) {
172 writer.println("Is end session");
173 }
174 if (message.isExpirationUpdate()) {
175 writer.println("Is Expiration update: {}", message.isExpirationUpdate());
176 }
177 if (message.getExpiresInSeconds() > 0) {
178 writer.println("Expires in: {} seconds", message.getExpiresInSeconds());
179 }
180 if (message.getProfileKey().isPresent()) {
181 writer.println("Profile key update, key length: {}", message.getProfileKey().get().length);
182 }
183 if (message.getReaction().isPresent()) {
184 writer.println("Reaction:");
185 final var reaction = message.getReaction().get();
186 printReaction(writer.indentedWriter(), reaction);
187 }
188 if (message.getQuote().isPresent()) {
189 writer.println("Quote:");
190 var quote = message.getQuote().get();
191 printQuote(writer.indentedWriter(), quote);
192 }
193 if (message.getRemoteDelete().isPresent()) {
194 final var remoteDelete = message.getRemoteDelete().get();
195 writer.println("Remote delete message: timestamp = {}", remoteDelete.getTargetSentTimestamp());
196 }
197 if (message.getMentions().isPresent()) {
198 writer.println("Mentions:");
199 for (var mention : message.getMentions().get()) {
200 printMention(writer, mention);
201 }
202 }
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);
208 }
209 }
210 }
211
212 private void printTypingMessage(
213 final PlainTextWriter writer, final SignalServiceTypingMessage typingMessage
214 ) {
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);
221 }
222 }
223
224 private void printDecryptionErrorMessage(
225 final PlainTextWriter writer, final DecryptionErrorMessage decryptionErrorMessage
226 ) {
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");
231 }
232
233 private void printReceiptMessage(
234 final PlainTextWriter writer, final SignalServiceReceiptMessage receiptMessage
235 ) {
236 writer.println("When: {}", DateUtils.formatTimestamp(receiptMessage.getWhen()));
237 if (receiptMessage.isDeliveryReceipt()) {
238 writer.println("Is delivery receipt");
239 }
240 if (receiptMessage.isReadReceipt()) {
241 writer.println("Is read receipt");
242 }
243 if (receiptMessage.isViewedReceipt()) {
244 writer.println("Is viewed receipt");
245 }
246 writer.println("Timestamps:");
247 for (long timestamp : receiptMessage.getTimestamps()) {
248 writer.println("- {}", DateUtils.formatTimestamp(timestamp));
249 }
250 }
251
252 private void printCallMessage(
253 final PlainTextWriter writer, final SignalServiceCallMessage callMessage
254 ) {
255 if (callMessage.getDestinationDeviceId().isPresent()) {
256 final var deviceId = callMessage.getDestinationDeviceId().get();
257 writer.println("Destination device id: {}", deviceId);
258 }
259 if (callMessage.getGroupId().isPresent()) {
260 final var groupId = GroupId.unknownVersion(callMessage.getGroupId().get());
261 writer.println("Destination group id: {}", groupId);
262 }
263 if (callMessage.getTimestamp().isPresent()) {
264 writer.println("Timestamp: {}", DateUtils.formatTimestamp(callMessage.getTimestamp().get()));
265 }
266 if (callMessage.getAnswerMessage().isPresent()) {
267 var answerMessage = callMessage.getAnswerMessage().get();
268 writer.println("Answer message: {}, sdp: {})", answerMessage.getId(), answerMessage.getSdp());
269 }
270 if (callMessage.getBusyMessage().isPresent()) {
271 var busyMessage = callMessage.getBusyMessage().get();
272 writer.println("Busy message: {}", busyMessage.getId());
273 }
274 if (callMessage.getHangupMessage().isPresent()) {
275 var hangupMessage = callMessage.getHangupMessage().get();
276 writer.println("Hangup message: {}", hangupMessage.getId());
277 }
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());
283 }
284 }
285 if (callMessage.getOfferMessage().isPresent()) {
286 var offerMessage = callMessage.getOfferMessage().get();
287 writer.println("Offer message: {}, sdp: {}", offerMessage.getId(), offerMessage.getSdp());
288 }
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());
294 }
295 }
296
297 private void printSyncMessage(
298 final PlainTextWriter writer, final SignalServiceSyncMessage syncMessage
299 ) {
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());
305 }
306 if (syncMessage.getGroups().isPresent()) {
307 writer.println("Received sync groups:");
308 printAttachment(writer.indentedWriter(), syncMessage.getGroups().get());
309 }
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()));
316 }
317 }
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()));
324 }
325 }
326 if (syncMessage.getRequest().isPresent()) {
327 String type;
328 if (syncMessage.getRequest().get().isContactsRequest()) {
329 type = "contacts";
330 } else if (syncMessage.getRequest().get().isGroupsRequest()) {
331 type = "groups";
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()) {
337 type = "keys";
338 } else {
339 type = "<unknown>";
340 }
341 writer.println("Received sync request for: {}", type);
342 }
343 if (syncMessage.getSent().isPresent()) {
344 writer.println("Received sync sent message");
345 final var sentTranscriptMessage = syncMessage.getSent().get();
346 String to;
347 if (sentTranscriptMessage.getDestination().isPresent()) {
348 to = formatContact(sentTranscriptMessage.getDestination().get());
349 } else if (sentTranscriptMessage.getRecipients().size() > 0) {
350 to = sentTranscriptMessage.getRecipients()
351 .stream()
352 .map(this::formatContact)
353 .collect(Collectors.joining(", "));
354 } else {
355 to = "<unknown>";
356 }
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()));
364 }
365 var message = sentTranscriptMessage.getMessage();
366 printDataMessage(writer.indentedWriter(), message);
367 }
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));
374 }
375 }
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);
383 }
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");
390 }
391 if (configurationMessage.getLinkPreviews().isPresent()) {
392 writer.println("- Link previews: {}",
393 configurationMessage.getLinkPreviews().get() ? "enabled" : "disabled");
394 }
395 if (configurationMessage.getTypingIndicators().isPresent()) {
396 writer.println("- Typing indicators: {}",
397 configurationMessage.getTypingIndicators().get() ? "enabled" : "disabled");
398 }
399 if (configurationMessage.getUnidentifiedDeliveryIndicators().isPresent()) {
400 writer.println("- Unidentified Delivery Indicators: {}",
401 configurationMessage.getUnidentifiedDeliveryIndicators().get() ? "enabled" : "disabled");
402 }
403 }
404 if (syncMessage.getFetchType().isPresent()) {
405 final var fetchType = syncMessage.getFetchType().get();
406 writer.println("Received sync message with fetch type: {}", fetchType);
407 }
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()));
414 }
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()));
423 }
424 if (m.getPackKey().isPresent()) {
425 writer.indentedWriter()
426 .println("packKey: {}", Base64.getEncoder().encodeToString(m.getPackKey().get()));
427 }
428 }
429 }
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()));
438 }
439 if (requestResponseMessage.getPerson().isPresent()) {
440 writer.indentedWriter()
441 .println("For Person: {}", formatContact(requestResponseMessage.getPerson().get()));
442 }
443 }
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);
449 }
450 }
451 }
452
453 private void printPreview(
454 final PlainTextWriter writer, final SignalServiceDataMessage.Preview preview
455 ) {
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());
463 }
464 }
465
466 private void printSticker(
467 final PlainTextWriter writer, final SignalServiceDataMessage.Sticker sticker
468 ) {
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());
474 }
475
476 private void printReaction(
477 final PlainTextWriter writer, final SignalServiceDataMessage.Reaction reaction
478 ) {
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());
483 }
484
485 private void printQuote(
486 final PlainTextWriter writer, final SignalServiceDataMessage.Quote quote
487 ) {
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);
495 }
496 }
497 if (quote.getAttachments().size() > 0) {
498 writer.println("Attachments:");
499 for (var attachment : quote.getAttachments()) {
500 writer.println("- Filename: {}", attachment.getFileName());
501 writer.indent(w -> {
502 w.println("Type: {}", attachment.getContentType());
503 w.println("Thumbnail:");
504 if (attachment.getThumbnail() != null) {
505 printAttachment(w, attachment.getThumbnail());
506 }
507 });
508 }
509 }
510 }
511
512 private void printSharedContact(final PlainTextWriter writer, final SharedContact contact) {
513 writer.println("Name:");
514 var name = contact.getName();
515 writer.indent(w -> {
516 if (name.getDisplay().isPresent() && !name.getDisplay().get().isBlank()) {
517 w.println("Display name: {}", name.getDisplay().get());
518 }
519 if (name.getGiven().isPresent() && !name.getGiven().get().isBlank()) {
520 w.println("First name: {}", name.getGiven().get());
521 }
522 if (name.getMiddle().isPresent() && !name.getMiddle().get().isBlank()) {
523 w.println("Middle name: {}", name.getMiddle().get());
524 }
525 if (name.getFamily().isPresent() && !name.getFamily().get().isBlank()) {
526 w.println("Family name: {}", name.getFamily().get());
527 }
528 if (name.getPrefix().isPresent() && !name.getPrefix().get().isBlank()) {
529 w.println("Prefix name: {}", name.getPrefix().get());
530 }
531 if (name.getSuffix().isPresent() && !name.getSuffix().get().isBlank()) {
532 w.println("Suffix name: {}", name.getSuffix().get());
533 }
534 });
535
536 if (contact.getAvatar().isPresent()) {
537 var avatar = contact.getAvatar().get();
538 writer.println("Avatar: (profile: {})", avatar.isProfile());
539 printAttachment(writer.indentedWriter(), avatar.getAttachment());
540 }
541
542 if (contact.getOrganization().isPresent()) {
543 writer.println("Organisation: {}", contact.getOrganization().get());
544 }
545
546 if (contact.getPhone().isPresent()) {
547 writer.println("Phone details:");
548 for (var phone : contact.getPhone().get()) {
549 writer.println("- Phone:");
550 writer.indent(w -> {
551 if (phone.getValue() != null) {
552 w.println("Number: {}", phone.getValue());
553 }
554 if (phone.getType() != null) {
555 w.println("Type: {}", phone.getType());
556 }
557 if (phone.getLabel().isPresent() && !phone.getLabel().get().isBlank()) {
558 w.println("Label: {}", phone.getLabel().get());
559 }
560 });
561 }
562 }
563
564 if (contact.getEmail().isPresent()) {
565 writer.println("Email details:");
566 for (var email : contact.getEmail().get()) {
567 writer.println("- Email:");
568 writer.indent(w -> {
569 if (email.getValue() != null) {
570 w.println("Address: {}", email.getValue());
571 }
572 if (email.getType() != null) {
573 w.println("Type: {}", email.getType());
574 }
575 if (email.getLabel().isPresent() && !email.getLabel().get().isBlank()) {
576 w.println("Label: {}", email.getLabel().get());
577 }
578 });
579 }
580 }
581
582 if (contact.getAddress().isPresent()) {
583 writer.println("Address details:");
584 for (var address : contact.getAddress().get()) {
585 writer.println("- Address:");
586 writer.indent(w -> {
587 if (address.getType() != null) {
588 w.println("Type: {}", address.getType());
589 }
590 if (address.getLabel().isPresent() && !address.getLabel().get().isBlank()) {
591 w.println("Label: {}", address.getLabel().get());
592 }
593 if (address.getStreet().isPresent() && !address.getStreet().get().isBlank()) {
594 w.println("Street: {}", address.getStreet().get());
595 }
596 if (address.getPobox().isPresent() && !address.getPobox().get().isBlank()) {
597 w.println("Pobox: {}", address.getPobox().get());
598 }
599 if (address.getNeighborhood().isPresent() && !address.getNeighborhood().get().isBlank()) {
600 w.println("Neighbourhood: {}", address.getNeighborhood().get());
601 }
602 if (address.getCity().isPresent() && !address.getCity().get().isBlank()) {
603 w.println("City: {}", address.getCity().get());
604 }
605 if (address.getRegion().isPresent() && !address.getRegion().get().isBlank()) {
606 w.println("Region: {}", address.getRegion().get());
607 }
608 if (address.getPostcode().isPresent() && !address.getPostcode().get().isBlank()) {
609 w.println("Postcode: {}", address.getPostcode().get());
610 }
611 if (address.getCountry().isPresent() && !address.getCountry().get().isBlank()) {
612 w.println("Country: {}", address.getCountry().get());
613 }
614 });
615 }
616 }
617 }
618
619 private void printGroupContext(
620 final PlainTextWriter writer, final SignalServiceGroupContext groupContext
621 ) {
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));
631 }
632 }
633 if (groupInfo.getAvatar().isPresent()) {
634 writer.println("Avatar:");
635 printAttachment(writer.indentedWriter(), groupInfo.getAvatar().get());
636 }
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());
643 }
644 }
645
646 private void printGroupInfo(final PlainTextWriter writer, final GroupId groupId) {
647 writer.println("Id: {}", groupId.toBase64());
648
649 var group = m.getGroup(groupId);
650 if (group != null) {
651 writer.println("Name: {}", group.getTitle());
652 } else {
653 writer.println("Name: <Unknown group>");
654 }
655 }
656
657 private void printMention(
658 PlainTextWriter writer, SignalServiceDataMessage.Mention mention
659 ) {
660 final var address = m.resolveSignalServiceAddress(mention.getUuid());
661 writer.println("- {}: {} (length: {})", formatContact(address), mention.getStart(), mention.getLength());
662 }
663
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()));
672 }
673 if (pointer.getCaption().isPresent()) {
674 writer.println("Caption: {}", pointer.getCaption().get());
675 }
676 if (pointer.getFileName().isPresent()) {
677 writer.println("Filename: {}", pointer.getFileName().get());
678 }
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
683 + " bytes)" : "");
684 final var flags = new ArrayList<String>();
685 if (pointer.getVoiceNote()) {
686 flags.add("voice note");
687 }
688 if (pointer.isBorderless()) {
689 flags.add("borderless");
690 }
691 if (pointer.isGif()) {
692 flags.add("video gif");
693 }
694 if (flags.size() > 0) {
695 writer.println("Flags: {}", String.join(", ", flags));
696 }
697 if (pointer.getWidth() > 0 || pointer.getHeight() > 0) {
698 writer.println("Dimensions: {}x{}", pointer.getWidth(), pointer.getHeight());
699 }
700 var file = m.getAttachmentFile(pointer.getRemoteId());
701 if (file.exists()) {
702 writer.println("Stored plaintext in: {}", file);
703 }
704 }
705 }
706
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()) {
712 return number;
713 } else {
714 return MessageFormatter.arrayFormat("“{}” {}", new Object[]{name, number}).getMessage();
715 }
716 }
717 }