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 retrieveAvatar(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 retrieveAvatarMetaData(final Jid to) {
103 final IqPacket packet = retrieve("urn:xmpp:avatar:metadata", null);
104 if (to != null) {
105 packet.setTo(to);
106 }
107 return packet;
108 }
109
110 public IqPacket queryMessageArchiveManagement(final MessageArchiveService.Query mam) {
111 final IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
112 final Element query = packet.query("urn:xmpp:mam:0");
113 query.setAttribute("queryid",mam.getQueryId());
114 final Data data = new Data();
115 data.setFormType("urn:xmpp:mam:0");
116 if (mam.muc()) {
117 packet.setTo(mam.getWith());
118 } else if (mam.getWith()!=null) {
119 data.put("with", mam.getWith().toString());
120 }
121 data.put("start",getTimestamp(mam.getStart()));
122 data.put("end",getTimestamp(mam.getEnd()));
123 query.addChild(data);
124 if (mam.getPagingOrder() == MessageArchiveService.PagingOrder.REVERSE) {
125 query.addChild("set", "http://jabber.org/protocol/rsm").addChild("before").setContent(mam.getReference());
126 } else if (mam.getReference() != null) {
127 query.addChild("set", "http://jabber.org/protocol/rsm").addChild("after").setContent(mam.getReference());
128 }
129 return packet;
130 }
131 public IqPacket generateGetBlockList() {
132 final IqPacket iq = new IqPacket(IqPacket.TYPE.GET);
133 iq.addChild("blocklist", Xmlns.BLOCKING);
134
135 return iq;
136 }
137
138 public IqPacket generateSetBlockRequest(final Jid jid) {
139 final IqPacket iq = new IqPacket(IqPacket.TYPE.SET);
140 final Element block = iq.addChild("block", Xmlns.BLOCKING);
141 block.addChild("item").setAttribute("jid", jid.toBareJid().toString());
142 return iq;
143 }
144
145 public IqPacket generateSetUnblockRequest(final Jid jid) {
146 final IqPacket iq = new IqPacket(IqPacket.TYPE.SET);
147 final Element block = iq.addChild("unblock", Xmlns.BLOCKING);
148 block.addChild("item").setAttribute("jid", jid.toBareJid().toString());
149 return iq;
150 }
151
152 public IqPacket generateSetPassword(final Account account, final String newPassword) {
153 final IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
154 packet.setTo(account.getServer());
155 final Element query = packet.addChild("query", Xmlns.REGISTER);
156 final Jid jid = account.getJid();
157 query.addChild("username").setContent(jid.getLocalpart());
158 query.addChild("password").setContent(newPassword);
159 return packet;
160 }
161
162 public IqPacket changeAffiliation(Conversation conference, Jid jid, String affiliation) {
163 List<Jid> jids = new ArrayList<>();
164 jids.add(jid);
165 return changeAffiliation(conference,jids,affiliation);
166 }
167
168 public IqPacket changeAffiliation(Conversation conference, List<Jid> jids, String affiliation) {
169 IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
170 packet.setTo(conference.getJid().toBareJid());
171 packet.setFrom(conference.getAccount().getJid());
172 Element query = packet.query("http://jabber.org/protocol/muc#admin");
173 for(Jid jid : jids) {
174 Element item = query.addChild("item");
175 item.setAttribute("jid", jid.toString());
176 item.setAttribute("affiliation", affiliation);
177 }
178 return packet;
179 }
180
181 public IqPacket changeRole(Conversation conference, String nick, String role) {
182 IqPacket packet = new IqPacket(IqPacket.TYPE.SET);
183 packet.setTo(conference.getJid().toBareJid());
184 packet.setFrom(conference.getAccount().getJid());
185 Element item = packet.query("http://jabber.org/protocol/muc#admin").addChild("item");
186 item.setAttribute("nick", nick);
187 item.setAttribute("role", role);
188 return packet;
189 }
190}