1package eu.siacs.conversations.parser;
2
3import java.util.ArrayList;
4
5import eu.siacs.conversations.crypto.PgpEngine;
6import eu.siacs.conversations.entities.Account;
7import eu.siacs.conversations.entities.Contact;
8import eu.siacs.conversations.entities.Conversation;
9import eu.siacs.conversations.entities.MucOptions;
10import eu.siacs.conversations.entities.Presences;
11import eu.siacs.conversations.generator.PresenceGenerator;
12import eu.siacs.conversations.services.XmppConnectionService;
13import eu.siacs.conversations.xml.Element;
14import eu.siacs.conversations.xmpp.OnPresencePacketReceived;
15import eu.siacs.conversations.xmpp.jid.Jid;
16import eu.siacs.conversations.xmpp.pep.Avatar;
17import eu.siacs.conversations.xmpp.stanzas.PresencePacket;
18
19public class PresenceParser extends AbstractParser implements
20 OnPresencePacketReceived {
21
22 public PresenceParser(XmppConnectionService service) {
23 super(service);
24 }
25
26 public void parseConferencePresence(PresencePacket packet, Account account) {
27 PgpEngine mPgpEngine = mXmppConnectionService.getPgpEngine();
28 final Conversation conversation = packet.getFrom() == null ? null : mXmppConnectionService.find(account, packet.getFrom().toBareJid());
29 if (conversation != null) {
30 final MucOptions mucOptions = conversation.getMucOptions();
31 boolean before = mucOptions.online();
32 int count = mucOptions.getUsers().size();
33 final ArrayList<MucOptions.User> tileUserBefore = new ArrayList<>(mucOptions.getUsers().subList(0,Math.min(mucOptions.getUsers().size(),5)));
34 mucOptions.processPacket(packet, mPgpEngine);
35 final ArrayList<MucOptions.User> tileUserAfter = new ArrayList<>(mucOptions.getUsers().subList(0,Math.min(mucOptions.getUsers().size(),5)));
36 if (!tileUserAfter.equals(tileUserBefore)) {
37 mXmppConnectionService.getAvatarService().clear(conversation);
38 }
39 if (before != mucOptions.online() || (mucOptions.online() && count != mucOptions.getUsers().size())) {
40 mXmppConnectionService.updateConversationUi();
41 } else if (mucOptions.online()) {
42 mXmppConnectionService.updateMucRosterUi();
43 }
44 }
45 }
46
47 public void parseContactPresence(PresencePacket packet, Account account) {
48 PresenceGenerator mPresenceGenerator = mXmppConnectionService
49 .getPresenceGenerator();
50 if (packet.getFrom() == null) {
51 return;
52 }
53 final Jid from = packet.getFrom();
54 String type = packet.getAttribute("type");
55 Contact contact = account.getRoster().getContact(packet.getFrom());
56 if (type == null) {
57 String presence;
58 if (!from.isBareJid()) {
59 presence = from.getResourcepart();
60 } else {
61 presence = "";
62 }
63 int sizeBefore = contact.getPresences().size();
64 contact.updatePresence(presence,
65 Presences.parseShow(packet.findChild("show")));
66 PgpEngine pgp = mXmppConnectionService.getPgpEngine();
67 if (pgp != null) {
68 Element x = packet.findChild("x", "jabber:x:signed");
69 if (x != null) {
70 Element status = packet.findChild("status");
71 String msg;
72 if (status != null) {
73 msg = status.getContent();
74 } else {
75 msg = "";
76 }
77 contact.setPgpKeyId(pgp.fetchKeyId(account, msg,
78 x.getContent()));
79 }
80 }
81 boolean online = sizeBefore < contact.getPresences().size();
82 updateLastseen(packet, account, false);
83 mXmppConnectionService.onContactStatusChanged.onContactStatusChanged(contact, online);
84 } else if (type.equals("unavailable")) {
85 if (from.isBareJid()) {
86 contact.clearPresences();
87 } else {
88 contact.removePresence(from.getResourcepart());
89 }
90 mXmppConnectionService.onContactStatusChanged
91 .onContactStatusChanged(contact, false);
92 } else if (type.equals("subscribe")) {
93 if (contact.getOption(Contact.Options.PREEMPTIVE_GRANT)) {
94 mXmppConnectionService.sendPresencePacket(account,
95 mPresenceGenerator.sendPresenceUpdatesTo(contact));
96 } else {
97 contact.setOption(Contact.Options.PENDING_SUBSCRIPTION_REQUEST);
98 }
99 }
100 Element nick = packet.findChild("nick",
101 "http://jabber.org/protocol/nick");
102 if (nick != null) {
103 contact.setPresenceName(nick.getContent());
104 }
105 Element x = packet.findChild("x","vcard-temp:x:update");
106 Avatar avatar = Avatar.parsePresence(x);
107 if (avatar != null && !contact.isSelf()) {
108 avatar.owner = from.toBareJid();
109 if (mXmppConnectionService.getFileBackend().isAvatarCached(avatar)) {
110 if (contact.setAvatar(avatar)) {
111 mXmppConnectionService.getAvatarService().clear(contact);
112 mXmppConnectionService.updateConversationUi();
113 mXmppConnectionService.updateRosterUi();
114 }
115 } else {
116 mXmppConnectionService.fetchAvatar(account,avatar);
117 }
118 }
119 mXmppConnectionService.updateRosterUi();
120 }
121
122 @Override
123 public void onPresencePacketReceived(Account account, PresencePacket packet) {
124 if (packet.hasChild("x", "http://jabber.org/protocol/muc#user")) {
125 this.parseConferencePresence(packet, account);
126 } else if (packet.hasChild("x", "http://jabber.org/protocol/muc")) {
127 this.parseConferencePresence(packet, account);
128 } else {
129 this.parseContactPresence(packet, account);
130 }
131 }
132
133}