1package eu.siacs.conversations.generator;
2
3
4import java.util.ArrayList;
5import java.util.List;
6
7import eu.siacs.conversations.entities.Account;
8import eu.siacs.conversations.entities.Conversation;
9import eu.siacs.conversations.services.MessageArchiveService;
10import eu.siacs.conversations.services.XmppConnectionService;
11import eu.siacs.conversations.utils.PhoneHelper;
12import eu.siacs.conversations.utils.Xmlns;
13import eu.siacs.conversations.xml.Element;
14import eu.siacs.conversations.xmpp.forms.Data;
15import eu.siacs.conversations.xmpp.jid.Jid;
16import eu.siacs.conversations.xmpp.pep.Avatar;
17import eu.siacs.conversations.xmpp.stanzas.IqPacket;
18
19public class IqGenerator extends AbstractGenerator {
20
21 public IqGenerator(final XmppConnectionService service) {
22 super(service);
23 }
24
25 public IqPacket discoResponse(final IqPacket request) {
26 final IqPacket packet = new IqPacket(IqPacket.TYPE.RESULT);
27 packet.setId(request.getId());
28 packet.setTo(request.getFrom());
29 final Element query = packet.addChild("query",
30 "http://jabber.org/protocol/disco#info");
31 query.setAttribute("node", request.query().getAttribute("node"));
32 final Element identity = query.addChild("identity");
33 identity.setAttribute("category", "client");
34 identity.setAttribute("type", IDENTITY_TYPE);
35 identity.setAttribute("name", getIdentityName());
36 for (final String feature : getFeatures()) {
37 query.addChild("feature").setAttribute("var", feature);
38 }
39 return packet;
40 }
41
42 public IqPacket versionResponse(final IqPacket request) {
43 final IqPacket packet = request.generateResponse(IqPacket.TYPE.RESULT);
44 Element query = packet.query("jabber:iq:version");
45 query.addChild("name").setContent(IDENTITY_NAME);
46 query.addChild("version").setContent(getIdentityVersion());
47 return packet;
48 }
49
50 protected IqPacket publish(final String node, final Element item) {
51 final IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
52 final Element pubsub = packet.addChild("pubsub",
53 "http://jabber.org/protocol/pubsub");
54 final Element publish = pubsub.addChild("publish");
55 publish.setAttribute("node", node);
56 publish.addChild(item);
57 return packet;
58 }
59
60 protected IqPacket retrieve(String node, Element item) {
61 final IqPacket packet = new IqPacket(IqPacket.TYPE.GET);
62 final Element pubsub = packet.addChild("pubsub",
63 "http://jabber.org/protocol/pubsub");
64 final Element items = pubsub.addChild("items");
65 items.setAttribute("node", node);
66 if (item != null) {
67 items.addChild(item);
68 }
69 return packet;
70 }
71
72 public IqPacket publishAvatar(Avatar avatar) {
73 final Element item = new Element("item");
74 item.setAttribute("id", avatar.sha1sum);
75 final Element data = item.addChild("data", "urn:xmpp:avatar:data");
76 data.setContent(avatar.image);
77 return publish("urn:xmpp:avatar:data", item);
78 }
79
80 public IqPacket publishAvatarMetadata(final Avatar avatar) {
81 final Element item = new Element("item");
82 item.setAttribute("id", avatar.sha1sum);
83 final Element metadata = item
84 .addChild("metadata", "urn:xmpp:avatar:metadata");
85 final Element info = metadata.addChild("info");
86 info.setAttribute("bytes", avatar.size);
87 info.setAttribute("id", avatar.sha1sum);
88 info.setAttribute("height", avatar.height);
89 info.setAttribute("width", avatar.height);
90 info.setAttribute("type", avatar.type);
91 return publish("urn:xmpp:avatar:metadata", item);
92 }
93
94 public IqPacket retrievePepAvatar(final Avatar avatar) {
95 final Element item = new Element("item");
96 item.setAttribute("id", avatar.sha1sum);
97 final IqPacket packet = retrieve("urn:xmpp:avatar:data", item);
98 packet.setTo(avatar.owner);
99 return packet;
100 }
101
102 public IqPacket retrieveVcardAvatar(final Avatar avatar) {
103 final IqPacket packet = new IqPacket(IqPacket.TYPE.GET);
104 packet.setTo(avatar.owner);
105 packet.addChild("vCard","vcard-temp");
106 return packet;
107 }
108
109 public IqPacket retrieveAvatarMetaData(final Jid to) {
110 final IqPacket packet = retrieve("urn:xmpp:avatar:metadata", null);
111 if (to != null) {
112 packet.setTo(to);
113 }
114 return packet;
115 }
116
117 public IqPacket queryMessageArchiveManagement(final MessageArchiveService.Query mam) {
118 final IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
119 final Element query = packet.query("urn:xmpp:mam:0");
120 query.setAttribute("queryid",mam.getQueryId());
121 final Data data = new Data();
122 data.setFormType("urn:xmpp:mam:0");
123 if (mam.muc()) {
124 packet.setTo(mam.getWith());
125 } else if (mam.getWith()!=null) {
126 data.put("with", mam.getWith().toString());
127 }
128 data.put("start",getTimestamp(mam.getStart()));
129 data.put("end",getTimestamp(mam.getEnd()));
130 query.addChild(data);
131 if (mam.getPagingOrder() == MessageArchiveService.PagingOrder.REVERSE) {
132 query.addChild("set", "http://jabber.org/protocol/rsm").addChild("before").setContent(mam.getReference());
133 } else if (mam.getReference() != null) {
134 query.addChild("set", "http://jabber.org/protocol/rsm").addChild("after").setContent(mam.getReference());
135 }
136 return packet;
137 }
138 public IqPacket generateGetBlockList() {
139 final IqPacket iq = new IqPacket(IqPacket.TYPE.GET);
140 iq.addChild("blocklist", Xmlns.BLOCKING);
141
142 return iq;
143 }
144
145 public IqPacket generateSetBlockRequest(final Jid jid) {
146 final IqPacket iq = new IqPacket(IqPacket.TYPE.SET);
147 final Element block = iq.addChild("block", Xmlns.BLOCKING);
148 block.addChild("item").setAttribute("jid", jid.toBareJid().toString());
149 return iq;
150 }
151
152 public IqPacket generateSetUnblockRequest(final Jid jid) {
153 final IqPacket iq = new IqPacket(IqPacket.TYPE.SET);
154 final Element block = iq.addChild("unblock", Xmlns.BLOCKING);
155 block.addChild("item").setAttribute("jid", jid.toBareJid().toString());
156 return iq;
157 }
158
159 public IqPacket generateSetPassword(final Account account, final String newPassword) {
160 final IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
161 packet.setTo(account.getServer());
162 final Element query = packet.addChild("query", Xmlns.REGISTER);
163 final Jid jid = account.getJid();
164 query.addChild("username").setContent(jid.getLocalpart());
165 query.addChild("password").setContent(newPassword);
166 return packet;
167 }
168
169 public IqPacket changeAffiliation(Conversation conference, Jid jid, String affiliation) {
170 List<Jid> jids = new ArrayList<>();
171 jids.add(jid);
172 return changeAffiliation(conference,jids,affiliation);
173 }
174
175 public IqPacket changeAffiliation(Conversation conference, List<Jid> jids, String affiliation) {
176 IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
177 packet.setTo(conference.getJid().toBareJid());
178 packet.setFrom(conference.getAccount().getJid());
179 Element query = packet.query("http://jabber.org/protocol/muc#admin");
180 for(Jid jid : jids) {
181 Element item = query.addChild("item");
182 item.setAttribute("jid", jid.toString());
183 item.setAttribute("affiliation", affiliation);
184 }
185 return packet;
186 }
187
188 public IqPacket changeRole(Conversation conference, String nick, String role) {
189 IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
190 packet.setTo(conference.getJid().toBareJid());
191 packet.setFrom(conference.getAccount().getJid());
192 Element item = packet.query("http://jabber.org/protocol/muc#admin").addChild("item");
193 item.setAttribute("nick", nick);
194 item.setAttribute("role", role);
195 return packet;
196 }
197}