1package eu.siacs.conversations.utils;
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.Conversation;
10import eu.siacs.conversations.entities.Message;
11import eu.siacs.conversations.services.XmppConnectionService;
12import eu.siacs.conversations.xml.Element;
13import eu.siacs.conversations.xmpp.stanzas.MessagePacket;
14
15public class MessageParser {
16
17 protected static final String LOGTAG = "xmppService";
18
19 public static Message parsePlainTextChat(MessagePacket packet, Account account, XmppConnectionService service) {
20 String[] fromParts = packet.getFrom().split("/");
21 Conversation conversation = service.findOrCreateConversation(account, fromParts[0],false);
22 String body = packet.getBody();
23 return new Message(conversation, packet.getFrom(), body, Message.ENCRYPTION_NONE, Message.STATUS_RECIEVED);
24 }
25
26 public static Message parsePgpChat(String pgpBody, MessagePacket packet, Account account, XmppConnectionService service) {
27 String[] fromParts = packet.getFrom().split("/");
28 Conversation conversation = service.findOrCreateConversation(account, fromParts[0],false);
29 return new Message(conversation, packet.getFrom(), pgpBody, Message.ENCRYPTION_PGP, Message.STATUS_RECIEVED);
30 }
31
32 public static Message parseOtrChat(MessagePacket packet, Account account, XmppConnectionService service) {
33 boolean justStarted = false;
34 boolean properlyAddressed = (packet.getTo().split("/").length == 2) || (account.countPresences() == 1);
35 String[] fromParts = packet.getFrom().split("/");
36 Conversation conversation = service.findOrCreateConversation(account, fromParts[0],false);
37 String body = packet.getBody();
38 if (!conversation.hasValidOtrSession()) {
39 if (properlyAddressed) {
40 Log.d("xmppService","starting new otr session with "+packet.getFrom()+" because no valid otr session has been found");
41 conversation.startOtrSession(service.getApplicationContext(), fromParts[1]);
42 justStarted = true;
43 } else {
44 Log.d("xmppService",account.getJid()+": ignoring otr session with "+fromParts[0]);
45 return null;
46 }
47 } else {
48 String foreignPresence = conversation.getOtrSession().getSessionID().getUserID();
49 if (!foreignPresence.equals(fromParts[1])) {
50 conversation.resetOtrSession();
51 if (properlyAddressed) {
52 Log.d("xmppService","replacing otr session with "+packet.getFrom());
53 conversation.startOtrSession(service.getApplicationContext(), fromParts[1]);
54 justStarted = true;
55 } else {
56 return null;
57 }
58 }
59 }
60 try {
61 Session otrSession = conversation.getOtrSession();
62 SessionStatus before = otrSession
63 .getSessionStatus();
64 body = otrSession.transformReceiving(body);
65 SessionStatus after = otrSession.getSessionStatus();
66 if ((before != after)
67 && (after == SessionStatus.ENCRYPTED)) {
68 Log.d(LOGTAG, "otr session etablished");
69 List<Message> messages = conversation
70 .getMessages();
71 for (int i = 0; i < messages.size(); ++i) {
72 Message msg = messages.get(i);
73 if ((msg.getStatus() == Message.STATUS_UNSEND)
74 && (msg.getEncryption() == Message.ENCRYPTION_OTR)) {
75 MessagePacket outPacket = service.prepareMessagePacket(
76 account, msg, otrSession);
77 msg.setStatus(Message.STATUS_SEND);
78 service.databaseBackend.updateMessage(msg);
79 account.getXmppConnection()
80 .sendMessagePacket(outPacket);
81 }
82 }
83 if (service.convChangedListener!=null) {
84 service.convChangedListener.onConversationListChanged();
85 }
86 } else if ((before != after) && (after == SessionStatus.FINISHED)) {
87 conversation.resetOtrSession();
88 Log.d(LOGTAG,"otr session stoped");
89 }
90 } catch (Exception e) {
91 if (!justStarted) {
92 conversation.resetOtrSession();
93 }
94 return null;
95 }
96
97 //isEmpty is a work around for some weird clients which send emtpty strings over otr
98 if ((body == null)||(body.isEmpty())) {
99 return null;
100 }
101 return new Message(conversation, packet.getFrom(), body, Message.ENCRYPTION_OTR,Message.STATUS_RECIEVED);
102 }
103
104 public static Message parseGroupchat(MessagePacket packet, Account account, XmppConnectionService service) {
105 int status;
106 String[] fromParts = packet.getFrom().split("/");
107 Conversation conversation = service.findOrCreateConversation(account, fromParts[0],true);
108 if (packet.hasChild("subject")) {
109 conversation.getMucOptions().setSubject(packet.findChild("subject").getContent());
110 service.updateConversationInGui();
111 return null;
112 }
113 if ((fromParts.length == 1)) {
114 return null;
115 }
116 String counterPart = fromParts[1];
117 if (counterPart.equals(conversation.getMucOptions().getNick())) {
118 status = Message.STATUS_SEND;
119 } else {
120 status = Message.STATUS_RECIEVED;
121 }
122 return new Message(conversation, counterPart, packet.getBody(), Message.ENCRYPTION_NONE, status);
123 }
124
125 public static Message parseCarbonMessage(MessagePacket packet,
126 Account account, XmppConnectionService service) {
127 // TODO Auto-generated method stub
128 int status;
129 String fullJid;
130 Element forwarded;
131 if (packet.hasChild("received")) {
132 forwarded = packet.findChild("received").findChild(
133 "forwarded");
134 status = Message.STATUS_RECIEVED;
135 } else if (packet.hasChild("sent")) {
136 forwarded = packet.findChild("sent").findChild(
137 "forwarded");
138 status = Message.STATUS_SEND;
139 } else {
140 return null;
141 }
142 Element message = forwarded.findChild("message");
143 if ((message == null) || (!message.hasChild("body")))
144 return null; // either malformed or boring
145 if (status == Message.STATUS_RECIEVED) {
146 fullJid = message.getAttribute("from");
147 } else {
148 fullJid = message.getAttribute("to");
149 }
150 String[] parts = fullJid.split("/");
151 Conversation conversation = service.findOrCreateConversation(account, parts[0],false);
152 return new Message(conversation,fullJid, message.findChild("body").getContent(), Message.ENCRYPTION_NONE,status);
153 }
154
155 public static Message parseError(MessagePacket packet, Account account, XmppConnectionService service) {
156
157 String[] fromParts = packet.getFrom().split("/");
158 Conversation conversation = service.findOrCreateConversation(account, fromParts[0],false);
159 Element error = packet.findChild("error");
160 String errorName = error.getChildren().get(0).getName();
161 String displayError;
162 if (errorName.equals("service-unavailable")) {
163 displayError = "Contact is offline and does not have offline storage";
164 } else {
165 displayError = errorName.replace("-", " ");
166 }
167 return new Message(conversation, packet.getFrom(), displayError, Message.ENCRYPTION_NONE, Message.STATUS_ERROR);
168 }
169
170 public static String getPgpBody(MessagePacket packet) {
171 for(Element child : packet.getChildren()) {
172 if (child.getName().equals("x")&&child.getAttribute("xmlns").equals("jabber:x:encrypted")) {
173 return child.getContent();
174 }
175 }
176 return null;
177 }
178}