1package eu.siacs.conversations.parser;
2
3import java.util.ArrayList;
4import java.util.List;
5
6import eu.siacs.conversations.crypto.PgpEngine;
7import eu.siacs.conversations.entities.Account;
8import eu.siacs.conversations.entities.Contact;
9import eu.siacs.conversations.entities.Conversation;
10import eu.siacs.conversations.entities.Message;
11import eu.siacs.conversations.entities.MucOptions;
12import eu.siacs.conversations.entities.Presences;
13import eu.siacs.conversations.entities.Presence;
14import eu.siacs.conversations.generator.PresenceGenerator;
15import eu.siacs.conversations.services.XmppConnectionService;
16import eu.siacs.conversations.xml.Element;
17import eu.siacs.conversations.xmpp.OnPresencePacketReceived;
18import eu.siacs.conversations.xmpp.jid.Jid;
19import eu.siacs.conversations.xmpp.pep.Avatar;
20import eu.siacs.conversations.xmpp.stanzas.PresencePacket;
21
22public class PresenceParser extends AbstractParser implements
23 OnPresencePacketReceived {
24
25 public PresenceParser(XmppConnectionService service) {
26 super(service);
27 }
28
29 public void parseConferencePresence(PresencePacket packet, Account account) {
30 final Conversation conversation = packet.getFrom() == null ? null : mXmppConnectionService.find(account, packet.getFrom().toBareJid());
31 if (conversation != null) {
32 final MucOptions mucOptions = conversation.getMucOptions();
33 boolean before = mucOptions.online();
34 int count = mucOptions.getUserCount();
35 final List<MucOptions.User> tileUserBefore = mucOptions.getUsers(5);
36 processConferencePresence(packet, mucOptions);
37 final List<MucOptions.User> tileUserAfter = mucOptions.getUsers(5);
38 if (!tileUserAfter.equals(tileUserBefore)) {
39 mXmppConnectionService.getAvatarService().clear(mucOptions);
40 }
41 if (before != mucOptions.online() || (mucOptions.online() && count != mucOptions.getUserCount())) {
42 mXmppConnectionService.updateConversationUi();
43 } else if (mucOptions.online()) {
44 mXmppConnectionService.updateMucRosterUi();
45 }
46 }
47 }
48
49 private void processConferencePresence(PresencePacket packet, MucOptions mucOptions) {
50 final Jid from = packet.getFrom();
51 if (!from.isBareJid()) {
52 final String type = packet.getAttribute("type");
53 final Element x = packet.findChild("x", "http://jabber.org/protocol/muc#user");
54 Avatar avatar = Avatar.parsePresence(packet.findChild("x", "vcard-temp:x:update"));
55 final List<String> codes = getStatusCodes(x);
56 if (type == null) {
57 if (x != null) {
58 Element item = x.findChild("item");
59 if (item != null && !from.isBareJid()) {
60 MucOptions.User user = new MucOptions.User(mucOptions,from);
61 user.setAffiliation(item.getAttribute("affiliation"));
62 user.setRole(item.getAttribute("role"));
63 user.setJid(item.getAttributeAsJid("jid"));
64 if (codes.contains(MucOptions.STATUS_CODE_SELF_PRESENCE) || packet.getFrom().equals(mucOptions.getConversation().getJid())) {
65 mucOptions.setError(MucOptions.ERROR_NO_ERROR);
66 mucOptions.setSelf(user);
67 if (mucOptions.mNickChangingInProgress) {
68 if (mucOptions.onRenameListener != null) {
69 mucOptions.onRenameListener.onSuccess();
70 }
71 mucOptions.mNickChangingInProgress = false;
72 }
73 } else {
74 mucOptions.addUser(user);
75 }
76 if (mXmppConnectionService.getPgpEngine() != null) {
77 Element signed = packet.findChild("x", "jabber:x:signed");
78 if (signed != null) {
79 Element status = packet.findChild("status");
80 String msg = status == null ? "" : status.getContent();
81 long keyId = mXmppConnectionService.getPgpEngine().fetchKeyId(mucOptions.getAccount(), msg, signed.getContent());
82 if (keyId != 0) {
83 user.setPgpKeyId(keyId);
84 }
85 }
86 }
87 if (avatar != null) {
88 avatar.owner = from;
89 if (mXmppConnectionService.getFileBackend().isAvatarCached(avatar)) {
90 if (user.setAvatar(avatar)) {
91 mXmppConnectionService.getAvatarService().clear(user);
92 }
93 } else {
94 mXmppConnectionService.fetchAvatar(mucOptions.getAccount(), avatar);
95 }
96 }
97 }
98 }
99 } else if (type.equals("unavailable")) {
100 if (codes.contains(MucOptions.STATUS_CODE_SELF_PRESENCE) ||
101 packet.getFrom().equals(mucOptions.getConversation().getJid())) {
102 if (codes.contains(MucOptions.STATUS_CODE_CHANGED_NICK)) {
103 mucOptions.mNickChangingInProgress = true;
104 } else if (codes.contains(MucOptions.STATUS_CODE_KICKED)) {
105 mucOptions.setError(MucOptions.KICKED_FROM_ROOM);
106 } else if (codes.contains(MucOptions.STATUS_CODE_BANNED)) {
107 mucOptions.setError(MucOptions.ERROR_BANNED);
108 } else if (codes.contains(MucOptions.STATUS_CODE_LOST_MEMBERSHIP)) {
109 mucOptions.setError(MucOptions.ERROR_MEMBERS_ONLY);
110 } else {
111 mucOptions.setError(MucOptions.ERROR_UNKNOWN);
112 }
113 } else if (!from.isBareJid()){
114 MucOptions.User user = mucOptions.deleteUser(from.getResourcepart());
115 if (user != null) {
116 mXmppConnectionService.getAvatarService().clear(user);
117 }
118 }
119 } else if (type.equals("error")) {
120 Element error = packet.findChild("error");
121 if (error != null && error.hasChild("conflict")) {
122 if (mucOptions.online()) {
123 if (mucOptions.onRenameListener != null) {
124 mucOptions.onRenameListener.onFailure();
125 }
126 } else {
127 mucOptions.setError(MucOptions.ERROR_NICK_IN_USE);
128 }
129 } else if (error != null && error.hasChild("not-authorized")) {
130 mucOptions.setError(MucOptions.ERROR_PASSWORD_REQUIRED);
131 } else if (error != null && error.hasChild("forbidden")) {
132 mucOptions.setError(MucOptions.ERROR_BANNED);
133 } else if (error != null && error.hasChild("registration-required")) {
134 mucOptions.setError(MucOptions.ERROR_MEMBERS_ONLY);
135 }
136 }
137 }
138 }
139
140 private static List<String> getStatusCodes(Element x) {
141 List<String> codes = new ArrayList<>();
142 if (x != null) {
143 for (Element child : x.getChildren()) {
144 if (child.getName().equals("status")) {
145 String code = child.getAttribute("code");
146 if (code != null) {
147 codes.add(code);
148 }
149 }
150 }
151 }
152 return codes;
153 }
154
155 public void parseContactPresence(final PresencePacket packet, final Account account) {
156 final PresenceGenerator mPresenceGenerator = mXmppConnectionService.getPresenceGenerator();
157 final Jid from = packet.getFrom();
158 if (from == null) {
159 return;
160 }
161 final String type = packet.getAttribute("type");
162 final Contact contact = account.getRoster().getContact(from);
163 if (type == null) {
164 String presence = from.isBareJid() ? "" : from.getResourcepart();
165 contact.setPresenceName(packet.findChildContent("nick", "http://jabber.org/protocol/nick"));
166 Avatar avatar = Avatar.parsePresence(packet.findChild("x", "vcard-temp:x:update"));
167 if (avatar != null && !contact.isSelf()) {
168 avatar.owner = from.toBareJid();
169 if (mXmppConnectionService.getFileBackend().isAvatarCached(avatar)) {
170 if (contact.setAvatar(avatar)) {
171 mXmppConnectionService.getAvatarService().clear(contact);
172 mXmppConnectionService.updateConversationUi();
173 mXmppConnectionService.updateRosterUi();
174 }
175 } else {
176 mXmppConnectionService.fetchAvatar(account, avatar);
177 }
178 }
179 int sizeBefore = contact.getPresences().size();
180 contact.updatePresence(presence, new Presence(packet.findChild("show")));
181 PgpEngine pgp = mXmppConnectionService.getPgpEngine();
182 Element x = packet.findChild("x", "jabber:x:signed");
183 if (pgp != null && x != null) {
184 Element status = packet.findChild("status");
185 String msg = status != null ? status.getContent() : "";
186 contact.setPgpKeyId(pgp.fetchKeyId(account, msg, x.getContent()));
187 }
188 boolean online = sizeBefore < contact.getPresences().size();
189 updateLastseen(packet, account, false);
190 mXmppConnectionService.onContactStatusChanged.onContactStatusChanged(contact, online);
191 } else if (type.equals("unavailable")) {
192 if (from.isBareJid()) {
193 contact.clearPresences();
194 } else {
195 contact.removePresence(from.getResourcepart());
196 }
197 mXmppConnectionService.onContactStatusChanged.onContactStatusChanged(contact, false);
198 } else if (type.equals("subscribe")) {
199 if (contact.getOption(Contact.Options.PREEMPTIVE_GRANT)) {
200 mXmppConnectionService.sendPresencePacket(account,
201 mPresenceGenerator.sendPresenceUpdatesTo(contact));
202 } else {
203 contact.setOption(Contact.Options.PENDING_SUBSCRIPTION_REQUEST);
204 final Conversation conversation = mXmppConnectionService.findOrCreateConversation(
205 account, contact.getJid().toBareJid(), false);
206 final String statusMessage = packet.findChildContent("status");
207 if (statusMessage != null
208 && !statusMessage.isEmpty()
209 && conversation.countMessages() == 0) {
210 conversation.add(new Message(
211 conversation,
212 statusMessage,
213 Message.ENCRYPTION_NONE,
214 Message.STATUS_RECEIVED
215 ));
216 }
217 }
218 }
219 mXmppConnectionService.updateRosterUi();
220 }
221
222 @Override
223 public void onPresencePacketReceived(Account account, PresencePacket packet) {
224 if (packet.hasChild("x", "http://jabber.org/protocol/muc#user")) {
225 this.parseConferencePresence(packet, account);
226 } else if (packet.hasChild("x", "http://jabber.org/protocol/muc")) {
227 this.parseConferencePresence(packet, account);
228 } else {
229 this.parseContactPresence(packet, account);
230 }
231 }
232
233}