+ }
+
+ if (envelope.data().isPresent()) {
+ var message = envelope.data().get();
+ printDataMessage(writer, message);
+ }
+ if (envelope.story().isPresent()) {
+ var message = envelope.story().get();
+ printStoryMessage(writer.indentedWriter(), message);
+ }
+ if (envelope.sync().isPresent()) {
+ writer.println("Received a sync message");
+ var syncMessage = envelope.sync().get();
+ printSyncMessage(writer, syncMessage);
+ }
+ if (envelope.call().isPresent()) {
+ writer.println("Received a call message");
+ var callMessage = envelope.call().get();
+ printCallMessage(writer.indentedWriter(), callMessage);
+ }
+ if (envelope.receipt().isPresent()) {
+ writer.println("Received a receipt message");
+ var receiptMessage = envelope.receipt().get();
+ printReceiptMessage(writer.indentedWriter(), receiptMessage);
+ }
+ if (envelope.typing().isPresent()) {
+ writer.println("Received a typing message");
+ var typingMessage = envelope.typing().get();
+ printTypingMessage(writer.indentedWriter(), typingMessage);
+ }
+ writer.println();
+ }
+
+ private void printDataMessage(
+ PlainTextWriter writer, MessageEnvelope.Data message
+ ) {
+ writer.println("Message timestamp: {}", DateUtils.formatTimestamp(message.timestamp()));
+ if (message.isViewOnce()) {
+ writer.println("=VIEW ONCE=");
+ }
+
+ if (message.body().isPresent()) {
+ writer.println("Body: {}", message.body().get());
+ }
+ if (message.groupContext().isPresent()) {
+ writer.println("Group info:");
+ final var groupContext = message.groupContext().get();
+ printGroupContext(writer.indentedWriter(), groupContext);
+ }
+ if (message.storyContext().isPresent()) {
+ writer.println("Story reply:");
+ final var storyContext = message.storyContext().get();
+ printStoryContext(writer.indentedWriter(), storyContext);
+ }
+ if (message.groupCallUpdate().isPresent()) {
+ writer.println("Group call update:");
+ final var groupCallUpdate = message.groupCallUpdate().get();
+ writer.indentedWriter().println("Era id: {}", groupCallUpdate.eraId());
+ }
+ if (message.previews().size() > 0) {
+ writer.println("Previews:");
+ final var previews = message.previews();
+ for (var preview : previews) {
+ writer.println("- Preview");
+ printPreview(writer.indentedWriter(), preview);
+ }
+ }
+ if (message.sharedContacts().size() > 0) {
+ writer.println("Contacts:");
+ for (var contact : message.sharedContacts()) {
+ writer.println("- Contact:");
+ printSharedContact(writer.indentedWriter(), contact);
+ }
+ }
+ if (message.sticker().isPresent()) {
+ final var sticker = message.sticker().get();
+ writer.println("Sticker:");
+ printSticker(writer.indentedWriter(), sticker);
+ }
+ if (message.isEndSession()) {
+ writer.println("Is end session");
+ }
+ if (message.isExpirationUpdate()) {
+ writer.println("Is Expiration update: true");
+ }
+ if (message.expiresInSeconds() > 0) {
+ writer.println("Expires in: {} seconds", message.expiresInSeconds());
+ }
+ if (message.isProfileKeyUpdate()) {
+ writer.println("Profile key update");
+ }
+ if (message.hasProfileKey()) {
+ writer.println("With profile key");
+ }
+ if (message.reaction().isPresent()) {
+ writer.println("Reaction:");
+ final var reaction = message.reaction().get();
+ printReaction(writer.indentedWriter(), reaction);
+ }
+ if (message.quote().isPresent()) {
+ writer.println("Quote:");
+ var quote = message.quote().get();
+ printQuote(writer.indentedWriter(), quote);
+ }
+ if (message.remoteDeleteId().isPresent()) {
+ final var remoteDelete = message.remoteDeleteId().get();
+ writer.println("Remote delete message: timestamp = {}", remoteDelete);
+ }
+ if (message.mentions().size() > 0) {
+ writer.println("Mentions:");
+ for (var mention : message.mentions()) {
+ printMention(writer, mention);
+ }
+ }
+ if (message.textStyles().size() > 0) {
+ writer.println("Text styles:");
+ for (var textStyle : message.textStyles()) {
+ printTextStyle(writer, textStyle);
+ }
+ }
+ if (message.attachments().size() > 0) {
+ writer.println("Attachments:");
+ for (var attachment : message.attachments()) {
+ writer.println("- Attachment:");
+ printAttachment(writer.indentedWriter(), attachment);
+ }
+ }
+ }
+
+ private void printStoryMessage(
+ PlainTextWriter writer, MessageEnvelope.Story message
+ ) {
+ writer.println("Story: with replies: {}", message.allowsReplies());
+ if (message.groupId().isPresent()) {
+ writer.println("Group info:");
+ printGroupInfo(writer.indentedWriter(), message.groupId().get());
+ }
+ if (message.textAttachment().isPresent()) {
+ writer.println("Body: {}", message.textAttachment().get().text().orElse(""));
+
+ if (message.textAttachment().get().preview().isPresent()) {
+ writer.println("Preview:");
+ printPreview(writer.indentedWriter(), message.textAttachment().get().preview().get());
+ }
+ }
+ if (message.fileAttachment().isPresent()) {
+ writer.println("Attachments:");
+ printAttachment(writer.indentedWriter(), message.fileAttachment().get());
+ }
+ }
+
+ private void printTypingMessage(
+ final PlainTextWriter writer, final MessageEnvelope.Typing typingMessage
+ ) {
+ writer.println("Action: {}", typingMessage.type());
+ writer.println("Timestamp: {}", DateUtils.formatTimestamp(typingMessage.timestamp()));
+ if (typingMessage.groupId().isPresent()) {
+ writer.println("Group Info:");
+ final var groupId = typingMessage.groupId().get();
+ printGroupInfo(writer.indentedWriter(), groupId);
+ }
+ }
+
+ private void printReceiptMessage(
+ final PlainTextWriter writer, final MessageEnvelope.Receipt receiptMessage
+ ) {
+ writer.println("When: {}", DateUtils.formatTimestamp(receiptMessage.when()));
+ if (receiptMessage.type() == MessageEnvelope.Receipt.Type.DELIVERY) {
+ writer.println("Is delivery receipt");
+ }
+ if (receiptMessage.type() == MessageEnvelope.Receipt.Type.READ) {
+ writer.println("Is read receipt");
+ }
+ if (receiptMessage.type() == MessageEnvelope.Receipt.Type.VIEWED) {
+ writer.println("Is viewed receipt");
+ }
+ writer.println("Timestamps:");
+ for (long timestamp : receiptMessage.timestamps()) {
+ writer.println("- {}", DateUtils.formatTimestamp(timestamp));
+ }
+ }
+
+ private void printCallMessage(
+ final PlainTextWriter writer, final MessageEnvelope.Call callMessage
+ ) {
+ if (callMessage.destinationDeviceId().isPresent()) {
+ final var deviceId = callMessage.destinationDeviceId().get();
+ writer.println("Destination device id: {}", deviceId);
+ }
+ if (callMessage.groupId().isPresent()) {
+ final var groupId = callMessage.groupId().get();
+ writer.println("Destination group id: {}", groupId);
+ }
+ if (callMessage.timestamp().isPresent()) {
+ writer.println("Timestamp: {}", DateUtils.formatTimestamp(callMessage.timestamp().get()));
+ }
+ if (callMessage.answer().isPresent()) {
+ var answerMessage = callMessage.answer().get();
+ writer.println("Answer message: {}, sdp: {})", answerMessage.id(), answerMessage.sdp());
+ }
+ if (callMessage.busy().isPresent()) {
+ var busyMessage = callMessage.busy().get();
+ writer.println("Busy message: {}", busyMessage.id());
+ }
+ if (callMessage.hangup().isPresent()) {
+ var hangupMessage = callMessage.hangup().get();
+ writer.println("Hangup message: {}", hangupMessage.id());
+ }
+ if (callMessage.iceUpdate().size() > 0) {
+ writer.println("Ice update messages:");
+ var iceUpdateMessages = callMessage.iceUpdate();
+ for (var iceUpdateMessage : iceUpdateMessages) {
+ writer.println("- {}, sdp: {}", iceUpdateMessage.id(), iceUpdateMessage.sdp());
+ }
+ }
+ if (callMessage.offer().isPresent()) {
+ var offerMessage = callMessage.offer().get();
+ writer.println("Offer message: {}, sdp: {}", offerMessage.id(), offerMessage.sdp());
+ }
+ if (callMessage.opaque().isPresent()) {
+ final var opaqueMessage = callMessage.opaque().get();
+ writer.println("Opaque message: size {}, urgency: {}",
+ opaqueMessage.opaque().length,
+ opaqueMessage.urgency().name());
+ }
+ }
+
+ private void printSyncMessage(
+ final PlainTextWriter writer, final MessageEnvelope.Sync syncMessage
+ ) {
+ if (syncMessage.contacts().isPresent()) {
+ final var contactsMessage = syncMessage.contacts().get();
+ var type = contactsMessage.isComplete() ? "complete" : "partial";
+ writer.println("Received {} sync contacts:", type);
+ }
+ if (syncMessage.groups().isPresent()) {
+ writer.println("Received sync groups.");
+ }
+ if (syncMessage.read().size() > 0) {
+ writer.println("Received sync read messages list");
+ for (var rm : syncMessage.read()) {
+ writer.println("- From: {} Message timestamp: {}",
+ formatContact(rm.sender()),
+ DateUtils.formatTimestamp(rm.timestamp()));
+ }
+ }
+ if (syncMessage.viewed().size() > 0) {
+ writer.println("Received sync viewed messages list");
+ for (var vm : syncMessage.viewed()) {
+ writer.println("- From: {} Message timestamp: {}",
+ formatContact(vm.sender()),
+ DateUtils.formatTimestamp(vm.timestamp()));
+ }
+ }
+ if (syncMessage.sent().isPresent()) {
+ writer.println("Received sync sent message");
+ final var sentTranscriptMessage = syncMessage.sent().get();
+ String to;
+ if (sentTranscriptMessage.destination().isPresent()) {
+ to = formatContact(sentTranscriptMessage.destination().get());
+ } else if (sentTranscriptMessage.recipients().size() > 0) {
+ to = sentTranscriptMessage.recipients()
+ .stream()
+ .map(this::formatContact)
+ .collect(Collectors.joining(", "));
git.nmode.ca / signal-cli / blobdiff
