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