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