2014-05-14 10:56:34 +00:00
package eu.siacs.conversations.parser ;
2014-02-19 00:35:23 +00:00
2015-05-15 03:14:15 +00:00
import android.util.Log ;
import android.util.Pair ;
2014-02-19 00:35:23 +00:00
import net.java.otr4j.session.Session ;
import net.java.otr4j.session.SessionStatus ;
2014-11-04 17:27:20 +00:00
2015-06-29 12:22:26 +00:00
import java.util.Set ;
2015-06-25 14:58:24 +00:00
2015-05-15 03:14:15 +00:00
import eu.siacs.conversations.Config ;
2015-06-25 14:58:24 +00:00
import eu.siacs.conversations.crypto.axolotl.AxolotlService ;
import eu.siacs.conversations.crypto.axolotl.XmppAxolotlMessage ;
2014-02-28 17:46:01 +00:00
import eu.siacs.conversations.entities.Account ;
2014-08-05 20:58:46 +00:00
import eu.siacs.conversations.entities.Contact ;
2014-02-28 17:46:01 +00:00
import eu.siacs.conversations.entities.Conversation ;
import eu.siacs.conversations.entities.Message ;
2015-01-07 17:34:24 +00:00
import eu.siacs.conversations.entities.MucOptions ;
2015-01-11 21:18:18 +00:00
import eu.siacs.conversations.http.HttpConnectionManager ;
2014-12-13 11:25:52 +00:00
import eu.siacs.conversations.services.MessageArchiveService ;
2014-02-28 17:46:01 +00:00
import eu.siacs.conversations.services.XmppConnectionService ;
2014-06-20 15:30:19 +00:00
import eu.siacs.conversations.utils.CryptoHelper ;
2014-02-28 17:46:01 +00:00
import eu.siacs.conversations.xml.Element ;
2014-07-12 00:36:37 +00:00
import eu.siacs.conversations.xmpp.OnMessagePacketReceived ;
2015-02-21 10:06:52 +00:00
import eu.siacs.conversations.xmpp.chatstate.ChatState ;
2014-11-06 19:10:03 +00:00
import eu.siacs.conversations.xmpp.jid.Jid ;
2014-08-05 20:58:46 +00:00
import eu.siacs.conversations.xmpp.pep.Avatar ;
2014-03-10 18:22:13 +00:00
import eu.siacs.conversations.xmpp.stanzas.MessagePacket ;
2014-02-19 00:35:23 +00:00
2014-07-12 00:36:37 +00:00
public class MessageParser extends AbstractParser implements
OnMessagePacketReceived {
2014-05-14 10:56:34 +00:00
public MessageParser ( XmppConnectionService service ) {
2014-06-06 16:26:40 +00:00
super ( service ) ;
2014-05-14 10:56:34 +00:00
}
2014-06-04 10:31:19 +00:00
2015-05-15 03:14:15 +00:00
private boolean extractChatState ( Conversation conversation , final MessagePacket packet ) {
ChatState state = ChatState . parse ( packet ) ;
2015-02-21 10:06:52 +00:00
if ( state ! = null & & conversation ! = null ) {
final Account account = conversation . getAccount ( ) ;
2015-05-15 03:14:15 +00:00
Jid from = packet . getFrom ( ) ;
if ( from . toBareJid ( ) . equals ( account . getJid ( ) . toBareJid ( ) ) ) {
2015-02-21 10:06:52 +00:00
conversation . setOutgoingChatState ( state ) ;
return false ;
} else {
return conversation . setIncomingChatState ( state ) ;
}
}
return false ;
}
2015-05-15 03:14:15 +00:00
private Message parseOtrChat ( String body , Jid from , String id , Conversation conversation ) {
2014-08-11 11:46:32 +00:00
String presence ;
2014-11-06 19:10:03 +00:00
if ( from . isBareJid ( ) ) {
2015-03-16 22:23:51 +00:00
presence = " " ;
2014-08-11 11:46:32 +00:00
} else {
2014-11-06 19:10:03 +00:00
presence = from . getResourcepart ( ) ;
2014-08-11 11:46:32 +00:00
}
2015-01-24 15:19:58 +00:00
if ( body . matches ( " ^ \\ ?OTRv \\ d{1,2} \\ ?.* " ) ) {
2014-10-05 09:14:50 +00:00
conversation . endOtrIfNeeded ( ) ;
2014-09-06 16:21:31 +00:00
}
2014-02-19 00:35:23 +00:00
if ( ! conversation . hasValidOtrSession ( ) ) {
2015-05-15 03:14:15 +00:00
conversation . startOtrSession ( presence , false ) ;
2014-03-07 23:48:52 +00:00
} else {
2015-05-15 03:14:15 +00:00
String foreignPresence = conversation . getOtrSession ( ) . getSessionID ( ) . getUserID ( ) ;
2014-08-11 11:46:32 +00:00
if ( ! foreignPresence . equals ( presence ) ) {
2014-06-25 14:55:47 +00:00
conversation . endOtrIfNeeded ( ) ;
2015-05-15 03:14:15 +00:00
conversation . startOtrSession ( presence , false ) ;
2014-03-07 23:48:52 +00:00
}
2014-02-19 00:35:23 +00:00
}
try {
2015-05-15 03:14:15 +00:00
conversation . setLastReceivedOtrMessageId ( id ) ;
2014-02-19 00:35:23 +00:00
Session otrSession = conversation . getOtrSession ( ) ;
body = otrSession . transformReceiving ( body ) ;
2015-07-21 09:46:51 +00:00
SessionStatus status = otrSession . getSessionStatus ( ) ;
if ( body = = null & & status = = SessionStatus . ENCRYPTED ) {
2014-06-11 19:53:25 +00:00
mXmppConnectionService . onOtrSessionEstablished ( conversation ) ;
2015-07-21 09:46:51 +00:00
return null ;
} else if ( body = = null & & status = = SessionStatus . FINISHED ) {
2014-02-19 00:35:23 +00:00
conversation . resetOtrSession ( ) ;
2014-07-20 10:36:57 +00:00
mXmppConnectionService . updateConversationUi ( ) ;
2015-07-21 09:46:51 +00:00
return null ;
} else if ( body = = null | | ( body . isEmpty ( ) ) ) {
2014-03-23 13:15:14 +00:00
return null ;
}
2014-06-20 15:30:19 +00:00
if ( body . startsWith ( CryptoHelper . FILETRANSFER ) ) {
String key = body . substring ( CryptoHelper . FILETRANSFER . length ( ) ) ;
conversation . setSymmetricKey ( CryptoHelper . hexToBytes ( key ) ) ;
return null ;
}
2015-05-15 03:14:15 +00:00
Message finishedMessage = new Message ( conversation , body , Message . ENCRYPTION_OTR , Message . STATUS_RECEIVED ) ;
2015-03-21 15:07:17 +00:00
conversation . setLastReceivedOtrMessageId ( null ) ;
2014-06-06 16:26:40 +00:00
return finishedMessage ;
2014-02-19 00:35:23 +00:00
} catch ( Exception e ) {
2014-09-06 16:21:31 +00:00
conversation . resetOtrSession ( ) ;
2014-02-19 00:35:23 +00:00
return null ;
}
}
2014-06-04 10:31:19 +00:00
2015-07-03 11:27:35 +00:00
private Message parseAxolotlChat ( Element axolotlMessage , Jid from , String id , Conversation conversation , int status ) {
2015-06-26 13:41:02 +00:00
Message finishedMessage = null ;
AxolotlService service = conversation . getAccount ( ) . getAxolotlService ( ) ;
2015-07-31 19:12:34 +00:00
XmppAxolotlMessage xmppAxolotlMessage = XmppAxolotlMessage . fromElement ( axolotlMessage , from . toBareJid ( ) ) ;
2015-07-31 21:28:09 +00:00
XmppAxolotlMessage . XmppAxolotlPlaintextMessage plaintextMessage = service . processReceivingPayloadMessage ( xmppAxolotlMessage ) ;
2015-06-26 13:41:02 +00:00
if ( plaintextMessage ! = null ) {
2015-07-03 11:27:35 +00:00
finishedMessage = new Message ( conversation , plaintextMessage . getPlaintext ( ) , Message . ENCRYPTION_AXOLOTL , status ) ;
2015-07-09 12:23:17 +00:00
finishedMessage . setAxolotlFingerprint ( plaintextMessage . getFingerprint ( ) ) ;
Log . d ( Config . LOGTAG , AxolotlService . getLogprefix ( finishedMessage . getConversation ( ) . getAccount ( ) ) + " Received Message with session fingerprint: " + plaintextMessage . getFingerprint ( ) ) ;
2015-06-26 13:41:02 +00:00
}
2015-06-25 14:58:24 +00:00
2015-06-26 13:41:02 +00:00
return finishedMessage ;
}
2015-06-25 14:58:24 +00:00
2015-04-21 16:36:11 +00:00
private class Invite {
Jid jid ;
String password ;
Invite ( Jid jid , String password ) {
this . jid = jid ;
this . password = password ;
2015-01-07 15:45:44 +00:00
}
2015-05-19 06:23:12 +00:00
public boolean execute ( Account account ) {
if ( jid ! = null ) {
Conversation conversation = mXmppConnectionService . findOrCreateConversation ( account , jid , true ) ;
if ( ! conversation . getMucOptions ( ) . online ( ) ) {
conversation . getMucOptions ( ) . setPassword ( password ) ;
mXmppConnectionService . databaseBackend . updateConversation ( conversation ) ;
mXmppConnectionService . joinMuc ( conversation ) ;
mXmppConnectionService . updateConversationUi ( ) ;
}
return true ;
}
return false ;
}
2015-04-21 16:36:11 +00:00
}
private Invite extractInvite ( Element message ) {
2015-05-15 03:14:15 +00:00
Element x = message . findChild ( " x " , " http://jabber.org/protocol/muc#user " ) ;
2015-04-21 16:36:11 +00:00
if ( x ! = null ) {
Element invite = x . findChild ( " invite " ) ;
if ( invite ! = null ) {
Element pw = x . findChild ( " password " ) ;
return new Invite ( message . getAttributeAsJid ( " from " ) , pw ! = null ? pw . getContent ( ) : null ) ;
}
2015-01-07 15:45:44 +00:00
} else {
2015-04-21 16:36:11 +00:00
x = message . findChild ( " x " , " jabber:x:conference " ) ;
if ( x ! = null ) {
return new Invite ( x . getAttributeAsJid ( " jid " ) , x . getAttribute ( " password " ) ) ;
}
2014-06-06 16:49:35 +00:00
}
2015-04-21 16:36:11 +00:00
return null ;
2014-06-06 16:49:35 +00:00
}
2014-02-27 23:22:56 +00:00
2014-11-06 19:10:03 +00:00
private void parseEvent ( final Element event , final Jid from , final Account account ) {
2014-08-04 23:36:17 +00:00
Element items = event . findChild ( " items " ) ;
2015-05-19 06:23:12 +00:00
String node = items = = null ? null : items . getAttribute ( " node " ) ;
if ( " urn:xmpp:avatar:metadata " . equals ( node ) ) {
2014-11-20 17:42:47 +00:00
Avatar avatar = Avatar . parseMetadata ( items ) ;
if ( avatar ! = null ) {
avatar . owner = from ;
2015-05-19 06:23:12 +00:00
if ( mXmppConnectionService . getFileBackend ( ) . isAvatarCached ( avatar ) ) {
2014-11-20 17:42:47 +00:00
if ( account . getJid ( ) . toBareJid ( ) . equals ( from ) ) {
if ( account . setAvatar ( avatar . getFilename ( ) ) ) {
2015-05-19 06:23:12 +00:00
mXmppConnectionService . databaseBackend . updateAccount ( account ) ;
2014-08-15 11:11:33 +00:00
}
2015-05-19 06:23:12 +00:00
mXmppConnectionService . getAvatarService ( ) . clear ( account ) ;
2014-11-20 17:42:47 +00:00
mXmppConnectionService . updateConversationUi ( ) ;
mXmppConnectionService . updateAccountUi ( ) ;
2014-08-05 20:58:46 +00:00
} else {
2015-05-19 06:23:12 +00:00
Contact contact = account . getRoster ( ) . getContact ( from ) ;
2015-05-05 04:17:34 +00:00
contact . setAvatar ( avatar ) ;
2015-05-19 06:23:12 +00:00
mXmppConnectionService . getAvatarService ( ) . clear ( contact ) ;
2014-11-20 17:42:47 +00:00
mXmppConnectionService . updateConversationUi ( ) ;
mXmppConnectionService . updateRosterUi ( ) ;
2014-08-05 20:58:46 +00:00
}
2014-11-20 17:42:47 +00:00
} else {
mXmppConnectionService . fetchAvatar ( account , avatar ) ;
2014-08-05 20:58:46 +00:00
}
2014-11-20 17:42:47 +00:00
}
2015-05-19 06:23:12 +00:00
} else if ( " http://jabber.org/protocol/nick " . equals ( node ) ) {
Element i = items . findChild ( " item " ) ;
Element nick = i = = null ? null : i . findChild ( " nick " , " http://jabber.org/protocol/nick " ) ;
if ( nick ! = null ) {
Contact contact = account . getRoster ( ) . getContact ( from ) ;
contact . setPresenceName ( nick . getContent ( ) ) ;
mXmppConnectionService . getAvatarService ( ) . clear ( account ) ;
mXmppConnectionService . updateConversationUi ( ) ;
mXmppConnectionService . updateAccountUi ( ) ;
2014-08-05 20:58:46 +00:00
}
2015-06-25 14:58:24 +00:00
} else if ( AxolotlService . PEP_DEVICE_LIST . equals ( node ) ) {
2015-07-08 15:44:24 +00:00
Log . d ( Config . LOGTAG , AxolotlService . getLogprefix ( account ) + " Received PEP device list update from " + from + " , processing... " ) ;
2015-06-26 13:41:02 +00:00
Element item = items . findChild ( " item " ) ;
2015-06-29 12:22:26 +00:00
Set < Integer > deviceIds = mXmppConnectionService . getIqParser ( ) . deviceIds ( item ) ;
2015-06-26 13:41:02 +00:00
AxolotlService axolotlService = account . getAxolotlService ( ) ;
2015-06-29 12:22:26 +00:00
axolotlService . registerDevices ( from , deviceIds ) ;
2015-07-07 17:32:52 +00:00
mXmppConnectionService . updateAccountUi ( ) ;
2014-08-04 23:36:17 +00:00
}
}
2015-05-19 06:23:12 +00:00
private boolean handleErrorMessage ( Account account , MessagePacket packet ) {
if ( packet . getType ( ) = = MessagePacket . TYPE_ERROR ) {
Jid from = packet . getFrom ( ) ;
if ( from ! = null ) {
2015-07-28 12:44:11 +00:00
Element error = packet . findChild ( " error " ) ;
String text = error = = null ? null : error . findChildContent ( " text " ) ;
if ( text ! = null ) {
Log . d ( Config . LOGTAG , account . getJid ( ) . toBareJid ( ) + " : sending message to " + from + " failed - " + text ) ;
} else if ( error ! = null ) {
Log . d ( Config . LOGTAG , account . getJid ( ) . toBareJid ( ) + " : sending message to " + from + " failed - " + error ) ;
}
2015-07-21 09:52:49 +00:00
Message message = mXmppConnectionService . markMessage ( account ,
from . toBareJid ( ) ,
packet . getId ( ) ,
Message . STATUS_SEND_FAILED ) ;
2015-07-21 17:44:25 +00:00
if ( message ! = null & & message . getEncryption ( ) = = Message . ENCRYPTION_OTR ) {
2015-07-21 09:52:49 +00:00
message . getConversation ( ) . endOtrIfNeeded ( ) ;
}
2015-05-19 06:23:12 +00:00
}
return true ;
}
return false ;
}
2015-05-15 03:14:15 +00:00
@Override
public void onMessagePacketReceived ( Account account , MessagePacket original ) {
2015-05-19 06:23:12 +00:00
if ( handleErrorMessage ( account , original ) ) {
return ;
}
2015-05-15 03:14:15 +00:00
final MessagePacket packet ;
Long timestamp = null ;
final boolean isForwarded ;
2015-07-29 14:41:58 +00:00
boolean isCarbon = false ;
2015-05-15 04:31:27 +00:00
String serverMsgId = null ;
2015-05-15 10:29:45 +00:00
final Element fin = original . findChild ( " fin " , " urn:xmpp:mam:0 " ) ;
if ( fin ! = null ) {
mXmppConnectionService . getMessageArchiveService ( ) . processFin ( fin , original . getFrom ( ) ) ;
return ;
}
final Element result = original . findChild ( " result " , " urn:xmpp:mam:0 " ) ;
final MessageArchiveService . Query query = result = = null ? null : mXmppConnectionService . getMessageArchiveService ( ) . findQuery ( result . getAttribute ( " queryid " ) ) ;
if ( query ! = null & & query . validFrom ( original . getFrom ( ) ) ) {
Pair < MessagePacket , Long > f = original . getForwardedMessagePacket ( " result " , " urn:xmpp:mam:0 " ) ;
if ( f = = null ) {
return ;
}
timestamp = f . second ;
packet = f . first ;
isForwarded = true ;
serverMsgId = result . getAttribute ( " id " ) ;
query . incrementTotalCount ( ) ;
} else if ( query ! = null ) {
Log . d ( Config . LOGTAG , account . getJid ( ) . toBareJid ( ) + " : received mam result from invalid sender " ) ;
return ;
} else if ( original . fromServer ( account ) ) {
2015-05-15 03:14:15 +00:00
Pair < MessagePacket , Long > f ;
f = original . getForwardedMessagePacket ( " received " , " urn:xmpp:carbons:2 " ) ;
f = f = = null ? original . getForwardedMessagePacket ( " sent " , " urn:xmpp:carbons:2 " ) : f ;
packet = f ! = null ? f . first : original ;
2015-05-19 06:23:12 +00:00
if ( handleErrorMessage ( account , packet ) ) {
return ;
}
2015-05-15 03:14:15 +00:00
timestamp = f ! = null ? f . second : null ;
2015-07-29 14:41:58 +00:00
isCarbon = f ! = null ;
isForwarded = isCarbon ;
2014-05-22 14:17:51 +00:00
} else {
2015-05-15 03:14:15 +00:00
packet = original ;
isForwarded = false ;
}
2015-05-19 06:23:12 +00:00
2015-05-15 03:14:15 +00:00
if ( timestamp = = null ) {
timestamp = AbstractParser . getTimestamp ( packet , System . currentTimeMillis ( ) ) ;
}
final String body = packet . getBody ( ) ;
2015-07-22 12:15:00 +00:00
final Element mucUserElement = packet . findChild ( " x " , " http://jabber.org/protocol/muc#user " ) ;
2015-06-25 14:58:24 +00:00
final String pgpEncrypted = packet . findChildContent ( " x " , " jabber:x:encrypted " ) ;
2015-07-31 19:12:34 +00:00
final Element axolotlEncrypted = packet . findChild ( XmppAxolotlMessage . CONTAINERTAG , AxolotlService . PEP_PREFIX ) ;
2015-05-15 03:14:15 +00:00
int status ;
2015-05-15 10:29:45 +00:00
final Jid counterpart ;
2015-05-15 03:14:15 +00:00
final Jid to = packet . getTo ( ) ;
final Jid from = packet . getFrom ( ) ;
2015-05-15 04:31:27 +00:00
final String remoteMsgId = packet . getId ( ) ;
2015-07-02 16:02:32 +00:00
if ( from = = null | | to = = null ) {
Log . d ( Config . LOGTAG , " no to or from in: " + packet . toString ( ) ) ;
return ;
}
2015-05-15 03:14:15 +00:00
boolean isTypeGroupChat = packet . getType ( ) = = MessagePacket . TYPE_GROUPCHAT ;
2015-06-28 20:14:40 +00:00
boolean isProperlyAddressed = ! to . isBareJid ( ) | | account . countPresences ( ) = = 1 ;
boolean isMucStatusMessage = from . isBareJid ( ) & & mucUserElement ! = null & & mucUserElement . hasChild ( " status " ) ;
2015-05-15 03:14:15 +00:00
if ( packet . fromAccount ( account ) ) {
status = Message . STATUS_SEND ;
counterpart = to ;
} else {
status = Message . STATUS_RECEIVED ;
counterpart = from ;
2014-02-27 23:22:56 +00:00
}
2014-07-12 00:36:37 +00:00
2015-05-15 03:14:15 +00:00
Invite invite = extractInvite ( packet ) ;
2015-05-19 06:23:12 +00:00
if ( invite ! = null & & invite . execute ( account ) ) {
2015-05-15 03:14:15 +00:00
return ;
}
2015-06-25 14:58:24 +00:00
if ( extractChatState ( mXmppConnectionService . find ( account , from ) , packet ) ) {
2015-05-15 03:14:15 +00:00
mXmppConnectionService . updateConversationUi ( ) ;
}
2015-06-25 14:58:24 +00:00
if ( ( body ! = null | | pgpEncrypted ! = null | | axolotlEncrypted ! = null ) & & ! isMucStatusMessage ) {
2015-05-15 03:14:15 +00:00
Conversation conversation = mXmppConnectionService . findOrCreateConversation ( account , counterpart . toBareJid ( ) , isTypeGroupChat ) ;
if ( isTypeGroupChat ) {
if ( counterpart . getResourcepart ( ) . equals ( conversation . getMucOptions ( ) . getActualNick ( ) ) ) {
2015-06-02 10:21:35 +00:00
status = Message . STATUS_SEND_RECEIVED ;
if ( mXmppConnectionService . markMessage ( conversation , remoteMsgId , status ) ) {
2015-05-15 03:14:15 +00:00
return ;
2015-08-26 09:39:18 +00:00
} else if ( remoteMsgId = = null ) {
Message message = conversation . findSentMessageWithBody ( packet . getBody ( ) ) ;
2015-05-15 03:14:15 +00:00
if ( message ! = null ) {
2015-06-02 10:21:35 +00:00
mXmppConnectionService . markMessage ( message , status ) ;
2015-05-15 03:14:15 +00:00
return ;
}
2014-07-12 00:36:37 +00:00
}
2015-05-15 03:14:15 +00:00
} else {
status = Message . STATUS_RECEIVED ;
2014-07-12 00:36:37 +00:00
}
2015-05-15 03:14:15 +00:00
}
Message message ;
if ( body ! = null & & body . startsWith ( " ?OTR " ) ) {
2015-06-28 20:14:40 +00:00
if ( ! isForwarded & & ! isTypeGroupChat & & isProperlyAddressed ) {
2015-05-15 04:31:27 +00:00
message = parseOtrChat ( body , from , remoteMsgId , conversation ) ;
2015-05-15 03:14:15 +00:00
if ( message = = null ) {
return ;
}
} else {
message = new Message ( conversation , body , Message . ENCRYPTION_NONE , status ) ;
2014-12-05 00:54:16 +00:00
}
2015-06-25 14:58:24 +00:00
} else if ( pgpEncrypted ! = null ) {
2015-06-26 13:41:02 +00:00
message = new Message ( conversation , pgpEncrypted , Message . ENCRYPTION_PGP , status ) ;
} else if ( axolotlEncrypted ! = null ) {
2015-07-03 11:27:35 +00:00
message = parseAxolotlChat ( axolotlEncrypted , from , remoteMsgId , conversation , status ) ;
2015-06-26 13:41:02 +00:00
if ( message = = null ) {
return ;
}
2014-07-23 12:30:27 +00:00
} else {
2015-05-15 03:14:15 +00:00
message = new Message ( conversation , body , Message . ENCRYPTION_NONE , status ) ;
2014-07-12 00:36:37 +00:00
}
2015-05-15 03:14:15 +00:00
message . setCounterpart ( counterpart ) ;
2015-05-15 04:31:27 +00:00
message . setRemoteMsgId ( remoteMsgId ) ;
message . setServerMsgId ( serverMsgId ) ;
2015-07-29 14:41:58 +00:00
message . setCarbon ( isCarbon ) ;
2015-05-15 03:14:15 +00:00
message . setTime ( timestamp ) ;
message . markable = packet . hasChild ( " markable " , " urn:xmpp:chat-markers:0 " ) ;
if ( conversation . getMode ( ) = = Conversation . MODE_MULTI ) {
message . setTrueCounterpart ( conversation . getMucOptions ( ) . getTrueCounterpart ( counterpart . getResourcepart ( ) ) ) ;
if ( ! isTypeGroupChat ) {
message . setType ( Message . TYPE_PRIVATE ) ;
2014-07-12 00:36:37 +00:00
}
}
2015-05-15 03:14:15 +00:00
updateLastseen ( packet , account , true ) ;
2015-05-26 10:00:55 +00:00
boolean checkForDuplicates = serverMsgId ! = null
| | ( isTypeGroupChat & & packet . hasChild ( " delay " , " urn:xmpp:delay " ) )
| | message . getType ( ) = = Message . TYPE_PRIVATE ;
2015-05-15 04:31:27 +00:00
if ( checkForDuplicates & & conversation . hasDuplicateMessage ( message ) ) {
Log . d ( Config . LOGTAG , " skipping duplicate message from " + message . getCounterpart ( ) . toString ( ) + " " + message . getBody ( ) ) ;
return ;
}
if ( query ! = null ) {
query . incrementMessageCount ( ) ;
}
2015-05-15 03:14:15 +00:00
conversation . add ( message ) ;
2015-05-15 09:51:20 +00:00
if ( serverMsgId = = null ) {
2015-06-04 00:47:24 +00:00
if ( status = = Message . STATUS_SEND | | status = = Message . STATUS_SEND_RECEIVED ) {
2015-05-15 09:51:20 +00:00
mXmppConnectionService . markRead ( conversation ) ;
account . activateGracePeriod ( ) ;
} else {
message . markUnread ( ) ;
}
2015-05-15 10:29:45 +00:00
mXmppConnectionService . updateConversationUi ( ) ;
2014-07-23 23:04:25 +00:00
}
2015-05-15 03:14:15 +00:00
2015-07-22 12:15:00 +00:00
if ( mXmppConnectionService . confirmMessages ( ) & & remoteMsgId ! = null & & ! isForwarded & & ! isTypeGroupChat ) {
2015-05-15 03:14:15 +00:00
if ( packet . hasChild ( " markable " , " urn:xmpp:chat-markers:0 " ) ) {
2015-07-22 12:15:00 +00:00
MessagePacket receipt = mXmppConnectionService . getMessageGenerator ( ) . received ( account ,
packet ,
" urn:xmpp:chat-markers:0 " ,
MessagePacket . TYPE_CHAT ) ;
2015-05-15 03:14:15 +00:00
mXmppConnectionService . sendMessagePacket ( account , receipt ) ;
}
if ( packet . hasChild ( " request " , " urn:xmpp:receipts " ) ) {
2015-07-22 12:15:00 +00:00
MessagePacket receipt = mXmppConnectionService . getMessageGenerator ( ) . received ( account ,
packet ,
" urn:xmpp:receipts " ,
packet . getType ( ) ) ;
2015-05-15 03:14:15 +00:00
mXmppConnectionService . sendMessagePacket ( account , receipt ) ;
}
2014-07-12 00:36:37 +00:00
}
2015-05-15 03:14:15 +00:00
if ( account . getXmppConnection ( ) ! = null & & account . getXmppConnection ( ) . getFeatures ( ) . advancedStreamFeaturesLoaded ( ) ) {
if ( conversation . setLastMessageTransmitted ( System . currentTimeMillis ( ) ) ) {
mXmppConnectionService . updateConversation ( conversation ) ;
}
2014-12-08 20:59:14 +00:00
}
2014-10-28 17:02:12 +00:00
2015-05-15 03:14:15 +00:00
if ( message . getStatus ( ) = = Message . STATUS_RECEIVED
& & conversation . getOtrSession ( ) ! = null
& & ! conversation . getOtrSession ( ) . getSessionID ( ) . getUserID ( )
. equals ( message . getCounterpart ( ) . getResourcepart ( ) ) ) {
conversation . endOtrIfNeeded ( ) ;
}
2014-10-28 17:02:12 +00:00
2015-05-15 10:29:45 +00:00
if ( message . getEncryption ( ) = = Message . ENCRYPTION_NONE | | mXmppConnectionService . saveEncryptedMessages ( ) ) {
2014-09-08 11:37:22 +00:00
mXmppConnectionService . databaseBackend . createMessage ( message ) ;
}
2015-05-15 03:14:15 +00:00
final HttpConnectionManager manager = this . mXmppConnectionService . getHttpConnectionManager ( ) ;
2015-07-01 14:01:18 +00:00
if ( message . trusted ( ) & & message . treatAsDownloadable ( ) ! = Message . Decision . NEVER & & manager . getAutoAcceptFileSize ( ) > 0 ) {
2015-07-10 13:14:13 +00:00
manager . createNewDownloadConnection ( message ) ;
2015-05-15 03:14:15 +00:00
} else if ( ! message . isRead ( ) ) {
mXmppConnectionService . getNotificationService ( ) . push ( message ) ;
}
2015-05-15 10:29:45 +00:00
} else { //no body
2015-06-28 18:11:28 +00:00
if ( isTypeGroupChat ) {
2015-05-15 03:14:15 +00:00
Conversation conversation = mXmppConnectionService . find ( account , from . toBareJid ( ) ) ;
2015-06-28 18:11:28 +00:00
if ( packet . hasChild ( " subject " ) ) {
if ( conversation ! = null & & conversation . getMode ( ) = = Conversation . MODE_MULTI ) {
conversation . setHasMessagesLeftOnServer ( conversation . countMessages ( ) > 0 ) ;
conversation . getMucOptions ( ) . setSubject ( packet . findChildContent ( " subject " ) ) ;
mXmppConnectionService . updateConversationUi ( ) ;
return ;
}
}
2015-06-28 20:14:40 +00:00
if ( conversation ! = null & & isMucStatusMessage ) {
for ( Element child : mucUserElement . getChildren ( ) ) {
2015-06-28 18:11:28 +00:00
if ( child . getName ( ) . equals ( " status " )
& & MucOptions . STATUS_CODE_ROOM_CONFIG_CHANGED . equals ( child . getAttribute ( " code " ) ) ) {
mXmppConnectionService . fetchConferenceConfiguration ( conversation ) ;
}
}
2015-05-15 03:14:15 +00:00
}
}
2014-07-12 00:36:37 +00:00
}
2015-05-15 03:14:15 +00:00
Element received = packet . findChild ( " received " , " urn:xmpp:chat-markers:0 " ) ;
if ( received = = null ) {
received = packet . findChild ( " received " , " urn:xmpp:receipts " ) ;
}
if ( received ! = null & & ! packet . fromAccount ( account ) ) {
mXmppConnectionService . markMessage ( account , from . toBareJid ( ) , received . getAttribute ( " id " ) , Message . STATUS_SEND_RECEIVED ) ;
}
Element displayed = packet . findChild ( " displayed " , " urn:xmpp:chat-markers:0 " ) ;
if ( displayed ! = null ) {
if ( packet . fromAccount ( account ) ) {
Conversation conversation = mXmppConnectionService . find ( account , counterpart . toBareJid ( ) ) ;
2015-05-16 10:43:38 +00:00
if ( conversation ! = null ) {
mXmppConnectionService . markRead ( conversation ) ;
}
2015-05-15 03:14:15 +00:00
} else {
updateLastseen ( packet , account , true ) ;
final Message displayedMessage = mXmppConnectionService . markMessage ( account , from . toBareJid ( ) , displayed . getAttribute ( " id " ) , Message . STATUS_SEND_DISPLAYED ) ;
Message message = displayedMessage = = null ? null : displayedMessage . prev ( ) ;
while ( message ! = null
& & message . getStatus ( ) = = Message . STATUS_SEND_RECEIVED
& & message . getTimeSent ( ) < displayedMessage . getTimeSent ( ) ) {
mXmppConnectionService . markMessage ( message , Message . STATUS_SEND_DISPLAYED ) ;
message = message . prev ( ) ;
}
}
2014-09-28 13:21:56 +00:00
}
2014-08-04 23:36:17 +00:00
2015-05-15 03:14:15 +00:00
Element event = packet . findChild ( " event " , " http://jabber.org/protocol/pubsub#event " ) ;
if ( event ! = null ) {
parseEvent ( event , from , account ) ;
2014-08-04 23:36:17 +00:00
}
2014-09-04 08:50:06 +00:00
2015-05-15 03:14:15 +00:00
String nick = packet . findChildContent ( " nick " , " http://jabber.org/protocol/nick " ) ;
2014-09-04 08:50:06 +00:00
if ( nick ! = null ) {
2015-05-15 03:14:15 +00:00
Contact contact = account . getRoster ( ) . getContact ( from ) ;
contact . setPresenceName ( nick ) ;
2014-09-04 08:50:06 +00:00
}
}
2015-08-15 12:26:37 +00:00
}