IqGenerator.java

  1package eu.siacs.conversations.generator;
  2
  3import android.os.Bundle;
  4import android.util.Base64;
  5import android.util.Log;
  6import eu.siacs.conversations.Config;
  7import eu.siacs.conversations.R;
  8import eu.siacs.conversations.crypto.axolotl.AxolotlService;
  9import eu.siacs.conversations.entities.Account;
 10import eu.siacs.conversations.entities.Bookmark;
 11import eu.siacs.conversations.entities.Conversation;
 12import eu.siacs.conversations.entities.DownloadableFile;
 13import eu.siacs.conversations.services.MessageArchiveService;
 14import eu.siacs.conversations.services.XmppConnectionService;
 15import eu.siacs.conversations.xml.Element;
 16import eu.siacs.conversations.xml.Namespace;
 17import eu.siacs.conversations.xmpp.Jid;
 18import eu.siacs.conversations.xmpp.forms.Data;
 19import eu.siacs.conversations.xmpp.pep.Avatar;
 20import im.conversations.android.xmpp.model.stanza.Iq;
 21import java.nio.ByteBuffer;
 22import java.security.cert.CertificateEncodingException;
 23import java.security.cert.X509Certificate;
 24import java.util.ArrayList;
 25import java.util.List;
 26import java.util.Locale;
 27import java.util.Set;
 28import java.util.TimeZone;
 29import java.util.UUID;
 30import org.whispersystems.libsignal.IdentityKey;
 31import org.whispersystems.libsignal.ecc.ECPublicKey;
 32import org.whispersystems.libsignal.state.PreKeyRecord;
 33import org.whispersystems.libsignal.state.SignedPreKeyRecord;
 34
 35public class IqGenerator extends AbstractGenerator {
 36
 37    public IqGenerator(final XmppConnectionService service) {
 38        super(service);
 39    }
 40
 41    public Iq discoResponse(final Account account, final Iq request) {
 42        final var packet = new Iq(Iq.Type.RESULT);
 43        packet.setId(request.getId());
 44        packet.setTo(request.getFrom());
 45        final Element query = packet.addChild("query", "http://jabber.org/protocol/disco#info");
 46        query.setAttribute("node", request.query().getAttribute("node"));
 47        final Element identity = query.addChild("identity");
 48        identity.setAttribute("category", "client");
 49        identity.setAttribute("type", getIdentityType());
 50        identity.setAttribute("name", getIdentityName());
 51        for (final String feature : getFeatures(account)) {
 52            query.addChild("feature").setAttribute("var", feature);
 53        }
 54        return packet;
 55    }
 56
 57    public Iq versionResponse(final Iq request) {
 58        final var packet = request.generateResponse(Iq.Type.RESULT);
 59        Element query = packet.query("jabber:iq:version");
 60        query.addChild("name").setContent(mXmppConnectionService.getString(R.string.app_name));
 61        query.addChild("version").setContent(getIdentityVersion());
 62        if ("chromium".equals(android.os.Build.BRAND)) {
 63            query.addChild("os").setContent("Chrome OS");
 64        } else {
 65            query.addChild("os").setContent("Android");
 66        }
 67        return packet;
 68    }
 69
 70    public Iq entityTimeResponse(final Iq request) {
 71        final Iq packet = request.generateResponse(Iq.Type.RESULT);
 72        Element time = packet.addChild("time", "urn:xmpp:time");
 73        final long now = System.currentTimeMillis();
 74        time.addChild("utc").setContent(getTimestamp(now));
 75        TimeZone ourTimezone = TimeZone.getDefault();
 76        long offsetSeconds = ourTimezone.getOffset(now) / 1000;
 77        long offsetMinutes = Math.abs((offsetSeconds % 3600) / 60);
 78        long offsetHours = offsetSeconds / 3600;
 79        String hours;
 80        if (offsetHours < 0) {
 81            hours = String.format(Locale.US, "%03d", offsetHours);
 82        } else {
 83            hours = String.format(Locale.US, "%02d", offsetHours);
 84        }
 85        String minutes = String.format(Locale.US, "%02d", offsetMinutes);
 86        time.addChild("tzo").setContent(hours + ":" + minutes);
 87        return packet;
 88    }
 89
 90    public static Iq purgeOfflineMessages() {
 91        final Iq packet = new Iq(Iq.Type.SET);
 92        packet.addChild("offline", Namespace.FLEXIBLE_OFFLINE_MESSAGE_RETRIEVAL).addChild("purge");
 93        return packet;
 94    }
 95
 96    protected Iq publish(final String node, final Element item, final Bundle options) {
 97        final var packet = new Iq(Iq.Type.SET);
 98        final Element pubsub = packet.addChild("pubsub", Namespace.PUBSUB);
 99        final Element publish = pubsub.addChild("publish");
100        publish.setAttribute("node", node);
101        publish.addChild(item);
102        if (options != null) {
103            final Element publishOptions = pubsub.addChild("publish-options");
104            publishOptions.addChild(Data.create(Namespace.PUBSUB_PUBLISH_OPTIONS, options));
105        }
106        return packet;
107    }
108
109    protected Iq publish(final String node, final Element item) {
110        return publish(node, item, null);
111    }
112
113    private Iq retrieve(String node, Element item) {
114        final var packet = new Iq(Iq.Type.GET);
115        final Element pubsub = packet.addChild("pubsub", Namespace.PUBSUB);
116        final Element items = pubsub.addChild("items");
117        items.setAttribute("node", node);
118        if (item != null) {
119            items.addChild(item);
120        }
121        return packet;
122    }
123
124    public Iq retrieveBookmarks() {
125        return retrieve(Namespace.BOOKMARKS2, null);
126    }
127
128    public Iq retrieveMds() {
129        return retrieve(Namespace.MDS_DISPLAYED, null);
130    }
131
132    public Iq publishNick(String nick) {
133        final Element item = new Element("item");
134        item.setAttribute("id", "current");
135        item.addChild("nick", Namespace.NICK).setContent(nick);
136        return publish(Namespace.NICK, item);
137    }
138
139    public Iq deleteNode(final String node) {
140        final var packet = new Iq(Iq.Type.SET);
141        final Element pubsub = packet.addChild("pubsub", Namespace.PUBSUB_OWNER);
142        pubsub.addChild("delete").setAttribute("node", node);
143        return packet;
144    }
145
146    public Iq deleteItem(final String node, final String id) {
147        final var packet = new Iq(Iq.Type.SET);
148        final Element pubsub = packet.addChild("pubsub", Namespace.PUBSUB);
149        final Element retract = pubsub.addChild("retract");
150        retract.setAttribute("node", node);
151        retract.setAttribute("notify", "true");
152        retract.addChild("item").setAttribute("id", id);
153        return packet;
154    }
155
156    public Iq publishAvatar(Avatar avatar, Bundle options) {
157        final Element item = new Element("item");
158        item.setAttribute("id", avatar.sha1sum);
159        final Element data = item.addChild("data", Namespace.AVATAR_DATA);
160        data.setContent(avatar.image);
161        return publish(Namespace.AVATAR_DATA, item, options);
162    }
163
164    public Iq publishElement(
165            final String namespace, final Element element, String id, final Bundle options) {
166        final Element item = new Element("item");
167        item.setAttribute("id", id);
168        item.addChild(element);
169        return publish(namespace, item, options);
170    }
171
172    public Iq publishAvatarMetadata(final Avatar avatar, final Bundle options) {
173        final Element item = new Element("item");
174        item.setAttribute("id", avatar.sha1sum);
175        final Element metadata = item.addChild("metadata", Namespace.AVATAR_METADATA);
176        final Element info = metadata.addChild("info");
177        info.setAttribute("bytes", avatar.size);
178        info.setAttribute("id", avatar.sha1sum);
179        info.setAttribute("height", avatar.height);
180        info.setAttribute("width", avatar.height);
181        info.setAttribute("type", avatar.type);
182        return publish(Namespace.AVATAR_METADATA, item, options);
183    }
184
185    public Iq retrievePepAvatar(final Avatar avatar) {
186        final Element item = new Element("item");
187        item.setAttribute("id", avatar.sha1sum);
188        final var packet = retrieve(Namespace.AVATAR_DATA, item);
189        packet.setTo(avatar.owner);
190        return packet;
191    }
192
193    public Iq retrieveVcardAvatar(final Avatar avatar) {
194        final Iq packet = new Iq(Iq.Type.GET);
195        packet.setTo(avatar.owner);
196        packet.addChild("vCard", "vcard-temp");
197        return packet;
198    }
199
200    public Iq retrieveVcardAvatar(final Jid to) {
201        final Iq packet = new Iq(Iq.Type.GET);
202        packet.setTo(to);
203        packet.addChild("vCard", "vcard-temp");
204        return packet;
205    }
206
207    public Iq retrieveAvatarMetaData(final Jid to) {
208        final Iq packet = retrieve("urn:xmpp:avatar:metadata", null);
209        if (to != null) {
210            packet.setTo(to);
211        }
212        return packet;
213    }
214
215    public Iq retrieveDeviceIds(final Jid to) {
216        final var packet = retrieve(AxolotlService.PEP_DEVICE_LIST, null);
217        if (to != null) {
218            packet.setTo(to);
219        }
220        return packet;
221    }
222
223    public Iq retrieveBundlesForDevice(final Jid to, final int deviceid) {
224        final var packet = retrieve(AxolotlService.PEP_BUNDLES + ":" + deviceid, null);
225        packet.setTo(to);
226        return packet;
227    }
228
229    public Iq retrieveVerificationForDevice(final Jid to, final int deviceid) {
230        final var packet = retrieve(AxolotlService.PEP_VERIFICATION + ":" + deviceid, null);
231        packet.setTo(to);
232        return packet;
233    }
234
235    public Iq publishDeviceIds(final Set<Integer> ids, final Bundle publishOptions) {
236        final Element item = new Element("item");
237        item.setAttribute("id", "current");
238        final Element list = item.addChild("list", AxolotlService.PEP_PREFIX);
239        for (Integer id : ids) {
240            final Element device = new Element("device");
241            device.setAttribute("id", id);
242            list.addChild(device);
243        }
244        return publish(AxolotlService.PEP_DEVICE_LIST, item, publishOptions);
245    }
246
247    public Element publishBookmarkItem(final Bookmark bookmark) {
248        final String name = bookmark.getBookmarkName();
249        final String nick = bookmark.getNick();
250        final String password = bookmark.getPassword();
251        final boolean autojoin = bookmark.autojoin();
252        final Element conference = new Element("conference", Namespace.BOOKMARKS2);
253        if (name != null) {
254            conference.setAttribute("name", name);
255        }
256        if (nick != null) {
257            conference.addChild("nick").setContent(nick);
258        }
259        if (password != null) {
260            conference.addChild("password").setContent(password);
261        }
262        conference.setAttribute("autojoin", String.valueOf(autojoin));
263        conference.addChild(bookmark.getExtensions());
264        return conference;
265    }
266
267    public Element mdsDisplayed(final String stanzaId, final Conversation conversation) {
268        final Jid by;
269        if (conversation.getMode() == Conversation.MODE_MULTI) {
270            by = conversation.getJid().asBareJid();
271        } else {
272            by = conversation.getAccount().getJid().asBareJid();
273        }
274        return mdsDisplayed(stanzaId, by);
275    }
276
277    private Element mdsDisplayed(final String stanzaId, final Jid by) {
278        final Element displayed = new Element("displayed", Namespace.MDS_DISPLAYED);
279        final Element stanzaIdElement = displayed.addChild("stanza-id", Namespace.STANZA_IDS);
280        stanzaIdElement.setAttribute("id", stanzaId);
281        stanzaIdElement.setAttribute("by", by);
282        return displayed;
283    }
284
285    public Iq publishBundles(
286            final SignedPreKeyRecord signedPreKeyRecord,
287            final IdentityKey identityKey,
288            final Set<PreKeyRecord> preKeyRecords,
289            final int deviceId,
290            Bundle publishOptions) {
291        final Element item = new Element("item");
292        item.setAttribute("id", "current");
293        final Element bundle = item.addChild("bundle", AxolotlService.PEP_PREFIX);
294        final Element signedPreKeyPublic = bundle.addChild("signedPreKeyPublic");
295        signedPreKeyPublic.setAttribute("signedPreKeyId", signedPreKeyRecord.getId());
296        ECPublicKey publicKey = signedPreKeyRecord.getKeyPair().getPublicKey();
297        signedPreKeyPublic.setContent(Base64.encodeToString(publicKey.serialize(), Base64.NO_WRAP));
298        final Element signedPreKeySignature = bundle.addChild("signedPreKeySignature");
299        signedPreKeySignature.setContent(
300                Base64.encodeToString(signedPreKeyRecord.getSignature(), Base64.NO_WRAP));
301        final Element identityKeyElement = bundle.addChild("identityKey");
302        identityKeyElement.setContent(
303                Base64.encodeToString(identityKey.serialize(), Base64.NO_WRAP));
304
305        final Element prekeys = bundle.addChild("prekeys", AxolotlService.PEP_PREFIX);
306        for (PreKeyRecord preKeyRecord : preKeyRecords) {
307            final Element prekey = prekeys.addChild("preKeyPublic");
308            prekey.setAttribute("preKeyId", preKeyRecord.getId());
309            prekey.setContent(
310                    Base64.encodeToString(
311                            preKeyRecord.getKeyPair().getPublicKey().serialize(), Base64.NO_WRAP));
312        }
313
314        return publish(AxolotlService.PEP_BUNDLES + ":" + deviceId, item, publishOptions);
315    }
316
317    public Iq publishVerification(
318            byte[] signature, X509Certificate[] certificates, final int deviceId) {
319        final Element item = new Element("item");
320        item.setAttribute("id", "current");
321        final Element verification = item.addChild("verification", AxolotlService.PEP_PREFIX);
322        final Element chain = verification.addChild("chain");
323        for (int i = 0; i < certificates.length; ++i) {
324            try {
325                Element certificate = chain.addChild("certificate");
326                certificate.setContent(
327                        Base64.encodeToString(certificates[i].getEncoded(), Base64.NO_WRAP));
328                certificate.setAttribute("index", i);
329            } catch (CertificateEncodingException e) {
330                Log.d(Config.LOGTAG, "could not encode certificate");
331            }
332        }
333        verification
334                .addChild("signature")
335                .setContent(Base64.encodeToString(signature, Base64.NO_WRAP));
336        return publish(AxolotlService.PEP_VERIFICATION + ":" + deviceId, item);
337    }
338
339    public Iq queryMessageArchiveManagement(final MessageArchiveService.Query mam) {
340        final Iq packet = new Iq(Iq.Type.SET);
341        final Element query = packet.query(mam.version.namespace);
342        query.setAttribute("queryid", mam.getQueryId());
343        final Data data = new Data();
344        data.setFormType(mam.version.namespace);
345        if (mam.muc()) {
346            packet.setTo(mam.getWith());
347        } else if (mam.getWith() != null) {
348            data.put("with", mam.getWith().toString());
349        }
350        final long start = mam.getStart();
351        final long end = mam.getEnd();
352        if (start != 0) {
353            data.put("start", getTimestamp(start));
354        }
355        if (end != 0) {
356            data.put("end", getTimestamp(end));
357        }
358        data.submit();
359        query.addChild(data);
360        Element set = query.addChild("set", "http://jabber.org/protocol/rsm");
361        if (mam.getPagingOrder() == MessageArchiveService.PagingOrder.REVERSE) {
362            set.addChild("before").setContent(mam.getReference());
363        } else if (mam.getReference() != null) {
364            set.addChild("after").setContent(mam.getReference());
365        }
366        set.addChild("max").setContent(String.valueOf(Config.PAGE_SIZE));
367        return packet;
368    }
369
370    public Iq generateGetBlockList() {
371        final Iq iq = new Iq(Iq.Type.GET);
372        iq.addChild("blocklist", Namespace.BLOCKING);
373
374        return iq;
375    }
376
377    public Iq generateSetBlockRequest(
378            final Jid jid, final boolean reportSpam, final String serverMsgId) {
379        final Iq iq = new Iq(Iq.Type.SET);
380        final Element block = iq.addChild("block", Namespace.BLOCKING);
381        final Element item = block.addChild("item").setAttribute("jid", jid);
382        if (reportSpam) {
383            final Element report = item.addChild("report", Namespace.REPORTING);
384            report.setAttribute("reason", Namespace.REPORTING_REASON_SPAM);
385            if (serverMsgId != null) {
386                final Element stanzaId = report.addChild("stanza-id", Namespace.STANZA_IDS);
387                stanzaId.setAttribute("by", jid);
388                stanzaId.setAttribute("id", serverMsgId);
389            }
390        }
391        Log.d(Config.LOGTAG, iq.toString());
392        return iq;
393    }
394
395    public Iq generateSetUnblockRequest(final Jid jid) {
396        final Iq iq = new Iq(Iq.Type.SET);
397        final Element block = iq.addChild("unblock", Namespace.BLOCKING);
398        block.addChild("item").setAttribute("jid", jid);
399        return iq;
400    }
401
402    public Iq generateSetPassword(final Account account, final String newPassword) {
403        final Iq packet = new Iq(Iq.Type.SET);
404        packet.setTo(account.getDomain());
405        final Element query = packet.addChild("query", Namespace.REGISTER);
406        final Jid jid = account.getJid();
407        query.addChild("username").setContent(jid.getLocal());
408        query.addChild("password").setContent(newPassword);
409        return packet;
410    }
411
412    public Iq changeAffiliation(Conversation conference, Jid jid, String affiliation) {
413        List<Jid> jids = new ArrayList<>();
414        jids.add(jid);
415        return changeAffiliation(conference, jids, affiliation);
416    }
417
418    public Iq changeAffiliation(Conversation conference, List<Jid> jids, String affiliation) {
419        final Iq packet = new Iq(Iq.Type.SET);
420        packet.setTo(conference.getJid().asBareJid());
421        packet.setFrom(conference.getAccount().getJid());
422        Element query = packet.query("http://jabber.org/protocol/muc#admin");
423        for (Jid jid : jids) {
424            Element item = query.addChild("item");
425            item.setAttribute("jid", jid);
426            item.setAttribute("affiliation", affiliation);
427        }
428        return packet;
429    }
430
431    public Iq changeRole(Conversation conference, String nick, String role) {
432        final Iq packet = new Iq(Iq.Type.SET);
433        packet.setTo(conference.getJid().asBareJid());
434        packet.setFrom(conference.getAccount().getJid());
435        Element item = packet.query("http://jabber.org/protocol/muc#admin").addChild("item");
436        item.setAttribute("nick", nick);
437        item.setAttribute("role", role);
438        return packet;
439    }
440
441    public Iq requestHttpUploadSlot(Jid host, DownloadableFile file, String mime) {
442        final Iq packet = new Iq(Iq.Type.GET);
443        packet.setTo(host);
444        Element request = packet.addChild("request", Namespace.HTTP_UPLOAD);
445        request.setAttribute("filename", convertFilename(file.getName()));
446        request.setAttribute("size", file.getExpectedSize());
447        request.setAttribute("content-type", mime);
448        return packet;
449    }
450
451    public Iq requestHttpUploadLegacySlot(Jid host, DownloadableFile file, String mime) {
452        final Iq packet = new Iq(Iq.Type.GET);
453        packet.setTo(host);
454        Element request = packet.addChild("request", Namespace.HTTP_UPLOAD_LEGACY);
455        request.addChild("filename").setContent(convertFilename(file.getName()));
456        request.addChild("size").setContent(String.valueOf(file.getExpectedSize()));
457        request.addChild("content-type").setContent(mime);
458        return packet;
459    }
460
461    private static String convertFilename(String name) {
462        int pos = name.indexOf('.');
463        if (pos != -1) {
464            try {
465                UUID uuid = UUID.fromString(name.substring(0, pos));
466                ByteBuffer bb = ByteBuffer.wrap(new byte[16]);
467                bb.putLong(uuid.getMostSignificantBits());
468                bb.putLong(uuid.getLeastSignificantBits());
469                return Base64.encodeToString(
470                                bb.array(), Base64.URL_SAFE | Base64.NO_PADDING | Base64.NO_WRAP)
471                        + name.substring(pos);
472            } catch (Exception e) {
473                return name;
474            }
475        } else {
476            return name;
477        }
478    }
479
480    public static Iq generateCreateAccountWithCaptcha(
481            final Account account, final String id, final Data data) {
482        final Iq register = new Iq(Iq.Type.SET);
483        register.setFrom(account.getJid().asBareJid());
484        register.setTo(account.getDomain());
485        register.setId(id);
486        Element query = register.query(Namespace.REGISTER);
487        if (data != null) {
488            query.addChild(data);
489        }
490        return register;
491    }
492
493    public Iq pushTokenToAppServer(Jid appServer, String token, String deviceId) {
494        return pushTokenToAppServer(appServer, token, deviceId, null);
495    }
496
497    public Iq pushTokenToAppServer(Jid appServer, String token, String deviceId, Jid muc) {
498        final Iq packet = new Iq(Iq.Type.SET);
499        packet.setTo(appServer);
500        final Element command = packet.addChild("command", Namespace.COMMANDS);
501        command.setAttribute("node", "register-push-fcm");
502        command.setAttribute("action", "execute");
503        final Data data = new Data();
504        data.put("token", token);
505        data.put("android-id", deviceId);
506        if (muc != null) {
507            data.put("muc", muc.toString());
508        }
509        data.submit();
510        command.addChild(data);
511        return packet;
512    }
513
514    public Iq unregisterChannelOnAppServer(Jid appServer, String deviceId, String channel) {
515        final Iq packet = new Iq(Iq.Type.SET);
516        packet.setTo(appServer);
517        final Element command = packet.addChild("command", Namespace.COMMANDS);
518        command.setAttribute("node", "unregister-push-fcm");
519        command.setAttribute("action", "execute");
520        final Data data = new Data();
521        data.put("channel", channel);
522        data.put("android-id", deviceId);
523        data.submit();
524        command.addChild(data);
525        return packet;
526    }
527
528    public Iq enablePush(final Jid jid, final String node, final String secret) {
529        final Iq packet = new Iq(Iq.Type.SET);
530        Element enable = packet.addChild("enable", Namespace.PUSH);
531        enable.setAttribute("jid", jid);
532        enable.setAttribute("node", node);
533        if (secret != null) {
534            Data data = new Data();
535            data.setFormType(Namespace.PUBSUB_PUBLISH_OPTIONS);
536            data.put("secret", secret);
537            data.submit();
538            enable.addChild(data);
539        }
540        return packet;
541    }
542
543    public Iq disablePush(final Jid jid, final String node) {
544        Iq packet = new Iq(Iq.Type.SET);
545        Element disable = packet.addChild("disable", Namespace.PUSH);
546        disable.setAttribute("jid", jid);
547        disable.setAttribute("node", node);
548        return packet;
549    }
550
551    public Iq queryAffiliation(Conversation conversation, String affiliation) {
552        final Iq packet = new Iq(Iq.Type.GET);
553        packet.setTo(conversation.getJid().asBareJid());
554        packet.query("http://jabber.org/protocol/muc#admin")
555                .addChild("item")
556                .setAttribute("affiliation", affiliation);
557        return packet;
558    }
559
560    public static Bundle defaultGroupChatConfiguration() {
561        Bundle options = new Bundle();
562        options.putString("muc#roomconfig_persistentroom", "1");
563        options.putString("muc#roomconfig_membersonly", "1");
564        options.putString("muc#roomconfig_publicroom", "0");
565        options.putString("muc#roomconfig_whois", "anyone");
566        options.putString("muc#roomconfig_changesubject", "0");
567        options.putString("muc#roomconfig_allowinvites", "0");
568        options.putString("muc#roomconfig_enablearchiving", "1"); // prosody
569        options.putString("mam", "1"); // ejabberd community
570        options.putString("muc#roomconfig_mam", "1"); // ejabberd saas
571        return options;
572    }
573
574    public static Bundle defaultChannelConfiguration() {
575        Bundle options = new Bundle();
576        options.putString("muc#roomconfig_persistentroom", "1");
577        options.putString("muc#roomconfig_membersonly", "0");
578        options.putString("muc#roomconfig_publicroom", "1");
579        options.putString("muc#roomconfig_whois", "moderators");
580        options.putString("muc#roomconfig_changesubject", "0");
581        options.putString("muc#roomconfig_enablearchiving", "1"); // prosody
582        options.putString("mam", "1"); // ejabberd community
583        options.putString("muc#roomconfig_mam", "1"); // ejabberd saas
584        return options;
585    }
586
587    public Iq requestPubsubConfiguration(Jid jid, String node) {
588        return pubsubConfiguration(jid, node, null);
589    }
590
591    public Iq publishPubsubConfiguration(Jid jid, String node, Data data) {
592        return pubsubConfiguration(jid, node, data);
593    }
594
595    private Iq pubsubConfiguration(Jid jid, String node, Data data) {
596        final Iq packet = new Iq(data == null ? Iq.Type.GET : Iq.Type.SET);
597        packet.setTo(jid);
598        Element pubsub = packet.addChild("pubsub", "http://jabber.org/protocol/pubsub#owner");
599        Element configure = pubsub.addChild("configure").setAttribute("node", node);
600        if (data != null) {
601            configure.addChild(data);
602        }
603        return packet;
604    }
605
606    public Iq queryDiscoItems(final Jid jid) {
607        final Iq packet = new Iq(Iq.Type.GET);
608        packet.setTo(jid);
609        packet.addChild("query", Namespace.DISCO_ITEMS);
610        return packet;
611    }
612
613    public Iq queryDiscoInfo(final Jid jid) {
614        final Iq packet = new Iq(Iq.Type.GET);
615        packet.setTo(jid);
616        packet.addChild("query", Namespace.DISCO_INFO);
617        return packet;
618    }
619}