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