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