- if (content.getDataMessage().isPresent()) {
- SignalServiceDataMessage message = content.getDataMessage().get();
- handleSignalServiceDataMessage(message);
- }
- if (content.getSyncMessage().isPresent()) {
- System.out.println("Received a sync message");
- SignalServiceSyncMessage syncMessage = content.getSyncMessage().get();
-
- if (syncMessage.getContacts().isPresent()) {
- final ContactsMessage contactsMessage = syncMessage.getContacts().get();
- if (contactsMessage.isComplete()) {
- System.out.println("Received complete sync contacts");
- } else {
- System.out.println("Received sync contacts");
- }
- printAttachment(contactsMessage.getContactsStream());
- }
- if (syncMessage.getGroups().isPresent()) {
- System.out.println("Received sync groups");
- printAttachment(syncMessage.getGroups().get());
- }
- if (syncMessage.getRead().isPresent()) {
- System.out.println("Received sync read messages list");
- for (ReadMessage rm : syncMessage.getRead().get()) {
- ContactInfo fromContact = m.getContact(rm.getSender());
- System.out.println("From: " + (fromContact == null ? "" : "“" + fromContact.name + "” ") + rm.getSender() + " Message timestamp: " + DateUtils.formatTimestamp(rm.getTimestamp()));
- }
- }
- if (syncMessage.getRequest().isPresent()) {
- System.out.println("Received sync request");
- if (syncMessage.getRequest().get().isContactsRequest()) {
- System.out.println(" - contacts request");
- }
- if (syncMessage.getRequest().get().isGroupsRequest()) {
- System.out.println(" - groups request");
- }
- }
- if (syncMessage.getSent().isPresent()) {
- System.out.println("Received sync sent message");
- final SentTranscriptMessage sentTranscriptMessage = syncMessage.getSent().get();
- String to;
- if (sentTranscriptMessage.getDestination().isPresent()) {
- String dest = sentTranscriptMessage.getDestination().get();
- ContactInfo destContact = m.getContact(dest);
- to = (destContact == null ? "" : "“" + destContact.name + "” ") + dest;
- } else {
- to = "Unknown";
- }
- System.out.println("To: " + to + " , Message timestamp: " + DateUtils.formatTimestamp(sentTranscriptMessage.getTimestamp()));
- if (sentTranscriptMessage.getExpirationStartTimestamp() > 0) {
- System.out.println("Expiration started at: " + DateUtils.formatTimestamp(sentTranscriptMessage.getExpirationStartTimestamp()));
- }
- SignalServiceDataMessage message = sentTranscriptMessage.getMessage();
- handleSignalServiceDataMessage(message);
- }
- if (syncMessage.getBlockedList().isPresent()) {
- System.out.println("Received sync message with block list");
- System.out.println("Blocked numbers:");
- final BlockedListMessage blockedList = syncMessage.getBlockedList().get();
- for (String number : blockedList.getNumbers()) {
- System.out.println(" - " + number);
- }
- }
- if (syncMessage.getVerified().isPresent()) {
- System.out.println("Received sync message with verified identities:");
- final VerifiedMessage verifiedMessage = syncMessage.getVerified().get();
- System.out.println(" - " + verifiedMessage.getDestination() + ": " + verifiedMessage.getVerified());
- String safetyNumber = Util.formatSafetyNumber(m.computeSafetyNumber(verifiedMessage.getDestination(), verifiedMessage.getIdentityKey()));
- System.out.println(" " + safetyNumber);
- }
- if (syncMessage.getConfiguration().isPresent()) {
- System.out.println("Received sync message with configuration:");
- final ConfigurationMessage configurationMessage = syncMessage.getConfiguration().get();
- if (configurationMessage.getReadReceipts().isPresent()) {
- System.out.println(" - Read receipts: " + (configurationMessage.getReadReceipts().get() ? "enabled" : "disabled"));
- }
+ to = "<unknown>";
+ }
+ writer.indentedWriter().println("To: {}", to);
+ writer.indentedWriter()
+ .println("Timestamp: {}", DateUtils.formatTimestamp(sentTranscriptMessage.timestamp()));
+ if (sentTranscriptMessage.expirationStartTimestamp() > 0) {
+ writer.indentedWriter()
+ .println("Expiration started at: {}",
+ DateUtils.formatTimestamp(sentTranscriptMessage.expirationStartTimestamp()));
+ }
+ if (sentTranscriptMessage.message().isPresent()) {
+ var message = sentTranscriptMessage.message().get();
+ printDataMessage(writer.indentedWriter(), message);
+ }
+ if (sentTranscriptMessage.story().isPresent()) {
+ var message = sentTranscriptMessage.story().get();
+ printStoryMessage(writer.indentedWriter(), message);
+ }
+ }
+ if (syncMessage.blocked().isPresent()) {
+ writer.println("Received sync message with block list");
+ writer.println("Blocked:");
+ final var blockedList = syncMessage.blocked().get();
+ for (var address : blockedList.recipients()) {
+ writer.println("- {}", address.getLegacyIdentifier());
+ }
+ for (var groupId : blockedList.groupIds()) {
+ writer.println("- {}", groupId.toBase64());
+ }
+ }
+ if (syncMessage.viewOnceOpen().isPresent()) {
+ final var viewOnceOpenMessage = syncMessage.viewOnceOpen().get();
+ writer.println("Received sync message with view once open message:");
+ writer.indentedWriter().println("Sender: {}", formatContact(viewOnceOpenMessage.sender()));
+ writer.indentedWriter()
+ .println("Timestamp: {}", DateUtils.formatTimestamp(viewOnceOpenMessage.timestamp()));
+ }
+ if (syncMessage.messageRequestResponse().isPresent()) {
+ final var requestResponseMessage = syncMessage.messageRequestResponse().get();
+ writer.println("Received message request response:");
+ writer.indentedWriter().println("Type: {}", requestResponseMessage.type());
+ if (requestResponseMessage.groupId().isPresent()) {
+ writer.println("For group:");
+ printGroupInfo(writer.indentedWriter(), requestResponseMessage.groupId().get());
+ }
+ if (requestResponseMessage.person().isPresent()) {
+ writer.indentedWriter().println("For Person: {}", formatContact(requestResponseMessage.person().get()));
+ }
+ }
+ }
+
+ private void printPreview(
+ final PlainTextWriter writer, final MessageEnvelope.Data.Preview preview
+ ) {
+ writer.println("Title: {}", preview.title());
+ writer.println("Description: {}", preview.description());
+ writer.println("Date: {}", DateUtils.formatTimestamp(preview.date()));
+ writer.println("Url: {}", preview.url());
+ if (preview.image().isPresent()) {
+ writer.println("Image:");
+ printAttachment(writer.indentedWriter(), preview.image().get());
+ }
+ }
+
+ private void printSticker(
+ final PlainTextWriter writer, final MessageEnvelope.Data.Sticker sticker
+ ) {
+ writer.println("Pack id: {}", Hex.toStringCondensed(sticker.packId().serialize()));
+ writer.println("Sticker id: {}", sticker.stickerId());
+ }
+
+ private void printReaction(
+ final PlainTextWriter writer, final MessageEnvelope.Data.Reaction reaction
+ ) {
+ writer.println("Emoji: {}", reaction.emoji());
+ writer.println("Target author: {}", formatContact(reaction.targetAuthor()));
+ writer.println("Target timestamp: {}", DateUtils.formatTimestamp(reaction.targetSentTimestamp()));
+ writer.println("Is remove: {}", reaction.isRemove());
+ }
+
+ private void printQuote(
+ final PlainTextWriter writer, final MessageEnvelope.Data.Quote quote
+ ) {
+ writer.println("Id: {}", quote.id());
+ writer.println("Author: {}", formatContact(quote.author()));
+ if (quote.text().isPresent()) {
+ writer.println("Text: {}", quote.text().get());
+ }
+ if (quote.mentions() != null && quote.mentions().size() > 0) {
+ writer.println("Mentions:");
+ for (var mention : quote.mentions()) {
+ printMention(writer, mention);
+ }
+ }
+ if (quote.attachments().size() > 0) {
+ writer.println("Attachments:");
+ for (var attachment : quote.attachments()) {
+ writer.println("- Attachment:");
+ printAttachment(writer.indentedWriter(), attachment);
+ }
+ }
+ }
+
+ private void printSharedContact(final PlainTextWriter writer, final MessageEnvelope.Data.SharedContact contact) {
+ writer.println("Name:");
+ var name = contact.name();
+ writer.indent(w -> {
+ if (name.display().isPresent() && !name.display().get().isBlank()) {
+ w.println("Display name: {}", name.display().get());
+ }
+ if (name.given().isPresent() && !name.given().get().isBlank()) {
+ w.println("First name: {}", name.given().get());
+ }
+ if (name.middle().isPresent() && !name.middle().get().isBlank()) {
+ w.println("Middle name: {}", name.middle().get());
+ }
+ if (name.family().isPresent() && !name.family().get().isBlank()) {
+ w.println("Family name: {}", name.family().get());
+ }
+ if (name.prefix().isPresent() && !name.prefix().get().isBlank()) {
+ w.println("Prefix name: {}", name.prefix().get());
+ }
+ if (name.suffix().isPresent() && !name.suffix().get().isBlank()) {
+ w.println("Suffix name: {}", name.suffix().get());
+ }
+ });
+
+ if (contact.avatar().isPresent()) {
+ var avatar = contact.avatar().get();
+ writer.println("Avatar: (profile: {})", avatar.isProfile());
+ printAttachment(writer.indentedWriter(), avatar.attachment());
+ }
+
+ if (contact.organization().isPresent()) {
+ writer.println("Organisation: {}", contact.organization().get());
+ }
+
+ if (contact.phone().size() > 0) {
+ writer.println("Phone details:");
+ for (var phone : contact.phone()) {
+ writer.println("- Phone:");
+ writer.indent(w -> {
+ w.println("Number: {}", phone.value());
+ w.println("Type: {}", phone.type());
+ if (phone.label().isPresent() && !phone.label().get().isBlank()) {
+ w.println("Label: {}", phone.label().get());
git.nmode.ca / signal-cli / blobdiff
