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