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