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