1package eu.siacs.conversations.parser;
2
3import android.text.Html;
4import android.util.Log;
5import android.util.Pair;
6
7import net.java.otr4j.session.Session;
8import net.java.otr4j.session.SessionStatus;
9
10import java.text.SimpleDateFormat;
11import java.util.ArrayList;
12import java.util.Arrays;
13import java.util.Date;
14import java.util.List;
15import java.util.Set;
16import java.util.UUID;
17
18import eu.siacs.conversations.Config;
19import eu.siacs.conversations.crypto.OtrService;
20import eu.siacs.conversations.crypto.axolotl.AxolotlService;
21import eu.siacs.conversations.crypto.axolotl.XmppAxolotlMessage;
22import eu.siacs.conversations.entities.Account;
23import eu.siacs.conversations.entities.Bookmark;
24import eu.siacs.conversations.entities.Contact;
25import eu.siacs.conversations.entities.Conversation;
26import eu.siacs.conversations.entities.Message;
27import eu.siacs.conversations.entities.MucOptions;
28import eu.siacs.conversations.entities.Presence;
29import eu.siacs.conversations.entities.ServiceDiscoveryResult;
30import eu.siacs.conversations.http.HttpConnectionManager;
31import eu.siacs.conversations.services.MessageArchiveService;
32import eu.siacs.conversations.services.XmppConnectionService;
33import eu.siacs.conversations.utils.CryptoHelper;
34import eu.siacs.conversations.utils.Xmlns;
35import eu.siacs.conversations.xml.Element;
36import eu.siacs.conversations.xmpp.OnMessagePacketReceived;
37import eu.siacs.conversations.xmpp.chatstate.ChatState;
38import eu.siacs.conversations.xmpp.jid.Jid;
39import eu.siacs.conversations.xmpp.pep.Avatar;
40import eu.siacs.conversations.xmpp.stanzas.MessagePacket;
41
42public class MessageParser extends AbstractParser implements OnMessagePacketReceived {
43
44 private static final List<String> CLIENTS_SENDING_HTML_IN_OTR = Arrays.asList("Pidgin","Adium","Trillian");
45
46 public MessageParser(XmppConnectionService service) {
47 super(service);
48 }
49
50 private boolean extractChatState(Conversation conversation, final MessagePacket packet) {
51 ChatState state = ChatState.parse(packet);
52 if (state != null && conversation != null) {
53 final Account account = conversation.getAccount();
54 Jid from = packet.getFrom();
55 if (from.toBareJid().equals(account.getJid().toBareJid())) {
56 conversation.setOutgoingChatState(state);
57 if (state == ChatState.ACTIVE || state == ChatState.COMPOSING) {
58 mXmppConnectionService.markRead(conversation);
59 activateGracePeriod(account);
60 }
61 return false;
62 } else {
63 return conversation.setIncomingChatState(state);
64 }
65 }
66 return false;
67 }
68
69 private Message parseOtrChat(String body, Jid from, String id, Conversation conversation) {
70 String presence;
71 if (from.isBareJid()) {
72 presence = "";
73 } else {
74 presence = from.getResourcepart();
75 }
76 if (body.matches("^\\?OTRv\\d{1,2}\\?.*")) {
77 conversation.endOtrIfNeeded();
78 }
79 if (!conversation.hasValidOtrSession()) {
80 conversation.startOtrSession(presence,false);
81 } else {
82 String foreignPresence = conversation.getOtrSession().getSessionID().getUserID();
83 if (!foreignPresence.equals(presence)) {
84 conversation.endOtrIfNeeded();
85 conversation.startOtrSession(presence, false);
86 }
87 }
88 try {
89 conversation.setLastReceivedOtrMessageId(id);
90 Session otrSession = conversation.getOtrSession();
91 body = otrSession.transformReceiving(body);
92 SessionStatus status = otrSession.getSessionStatus();
93 if (body == null && status == SessionStatus.ENCRYPTED) {
94 mXmppConnectionService.onOtrSessionEstablished(conversation);
95 return null;
96 } else if (body == null && status == SessionStatus.FINISHED) {
97 conversation.resetOtrSession();
98 mXmppConnectionService.updateConversationUi();
99 return null;
100 } else if (body == null || (body.isEmpty())) {
101 return null;
102 }
103 if (body.startsWith(CryptoHelper.FILETRANSFER)) {
104 String key = body.substring(CryptoHelper.FILETRANSFER.length());
105 conversation.setSymmetricKey(CryptoHelper.hexToBytes(key));
106 return null;
107 }
108 if (clientMightSendHtml(conversation.getAccount(), from)) {
109 Log.d(Config.LOGTAG,conversation.getAccount().getJid().toBareJid()+": received OTR message from bad behaving client. escaping HTML…");
110 body = Html.fromHtml(body).toString();
111 }
112
113 final OtrService otrService = conversation.getAccount().getOtrService();
114 Message finishedMessage = new Message(conversation, body, Message.ENCRYPTION_OTR, Message.STATUS_RECEIVED);
115 finishedMessage.setFingerprint(otrService.getFingerprint(otrSession.getRemotePublicKey()));
116 conversation.setLastReceivedOtrMessageId(null);
117
118 return finishedMessage;
119 } catch (Exception e) {
120 conversation.resetOtrSession();
121 return null;
122 }
123 }
124
125 private static boolean clientMightSendHtml(Account account, Jid from) {
126 String resource = from.getResourcepart();
127 if (resource == null) {
128 return false;
129 }
130 Presence presence = account.getRoster().getContact(from).getPresences().getPresences().get(resource);
131 ServiceDiscoveryResult disco = presence == null ? null : presence.getServiceDiscoveryResult();
132 if (disco == null) {
133 return false;
134 }
135 return hasIdentityKnowForSendingHtml(disco.getIdentities());
136 }
137
138 private static boolean hasIdentityKnowForSendingHtml(List<ServiceDiscoveryResult.Identity> identities) {
139 for(ServiceDiscoveryResult.Identity identity : identities) {
140 if (identity.getName() != null) {
141 if (CLIENTS_SENDING_HTML_IN_OTR.contains(identity.getName())) {
142 return true;
143 }
144 }
145 }
146 return false;
147 }
148
149 private Message parseAxolotlChat(Element axolotlMessage, Jid from, Conversation conversation, int status) {
150 AxolotlService service = conversation.getAccount().getAxolotlService();
151 XmppAxolotlMessage xmppAxolotlMessage;
152 try {
153 xmppAxolotlMessage = XmppAxolotlMessage.fromElement(axolotlMessage, from.toBareJid());
154 } catch (Exception e) {
155 Log.d(Config.LOGTAG,conversation.getAccount().getJid().toBareJid()+": invalid omemo message received "+e.getMessage());
156 return null;
157 }
158 XmppAxolotlMessage.XmppAxolotlPlaintextMessage plaintextMessage = service.processReceivingPayloadMessage(xmppAxolotlMessage);
159 if(plaintextMessage != null) {
160 Message finishedMessage = new Message(conversation, plaintextMessage.getPlaintext(), Message.ENCRYPTION_AXOLOTL, status);
161 finishedMessage.setFingerprint(plaintextMessage.getFingerprint());
162 Log.d(Config.LOGTAG, AxolotlService.getLogprefix(finishedMessage.getConversation().getAccount())+" Received Message with session fingerprint: "+plaintextMessage.getFingerprint());
163 return finishedMessage;
164 } else {
165 return null;
166 }
167 }
168
169 private class Invite {
170 final Jid jid;
171 final String password;
172 final Contact inviter;
173 Invite(Jid jid, String password, Contact inviter) {
174 this.jid = jid;
175 this.password = password;
176 this.inviter = inviter;
177 }
178
179 public boolean execute(Account account) {
180 if (jid != null) {
181 Conversation conversation = mXmppConnectionService.findOrCreateConversation(account, jid, true);
182 if (!conversation.getMucOptions().online()) {
183 conversation.getMucOptions().setPassword(password);
184 mXmppConnectionService.databaseBackend.updateConversation(conversation);
185 mXmppConnectionService.joinMuc(conversation, inviter != null && inviter.mutualPresenceSubscription());
186 mXmppConnectionService.updateConversationUi();
187 }
188 return true;
189 }
190 return false;
191 }
192 }
193
194 private Invite extractInvite(Account account, Element message) {
195 Element x = message.findChild("x", "http://jabber.org/protocol/muc#user");
196 if (x != null) {
197 Element invite = x.findChild("invite");
198 if (invite != null) {
199 Element pw = x.findChild("password");
200 Jid from = invite.getAttributeAsJid("from");
201 Contact contact = from == null ? null : account.getRoster().getContact(from);
202 return new Invite(message.getAttributeAsJid("from"), pw != null ? pw.getContent(): null, contact);
203 }
204 } else {
205 x = message.findChild("x","jabber:x:conference");
206 if (x != null) {
207 Jid from = message.getAttributeAsJid("from");
208 Contact contact = from == null ? null : account.getRoster().getContact(from);
209 return new Invite(x.getAttributeAsJid("jid"),x.getAttribute("password"),contact);
210 }
211 }
212 return null;
213 }
214
215 private static String extractStanzaId(Element packet, Jid by) {
216 for(Element child : packet.getChildren()) {
217 if (child.getName().equals("stanza-id")
218 && Xmlns.STANZA_IDS.equals(child.getNamespace())
219 && by.equals(child.getAttributeAsJid("by"))) {
220 return child.getAttribute("id");
221 }
222 }
223 return null;
224 }
225
226 private void parseEvent(final Element event, final Jid from, final Account account) {
227 Element items = event.findChild("items");
228 String node = items == null ? null : items.getAttribute("node");
229 if ("urn:xmpp:avatar:metadata".equals(node)) {
230 Avatar avatar = Avatar.parseMetadata(items);
231 if (avatar != null) {
232 avatar.owner = from.toBareJid();
233 if (mXmppConnectionService.getFileBackend().isAvatarCached(avatar)) {
234 if (account.getJid().toBareJid().equals(from)) {
235 if (account.setAvatar(avatar.getFilename())) {
236 mXmppConnectionService.databaseBackend.updateAccount(account);
237 }
238 mXmppConnectionService.getAvatarService().clear(account);
239 mXmppConnectionService.updateConversationUi();
240 mXmppConnectionService.updateAccountUi();
241 } else {
242 Contact contact = account.getRoster().getContact(from);
243 contact.setAvatar(avatar);
244 mXmppConnectionService.getAvatarService().clear(contact);
245 mXmppConnectionService.updateConversationUi();
246 mXmppConnectionService.updateRosterUi();
247 }
248 } else if (mXmppConnectionService.isDataSaverDisabled()) {
249 mXmppConnectionService.fetchAvatar(account, avatar);
250 }
251 }
252 } else if ("http://jabber.org/protocol/nick".equals(node)) {
253 Element i = items.findChild("item");
254 Element nick = i == null ? null : i.findChild("nick", "http://jabber.org/protocol/nick");
255 if (nick != null && nick.getContent() != null) {
256 Contact contact = account.getRoster().getContact(from);
257 contact.setPresenceName(nick.getContent());
258 mXmppConnectionService.getAvatarService().clear(account);
259 mXmppConnectionService.updateConversationUi();
260 mXmppConnectionService.updateAccountUi();
261 }
262 } else if (AxolotlService.PEP_DEVICE_LIST.equals(node)) {
263
264 Element item = items.findChild("item");
265 Set<Integer> deviceIds = mXmppConnectionService.getIqParser().deviceIds(item);
266 Log.d(Config.LOGTAG, AxolotlService.getLogprefix(account)+"Received PEP device list ("+deviceIds+") update from "+ from + ", processing...");
267 AxolotlService axolotlService = account.getAxolotlService();
268 axolotlService.registerDevices(from, deviceIds);
269 mXmppConnectionService.updateAccountUi();
270 }
271 }
272
273 private boolean handleErrorMessage(Account account, MessagePacket packet) {
274 if (packet.getType() == MessagePacket.TYPE_ERROR) {
275 Jid from = packet.getFrom();
276 if (from != null) {
277 Message message = mXmppConnectionService.markMessage(account,
278 from.toBareJid(),
279 packet.getId(),
280 Message.STATUS_SEND_FAILED,
281 extractErrorMessage(packet));
282 if (message != null) {
283 if (message.getEncryption() == Message.ENCRYPTION_OTR) {
284 message.getConversation().endOtrIfNeeded();
285 }
286 }
287 }
288 return true;
289 }
290 return false;
291 }
292
293 @Override
294 public void onMessagePacketReceived(Account account, MessagePacket original) {
295 if (handleErrorMessage(account, original)) {
296 return;
297 }
298 final MessagePacket packet;
299 Long timestamp = null;
300 final boolean isForwarded;
301 boolean isCarbon = false;
302 String serverMsgId = null;
303 final Element fin = original.findChild("fin", "urn:xmpp:mam:0");
304 if (fin != null) {
305 mXmppConnectionService.getMessageArchiveService().processFin(fin,original.getFrom());
306 return;
307 }
308 final Element result = original.findChild("result","urn:xmpp:mam:0");
309 final MessageArchiveService.Query query = result == null ? null : mXmppConnectionService.getMessageArchiveService().findQuery(result.getAttribute("queryid"));
310 if (query != null && query.validFrom(original.getFrom())) {
311 Pair<MessagePacket, Long> f = original.getForwardedMessagePacket("result", "urn:xmpp:mam:0");
312 if (f == null) {
313 return;
314 }
315 timestamp = f.second;
316 packet = f.first;
317 isForwarded = true;
318 serverMsgId = result.getAttribute("id");
319 query.incrementMessageCount();
320 } else if (query != null) {
321 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": received mam result from invalid sender");
322 return;
323 } else if (original.fromServer(account)) {
324 Pair<MessagePacket, Long> f;
325 f = original.getForwardedMessagePacket("received", "urn:xmpp:carbons:2");
326 f = f == null ? original.getForwardedMessagePacket("sent", "urn:xmpp:carbons:2") : f;
327 packet = f != null ? f.first : original;
328 if (handleErrorMessage(account, packet)) {
329 return;
330 }
331 timestamp = f != null ? f.second : null;
332 isCarbon = f != null;
333 isForwarded = isCarbon;
334 } else {
335 packet = original;
336 isForwarded = false;
337 }
338
339 if (timestamp == null) {
340 timestamp = AbstractParser.parseTimestamp(original,AbstractParser.parseTimestamp(packet));
341 }
342 final String body = packet.getBody();
343 final Element mucUserElement = packet.findChild("x", "http://jabber.org/protocol/muc#user");
344 final String pgpEncrypted = packet.findChildContent("x", "jabber:x:encrypted");
345 final Element replaceElement = packet.findChild("replace", "urn:xmpp:message-correct:0");
346 final Element oob = packet.findChild("x", "jabber:x:oob");
347 final boolean isOob = oob!= null && body != null && body.equals(oob.findChildContent("url"));
348 final String replacementId = replaceElement == null ? null : replaceElement.getAttribute("id");
349 final Element axolotlEncrypted = packet.findChild(XmppAxolotlMessage.CONTAINERTAG, AxolotlService.PEP_PREFIX);
350 int status;
351 final Jid counterpart;
352 final Jid to = packet.getTo();
353 final Jid from = packet.getFrom();
354 final String remoteMsgId = packet.getId();
355 boolean notify = false;
356
357 if (from == null) {
358 Log.d(Config.LOGTAG,"no from in: "+packet.toString());
359 return;
360 }
361
362 boolean isTypeGroupChat = packet.getType() == MessagePacket.TYPE_GROUPCHAT;
363 boolean isProperlyAddressed = (to != null ) && (!to.isBareJid() || account.countPresences() == 0);
364 boolean isMucStatusMessage = from.isBareJid() && mucUserElement != null && mucUserElement.hasChild("status");
365 if (packet.fromAccount(account)) {
366 status = Message.STATUS_SEND;
367 counterpart = to != null ? to : account.getJid();
368 } else {
369 status = Message.STATUS_RECEIVED;
370 counterpart = from;
371 }
372
373 Invite invite = extractInvite(account, packet);
374 if (invite != null && invite.execute(account)) {
375 return;
376 }
377
378 if (!isTypeGroupChat
379 && query == null
380 && extractChatState(mXmppConnectionService.find(account, counterpart.toBareJid()), packet)) {
381 mXmppConnectionService.updateConversationUi();
382 }
383
384 if ((body != null || pgpEncrypted != null || axolotlEncrypted != null) && !isMucStatusMessage) {
385 Conversation conversation = mXmppConnectionService.findOrCreateConversation(account, counterpart.toBareJid(), isTypeGroupChat, false, query);
386 final boolean conversationMultiMode = conversation.getMode() == Conversation.MODE_MULTI;
387 if (isTypeGroupChat) {
388 if (counterpart.getResourcepart().equals(conversation.getMucOptions().getActualNick())) {
389 status = Message.STATUS_SEND_RECEIVED;
390 isCarbon = true; //not really carbon but received from another resource
391 if (mXmppConnectionService.markMessage(conversation, remoteMsgId, status)) {
392 return;
393 } else if (remoteMsgId == null || Config.IGNORE_ID_REWRITE_IN_MUC) {
394 Message message = conversation.findSentMessageWithBody(packet.getBody());
395 if (message != null) {
396 mXmppConnectionService.markMessage(message, status);
397 return;
398 }
399 }
400 } else {
401 status = Message.STATUS_RECEIVED;
402 }
403 }
404 final Message message;
405 if (body != null && body.startsWith("?OTR") && Config.supportOtr()) {
406 if (!isForwarded && !isTypeGroupChat && isProperlyAddressed && !conversationMultiMode) {
407 message = parseOtrChat(body, from, remoteMsgId, conversation);
408 if (message == null) {
409 return;
410 }
411 } else {
412 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": ignoring OTR message from "+from+" isForwarded="+Boolean.toString(isForwarded)+", isProperlyAddressed="+Boolean.valueOf(isProperlyAddressed));
413 message = new Message(conversation, body, Message.ENCRYPTION_NONE, status);
414 }
415 } else if (pgpEncrypted != null && Config.supportOpenPgp()) {
416 message = new Message(conversation, pgpEncrypted, Message.ENCRYPTION_PGP, status);
417 } else if (axolotlEncrypted != null && Config.supportOmemo()) {
418 Jid origin;
419 if (conversationMultiMode) {
420 final Jid fallback = conversation.getMucOptions().getTrueCounterpart(counterpart);
421 origin = getTrueCounterpart(query != null ? mucUserElement : null, fallback);
422 if (origin == null) {
423 Log.d(Config.LOGTAG,"axolotl message in non anonymous conference received");
424 return;
425 }
426 } else {
427 origin = from;
428 }
429 message = parseAxolotlChat(axolotlEncrypted, origin, conversation, status);
430 if (message == null) {
431 return;
432 }
433 if (conversationMultiMode) {
434 message.setTrueCounterpart(origin);
435 }
436 } else {
437 message = new Message(conversation, body, Message.ENCRYPTION_NONE, status);
438 }
439
440 if (serverMsgId == null) {
441 final Jid by;
442 final boolean safeToExtract;
443 if (isTypeGroupChat) {
444 by = conversation.getJid().toBareJid();
445 safeToExtract = true; //conversation.getMucOptions().hasFeature(Xmlns.STANZA_IDS);
446 } else {
447 by = account.getJid().toBareJid();
448 safeToExtract = true; //account.getXmppConnection().getFeatures().stanzaIds();
449 }
450 if (safeToExtract) {
451 serverMsgId = extractStanzaId(packet, by);
452 }
453 }
454
455 message.setCounterpart(counterpart);
456 message.setRemoteMsgId(remoteMsgId);
457 message.setServerMsgId(serverMsgId);
458 message.setCarbon(isCarbon);
459 message.setTime(timestamp);
460 message.setOob(isOob);
461 message.markable = packet.hasChild("markable", "urn:xmpp:chat-markers:0");
462 if (conversationMultiMode) {
463 final Jid fallback = conversation.getMucOptions().getTrueCounterpart(counterpart);
464 Jid trueCounterpart;
465 if (message.getEncryption() == Message.ENCRYPTION_AXOLOTL) {
466 trueCounterpart = message.getTrueCounterpart();
467 } else if (Config.PARSE_REAL_JID_FROM_MUC_MAM) {
468 trueCounterpart = getTrueCounterpart(query != null ? mucUserElement : null, fallback);
469 } else {
470 trueCounterpart = fallback;
471 }
472 if (trueCounterpart != null && trueCounterpart.toBareJid().equals(account.getJid().toBareJid())) {
473 status = isTypeGroupChat ? Message.STATUS_SEND_RECEIVED : Message.STATUS_SEND;
474 }
475 message.setStatus(status);
476 message.setTrueCounterpart(trueCounterpart);
477 if (!isTypeGroupChat) {
478 message.setType(Message.TYPE_PRIVATE);
479 }
480 } else {
481 updateLastseen(account, from);
482 }
483
484 if (replacementId != null && mXmppConnectionService.allowMessageCorrection()) {
485 Message replacedMessage = conversation.findMessageWithRemoteIdAndCounterpart(replacementId,
486 counterpart,
487 message.getStatus() == Message.STATUS_RECEIVED,
488 message.isCarbon());
489 if (replacedMessage != null) {
490 final boolean fingerprintsMatch = replacedMessage.getFingerprint() == null
491 || replacedMessage.getFingerprint().equals(message.getFingerprint());
492 final boolean trueCountersMatch = replacedMessage.getTrueCounterpart() != null
493 && replacedMessage.getTrueCounterpart().equals(message.getTrueCounterpart());
494 final boolean duplicate = conversation.hasDuplicateMessage(message);
495 if (fingerprintsMatch && (trueCountersMatch || !conversationMultiMode) && !duplicate) {
496 Log.d(Config.LOGTAG, "replaced message '" + replacedMessage.getBody() + "' with '" + message.getBody() + "'");
497 synchronized (replacedMessage) {
498 final String uuid = replacedMessage.getUuid();
499 replacedMessage.setUuid(UUID.randomUUID().toString());
500 replacedMessage.setBody(message.getBody());
501 replacedMessage.setEdited(replacedMessage.getRemoteMsgId());
502 replacedMessage.setRemoteMsgId(remoteMsgId);
503 replacedMessage.setEncryption(message.getEncryption());
504 if (replacedMessage.getStatus() == Message.STATUS_RECEIVED) {
505 replacedMessage.markUnread();
506 }
507 mXmppConnectionService.updateMessage(replacedMessage, uuid);
508 mXmppConnectionService.getNotificationService().updateNotification(false);
509 if (mXmppConnectionService.confirmMessages() && remoteMsgId != null && !isForwarded && !isTypeGroupChat) {
510 sendMessageReceipts(account, packet);
511 }
512 if (replacedMessage.getEncryption() == Message.ENCRYPTION_PGP) {
513 conversation.getAccount().getPgpDecryptionService().discard(replacedMessage);
514 conversation.getAccount().getPgpDecryptionService().decrypt(replacedMessage, false);
515 }
516 }
517 return;
518 } else {
519 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": received message correction but verification didn't check out");
520 }
521 }
522 }
523
524 long deletionDate = mXmppConnectionService.getAutomaticMessageDeletionDate();
525 if (deletionDate != 0 && message.getTimeSent() < deletionDate) {
526 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": skipping message from "+message.getCounterpart().toString()+" because it was sent prior to our deletion date");
527 return;
528 }
529
530 boolean checkForDuplicates = query != null
531 || (isTypeGroupChat && packet.hasChild("delay","urn:xmpp:delay"))
532 || message.getType() == Message.TYPE_PRIVATE;
533 if (checkForDuplicates && conversation.hasDuplicateMessage(message)) {
534 Log.d(Config.LOGTAG,"skipping duplicate message from "+message.getCounterpart().toString()+" "+message.getBody());
535 return;
536 }
537
538 if (query != null && query.getPagingOrder() == MessageArchiveService.PagingOrder.REVERSE) {
539 conversation.prepend(message);
540 } else {
541 conversation.add(message);
542 }
543 if (query != null) {
544 query.incrementActualMessageCount();
545 }
546
547 if (query == null || !query.isCatchup()) { //either no mam or catchup
548 if (status == Message.STATUS_SEND || status == Message.STATUS_SEND_RECEIVED) {
549 mXmppConnectionService.markRead(conversation);
550 if (query == null) {
551 activateGracePeriod(account);
552 }
553 } else {
554 message.markUnread();
555 notify = true;
556 }
557 }
558
559 if (message.getEncryption() == Message.ENCRYPTION_PGP) {
560 notify = conversation.getAccount().getPgpDecryptionService().decrypt(message, notify);
561 }
562
563 if (query == null) {
564 mXmppConnectionService.updateConversationUi();
565 }
566
567 if (mXmppConnectionService.confirmMessages()
568 && message.trusted()
569 && remoteMsgId != null
570 && !isForwarded
571 && !isTypeGroupChat) {
572 sendMessageReceipts(account, packet);
573 }
574
575 if (message.getStatus() == Message.STATUS_RECEIVED
576 && conversation.getOtrSession() != null
577 && !conversation.getOtrSession().getSessionID().getUserID()
578 .equals(message.getCounterpart().getResourcepart())) {
579 conversation.endOtrIfNeeded();
580 }
581
582 mXmppConnectionService.databaseBackend.createMessage(message);
583 final HttpConnectionManager manager = this.mXmppConnectionService.getHttpConnectionManager();
584 if (message.trusted() && message.treatAsDownloadable() != Message.Decision.NEVER && manager.getAutoAcceptFileSize() > 0) {
585 manager.createNewDownloadConnection(message);
586 } else if (notify) {
587 if (query == null) {
588 mXmppConnectionService.getNotificationService().push(message);
589 } else if (query.getWith() == null) { // mam catchup
590 mXmppConnectionService.getNotificationService().pushFromBacklog(message);
591 }
592 }
593 } else if (!packet.hasChild("body")){ //no body
594 Conversation conversation = mXmppConnectionService.find(account, from.toBareJid());
595 if (isTypeGroupChat) {
596 if (packet.hasChild("subject")) {
597 if (conversation != null && conversation.getMode() == Conversation.MODE_MULTI) {
598 conversation.setHasMessagesLeftOnServer(conversation.countMessages() > 0);
599 String subject = packet.findChildContent("subject");
600 conversation.getMucOptions().setSubject(subject);
601 final Bookmark bookmark = conversation.getBookmark();
602 if (bookmark != null && bookmark.getBookmarkName() == null) {
603 if (bookmark.setBookmarkName(subject)) {
604 mXmppConnectionService.pushBookmarks(account);
605 }
606 }
607 mXmppConnectionService.updateConversationUi();
608 return;
609 }
610 }
611 }
612 if (conversation != null && mucUserElement != null && from.isBareJid()) {
613 for (Element child : mucUserElement.getChildren()) {
614 if ("status".equals(child.getName())) {
615 try {
616 int code = Integer.parseInt(child.getAttribute("code"));
617 if ((code >= 170 && code <= 174) || (code >= 102 && code <= 104)) {
618 mXmppConnectionService.fetchConferenceConfiguration(conversation);
619 break;
620 }
621 } catch (Exception e) {
622 //ignored
623 }
624 } else if ("item".equals(child.getName())) {
625 MucOptions.User user = AbstractParser.parseItem(conversation,child);
626 Log.d(Config.LOGTAG,account.getJid()+": changing affiliation for "
627 +user.getRealJid()+" to "+user.getAffiliation()+" in "
628 +conversation.getJid().toBareJid());
629 if (!user.realJidMatchesAccount()) {
630 conversation.getMucOptions().updateUser(user);
631 mXmppConnectionService.getAvatarService().clear(conversation);
632 mXmppConnectionService.updateMucRosterUi();
633 mXmppConnectionService.updateConversationUi();
634 if (!user.getAffiliation().ranks(MucOptions.Affiliation.MEMBER)) {
635 Jid jid = user.getRealJid();
636 List<Jid> cryptoTargets = conversation.getAcceptedCryptoTargets();
637 if (cryptoTargets.remove(user.getRealJid())) {
638 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": removed "+jid+" from crypto targets of "+conversation.getName());
639 conversation.setAcceptedCryptoTargets(cryptoTargets);
640 mXmppConnectionService.updateConversation(conversation);
641 }
642 }
643 }
644 }
645 }
646 }
647 }
648
649
650
651 Element received = packet.findChild("received", "urn:xmpp:chat-markers:0");
652 if (received == null) {
653 received = packet.findChild("received", "urn:xmpp:receipts");
654 }
655 if (received != null && !packet.fromAccount(account)) {
656 mXmppConnectionService.markMessage(account, from.toBareJid(), received.getAttribute("id"), Message.STATUS_SEND_RECEIVED);
657 }
658 Element displayed = packet.findChild("displayed", "urn:xmpp:chat-markers:0");
659 if (displayed != null) {
660 if (packet.fromAccount(account)) {
661 Conversation conversation = mXmppConnectionService.find(account,counterpart.toBareJid());
662 if (conversation != null) {
663 mXmppConnectionService.markRead(conversation);
664 }
665 } else {
666 final Message displayedMessage = mXmppConnectionService.markMessage(account, from.toBareJid(), displayed.getAttribute("id"), Message.STATUS_SEND_DISPLAYED);
667 Message message = displayedMessage == null ? null : displayedMessage.prev();
668 while (message != null
669 && message.getStatus() == Message.STATUS_SEND_RECEIVED
670 && message.getTimeSent() < displayedMessage.getTimeSent()) {
671 mXmppConnectionService.markMessage(message, Message.STATUS_SEND_DISPLAYED);
672 message = message.prev();
673 }
674 }
675 }
676
677 Element event = original.findChild("event", "http://jabber.org/protocol/pubsub#event");
678 if (event != null) {
679 parseEvent(event, original.getFrom(), account);
680 }
681
682 String nick = packet.findChildContent("nick", "http://jabber.org/protocol/nick");
683 if (nick != null) {
684 Contact contact = account.getRoster().getContact(from);
685 contact.setPresenceName(nick);
686 }
687 }
688
689 private static Jid getTrueCounterpart(Element mucUserElement, Jid fallback) {
690 final Element item = mucUserElement == null ? null : mucUserElement.findChild("item");
691 Jid result = item == null ? null : item.getAttributeAsJid("jid");
692 return result != null ? result : fallback;
693 }
694
695 private void sendMessageReceipts(Account account, MessagePacket packet) {
696 ArrayList<String> receiptsNamespaces = new ArrayList<>();
697 if (packet.hasChild("markable", "urn:xmpp:chat-markers:0")) {
698 receiptsNamespaces.add("urn:xmpp:chat-markers:0");
699 }
700 if (packet.hasChild("request", "urn:xmpp:receipts")) {
701 receiptsNamespaces.add("urn:xmpp:receipts");
702 }
703 if (receiptsNamespaces.size() > 0) {
704 MessagePacket receipt = mXmppConnectionService.getMessageGenerator().received(account,
705 packet,
706 receiptsNamespaces,
707 packet.getType());
708 mXmppConnectionService.sendMessagePacket(account, receipt);
709 }
710 }
711
712 private static SimpleDateFormat TIME_FORMAT = new SimpleDateFormat("HH:mm:ss");
713
714 private void activateGracePeriod(Account account) {
715 long duration = mXmppConnectionService.getPreferences().getLong("race_period_length", 144) * 1000;
716 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": activating grace period till "+TIME_FORMAT.format(new Date(System.currentTimeMillis() + duration)));
717 account.activateGracePeriod(duration);
718 }
719}