1package eu.siacs.conversations.parser;
2
3import java.util.List;
4
5import net.java.otr4j.session.Session;
6import net.java.otr4j.session.SessionStatus;
7import android.util.Log;
8import eu.siacs.conversations.entities.Account;
9import eu.siacs.conversations.entities.Contact;
10import eu.siacs.conversations.entities.Conversation;
11import eu.siacs.conversations.entities.Message;
12import eu.siacs.conversations.services.XmppConnectionService;
13import eu.siacs.conversations.xml.Element;
14import eu.siacs.conversations.xmpp.stanzas.MessagePacket;
15
16public class MessageParser extends AbstractParser {
17
18 public MessageParser(XmppConnectionService service) {
19 super(service);
20 }
21
22 public Message parseChat(MessagePacket packet, Account account) {
23 String[] fromParts = packet.getFrom().split("/");
24 Conversation conversation = mXmppConnectionService
25 .findOrCreateConversation(account, fromParts[0], false);
26 conversation.setLatestMarkableMessageId(getMarkableMessageId(packet));
27 updateLastseen(packet, account,true);
28 String pgpBody = getPgpBody(packet);
29 if (pgpBody != null) {
30 return new Message(conversation, packet.getFrom(), pgpBody,
31 Message.ENCRYPTION_PGP, Message.STATUS_RECIEVED);
32 } else {
33 return new Message(conversation, packet.getFrom(),
34 packet.getBody(), Message.ENCRYPTION_NONE,
35 Message.STATUS_RECIEVED);
36 }
37 }
38
39 public Message parseOtrChat(MessagePacket packet, Account account) {
40 boolean properlyAddressed = (packet.getTo().split("/").length == 2)
41 || (account.countPresences() == 1);
42 String[] fromParts = packet.getFrom().split("/");
43 Conversation conversation = mXmppConnectionService
44 .findOrCreateConversation(account, fromParts[0], false);
45 updateLastseen(packet, account,true);
46 String body = packet.getBody();
47 if (!conversation.hasValidOtrSession()) {
48 if (properlyAddressed) {
49 Log.d("xmppService",
50 "starting new otr session with "
51 + packet.getFrom()
52 + " because no valid otr session has been found");
53 conversation.startOtrSession(
54 mXmppConnectionService.getApplicationContext(),
55 fromParts[1], false);
56 } else {
57 Log.d("xmppService", account.getJid()
58 + ": ignoring otr session with " + fromParts[0]);
59 return null;
60 }
61 } else {
62 String foreignPresence = conversation.getOtrSession()
63 .getSessionID().getUserID();
64 if (!foreignPresence.equals(fromParts[1])) {
65 conversation.resetOtrSession();
66 if (properlyAddressed) {
67 Log.d("xmppService",
68 "replacing otr session with " + packet.getFrom());
69 conversation.startOtrSession(
70 mXmppConnectionService.getApplicationContext(),
71 fromParts[1], false);
72 } else {
73 return null;
74 }
75 }
76 }
77 try {
78 Session otrSession = conversation.getOtrSession();
79 SessionStatus before = otrSession.getSessionStatus();
80 body = otrSession.transformReceiving(body);
81 SessionStatus after = otrSession.getSessionStatus();
82 if ((before != after) && (after == SessionStatus.ENCRYPTED)) {
83 List<Message> messages = conversation.getMessages();
84 for (int i = 0; i < messages.size(); ++i) {
85 Message msg = messages.get(i);
86 if ((msg.getStatus() == Message.STATUS_UNSEND)
87 && (msg.getEncryption() == Message.ENCRYPTION_OTR)) {
88 MessagePacket outPacket = mXmppConnectionService
89 .prepareMessagePacket(account, msg, otrSession);
90 msg.setStatus(Message.STATUS_SEND);
91 mXmppConnectionService.databaseBackend
92 .updateMessage(msg);
93 account.getXmppConnection()
94 .sendMessagePacket(outPacket);
95 }
96 }
97 mXmppConnectionService.updateUi(conversation, false);
98 } else if ((before != after) && (after == SessionStatus.FINISHED)) {
99 conversation.resetOtrSession();
100 }
101 // isEmpty is a work around for some weird clients which send emtpty
102 // strings over otr
103 if ((body == null) || (body.isEmpty())) {
104 return null;
105 }
106 conversation.setLatestMarkableMessageId(getMarkableMessageId(packet));
107 Message finishedMessage = new Message(conversation, packet.getFrom(), body,
108 Message.ENCRYPTION_OTR, Message.STATUS_RECIEVED);
109 finishedMessage.setTime(getTimestamp(packet));
110 return finishedMessage;
111 } catch (Exception e) {
112 conversation.resetOtrSession();
113 return null;
114 }
115 }
116
117 public Message parseGroupchat(MessagePacket packet, Account account) {
118 int status;
119 String[] fromParts = packet.getFrom().split("/");
120 Conversation conversation = mXmppConnectionService
121 .findOrCreateConversation(account, fromParts[0], true);
122 if (packet.hasChild("subject")) {
123 conversation.getMucOptions().setSubject(
124 packet.findChild("subject").getContent());
125 mXmppConnectionService.updateUi(conversation, false);
126 return null;
127 }
128 if ((fromParts.length == 1)) {
129 return null;
130 }
131 String counterPart = fromParts[1];
132 if (counterPart.equals(conversation.getMucOptions().getNick())) {
133 if (mXmppConnectionService.markMessage(conversation,
134 packet.getId(), Message.STATUS_SEND)) {
135 return null;
136 } else {
137 status = Message.STATUS_SEND;
138 }
139 } else {
140 status = Message.STATUS_RECIEVED;
141 }
142 String pgpBody = getPgpBody(packet);
143 conversation.setLatestMarkableMessageId(getMarkableMessageId(packet));
144 Message finishedMessage;
145 if (pgpBody == null) {
146 finishedMessage = new Message(conversation, counterPart, packet.getBody(),
147 Message.ENCRYPTION_NONE, status);
148 } else {
149 finishedMessage= new Message(conversation, counterPart, pgpBody,
150 Message.ENCRYPTION_PGP, status);
151 }
152 finishedMessage.setTime(getTimestamp(packet));
153 return finishedMessage;
154 }
155
156 public Message parseCarbonMessage(MessagePacket packet, Account account) {
157 int status;
158 String fullJid;
159 Element forwarded;
160 if (packet.hasChild("received")) {
161 forwarded = packet.findChild("received").findChild("forwarded");
162 status = Message.STATUS_RECIEVED;
163 } else if (packet.hasChild("sent")) {
164 forwarded = packet.findChild("sent").findChild("forwarded");
165 status = Message.STATUS_SEND;
166 } else {
167 return null;
168 }
169 if (forwarded == null) {
170 return null;
171 }
172 Element message = forwarded.findChild("message");
173 if ((message == null) || (!message.hasChild("body")))
174 return null; // either malformed or boring
175 if (status == Message.STATUS_RECIEVED) {
176 fullJid = message.getAttribute("from");
177 updateLastseen(message, account,true);
178 } else {
179 fullJid = message.getAttribute("to");
180 }
181 String[] parts = fullJid.split("/");
182 Conversation conversation = mXmppConnectionService
183 .findOrCreateConversation(account, parts[0], false);
184 conversation.setLatestMarkableMessageId(getMarkableMessageId(packet));
185 String pgpBody = getPgpBody(message);
186 Message finishedMessage;
187 if (pgpBody != null) {
188 finishedMessage = new Message(conversation, fullJid, pgpBody,Message.ENCRYPTION_PGP, status);
189 } else {
190 String body = message.findChild("body").getContent();
191 finishedMessage= new Message(conversation, fullJid, body,Message.ENCRYPTION_NONE, status);
192 }
193 finishedMessage.setTime(getTimestamp(message));
194 return finishedMessage;
195 }
196
197 public void parseError(MessagePacket packet, Account account) {
198 String[] fromParts = packet.getFrom().split("/");
199 mXmppConnectionService.markMessage(account, fromParts[0],
200 packet.getId(), Message.STATUS_SEND_FAILED);
201 }
202
203 public void parseNormal(MessagePacket packet, Account account) {
204 if (packet.hasChild("displayed","urn:xmpp:chat-markers:0")) {
205 String id = packet.findChild("displayed","urn:xmpp:chat-markers:0").getAttribute("id");
206 String[] fromParts = packet.getFrom().split("/");
207 updateLastseen(packet, account,true);
208 mXmppConnectionService.markMessage(account,fromParts[0], id, Message.STATUS_SEND_DISPLAYED);
209 } else if (packet.hasChild("received","urn:xmpp:chat-markers:0")) {
210 String id = packet.findChild("received","urn:xmpp:chat-markers:0").getAttribute("id");
211 String[] fromParts = packet.getFrom().split("/");
212 updateLastseen(packet, account,false);
213 mXmppConnectionService.markMessage(account,fromParts[0], id, Message.STATUS_SEND_RECEIVED);
214 } else if (packet.hasChild("x")) {
215 Element x = packet.findChild("x");
216 if (x.hasChild("invite")) {
217 Conversation conversation = mXmppConnectionService.findOrCreateConversation(account, packet.getFrom(),
218 true);
219 mXmppConnectionService.updateUi(conversation, false);
220 }
221
222 }
223 }
224
225 private String getPgpBody(Element message) {
226 Element child = message.findChild("x", "jabber:x:encrypted");
227 if (child == null) {
228 return null;
229 } else {
230 return child.getContent();
231 }
232 }
233
234 private String getMarkableMessageId(Element message) {
235 if (message.hasChild("markable", "urn:xmpp:chat-markers:0")) {
236 return message.getAttribute("id");
237 } else {
238 return null;
239 }
240 }
241
242
243}