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