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