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