1package eu.siacs.conversations.parser;
2
3import android.util.Log;
4import androidx.annotation.NonNull;
5import com.google.common.base.Strings;
6import com.google.common.util.concurrent.FutureCallback;
7import com.google.common.util.concurrent.Futures;
8import com.google.common.util.concurrent.ListenableFuture;
9import com.google.common.util.concurrent.MoreExecutors;
10import eu.siacs.conversations.Config;
11import eu.siacs.conversations.crypto.PgpEngine;
12import eu.siacs.conversations.crypto.axolotl.AxolotlService;
13import eu.siacs.conversations.entities.Account;
14import eu.siacs.conversations.entities.Contact;
15import eu.siacs.conversations.entities.Conversation;
16import eu.siacs.conversations.entities.Message;
17import eu.siacs.conversations.entities.MucOptions;
18import eu.siacs.conversations.generator.IqGenerator;
19import eu.siacs.conversations.generator.PresenceGenerator;
20import eu.siacs.conversations.services.XmppConnectionService;
21import eu.siacs.conversations.utils.XmppUri;
22import eu.siacs.conversations.xml.Element;
23import eu.siacs.conversations.xml.Namespace;
24import eu.siacs.conversations.xmpp.Jid;
25import eu.siacs.conversations.xmpp.manager.DiscoManager;
26import eu.siacs.conversations.xmpp.pep.Avatar;
27import im.conversations.android.xmpp.Entity;
28import im.conversations.android.xmpp.model.occupant.OccupantId;
29import java.util.ArrayList;
30import java.util.List;
31import java.util.concurrent.TimeoutException;
32import java.util.function.Consumer;
33import org.openintents.openpgp.util.OpenPgpUtils;
34
35public class PresenceParser extends AbstractParser
36 implements Consumer<im.conversations.android.xmpp.model.stanza.Presence> {
37
38 public PresenceParser(final XmppConnectionService service, final Account account) {
39 super(service, account);
40 }
41
42 public void parseConferencePresence(
43 final im.conversations.android.xmpp.model.stanza.Presence packet, Account account) {
44 final Conversation conversation =
45 packet.getFrom() == null
46 ? null
47 : mXmppConnectionService.find(account, packet.getFrom().asBareJid());
48 if (conversation == null) {
49 return;
50 }
51 final MucOptions mucOptions = conversation.getMucOptions();
52 boolean before = mucOptions.online();
53 int count = mucOptions.getUserCount();
54 final List<MucOptions.User> tileUserBefore = mucOptions.getUsers(5);
55 processConferencePresence(packet, conversation);
56 final List<MucOptions.User> tileUserAfter = mucOptions.getUsers(5);
57 if (Strings.isNullOrEmpty(mucOptions.getAvatar())
58 && !tileUserAfter.equals(tileUserBefore)) {
59 mXmppConnectionService.getAvatarService().clear(mucOptions);
60 }
61 if (before != mucOptions.online()
62 || (mucOptions.online() && count != mucOptions.getUserCount())) {
63 mXmppConnectionService.updateConversationUi();
64 } else if (mucOptions.online()) {
65 mXmppConnectionService.updateMucRosterUi();
66 }
67 }
68
69 private void processConferencePresence(
70 final im.conversations.android.xmpp.model.stanza.Presence packet,
71 Conversation conversation) {
72 final Account account = conversation.getAccount();
73 final MucOptions mucOptions = conversation.getMucOptions();
74 final Jid jid = conversation.getAccount().getJid();
75 final Jid from = packet.getFrom();
76 if (!from.isBareJid()) {
77 final String type = packet.getAttribute("type");
78 final Element x = packet.findChild("x", Namespace.MUC_USER);
79 final Element nick = packet.findChild("nick", Namespace.NICK);
80 Element hats = packet.findChild("hats", "urn:xmpp:hats:0");
81 if (hats == null) {
82 hats = packet.findChild("hats", "xmpp:prosody.im/protocol/hats:1");
83 }
84 if (hats == null) hats = new Element("hats", "urn:xmpp:hats:0");
85 final Element occupantIdEl = packet.findChild("occupant-id", "urn:xmpp:occupant-id:0");
86 Avatar avatar = Avatar.parsePresence(packet.findChild("x", "vcard-temp:x:update"));
87 final List<String> codes = getStatusCodes(x);
88 if (type == null) {
89 if (x != null) {
90 Element item = x.findChild("item");
91 if (item != null && !from.isBareJid()) {
92 mucOptions.setError(MucOptions.Error.NONE);
93 final MucOptions.User user = parseItem(conversation, item, from, occupantIdEl, nick == null ? null : nick.getContent(), hats);
94 final var occupant = packet.getOnlyExtension(OccupantId.class);
95 final String occupantId =
96 mucOptions.occupantId() && occupant != null
97 ? occupant.getId()
98 : null;
99 user.setOccupantId(occupantId);
100 if (codes.contains(MucOptions.STATUS_CODE_SELF_PRESENCE)
101 || (codes.contains(MucOptions.STATUS_CODE_ROOM_CREATED)
102 && jid.equals(
103 Jid.Invalid.getNullForInvalid(
104 item.getAttributeAsJid("jid"))))) {
105 Log.d(
106 Config.LOGTAG,
107 account.getJid().asBareJid()
108 + ": got self-presence from "
109 + user.getFullJid()
110 + ". occupant-id="
111 + occupantId);
112 if (mucOptions.setOnline()) {
113 mXmppConnectionService.getAvatarService().clear(mucOptions);
114 }
115 final var current = mucOptions.getSelf().getFullJid();
116 if (mucOptions.setSelf(user)) {
117 Log.d(Config.LOGTAG,"role or affiliation changed");
118 mXmppConnectionService.databaseBackend.updateConversation(conversation);
119 }
120 final var modified =
121 current == null || !current.equals(user.getFullJid());
122 mXmppConnectionService.persistSelfNick(user, modified);
123 invokeRenameListener(mucOptions, true);
124 }
125 boolean isNew = mucOptions.updateUser(user);
126 final AxolotlService axolotlService =
127 conversation.getAccount().getAxolotlService();
128 Contact contact = user.getContact();
129 if (isNew
130 && user.getRealJid() != null
131 && mucOptions.isPrivateAndNonAnonymous()
132 && (contact == null || !contact.mutualPresenceSubscription())
133 && axolotlService.hasEmptyDeviceList(user.getRealJid())) {
134 axolotlService.fetchDeviceIds(user.getRealJid());
135 }
136 if (codes.contains(MucOptions.STATUS_CODE_ROOM_CREATED)
137 && mucOptions.autoPushConfiguration()) {
138 Log.d(
139 Config.LOGTAG,
140 account.getJid().asBareJid()
141 + ": room '"
142 + mucOptions.getConversation().getJid().asBareJid()
143 + "' created. pushing default configuration");
144 mXmppConnectionService.pushConferenceConfiguration(
145 mucOptions.getConversation(),
146 IqGenerator.defaultChannelConfiguration(),
147 null);
148 }
149 if (mXmppConnectionService.getPgpEngine() != null) {
150 Element signed = packet.findChild("x", "jabber:x:signed");
151 if (signed != null) {
152 Element status = packet.findChild("status");
153 String msg = status == null ? "" : status.getContent();
154 long keyId =
155 mXmppConnectionService
156 .getPgpEngine()
157 .fetchKeyId(
158 mucOptions.getAccount(),
159 msg,
160 signed.getContent());
161 if (keyId != 0) {
162 user.setPgpKeyId(keyId);
163 }
164 }
165 }
166 if (avatar != null) {
167 avatar.owner = from;
168 if (mXmppConnectionService.getFileBackend().isAvatarCached(avatar)) {
169 if (user.setAvatar(avatar)) {
170 mXmppConnectionService.getAvatarService().clear(user);
171 }
172 if (user.getRealJid() != null) {
173 final Contact c =
174 conversation
175 .getAccount()
176 .getRoster()
177 .getContact(user.getRealJid());
178 if (c.setAvatar(avatar)) {
179 mXmppConnectionService.syncRoster(
180 conversation.getAccount());
181 mXmppConnectionService.getAvatarService().clear(c);
182 }
183 mXmppConnectionService.updateRosterUi(XmppConnectionService.UpdateRosterReason.AVATAR);
184 }
185 } else if (mXmppConnectionService.isDataSaverDisabled()) {
186 mXmppConnectionService.fetchAvatar(mucOptions.getAccount(), avatar);
187 }
188 }
189 }
190 }
191 } else if (type.equals("unavailable")) {
192 final boolean fullJidMatches = from.equals(mucOptions.getSelf().getFullJid());
193 if (x.hasChild("destroy") && fullJidMatches) {
194 Element destroy = x.findChild("destroy");
195 final Jid alternate =
196 destroy == null
197 ? null
198 : Jid.Invalid.getNullForInvalid(
199 destroy.getAttributeAsJid("jid"));
200 mucOptions.setError(MucOptions.Error.DESTROYED);
201 if (alternate != null) {
202 Log.d(
203 Config.LOGTAG,
204 account.getJid().asBareJid()
205 + ": muc destroyed. alternate location "
206 + alternate);
207 }
208 } else if (codes.contains(MucOptions.STATUS_CODE_SHUTDOWN) && fullJidMatches) {
209 mucOptions.setError(MucOptions.Error.SHUTDOWN);
210 } else if (codes.contains(MucOptions.STATUS_CODE_SELF_PRESENCE)) {
211 if (codes.contains(MucOptions.STATUS_CODE_TECHNICAL_REASONS)) {
212 final boolean wasOnline = mucOptions.online();
213 mucOptions.setError(MucOptions.Error.TECHNICAL_PROBLEMS);
214 Log.d(
215 Config.LOGTAG,
216 account.getJid().asBareJid()
217 + ": received status code 333 in room "
218 + mucOptions.getConversation().getJid().asBareJid()
219 + " online="
220 + wasOnline);
221 if (wasOnline) {
222 mXmppConnectionService.mucSelfPingAndRejoin(conversation);
223 }
224 } else if (codes.contains(MucOptions.STATUS_CODE_KICKED)) {
225 mucOptions.setError(MucOptions.Error.KICKED);
226 } else if (codes.contains(MucOptions.STATUS_CODE_BANNED)) {
227 mucOptions.setError(MucOptions.Error.BANNED);
228 } else if (codes.contains(MucOptions.STATUS_CODE_LOST_MEMBERSHIP)) {
229 mucOptions.setError(MucOptions.Error.MEMBERS_ONLY);
230 } else if (codes.contains(MucOptions.STATUS_CODE_AFFILIATION_CHANGE)) {
231 mucOptions.setError(MucOptions.Error.MEMBERS_ONLY);
232 } else if (codes.contains(MucOptions.STATUS_CODE_SHUTDOWN)) {
233 mucOptions.setError(MucOptions.Error.SHUTDOWN);
234 } else if (!codes.contains(MucOptions.STATUS_CODE_CHANGED_NICK)) {
235 mucOptions.setError(MucOptions.Error.UNKNOWN);
236 Log.d(Config.LOGTAG, "unknown error in conference: " + packet);
237 }
238 } else if (!from.isBareJid()) {
239 Element item = x.findChild("item");
240 if (item != null) {
241 mucOptions.updateUser(parseItem(conversation, item, from, occupantIdEl, nick == null ? null : nick.getContent(), hats));
242 }
243 MucOptions.User user = mucOptions.deleteUser(from);
244 if (user != null && occupantIdEl == null) {
245 mXmppConnectionService.getAvatarService().clear(user);
246 }
247 }
248 } else if (type.equals("error")) {
249 final Element error = packet.findChild("error");
250 if (error == null) {
251 return;
252 }
253 if (error.hasChild("conflict")) {
254 if (mucOptions.online()) {
255 invokeRenameListener(mucOptions, false);
256 } else {
257 mucOptions.setError(MucOptions.Error.NICK_IN_USE);
258 }
259 } else if (error.hasChild("not-authorized")) {
260 mucOptions.setError(MucOptions.Error.PASSWORD_REQUIRED);
261 } else if (error.hasChild("forbidden")) {
262 mucOptions.setError(MucOptions.Error.BANNED);
263 } else if (error.hasChild("registration-required")) {
264 mucOptions.setError(MucOptions.Error.MEMBERS_ONLY);
265 } else if (error.hasChild("resource-constraint")) {
266 mucOptions.setError(MucOptions.Error.RESOURCE_CONSTRAINT);
267 } else if (error.hasChild("remote-server-timeout")) {
268 mucOptions.setError(MucOptions.Error.REMOTE_SERVER_TIMEOUT);
269 } else if (error.hasChild("gone")) {
270 final String gone = error.findChildContent("gone");
271 final Jid alternate;
272 if (gone != null) {
273 final XmppUri xmppUri = new XmppUri(gone);
274 if (xmppUri.isValidJid()) {
275 alternate = xmppUri.getJid();
276 } else {
277 alternate = null;
278 }
279 } else {
280 alternate = null;
281 }
282 mucOptions.setError(MucOptions.Error.DESTROYED);
283 if (alternate != null) {
284 Log.d(
285 Config.LOGTAG,
286 conversation.getAccount().getJid().asBareJid()
287 + ": muc destroyed. alternate location "
288 + alternate);
289 }
290 } else {
291 final String text = error.findChildContent("text");
292 if (text != null && text.contains("attribute 'to'")) {
293 if (mucOptions.online()) {
294 invokeRenameListener(mucOptions, false);
295 } else {
296 mucOptions.setError(MucOptions.Error.INVALID_NICK);
297 }
298 } else {
299 mucOptions.setError(MucOptions.Error.UNKNOWN);
300 Log.d(Config.LOGTAG, "unknown error in conference: " + packet);
301 }
302 }
303 }
304 }
305 }
306
307 private static void invokeRenameListener(final MucOptions options, boolean success) {
308 if (options.onRenameListener != null) {
309 if (success) {
310 options.onRenameListener.onSuccess();
311 } else {
312 options.onRenameListener.onFailure();
313 }
314 options.onRenameListener = null;
315 }
316 }
317
318 private static List<String> getStatusCodes(Element x) {
319 List<String> codes = new ArrayList<>();
320 if (x != null) {
321 for (Element child : x.getChildren()) {
322 if (child.getName().equals("status")) {
323 String code = child.getAttribute("code");
324 if (code != null) {
325 codes.add(code);
326 }
327 }
328 }
329 }
330 return codes;
331 }
332
333 private void parseContactPresence(
334 final im.conversations.android.xmpp.model.stanza.Presence packet,
335 final Account account) {
336 final PresenceGenerator mPresenceGenerator = mXmppConnectionService.getPresenceGenerator();
337 final Jid from = packet.getFrom();
338 if (from == null || from.equals(account.getJid())) {
339 return;
340 }
341 final String type = packet.getAttribute("type");
342 final Contact contact = account.getRoster().getContact(from);
343 if (type == null) {
344 final String resource = from.isBareJid() ? "" : from.getResource();
345 final Avatar avatar =
346 Avatar.parsePresence(packet.findChild("x", "vcard-temp:x:update"));
347 if (avatar != null && (!contact.isSelf() || account.getAvatar() == null)) {
348 avatar.owner = from.asBareJid();
349 if (mXmppConnectionService.getFileBackend().isAvatarCached(avatar)) {
350 if (avatar.owner.equals(account.getJid().asBareJid())) {
351 account.setAvatar(avatar.getFilename());
352 mXmppConnectionService.databaseBackend.updateAccount(account);
353 mXmppConnectionService.getAvatarService().clear(account);
354 mXmppConnectionService.updateConversationUi();
355 mXmppConnectionService.updateAccountUi();
356 } else {
357 if (contact.setAvatar(avatar)) {
358 mXmppConnectionService.syncRoster(account);
359 mXmppConnectionService.getAvatarService().clear(contact);
360 mXmppConnectionService.updateConversationUi();
361 mXmppConnectionService.updateRosterUi(XmppConnectionService.UpdateRosterReason.AVATAR);
362 }
363 }
364 } else if (mXmppConnectionService.isDataSaverDisabled()) {
365 mXmppConnectionService.fetchAvatar(account, avatar);
366 }
367 }
368
369 if (mXmppConnectionService.isMuc(account, from)) {
370 return;
371 }
372
373 final int sizeBefore = contact.getPresences().size();
374
375 contact.updatePresence(resource, packet);
376
377 final var nodeHash = packet.getCapabilities();
378 final var connection = account.getXmppConnection();
379 if (nodeHash != null && connection != null) {
380 final var discoFuture =
381 connection
382 .getManager(DiscoManager.class)
383 .infoOrCache(Entity.presence(from), nodeHash.node, nodeHash.hash);
384
385 logDiscoFailure(from, discoFuture);
386 }
387
388 final Element idle = packet.findChild("idle", Namespace.IDLE);
389 if (idle != null) {
390 try {
391 final String since = idle.getAttribute("since");
392 contact.setLastseen(AbstractParser.parseTimestamp(since));
393 contact.flagInactive();
394 } catch (Throwable throwable) {
395 if (contact.setLastseen(AbstractParser.parseTimestamp(packet))) {
396 contact.flagActive();
397 }
398 }
399 } else {
400 if (contact.setLastseen(AbstractParser.parseTimestamp(packet))) {
401 contact.flagActive();
402 }
403 }
404
405 final PgpEngine pgp = mXmppConnectionService.getPgpEngine();
406 final Element x = packet.findChild("x", "jabber:x:signed");
407 if (pgp != null && x != null) {
408 final String status = packet.findChildContent("status");
409 final long keyId = pgp.fetchKeyId(account, status, x.getContent());
410 if (keyId != 0 && contact.setPgpKeyId(keyId)) {
411 Log.d(
412 Config.LOGTAG,
413 account.getJid().asBareJid()
414 + ": found OpenPGP key id for "
415 + contact.getJid()
416 + " "
417 + OpenPgpUtils.convertKeyIdToHex(keyId));
418 mXmppConnectionService.syncRoster(account);
419 }
420 }
421 boolean online = sizeBefore < contact.getPresences().size();
422 mXmppConnectionService.onContactStatusChanged.onContactStatusChanged(contact, online);
423 } else if (type.equals("unavailable")) {
424 if (contact.setLastseen(AbstractParser.parseTimestamp(packet, 0L, true))) {
425 contact.flagInactive();
426 }
427 if (from.isBareJid()) {
428 contact.clearPresences();
429 } else {
430 contact.removePresence(from.getResource());
431 }
432 if (contact.getShownStatus()
433 == im.conversations.android.xmpp.model.stanza.Presence.Availability.OFFLINE) {
434 contact.flagInactive();
435 }
436 mXmppConnectionService.onContactStatusChanged.onContactStatusChanged(contact, false);
437 } else if (type.equals("subscribe")) {
438 if (contact.isBlocked()) {
439 Log.d(
440 Config.LOGTAG,
441 account.getJid().asBareJid()
442 + ": ignoring 'subscribe' presence from blocked "
443 + from);
444 return;
445 }
446 if (contact.setPresenceName(packet.findChildContent("nick", Namespace.NICK))) {
447 mXmppConnectionService.syncRoster(account);
448 mXmppConnectionService.getAvatarService().clear(contact);
449 }
450 if (contact.getOption(Contact.Options.PREEMPTIVE_GRANT)) {
451 mXmppConnectionService.sendPresencePacket(
452 account, mPresenceGenerator.sendPresenceUpdatesTo(contact));
453 } else {
454 contact.setOption(Contact.Options.PENDING_SUBSCRIPTION_REQUEST);
455 final Conversation conversation =
456 mXmppConnectionService.findOrCreateConversation(
457 account, contact.getJid().asBareJid(), false, false);
458 final String statusMessage = packet.findChildContent("status");
459 if (statusMessage != null
460 && !statusMessage.isEmpty()
461 && conversation.countMessages() == 0) {
462 conversation.add(
463 new Message(
464 conversation,
465 statusMessage,
466 Message.ENCRYPTION_NONE,
467 Message.STATUS_RECEIVED));
468 }
469 }
470 }
471 mXmppConnectionService.updateRosterUi(XmppConnectionService.UpdateRosterReason.PRESENCE, contact);
472 }
473
474 private static void logDiscoFailure(final Jid from, ListenableFuture<Void> discoFuture) {
475 Futures.addCallback(
476 discoFuture,
477 new FutureCallback<>() {
478 @Override
479 public void onSuccess(Void result) {}
480
481 @Override
482 public void onFailure(@NonNull Throwable throwable) {
483 if (throwable instanceof TimeoutException) {
484 return;
485 }
486 Log.d(Config.LOGTAG, "could not retrieve disco from " + from, throwable);
487 }
488 },
489 MoreExecutors.directExecutor());
490 }
491
492 @Override
493 public void accept(final im.conversations.android.xmpp.model.stanza.Presence packet) {
494 if (packet.hasChild("x", Namespace.MUC_USER)) {
495 this.parseConferencePresence(packet, account);
496 } else if (packet.hasChild("x", "http://jabber.org/protocol/muc")) {
497 this.parseConferencePresence(packet, account);
498 } else if ("error".equals(packet.getAttribute("type"))
499 && mXmppConnectionService.isMuc(account, packet.getFrom())) {
500 this.parseConferencePresence(packet, account);
501 } else {
502 this.parseContactPresence(packet, account);
503 }
504 }
505}