disco.js 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194
  1. (function (root, factory) {
  2. define([
  3. "jasmine",
  4. "mock",
  5. "test-utils"], factory);
  6. } (this, function (jasmine, mock, test_utils) {
  7. "use strict";
  8. const Strophe = converse.env.Strophe;
  9. const $iq = converse.env.$iq;
  10. const _ = converse.env._;
  11. const u = converse.env.utils;
  12. describe("Service Discovery", function () {
  13. describe("Whenever converse.js queries a server for its features", function () {
  14. it("stores the features it receives",
  15. mock.initConverse(
  16. ['discoInitialized'], {},
  17. async function (done, _converse) {
  18. const IQ_stanzas = _converse.connection.IQ_stanzas;
  19. const IQ_ids = _converse.connection.IQ_ids;
  20. await u.waitUntil(function () {
  21. return _.filter(IQ_stanzas, function (iq) {
  22. return iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]');
  23. }).length > 0;
  24. });
  25. /* <iq type='result'
  26. * from='plays.shakespeare.lit'
  27. * to='romeo@montague.net/orchard'
  28. * id='info1'>
  29. * <query xmlns='http://jabber.org/protocol/disco#info'>
  30. * <identity
  31. * category='server'
  32. * type='im'/>
  33. * <identity
  34. * category='conference'
  35. * type='text'
  36. * name='Play-Specific Chatrooms'/>
  37. * <identity
  38. * category='directory'
  39. * type='chatroom'
  40. * name='Play-Specific Chatrooms'/>
  41. * <feature var='http://jabber.org/protocol/disco#info'/>
  42. * <feature var='http://jabber.org/protocol/disco#items'/>
  43. * <feature var='http://jabber.org/protocol/muc'/>
  44. * <feature var='jabber:iq:register'/>
  45. * <feature var='jabber:iq:search'/>
  46. * <feature var='jabber:iq:time'/>
  47. * <feature var='jabber:iq:version'/>
  48. * </query>
  49. * </iq>
  50. */
  51. let stanza = _.find(IQ_stanzas, function (iq) {
  52. return iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]');
  53. });
  54. const info_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  55. stanza = $iq({
  56. 'type': 'result',
  57. 'from': 'montague.lit',
  58. 'to': 'romeo@montague.lit/orchard',
  59. 'id': info_IQ_id
  60. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
  61. .c('identity', {
  62. 'category': 'server',
  63. 'type': 'im'}).up()
  64. .c('identity', {
  65. 'category': 'conference',
  66. 'type': 'text',
  67. 'name': 'Play-Specific Chatrooms'}).up()
  68. .c('identity', {
  69. 'category': 'directory',
  70. 'type': 'chatroom',
  71. 'name': 'Play-Specific Chatrooms'}).up()
  72. .c('feature', {
  73. 'var': 'http://jabber.org/protocol/disco#info'}).up()
  74. .c('feature', {
  75. 'var': 'http://jabber.org/protocol/disco#items'}).up()
  76. .c('feature', {
  77. 'var': 'jabber:iq:register'}).up()
  78. .c('feature', {
  79. 'var': 'jabber:iq:time'}).up()
  80. .c('feature', {
  81. 'var': 'jabber:iq:version'});
  82. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  83. let entities = await _converse.api.disco.entities.get()
  84. expect(entities.length).toBe(2); // We have an extra entity, which is the user's JID
  85. expect(entities.get(_converse.domain).features.length).toBe(5);
  86. expect(entities.get(_converse.domain).identities.length).toBe(3);
  87. expect(entities.get('montague.lit').features.where({'var': 'jabber:iq:version'}).length).toBe(1);
  88. expect(entities.get('montague.lit').features.where({'var': 'jabber:iq:time'}).length).toBe(1);
  89. expect(entities.get('montague.lit').features.where({'var': 'jabber:iq:register'}).length).toBe(1);
  90. expect(entities.get('montague.lit').features.where(
  91. {'var': 'http://jabber.org/protocol/disco#items'}).length).toBe(1);
  92. expect(entities.get('montague.lit').features.where(
  93. {'var': 'http://jabber.org/protocol/disco#info'}).length).toBe(1);
  94. await u.waitUntil(function () {
  95. // Converse.js sees that the entity has a disco#items feature,
  96. // so it will make a query for it.
  97. return _.filter(IQ_stanzas, function (iq) {
  98. return iq.querySelector('query[xmlns="http://jabber.org/protocol/disco#items"]');
  99. }).length > 0;
  100. });
  101. /* <iq type='result'
  102. * from='catalog.shakespeare.lit'
  103. * to='romeo@montague.net/orchard'
  104. * id='items2'>
  105. * <query xmlns='http://jabber.org/protocol/disco#items'>
  106. * <item jid='people.shakespeare.lit'
  107. * name='Directory of Characters'/>
  108. * <item jid='plays.shakespeare.lit'
  109. * name='Play-Specific Chatrooms'/>
  110. * <item jid='mim.shakespeare.lit'
  111. * name='Gateway to Marlowe IM'/>
  112. * <item jid='words.shakespeare.lit'
  113. * name='Shakespearean Lexicon'/>
  114. *
  115. * <item jid='catalog.shakespeare.lit'
  116. * node='books'
  117. * name='Books by and about Shakespeare'/>
  118. * <item jid='catalog.shakespeare.lit'
  119. * node='clothing'
  120. * name='Wear your literary taste with pride'/>
  121. * <item jid='catalog.shakespeare.lit'
  122. * node='music'
  123. * name='Music from the time of Shakespeare'/>
  124. * </query>
  125. * </iq>
  126. */
  127. stanza = _.find(IQ_stanzas, function (iq) {
  128. return iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#items"]');
  129. });
  130. var items_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  131. stanza = $iq({
  132. 'type': 'result',
  133. 'from': 'montague.lit',
  134. 'to': 'romeo@montague.lit/orchard',
  135. 'id': items_IQ_id
  136. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#items'})
  137. .c('item', {
  138. 'jid': 'people.shakespeare.lit',
  139. 'name': 'Directory of Characters'}).up()
  140. .c('item', {
  141. 'jid': 'plays.shakespeare.lit',
  142. 'name': 'Play-Specific Chatrooms'}).up()
  143. .c('item', {
  144. 'jid': 'words.shakespeare.lit',
  145. 'name': 'Gateway to Marlowe IM'}).up()
  146. .c('item', {
  147. 'jid': 'montague.lit',
  148. 'node': 'books',
  149. 'name': 'Books by and about Shakespeare'}).up()
  150. .c('item', {
  151. 'node': 'montague.lit',
  152. 'name': 'Wear your literary taste with pride'}).up()
  153. .c('item', {
  154. 'jid': 'montague.lit',
  155. 'node': 'music',
  156. 'name': 'Music from the time of Shakespeare'
  157. });
  158. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  159. await u.waitUntil(() => _converse.disco_entities);
  160. entities = _converse.disco_entities;
  161. expect(entities.length).toBe(2); // We have an extra entity, which is the user's JID
  162. expect(entities.get(_converse.domain).items.length).toBe(3);
  163. expect(_.includes(entities.get(_converse.domain).items.pluck('jid'), 'people.shakespeare.lit')).toBeTruthy();
  164. expect(_.includes(entities.get(_converse.domain).items.pluck('jid'), 'plays.shakespeare.lit')).toBeTruthy();
  165. expect(_.includes(entities.get(_converse.domain).items.pluck('jid'), 'words.shakespeare.lit')).toBeTruthy();
  166. expect(entities.get(_converse.domain).identities.where({'category': 'conference'}).length).toBe(1);
  167. expect(entities.get(_converse.domain).identities.where({'category': 'directory'}).length).toBe(1);
  168. done();
  169. }));
  170. });
  171. describe("Whenever converse.js discovers a new server feature", function () {
  172. it("emits the serviceDiscovered event",
  173. mock.initConverse(
  174. ['discoInitialized'], {},
  175. function (done, _converse) {
  176. sinon.spy(_converse.api, "trigger");
  177. _converse.disco_entities.get(_converse.domain).features.create({'var': Strophe.NS.MAM});
  178. expect(_converse.api.trigger.called).toBe(true);
  179. expect(_converse.api.trigger.args[0][0]).toBe('serviceDiscovered');
  180. expect(_converse.api.trigger.args[0][1].get('var')).toBe(Strophe.NS.MAM);
  181. done();
  182. }));
  183. });
  184. });
  185. }));