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