1 package org
.asamk
.signal
;
3 import org
.asamk
.signal
.manager
.Manager
;
4 import org
.asamk
.signal
.storage
.contacts
.ContactInfo
;
5 import org
.asamk
.signal
.storage
.groups
.GroupInfo
;
6 import org
.asamk
.signal
.util
.DateUtils
;
7 import org
.asamk
.signal
.util
.Util
;
8 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachment
;
9 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceAttachmentPointer
;
10 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceContent
;
11 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceDataMessage
;
12 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceEnvelope
;
13 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroup
;
14 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupContext
;
15 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceGroupV2
;
16 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceReceiptMessage
;
17 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceTypingMessage
;
18 import org
.whispersystems
.signalservice
.api
.messages
.calls
.AnswerMessage
;
19 import org
.whispersystems
.signalservice
.api
.messages
.calls
.BusyMessage
;
20 import org
.whispersystems
.signalservice
.api
.messages
.calls
.HangupMessage
;
21 import org
.whispersystems
.signalservice
.api
.messages
.calls
.IceUpdateMessage
;
22 import org
.whispersystems
.signalservice
.api
.messages
.calls
.OfferMessage
;
23 import org
.whispersystems
.signalservice
.api
.messages
.calls
.SignalServiceCallMessage
;
24 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.BlockedListMessage
;
25 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ConfigurationMessage
;
26 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ContactsMessage
;
27 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.KeysMessage
;
28 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.MessageRequestResponseMessage
;
29 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ReadMessage
;
30 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SentTranscriptMessage
;
31 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.SignalServiceSyncMessage
;
32 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.StickerPackOperationMessage
;
33 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.VerifiedMessage
;
34 import org
.whispersystems
.signalservice
.api
.messages
.multidevice
.ViewOnceOpenMessage
;
35 import org
.whispersystems
.signalservice
.api
.messages
.shared
.SharedContact
;
36 import org
.whispersystems
.signalservice
.api
.push
.SignalServiceAddress
;
37 import org
.whispersystems
.util
.Base64
;
40 import java
.util
.List
;
42 public class ReceiveMessageHandler
implements Manager
.ReceiveMessageHandler
{
46 public ReceiveMessageHandler(Manager m
) {
51 public void handleMessage(SignalServiceEnvelope envelope
, SignalServiceContent content
, Throwable exception
) {
52 if (!envelope
.isUnidentifiedSender() && envelope
.hasSource()) {
53 SignalServiceAddress source
= envelope
.getSourceAddress();
54 ContactInfo sourceContact
= m
.getContact(source
.getLegacyIdentifier());
55 System
.out
.println(String
.format("Envelope from: %s (device: %d)", (sourceContact
== null ?
"" : "“" + sourceContact
.name
+ "” ") + source
.getLegacyIdentifier(), envelope
.getSourceDevice()));
56 if (source
.getRelay().isPresent()) {
57 System
.out
.println("Relayed by: " + source
.getRelay().get());
60 System
.out
.println("Envelope from: unknown source");
62 System
.out
.println("Timestamp: " + DateUtils
.formatTimestamp(envelope
.getTimestamp()));
63 if (envelope
.isUnidentifiedSender()) {
64 System
.out
.println("Sent by unidentified/sealed sender");
67 if (envelope
.isReceipt()) {
68 System
.out
.println("Got receipt.");
69 } else if (envelope
.isSignalMessage() || envelope
.isPreKeySignalMessage() || envelope
.isUnidentifiedSender()) {
70 if (exception
!= null) {
71 if (exception
instanceof org
.whispersystems
.libsignal
.UntrustedIdentityException
) {
72 org
.whispersystems
.libsignal
.UntrustedIdentityException e
= (org
.whispersystems
.libsignal
.UntrustedIdentityException
) exception
;
73 System
.out
.println("The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
74 System
.out
.println("Use 'signal-cli -u " + m
.getUsername() + " listIdentities -n " + e
.getName() + "', verify the key and run 'signal-cli -u " + m
.getUsername() + " trust -v \"FINGER_PRINT\" " + e
.getName() + "' to mark it as trusted");
75 System
.out
.println("If you don't care about security, use 'signal-cli -u " + m
.getUsername() + " trust -a " + e
.getName() + "' to trust it without verification");
77 System
.out
.println("Exception: " + exception
.getMessage() + " (" + exception
.getClass().getSimpleName() + ")");
80 if (content
== null) {
81 System
.out
.println("Failed to decrypt message.");
83 ContactInfo sourceContact
= m
.getContact(content
.getSender().getLegacyIdentifier());
84 System
.out
.println(String
.format("Sender: %s (device: %d)", (sourceContact
== null ?
"" : "“" + sourceContact
.name
+ "” ") + content
.getSender().getLegacyIdentifier(), content
.getSenderDevice()));
85 if (content
.getDataMessage().isPresent()) {
86 SignalServiceDataMessage message
= content
.getDataMessage().get();
87 handleSignalServiceDataMessage(message
);
89 if (content
.getSyncMessage().isPresent()) {
90 System
.out
.println("Received a sync message");
91 SignalServiceSyncMessage syncMessage
= content
.getSyncMessage().get();
93 if (syncMessage
.getContacts().isPresent()) {
94 final ContactsMessage contactsMessage
= syncMessage
.getContacts().get();
95 if (contactsMessage
.isComplete()) {
96 System
.out
.println("Received complete sync contacts");
98 System
.out
.println("Received sync contacts");
100 printAttachment(contactsMessage
.getContactsStream());
102 if (syncMessage
.getGroups().isPresent()) {
103 System
.out
.println("Received sync groups");
104 printAttachment(syncMessage
.getGroups().get());
106 if (syncMessage
.getRead().isPresent()) {
107 System
.out
.println("Received sync read messages list");
108 for (ReadMessage rm
: syncMessage
.getRead().get()) {
109 ContactInfo fromContact
= m
.getContact(rm
.getSender().getLegacyIdentifier());
110 System
.out
.println("From: " + (fromContact
== null ?
"" : "“" + fromContact
.name
+ "” ") + rm
.getSender().getLegacyIdentifier() + " Message timestamp: " + DateUtils
.formatTimestamp(rm
.getTimestamp()));
113 if (syncMessage
.getRequest().isPresent()) {
114 System
.out
.println("Received sync request");
115 if (syncMessage
.getRequest().get().isContactsRequest()) {
116 System
.out
.println(" - contacts request");
118 if (syncMessage
.getRequest().get().isGroupsRequest()) {
119 System
.out
.println(" - groups request");
121 if (syncMessage
.getRequest().get().isBlockedListRequest()) {
122 System
.out
.println(" - blocked list request");
124 if (syncMessage
.getRequest().get().isConfigurationRequest()) {
125 System
.out
.println(" - configuration request");
127 if (syncMessage
.getRequest().get().isKeysRequest()) {
128 System
.out
.println(" - keys request");
131 if (syncMessage
.getSent().isPresent()) {
132 System
.out
.println("Received sync sent message");
133 final SentTranscriptMessage sentTranscriptMessage
= syncMessage
.getSent().get();
135 if (sentTranscriptMessage
.getDestination().isPresent()) {
136 String dest
= sentTranscriptMessage
.getDestination().get().getLegacyIdentifier();
137 ContactInfo destContact
= m
.getContact(dest
);
138 to = (destContact
== null ?
"" : "“" + destContact
.name
+ "” ") + dest
;
139 } else if (sentTranscriptMessage
.getRecipients().size() > 0) {
140 StringBuilder toBuilder
= new StringBuilder();
141 for (SignalServiceAddress dest
: sentTranscriptMessage
.getRecipients()) {
142 ContactInfo destContact
= m
.getContact(dest
.getLegacyIdentifier());
143 toBuilder
.append(destContact
== null ?
"" : "“" + destContact
.name
+ "” ").append(dest
.getLegacyIdentifier()).append(" ");
145 to = toBuilder
.toString();
149 System
.out
.println("To: " + to + " , Message timestamp: " + DateUtils
.formatTimestamp(sentTranscriptMessage
.getTimestamp()));
150 if (sentTranscriptMessage
.getExpirationStartTimestamp() > 0) {
151 System
.out
.println("Expiration started at: " + DateUtils
.formatTimestamp(sentTranscriptMessage
.getExpirationStartTimestamp()));
153 SignalServiceDataMessage message
= sentTranscriptMessage
.getMessage();
154 handleSignalServiceDataMessage(message
);
156 if (syncMessage
.getBlockedList().isPresent()) {
157 System
.out
.println("Received sync message with block list");
158 System
.out
.println("Blocked numbers:");
159 final BlockedListMessage blockedList
= syncMessage
.getBlockedList().get();
160 for (SignalServiceAddress address
: blockedList
.getAddresses()) {
161 System
.out
.println(" - " + address
.getLegacyIdentifier());
164 if (syncMessage
.getVerified().isPresent()) {
165 System
.out
.println("Received sync message with verified identities:");
166 final VerifiedMessage verifiedMessage
= syncMessage
.getVerified().get();
167 System
.out
.println(" - " + verifiedMessage
.getDestination() + ": " + verifiedMessage
.getVerified());
168 String safetyNumber
= Util
.formatSafetyNumber(m
.computeSafetyNumber(verifiedMessage
.getDestination(), verifiedMessage
.getIdentityKey()));
169 System
.out
.println(" " + safetyNumber
);
171 if (syncMessage
.getConfiguration().isPresent()) {
172 System
.out
.println("Received sync message with configuration:");
173 final ConfigurationMessage configurationMessage
= syncMessage
.getConfiguration().get();
174 if (configurationMessage
.getReadReceipts().isPresent()) {
175 System
.out
.println(" - Read receipts: " + (configurationMessage
.getReadReceipts().get() ?
"enabled" : "disabled"));
177 if (configurationMessage
.getLinkPreviews().isPresent()) {
178 System
.out
.println(" - Link previews: " + (configurationMessage
.getLinkPreviews().get() ?
"enabled" : "disabled"));
180 if (configurationMessage
.getTypingIndicators().isPresent()) {
181 System
.out
.println(" - Typing indicators: " + (configurationMessage
.getTypingIndicators().get() ?
"enabled" : "disabled"));
183 if (configurationMessage
.getUnidentifiedDeliveryIndicators().isPresent()) {
184 System
.out
.println(" - Unidentified Delivery Indicators: " + (configurationMessage
.getUnidentifiedDeliveryIndicators().get() ?
"enabled" : "disabled"));
187 if (syncMessage
.getFetchType().isPresent()) {
188 final SignalServiceSyncMessage
.FetchType fetchType
= syncMessage
.getFetchType().get();
189 System
.out
.println("Received sync message with fetch type: " + fetchType
.toString());
191 if (syncMessage
.getViewOnceOpen().isPresent()) {
192 final ViewOnceOpenMessage viewOnceOpenMessage
= syncMessage
.getViewOnceOpen().get();
193 System
.out
.println("Received sync message with view once open message:");
194 System
.out
.println(" - Sender:" + viewOnceOpenMessage
.getSender().getLegacyIdentifier());
195 System
.out
.println(" - Timestamp:" + viewOnceOpenMessage
.getTimestamp());
197 if (syncMessage
.getStickerPackOperations().isPresent()) {
198 final List
<StickerPackOperationMessage
> stickerPackOperationMessages
= syncMessage
.getStickerPackOperations().get();
199 System
.out
.println("Received sync message with sticker pack operations:");
200 for (StickerPackOperationMessage m
: stickerPackOperationMessages
) {
201 System
.out
.println(" - " + m
.getType().toString());
202 if (m
.getPackId().isPresent()) {
203 System
.out
.println(" packId: " + Base64
.encodeBytes(m
.getPackId().get()));
205 if (m
.getPackKey().isPresent()) {
206 System
.out
.println(" packKey: " + Base64
.encodeBytes(m
.getPackKey().get()));
210 if (syncMessage
.getMessageRequestResponse().isPresent()) {
211 final MessageRequestResponseMessage requestResponseMessage
= syncMessage
.getMessageRequestResponse().get();
212 System
.out
.println("Received message request response:");
213 System
.out
.println(" Type: " + requestResponseMessage
.getType());
214 if (requestResponseMessage
.getGroupId().isPresent()) {
215 System
.out
.println(" Group id: " + Base64
.encodeBytes(requestResponseMessage
.getGroupId().get()));
217 if (requestResponseMessage
.getPerson().isPresent()) {
218 System
.out
.println(" Person: " + requestResponseMessage
.getPerson().get().getLegacyIdentifier());
221 if (syncMessage
.getKeys().isPresent()) {
222 final KeysMessage keysMessage
= syncMessage
.getKeys().get();
223 System
.out
.println("Received sync message with keys:");
224 if (keysMessage
.getStorageService().isPresent()) {
225 System
.out
.println(" With storage key length: " + keysMessage
.getStorageService().get().serialize().length
);
227 System
.out
.println(" With empty storage key");
231 if (content
.getCallMessage().isPresent()) {
232 System
.out
.println("Received a call message");
233 SignalServiceCallMessage callMessage
= content
.getCallMessage().get();
234 if (callMessage
.getAnswerMessage().isPresent()) {
235 AnswerMessage answerMessage
= callMessage
.getAnswerMessage().get();
236 System
.out
.println("Answer message: " + answerMessage
.getId() + ": " + answerMessage
.getSdp());
238 if (callMessage
.getBusyMessage().isPresent()) {
239 BusyMessage busyMessage
= callMessage
.getBusyMessage().get();
240 System
.out
.println("Busy message: " + busyMessage
.getId());
242 if (callMessage
.getHangupMessage().isPresent()) {
243 HangupMessage hangupMessage
= callMessage
.getHangupMessage().get();
244 System
.out
.println("Hangup message: " + hangupMessage
.getId());
246 if (callMessage
.getIceUpdateMessages().isPresent()) {
247 List
<IceUpdateMessage
> iceUpdateMessages
= callMessage
.getIceUpdateMessages().get();
248 for (IceUpdateMessage iceUpdateMessage
: iceUpdateMessages
) {
249 System
.out
.println("Ice update message: " + iceUpdateMessage
.getId() + ", sdp: " + iceUpdateMessage
.getSdp());
252 if (callMessage
.getOfferMessage().isPresent()) {
253 OfferMessage offerMessage
= callMessage
.getOfferMessage().get();
254 System
.out
.println("Offer message: " + offerMessage
.getId() + ": " + offerMessage
.getSdp());
257 if (content
.getReceiptMessage().isPresent()) {
258 System
.out
.println("Received a receipt message");
259 SignalServiceReceiptMessage receiptMessage
= content
.getReceiptMessage().get();
260 System
.out
.println(" - When: " + DateUtils
.formatTimestamp(receiptMessage
.getWhen()));
261 if (receiptMessage
.isDeliveryReceipt()) {
262 System
.out
.println(" - Is delivery receipt");
264 if (receiptMessage
.isReadReceipt()) {
265 System
.out
.println(" - Is read receipt");
267 System
.out
.println(" - Timestamps:");
268 for (long timestamp
: receiptMessage
.getTimestamps()) {
269 System
.out
.println(" " + DateUtils
.formatTimestamp(timestamp
));
272 if (content
.getTypingMessage().isPresent()) {
273 System
.out
.println("Received a typing message");
274 SignalServiceTypingMessage typingMessage
= content
.getTypingMessage().get();
275 System
.out
.println(" - Action: " + typingMessage
.getAction());
276 System
.out
.println(" - Timestamp: " + DateUtils
.formatTimestamp(typingMessage
.getTimestamp()));
277 if (typingMessage
.getGroupId().isPresent()) {
278 GroupInfo group
= m
.getGroup(typingMessage
.getGroupId().get());
280 System
.out
.println(" Name: " + group
.name
);
282 System
.out
.println(" Name: <Unknown group>");
288 System
.out
.println("Unknown message received.");
290 System
.out
.println();
293 private void handleSignalServiceDataMessage(SignalServiceDataMessage message
) {
294 System
.out
.println("Message timestamp: " + DateUtils
.formatTimestamp(message
.getTimestamp()));
295 if (message
.isViewOnce()) {
296 System
.out
.println("=VIEW ONCE=");
299 if (message
.getBody().isPresent()) {
300 System
.out
.println("Body: " + message
.getBody().get());
302 if (message
.getGroupContext().isPresent()) {
303 System
.out
.println("Group info:");
304 final SignalServiceGroupContext groupContext
= message
.getGroupContext().get();
305 if (groupContext
.getGroupV1().isPresent()) {
306 SignalServiceGroup groupInfo
= groupContext
.getGroupV1().get();
307 System
.out
.println(" Id: " + Base64
.encodeBytes(groupInfo
.getGroupId()));
308 if (groupInfo
.getType() == SignalServiceGroup
.Type
.UPDATE
&& groupInfo
.getName().isPresent()) {
309 System
.out
.println(" Name: " + groupInfo
.getName().get());
311 GroupInfo group
= m
.getGroup(groupInfo
.getGroupId());
313 System
.out
.println(" Name: " + group
.name
);
315 System
.out
.println(" Name: <Unknown group>");
318 System
.out
.println(" Type: " + groupInfo
.getType());
319 if (groupInfo
.getMembers().isPresent()) {
320 for (SignalServiceAddress member
: groupInfo
.getMembers().get()) {
321 System
.out
.println(" Member: " + member
.getLegacyIdentifier());
324 if (groupInfo
.getAvatar().isPresent()) {
325 System
.out
.println(" Avatar:");
326 printAttachment(groupInfo
.getAvatar().get());
328 } else if (groupContext
.getGroupV2().isPresent()) {
329 final SignalServiceGroupV2 groupInfo
= groupContext
.getGroupV2().get();
330 System
.out
.println(" Revision: " + groupInfo
.getRevision());
331 System
.out
.println(" Master key length: " + groupInfo
.getMasterKey().serialize().length
);
332 System
.out
.println(" Has signed group change: " + groupInfo
.hasSignedGroupChange());
335 if (message
.getPreviews().isPresent()) {
336 final List
<SignalServiceDataMessage
.Preview
> previews
= message
.getPreviews().get();
337 System
.out
.println("Previews:");
338 for (SignalServiceDataMessage
.Preview preview
: previews
) {
339 System
.out
.println(" - Title: " + preview
.getTitle());
340 System
.out
.println(" - Url: " + preview
.getUrl());
341 if (preview
.getImage().isPresent()) {
342 printAttachment(preview
.getImage().get());
346 if (message
.getSharedContacts().isPresent()) {
347 final List
<SharedContact
> sharedContacts
= message
.getSharedContacts().get();
348 System
.out
.println("Contacts:");
349 for (SharedContact contact
: sharedContacts
) {
350 System
.out
.println(" - Name: " + contact
.getName());
351 // TODO show or store rest of the contact info
354 if (message
.getSticker().isPresent()) {
355 final SignalServiceDataMessage
.Sticker sticker
= message
.getSticker().get();
356 System
.out
.println("Sticker:");
357 System
.out
.println(" - Pack id: " + Base64
.encodeBytes(sticker
.getPackId()));
358 System
.out
.println(" - Pack key: " + Base64
.encodeBytes(sticker
.getPackKey()));
359 System
.out
.println(" - Sticker id: " + sticker
.getStickerId());
360 // TODO also download sticker image ??
362 if (message
.isEndSession()) {
363 System
.out
.println("Is end session");
365 if (message
.isExpirationUpdate()) {
366 System
.out
.println("Is Expiration update: " + message
.isExpirationUpdate());
368 if (message
.getExpiresInSeconds() > 0) {
369 System
.out
.println("Expires in: " + message
.getExpiresInSeconds() + " seconds");
371 if (message
.getProfileKey().isPresent()) {
372 System
.out
.println("Profile key update, key length:" + message
.getProfileKey().get().length
);
375 if (message
.getReaction().isPresent()) {
376 final SignalServiceDataMessage
.Reaction reaction
= message
.getReaction().get();
377 System
.out
.println("Reaction:");
378 System
.out
.println(" - Emoji: " + reaction
.getEmoji());
379 System
.out
.println(" - Target author: " + reaction
.getTargetAuthor().getLegacyIdentifier()); // todo resolve
380 System
.out
.println(" - Target timestamp: " + reaction
.getTargetSentTimestamp());
381 System
.out
.println(" - Is remove: " + reaction
.isRemove());
384 if (message
.getQuote().isPresent()) {
385 SignalServiceDataMessage
.Quote quote
= message
.getQuote().get();
386 System
.out
.println("Quote: (" + quote
.getId() + ")");
387 System
.out
.println(" Author: " + quote
.getAuthor().getLegacyIdentifier());
388 System
.out
.println(" Text: " + quote
.getText());
389 if (quote
.getAttachments().size() > 0) {
390 System
.out
.println(" Attachments: ");
391 for (SignalServiceDataMessage
.Quote
.QuotedAttachment attachment
: quote
.getAttachments()) {
392 System
.out
.println(" Filename: " + attachment
.getFileName());
393 System
.out
.println(" Type: " + attachment
.getContentType());
394 System
.out
.println(" Thumbnail:");
395 if (attachment
.getThumbnail() != null) {
396 printAttachment(attachment
.getThumbnail());
402 if (message
.getRemoteDelete().isPresent()) {
403 final SignalServiceDataMessage
.RemoteDelete remoteDelete
= message
.getRemoteDelete().get();
404 System
.out
.println("Remote delete message: timestamp = " + remoteDelete
.getTargetSentTimestamp());
406 if (message
.getMentions().isPresent()) {
407 final List
<SignalServiceDataMessage
.Mention
> mentions
= message
.getMentions().get();
408 System
.out
.println("Mentions: ");
409 for (SignalServiceDataMessage
.Mention mention
: mentions
) {
410 System
.out
.println("- " + mention
.getUuid() + ": " + mention
.getStart() + " (length: " + mention
.getLength() + ")");
414 if (message
.getAttachments().isPresent()) {
415 System
.out
.println("Attachments: ");
416 for (SignalServiceAttachment attachment
: message
.getAttachments().get()) {
417 printAttachment(attachment
);
422 private void printAttachment(SignalServiceAttachment attachment
) {
423 System
.out
.println("- " + attachment
.getContentType() + " (" + (attachment
.isPointer() ?
"Pointer" : "") + (attachment
.isStream() ?
"Stream" : "") + ")");
424 if (attachment
.isPointer()) {
425 final SignalServiceAttachmentPointer pointer
= attachment
.asPointer();
426 System
.out
.println(" Id: " + pointer
.getRemoteId() + " Key length: " + pointer
.getKey().length
);
427 System
.out
.println(" Filename: " + (pointer
.getFileName().isPresent() ? pointer
.getFileName().get() : "-"));
428 System
.out
.println(" Size: " + (pointer
.getSize().isPresent() ? pointer
.getSize().get() + " bytes" : "<unavailable>") + (pointer
.getPreview().isPresent() ?
" (Preview is available: " + pointer
.getPreview().get().length
+ " bytes)" : ""));
429 System
.out
.println(" Voice note: " + (pointer
.getVoiceNote() ?
"yes" : "no"));
430 System
.out
.println(" Dimensions: " + pointer
.getWidth() + "x" + pointer
.getHeight());
431 File file
= m
.getAttachmentFile(pointer
.getRemoteId());
433 System
.out
.println(" Stored plaintext in: " + file
);