]> nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/ReceiveMessageHandler.java
7228e005d70a8e1b5bf2dd47de51960306b247f7
[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.util.DateUtils;
7 import org.asamk.signal.util.Util;
8 import org.signal.libsignal.metadata.ProtocolUntrustedIdentityException;
9 import org.slf4j.helpers.MessageFormatter;
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.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
33 public ReceiveMessageHandler(Manager m) {
34 this.m = m;
35 }
36
37 @Override
38 public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
39 PlainTextWriter writer = new PlainTextWriterImpl(System.out);
40
41 if (envelope.hasSource()) {
42 var source = envelope.getSourceAddress();
43 writer.println("Envelope from: {} (device: {})", formatContact(source), envelope.getSourceDevice());
44 if (source.getRelay().isPresent()) {
45 writer.println("Relayed by: {}", source.getRelay().get());
46 }
47 } else {
48 writer.println("Envelope from: unknown source");
49 }
50 writer.println("Timestamp: {}", DateUtils.formatTimestamp(envelope.getTimestamp()));
51 if (envelope.isUnidentifiedSender()) {
52 writer.println("Sent by unidentified/sealed sender");
53 }
54
55 if (envelope.isReceipt()) {
56 writer.println("Got receipt.");
57 } else if (envelope.isSignalMessage() || envelope.isPreKeySignalMessage() || envelope.isUnidentifiedSender()) {
58 if (exception != null) {
59 if (exception instanceof ProtocolUntrustedIdentityException) {
60 var e = (ProtocolUntrustedIdentityException) exception;
61 writer.println(
62 "The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
63 final var recipientName = getLegacyIdentifier(m.resolveSignalServiceAddress(e.getSender()));
64 writer.println(
65 "Use 'signal-cli -u {} listIdentities -n {}', verify the key and run 'signal-cli -u {} trust -v \"FINGER_PRINT\" {}' to mark it as trusted",
66 m.getUsername(),
67 recipientName,
68 m.getUsername(),
69 recipientName);
70 writer.println(
71 "If you don't care about security, use 'signal-cli -u {} trust -a {}' to trust it without verification",
72 m.getUsername(),
73 recipientName);
74 } else {
75 writer.println("Exception: {} ({})", exception.getMessage(), exception.getClass().getSimpleName());
76 }
77 }
78 if (content == null) {
79 writer.println("No message content");
80 } else {
81 writer.println("Sender: {} (device: {})",
82 formatContact(content.getSender()),
83 content.getSenderDevice());
84 writer.println("Server timestamps: received: {} delivered: {}",
85 DateUtils.formatTimestamp(content.getServerReceivedTimestamp()),
86 DateUtils.formatTimestamp(content.getServerDeliveredTimestamp()));
87
88 if (content.getDataMessage().isPresent()) {
89 var message = content.getDataMessage().get();
90 printDataMessage(writer, message);
91 }
92 if (content.getSyncMessage().isPresent()) {
93 writer.println("Received a sync message");
94 var syncMessage = content.getSyncMessage().get();
95 printSyncMessage(writer, syncMessage);
96 }
97
98 if (content.getCallMessage().isPresent()) {
99 writer.println("Received a call message");
100 var callMessage = content.getCallMessage().get();
101 printCallMessage(writer.indentedWriter(), callMessage);
102 }
103 if (content.getReceiptMessage().isPresent()) {
104 writer.println("Received a receipt message");
105 var receiptMessage = content.getReceiptMessage().get();
106 printReceiptMessage(writer.indentedWriter(), receiptMessage);
107 }
108 if (content.getTypingMessage().isPresent()) {
109 writer.println("Received a typing message");
110 var typingMessage = content.getTypingMessage().get();
111 printTypingMessage(writer.indentedWriter(), typingMessage);
112 }
113 }
114 } else {
115 writer.println("Unknown message received.");
116 }
117 writer.println();
118 }
119
120 private void printDataMessage(
121 PlainTextWriter writer, SignalServiceDataMessage message
122 ) {
123 writer.println("Message timestamp: {}", DateUtils.formatTimestamp(message.getTimestamp()));
124 if (message.isViewOnce()) {
125 writer.println("=VIEW ONCE=");
126 }
127
128 if (message.getBody().isPresent()) {
129 writer.println("Body: {}", message.getBody().get());
130 }
131 if (message.getGroupContext().isPresent()) {
132 writer.println("Group info:");
133 final var groupContext = message.getGroupContext().get();
134 printGroupContext(writer.indentedWriter(), groupContext);
135 }
136 if (message.getGroupCallUpdate().isPresent()) {
137 writer.println("Group call update:");
138 final var groupCallUpdate = message.getGroupCallUpdate().get();
139 writer.indentedWriter().println("Era id: {}", groupCallUpdate.getEraId());
140 }
141 if (message.getPreviews().isPresent()) {
142 writer.println("Previews:");
143 final var previews = message.getPreviews().get();
144 for (var preview : previews) {
145 writer.println("- Preview");
146 printPreview(writer.indentedWriter(), preview);
147 }
148 }
149 if (message.getSharedContacts().isPresent()) {
150 final var sharedContacts = message.getSharedContacts().get();
151 writer.println("Contacts:");
152 for (var contact : sharedContacts) {
153 writer.println("- Contact:");
154 printSharedContact(writer.indentedWriter(), contact);
155 }
156 }
157 if (message.getSticker().isPresent()) {
158 final var sticker = message.getSticker().get();
159 writer.println("Sticker:");
160 printSticker(writer.indentedWriter(), sticker);
161 }
162 if (message.isEndSession()) {
163 writer.println("Is end session");
164 }
165 if (message.isExpirationUpdate()) {
166 writer.println("Is Expiration update: {}", message.isExpirationUpdate());
167 }
168 if (message.getExpiresInSeconds() > 0) {
169 writer.println("Expires in: {} seconds", message.getExpiresInSeconds());
170 }
171 if (message.getProfileKey().isPresent()) {
172 writer.println("Profile key update, key length: {}", message.getProfileKey().get().length);
173 }
174 if (message.getReaction().isPresent()) {
175 writer.println("Reaction:");
176 final var reaction = message.getReaction().get();
177 printReaction(writer.indentedWriter(), reaction);
178 }
179 if (message.getQuote().isPresent()) {
180 writer.println("Quote:");
181 var quote = message.getQuote().get();
182 printQuote(writer.indentedWriter(), quote);
183 }
184 if (message.getRemoteDelete().isPresent()) {
185 final var remoteDelete = message.getRemoteDelete().get();
186 writer.println("Remote delete message: timestamp = {}", remoteDelete.getTargetSentTimestamp());
187 }
188 if (message.getMentions().isPresent()) {
189 writer.println("Mentions:");
190 for (var mention : message.getMentions().get()) {
191 printMention(writer, mention);
192 }
193 }
194 if (message.getAttachments().isPresent()) {
195 writer.println("Attachments:");
196 for (var attachment : message.getAttachments().get()) {
197 writer.println("- Attachment:");
198 printAttachment(writer.indentedWriter(), attachment);
199 }
200 }
201 }
202
203 private void printTypingMessage(
204 final PlainTextWriter writer, final SignalServiceTypingMessage typingMessage
205 ) {
206 writer.println("Action: {}", typingMessage.getAction());
207 writer.println("Timestamp: {}", DateUtils.formatTimestamp(typingMessage.getTimestamp()));
208 if (typingMessage.getGroupId().isPresent()) {
209 writer.println("Group Info:");
210 final var groupId = GroupId.unknownVersion(typingMessage.getGroupId().get());
211 printGroupInfo(writer.indentedWriter(), groupId);
212 }
213 }
214
215 private void printReceiptMessage(
216 final PlainTextWriter writer, final SignalServiceReceiptMessage receiptMessage
217 ) {
218 writer.println("When: {}", DateUtils.formatTimestamp(receiptMessage.getWhen()));
219 if (receiptMessage.isDeliveryReceipt()) {
220 writer.println("Is delivery receipt");
221 }
222 if (receiptMessage.isReadReceipt()) {
223 writer.println("Is read receipt");
224 }
225 if (receiptMessage.isViewedReceipt()) {
226 writer.println("Is viewed receipt");
227 }
228 writer.println("Timestamps:");
229 for (long timestamp : receiptMessage.getTimestamps()) {
230 writer.println("- {}", DateUtils.formatTimestamp(timestamp));
231 }
232 }
233
234 private void printCallMessage(
235 final PlainTextWriter writer, final SignalServiceCallMessage callMessage
236 ) {
237 if (callMessage.getDestinationDeviceId().isPresent()) {
238 final var deviceId = callMessage.getDestinationDeviceId().get();
239 writer.println("Destination device id: {}", deviceId);
240 }
241 if (callMessage.getAnswerMessage().isPresent()) {
242 var answerMessage = callMessage.getAnswerMessage().get();
243 writer.println("Answer message: {}, sdp: {})", answerMessage.getId(), answerMessage.getSdp());
244 }
245 if (callMessage.getBusyMessage().isPresent()) {
246 var busyMessage = callMessage.getBusyMessage().get();
247 writer.println("Busy message: {}", busyMessage.getId());
248 }
249 if (callMessage.getHangupMessage().isPresent()) {
250 var hangupMessage = callMessage.getHangupMessage().get();
251 writer.println("Hangup message: {}", hangupMessage.getId());
252 }
253 if (callMessage.getIceUpdateMessages().isPresent()) {
254 writer.println("Ice update messages:");
255 var iceUpdateMessages = callMessage.getIceUpdateMessages().get();
256 for (var iceUpdateMessage : iceUpdateMessages) {
257 writer.println("- {}, sdp: {}", iceUpdateMessage.getId(), iceUpdateMessage.getSdp());
258 }
259 }
260 if (callMessage.getOfferMessage().isPresent()) {
261 var offerMessage = callMessage.getOfferMessage().get();
262 writer.println("Offer message: {}, sdp: {}", offerMessage.getId(), offerMessage.getSdp());
263 }
264 if (callMessage.getOpaqueMessage().isPresent()) {
265 final var opaqueMessage = callMessage.getOpaqueMessage().get();
266 writer.println("Opaque message: size {}", opaqueMessage.getOpaque().length);
267 }
268 }
269
270 private void printSyncMessage(
271 final PlainTextWriter writer, final SignalServiceSyncMessage syncMessage
272 ) {
273 if (syncMessage.getContacts().isPresent()) {
274 final var contactsMessage = syncMessage.getContacts().get();
275 var type = contactsMessage.isComplete() ? "complete" : "partial";
276 writer.println("Received {} sync contacts:", type);
277 printAttachment(writer.indentedWriter(), contactsMessage.getContactsStream());
278 }
279 if (syncMessage.getGroups().isPresent()) {
280 writer.println("Received sync groups:");
281 printAttachment(writer.indentedWriter(), syncMessage.getGroups().get());
282 }
283 if (syncMessage.getRead().isPresent()) {
284 writer.println("Received sync read messages list");
285 for (var rm : syncMessage.getRead().get()) {
286 writer.println("- From: {} Message timestamp: {}",
287 formatContact(rm.getSender()),
288 DateUtils.formatTimestamp(rm.getTimestamp()));
289 }
290 }
291 if (syncMessage.getViewed().isPresent()) {
292 writer.println("Received sync viewed messages list");
293 for (var vm : syncMessage.getViewed().get()) {
294 writer.println("- From: {} Message timestamp: {}",
295 formatContact(vm.getSender()),
296 DateUtils.formatTimestamp(vm.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("- {}", getLegacyIdentifier(address));
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 ) {
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 ) {
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 ) {
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 ) {
461 writer.println("Id: {}", quote.getId());
462 writer.println("Author: {}", getLegacyIdentifier(m.resolveSignalServiceAddress(quote.getAuthor())));
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) {
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 ) {
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) {
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 ) {
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 final var flags = new ArrayList<String>();
658 if (pointer.getVoiceNote()) {
659 flags.add("voice note");
660 }
661 if (pointer.isBorderless()) {
662 flags.add("borderless");
663 }
664 if (pointer.isGif()) {
665 flags.add("video gif");
666 }
667 if (flags.size() > 0) {
668 writer.println("Flags: {}", String.join(", ", flags));
669 }
670 if (pointer.getWidth() > 0 || pointer.getHeight() > 0) {
671 writer.println("Dimensions: {}x{}", pointer.getWidth(), pointer.getHeight());
672 }
673 var file = m.getAttachmentFile(pointer.getRemoteId());
674 if (file.exists()) {
675 writer.println("Stored plaintext in: {}", file);
676 }
677 }
678 }
679
680 private String formatContact(SignalServiceAddress address) {
681 final var number = getLegacyIdentifier(address);
682 String name = null;
683 try {
684 name = m.getContactOrProfileName(number);
685 } catch (InvalidNumberException ignored) {
686 }
687 if (name == null || name.isEmpty()) {
688 return number;
689 } else {
690 return MessageFormatter.arrayFormat("“{}” {}", new Object[]{name, number}).getMessage();
691 }
692 }
693 }