twilio-chat
Advanced tools
twilio-chat - npm Package Compare versions
Comparing version 0.13.0-dev-build.343 to 0.13.0-dev-build.344
@@ -410,6 +410,24 @@ "use strict"; | ||
| value: function add(identity) { | ||
| if (!identity || typeof identity !== 'string') { | ||
| return _promise2.default.reject(new Error('Channel.add requires an <String>identity parameter')); | ||
| } | ||
| return this.membersEntity.add(identity); | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee3() { | ||
| return _regenerator2.default.wrap(function _callee3$(_context3) { | ||
| while (1) { | ||
| switch (_context3.prev = _context3.next) { | ||
| case 0: | ||
| if (!(!identity || typeof identity !== 'string')) { | ||
| _context3.next = 2; | ||
| break; | ||
| } | ||
| throw new Error('Channel.add requires an <String>identity parameter'); | ||
| case 2: | ||
| return _context3.abrupt("return", this.membersEntity.add(identity)); | ||
| case 3: | ||
| case "end": | ||
| return _context3.stop(); | ||
| } | ||
| } | ||
| }, _callee3, this); | ||
| })); | ||
| } | ||
@@ -426,9 +444,9 @@ /** | ||
| value: function advanceLastConsumedMessageIndex(index) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee3() { | ||
| return _regenerator2.default.wrap(function _callee3$(_context3) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee4() { | ||
| return _regenerator2.default.wrap(function _callee4$(_context4) { | ||
| while (1) { | ||
| switch (_context3.prev = _context3.next) { | ||
| switch (_context4.prev = _context4.next) { | ||
| case 0: | ||
| if ((0, _isInteger2.default)(index)) { | ||
| _context3.next = 2; | ||
| _context4.next = 2; | ||
| break; | ||
@@ -441,10 +459,10 @@ } | ||
| if (!(this.lastConsumedMessageIndex !== null && index <= this.lastConsumedMessageIndex || 0)) { | ||
| _context3.next = 4; | ||
| _context4.next = 4; | ||
| break; | ||
| } | ||
| return _context3.abrupt("return"); | ||
| return _context4.abrupt("return"); | ||
| case 4: | ||
| _context3.next = 6; | ||
| _context4.next = 6; | ||
| return this._subscribeStreams(); | ||
@@ -454,10 +472,10 @@ | ||
| this.services.consumptionHorizon.advanceLastConsumedMessageIndexForChannel(this.sid, index); | ||
| return _context3.abrupt("return", this); | ||
| return _context4.abrupt("return", this); | ||
| case 8: | ||
| case "end": | ||
| return _context3.stop(); | ||
| return _context4.stop(); | ||
| } | ||
| } | ||
| }, _callee3, this); | ||
| }, _callee4, this); | ||
| })); | ||
@@ -473,8 +491,8 @@ } | ||
| value: function decline() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee4() { | ||
| return _regenerator2.default.wrap(function _callee4$(_context4) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee5() { | ||
| return _regenerator2.default.wrap(function _callee5$(_context5) { | ||
| while (1) { | ||
| switch (_context4.prev = _context4.next) { | ||
| switch (_context5.prev = _context5.next) { | ||
| case 0: | ||
| _context4.next = 2; | ||
| _context5.next = 2; | ||
| return this.services.session.addCommand('declineInvitation', { | ||
@@ -485,10 +503,10 @@ channelSid: this.sid | ||
| case 2: | ||
| return _context4.abrupt("return", this); | ||
| return _context5.abrupt("return", this); | ||
| case 3: | ||
| case "end": | ||
| return _context4.stop(); | ||
| return _context5.stop(); | ||
| } | ||
| } | ||
| }, _callee4, this); | ||
| }, _callee5, this); | ||
| })); | ||
@@ -504,8 +522,8 @@ } | ||
| value: function _delete() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee5() { | ||
| return _regenerator2.default.wrap(function _callee5$(_context5) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee6() { | ||
| return _regenerator2.default.wrap(function _callee6$(_context6) { | ||
| while (1) { | ||
| switch (_context5.prev = _context5.next) { | ||
| switch (_context6.prev = _context6.next) { | ||
| case 0: | ||
| _context5.next = 2; | ||
| _context6.next = 2; | ||
| return this.services.session.addCommand('destroyChannel', { | ||
@@ -516,10 +534,10 @@ channelSid: this.sid | ||
| case 2: | ||
| return _context5.abrupt("return", this); | ||
| return _context6.abrupt("return", this); | ||
| case 3: | ||
| case "end": | ||
| return _context5.stop(); | ||
| return _context6.stop(); | ||
| } | ||
| } | ||
| }, _callee5, this); | ||
| }, _callee6, this); | ||
| })); | ||
@@ -537,19 +555,19 @@ } | ||
| value: function getAttributes() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee6() { | ||
| return _regenerator2.default.wrap(function _callee6$(_context6) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee7() { | ||
| return _regenerator2.default.wrap(function _callee7$(_context7) { | ||
| while (1) { | ||
| switch (_context6.prev = _context6.next) { | ||
| switch (_context7.prev = _context7.next) { | ||
| case 0: | ||
| _context6.next = 2; | ||
| _context7.next = 2; | ||
| return this._subscribe(); | ||
| case 2: | ||
| return _context6.abrupt("return", this.attributes); | ||
| return _context7.abrupt("return", this.attributes); | ||
| case 3: | ||
| case "end": | ||
| return _context6.stop(); | ||
| return _context7.stop(); | ||
| } | ||
| } | ||
| }, _callee6, this); | ||
| }, _callee7, this); | ||
| })); | ||
@@ -569,9 +587,9 @@ } | ||
| value: function getMessages(count, anchor, direction) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee7() { | ||
| return _regenerator2.default.wrap(function _callee7$(_context7) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee8() { | ||
| return _regenerator2.default.wrap(function _callee8$(_context8) { | ||
| while (1) { | ||
| switch (_context7.prev = _context7.next) { | ||
| switch (_context8.prev = _context8.next) { | ||
| case 0: | ||
| if (!(typeof anchor !== 'undefined' && !(0, _isInteger2.default)(anchor))) { | ||
| _context7.next = 2; | ||
| _context8.next = 2; | ||
| break; | ||
@@ -583,14 +601,14 @@ } | ||
| case 2: | ||
| _context7.next = 4; | ||
| _context8.next = 4; | ||
| return this._subscribeStreams(); | ||
| case 4: | ||
| return _context7.abrupt("return", this.messagesEntity.getMessages(count, anchor, direction)); | ||
| return _context8.abrupt("return", this.messagesEntity.getMessages(count, anchor, direction)); | ||
| case 5: | ||
| case "end": | ||
| return _context7.stop(); | ||
| return _context8.stop(); | ||
| } | ||
| } | ||
| }, _callee7, this); | ||
| }, _callee8, this); | ||
| })); | ||
@@ -606,19 +624,19 @@ } | ||
| value: function getMembers() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee8() { | ||
| return _regenerator2.default.wrap(function _callee8$(_context8) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee9() { | ||
| return _regenerator2.default.wrap(function _callee9$(_context9) { | ||
| while (1) { | ||
| switch (_context8.prev = _context8.next) { | ||
| switch (_context9.prev = _context9.next) { | ||
| case 0: | ||
| _context8.next = 2; | ||
| _context9.next = 2; | ||
| return this._subscribeStreams(); | ||
| case 2: | ||
| return _context8.abrupt("return", this.membersEntity.getMembers()); | ||
| return _context9.abrupt("return", this.membersEntity.getMembers()); | ||
| case 3: | ||
| case "end": | ||
| return _context8.stop(); | ||
| return _context9.stop(); | ||
| } | ||
| } | ||
| }, _callee8, this); | ||
| }, _callee9, this); | ||
| })); | ||
@@ -634,27 +652,27 @@ } | ||
| value: function getMembersCount() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee9() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee10() { | ||
| var links, url, response; | ||
| return _regenerator2.default.wrap(function _callee9$(_context9) { | ||
| return _regenerator2.default.wrap(function _callee10$(_context10) { | ||
| while (1) { | ||
| switch (_context9.prev = _context9.next) { | ||
| switch (_context10.prev = _context10.next) { | ||
| case 0: | ||
| _context9.next = 2; | ||
| _context10.next = 2; | ||
| return this.services.session.getSessionLinks(); | ||
| case 2: | ||
| links = _context9.sent; | ||
| links = _context10.sent; | ||
| url = new util_1.UriBuilder(links.publicChannelsUrl).path(this.sid).build(); | ||
| _context9.next = 6; | ||
| _context10.next = 6; | ||
| return this.services.network.get(url); | ||
| case 6: | ||
| response = _context9.sent; | ||
| return _context9.abrupt("return", response.body.members_count); | ||
| response = _context10.sent; | ||
| return _context10.abrupt("return", response.body.members_count); | ||
| case 8: | ||
| case "end": | ||
| return _context9.stop(); | ||
| return _context10.stop(); | ||
| } | ||
| } | ||
| }, _callee9, this); | ||
| }, _callee10, this); | ||
| })); | ||
@@ -670,27 +688,27 @@ } | ||
| value: function getMessagesCount() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee10() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee11() { | ||
| var links, url, response; | ||
| return _regenerator2.default.wrap(function _callee10$(_context10) { | ||
| return _regenerator2.default.wrap(function _callee11$(_context11) { | ||
| while (1) { | ||
| switch (_context10.prev = _context10.next) { | ||
| switch (_context11.prev = _context11.next) { | ||
| case 0: | ||
| _context10.next = 2; | ||
| _context11.next = 2; | ||
| return this.services.session.getSessionLinks(); | ||
| case 2: | ||
| links = _context10.sent; | ||
| links = _context11.sent; | ||
| url = new util_1.UriBuilder(links.publicChannelsUrl).path(this.sid).build(); | ||
| _context10.next = 6; | ||
| _context11.next = 6; | ||
| return this.services.network.get(url); | ||
| case 6: | ||
| response = _context10.sent; | ||
| return _context10.abrupt("return", response.body.messages_count); | ||
| response = _context11.sent; | ||
| return _context11.abrupt("return", response.body.messages_count); | ||
| case 8: | ||
| case "end": | ||
| return _context10.stop(); | ||
| return _context11.stop(); | ||
| } | ||
| } | ||
| }, _callee10, this); | ||
| }, _callee11, this); | ||
| })); | ||
@@ -706,26 +724,26 @@ } | ||
| value: function getUnconsumedMessagesCount() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee11() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee12() { | ||
| var links, url, response; | ||
| return _regenerator2.default.wrap(function _callee11$(_context11) { | ||
| return _regenerator2.default.wrap(function _callee12$(_context12) { | ||
| while (1) { | ||
| switch (_context11.prev = _context11.next) { | ||
| switch (_context12.prev = _context12.next) { | ||
| case 0: | ||
| _context11.next = 2; | ||
| _context12.next = 2; | ||
| return this.services.session.getSessionLinks(); | ||
| case 2: | ||
| links = _context11.sent; | ||
| links = _context12.sent; | ||
| url = new util_1.UriBuilder(links.myChannelsUrl).arg('ChannelSid', this.sid).build(); | ||
| _context11.next = 6; | ||
| _context12.next = 6; | ||
| return this.services.network.get(url); | ||
| case 6: | ||
| response = _context11.sent; | ||
| response = _context12.sent; | ||
| if (!response.body.channels.length) { | ||
| _context11.next = 9; | ||
| _context12.next = 9; | ||
| break; | ||
| } | ||
| return _context11.abrupt("return", response.body.channels[0].unread_messages_count || 0); | ||
| return _context12.abrupt("return", response.body.channels[0].unread_messages_count || 0); | ||
@@ -737,6 +755,6 @@ case 9: | ||
| case "end": | ||
| return _context11.stop(); | ||
| return _context12.stop(); | ||
| } | ||
| } | ||
| }, _callee11, this); | ||
| }, _callee12, this); | ||
| })); | ||
@@ -753,6 +771,24 @@ } | ||
| value: function invite(identity) { | ||
| if (typeof identity !== 'string' || !identity.length) { | ||
| return _promise2.default.reject(new Error('Channel.invite requires an <String>identity parameter')); | ||
| } | ||
| return this.membersEntity.invite(identity); | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee13() { | ||
| return _regenerator2.default.wrap(function _callee13$(_context13) { | ||
| while (1) { | ||
| switch (_context13.prev = _context13.next) { | ||
| case 0: | ||
| if (!(typeof identity !== 'string' || !identity.length)) { | ||
| _context13.next = 2; | ||
| break; | ||
| } | ||
| throw new Error('Channel.invite requires an <String>identity parameter'); | ||
| case 2: | ||
| return _context13.abrupt("return", this.membersEntity.invite(identity)); | ||
| case 3: | ||
| case "end": | ||
| return _context13.stop(); | ||
| } | ||
| } | ||
| }, _callee13, this); | ||
| })); | ||
| } | ||
@@ -767,19 +803,19 @@ /** | ||
| value: function join() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee12() { | ||
| return _regenerator2.default.wrap(function _callee12$(_context12) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee14() { | ||
| return _regenerator2.default.wrap(function _callee14$(_context14) { | ||
| while (1) { | ||
| switch (_context12.prev = _context12.next) { | ||
| switch (_context14.prev = _context14.next) { | ||
| case 0: | ||
| _context12.next = 2; | ||
| _context14.next = 2; | ||
| return this.services.session.addCommand('joinChannel', { channelSid: this.sid }); | ||
| case 2: | ||
| return _context12.abrupt("return", this); | ||
| return _context14.abrupt("return", this); | ||
| case 3: | ||
| case "end": | ||
| return _context12.stop(); | ||
| return _context14.stop(); | ||
| } | ||
| } | ||
| }, _callee12, this); | ||
| }, _callee14, this); | ||
| })); | ||
@@ -795,24 +831,24 @@ } | ||
| value: function leave() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee13() { | ||
| return _regenerator2.default.wrap(function _callee13$(_context13) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee15() { | ||
| return _regenerator2.default.wrap(function _callee15$(_context15) { | ||
| while (1) { | ||
| switch (_context13.prev = _context13.next) { | ||
| switch (_context15.prev = _context15.next) { | ||
| case 0: | ||
| if (!(this.state.status === 'joined')) { | ||
| _context13.next = 3; | ||
| _context15.next = 3; | ||
| break; | ||
| } | ||
| _context13.next = 3; | ||
| _context15.next = 3; | ||
| return this.services.session.addCommand('leaveChannel', { channelSid: this.sid }); | ||
| case 3: | ||
| return _context13.abrupt("return", this); | ||
| return _context15.abrupt("return", this); | ||
| case 4: | ||
| case "end": | ||
| return _context13.stop(); | ||
| return _context15.stop(); | ||
| } | ||
| } | ||
| }, _callee13, this); | ||
| }, _callee15, this); | ||
| })); | ||
@@ -829,9 +865,9 @@ } | ||
| value: function removeMember(member) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee14() { | ||
| return _regenerator2.default.wrap(function _callee14$(_context14) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee16() { | ||
| return _regenerator2.default.wrap(function _callee16$(_context16) { | ||
| while (1) { | ||
| switch (_context14.prev = _context14.next) { | ||
| switch (_context16.prev = _context16.next) { | ||
| case 0: | ||
| if (!(!member || typeof member !== 'string' && !(member instanceof member_1.Member))) { | ||
| _context14.next = 2; | ||
| _context16.next = 2; | ||
| break; | ||
@@ -843,10 +879,10 @@ } | ||
| case 2: | ||
| return _context14.abrupt("return", this.membersEntity.remove(typeof member === 'string' ? member : member.identity)); | ||
| return _context16.abrupt("return", this.membersEntity.remove(typeof member === 'string' ? member : member.identity)); | ||
| case 3: | ||
| case "end": | ||
| return _context14.stop(); | ||
| return _context16.stop(); | ||
| } | ||
| } | ||
| }, _callee14, this); | ||
| }, _callee16, this); | ||
| })); | ||
@@ -864,21 +900,21 @@ } | ||
| value: function sendMessage(messageBody, messageAttributes) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee15() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee17() { | ||
| var response; | ||
| return _regenerator2.default.wrap(function _callee15$(_context15) { | ||
| return _regenerator2.default.wrap(function _callee17$(_context17) { | ||
| while (1) { | ||
| switch (_context15.prev = _context15.next) { | ||
| switch (_context17.prev = _context17.next) { | ||
| case 0: | ||
| _context15.next = 2; | ||
| _context17.next = 2; | ||
| return this.messagesEntity.send(messageBody, messageAttributes); | ||
| case 2: | ||
| response = _context15.sent; | ||
| return _context15.abrupt("return", response.messageId); | ||
| response = _context17.sent; | ||
| return _context17.abrupt("return", response.messageId); | ||
| case 4: | ||
| case "end": | ||
| return _context15.stop(); | ||
| return _context17.stop(); | ||
| } | ||
| } | ||
| }, _callee15, this); | ||
| }, _callee17, this); | ||
| })); | ||
@@ -894,35 +930,35 @@ } | ||
| value: function setAllMessagesConsumed() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee16() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee18() { | ||
| var messagesPage; | ||
| return _regenerator2.default.wrap(function _callee16$(_context16) { | ||
| return _regenerator2.default.wrap(function _callee18$(_context18) { | ||
| while (1) { | ||
| switch (_context16.prev = _context16.next) { | ||
| switch (_context18.prev = _context18.next) { | ||
| case 0: | ||
| _context16.next = 2; | ||
| _context18.next = 2; | ||
| return this._subscribeStreams(); | ||
| case 2: | ||
| _context16.next = 4; | ||
| _context18.next = 4; | ||
| return this.getMessages(1); | ||
| case 4: | ||
| messagesPage = _context16.sent; | ||
| messagesPage = _context18.sent; | ||
| if (!(messagesPage.items.length > 0)) { | ||
| _context16.next = 8; | ||
| _context18.next = 8; | ||
| break; | ||
| } | ||
| _context16.next = 8; | ||
| _context18.next = 8; | ||
| return this.advanceLastConsumedMessageIndex(messagesPage.items[0].index); | ||
| case 8: | ||
| return _context16.abrupt("return", this); | ||
| return _context18.abrupt("return", this); | ||
| case 9: | ||
| case "end": | ||
| return _context16.stop(); | ||
| return _context18.stop(); | ||
| } | ||
| } | ||
| }, _callee16, this); | ||
| }, _callee18, this); | ||
| })); | ||
@@ -937,8 +973,8 @@ } | ||
| value: function setNoMessagesConsumed() { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee17() { | ||
| return _regenerator2.default.wrap(function _callee17$(_context17) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee19() { | ||
| return _regenerator2.default.wrap(function _callee19$(_context19) { | ||
| while (1) { | ||
| switch (_context17.prev = _context17.next) { | ||
| switch (_context19.prev = _context19.next) { | ||
| case 0: | ||
| _context17.next = 2; | ||
| _context19.next = 2; | ||
| return this._subscribeStreams(); | ||
@@ -948,10 +984,10 @@ | ||
| this.services.consumptionHorizon.updateLastConsumedMessageIndexForChannel(this.sid, null); | ||
| return _context17.abrupt("return", this); | ||
| return _context19.abrupt("return", this); | ||
| case 4: | ||
| case "end": | ||
| return _context17.stop(); | ||
| return _context19.stop(); | ||
| } | ||
| } | ||
| }, _callee17, this); | ||
| }, _callee19, this); | ||
| })); | ||
@@ -978,28 +1014,24 @@ } | ||
| value: function updateAttributes(attributes) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee18() { | ||
| var err, _err; | ||
| return _regenerator2.default.wrap(function _callee18$(_context18) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee20() { | ||
| return _regenerator2.default.wrap(function _callee20$(_context20) { | ||
| while (1) { | ||
| switch (_context18.prev = _context18.next) { | ||
| switch (_context20.prev = _context20.next) { | ||
| case 0: | ||
| if (attributes) { | ||
| _context18.next = 5; | ||
| _context20.next = 4; | ||
| break; | ||
| } | ||
| err = new Error('Attributes can\'t be null'); | ||
| return _context18.abrupt("return", _promise2.default.reject(err)); | ||
| throw new Error('Attributes can\'t be null'); | ||
| case 5: | ||
| case 4: | ||
| if (!(attributes.constructor !== Object)) { | ||
| _context18.next = 8; | ||
| _context20.next = 6; | ||
| break; | ||
| } | ||
| _err = new Error('Attributes must be a valid JSON object.'); | ||
| return _context18.abrupt("return", _promise2.default.reject(_err)); | ||
| throw new Error('Attributes must be a valid JSON object.'); | ||
| case 8: | ||
| _context18.next = 10; | ||
| case 6: | ||
| _context20.next = 8; | ||
| return this.services.session.addCommand('editAttributes', { | ||
@@ -1010,11 +1042,11 @@ channelSid: this.sid, | ||
| case 10: | ||
| return _context18.abrupt("return", this); | ||
| case 8: | ||
| return _context20.abrupt("return", this); | ||
| case 11: | ||
| case 9: | ||
| case "end": | ||
| return _context18.stop(); | ||
| return _context20.stop(); | ||
| } | ||
| } | ||
| }, _callee18, this); | ||
| }, _callee20, this); | ||
| })); | ||
@@ -1031,13 +1063,13 @@ } | ||
| value: function updateFriendlyName(name) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee19() { | ||
| return _regenerator2.default.wrap(function _callee19$(_context19) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee21() { | ||
| return _regenerator2.default.wrap(function _callee21$(_context21) { | ||
| while (1) { | ||
| switch (_context19.prev = _context19.next) { | ||
| switch (_context21.prev = _context21.next) { | ||
| case 0: | ||
| if (!(this.state.friendlyName !== name)) { | ||
| _context19.next = 3; | ||
| _context21.next = 3; | ||
| break; | ||
| } | ||
| _context19.next = 3; | ||
| _context21.next = 3; | ||
| return this.services.session.addCommand('editFriendlyName', { | ||
@@ -1049,10 +1081,10 @@ channelSid: this.sid, | ||
| case 3: | ||
| return _context19.abrupt("return", this); | ||
| return _context21.abrupt("return", this); | ||
| case 4: | ||
| case "end": | ||
| return _context19.stop(); | ||
| return _context21.stop(); | ||
| } | ||
| } | ||
| }, _callee19, this); | ||
| }, _callee21, this); | ||
| })); | ||
@@ -1069,9 +1101,9 @@ } | ||
| value: function updateLastConsumedMessageIndex(index) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee20() { | ||
| return _regenerator2.default.wrap(function _callee20$(_context20) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee22() { | ||
| return _regenerator2.default.wrap(function _callee22$(_context22) { | ||
| while (1) { | ||
| switch (_context20.prev = _context20.next) { | ||
| switch (_context22.prev = _context22.next) { | ||
| case 0: | ||
| if ((0, _isInteger2.default)(index) || index === null) { | ||
| _context20.next = 2; | ||
| _context22.next = 2; | ||
| break; | ||
@@ -1083,3 +1115,3 @@ } | ||
| case 2: | ||
| _context20.next = 4; | ||
| _context22.next = 4; | ||
| return this._subscribeStreams(); | ||
@@ -1089,10 +1121,10 @@ | ||
| this.services.consumptionHorizon.updateLastConsumedMessageIndexForChannel(this.sid, index); | ||
| return _context20.abrupt("return", this); | ||
| return _context22.abrupt("return", this); | ||
| case 6: | ||
| case "end": | ||
| return _context20.stop(); | ||
| return _context22.stop(); | ||
| } | ||
| } | ||
| }, _callee20, this); | ||
| }, _callee22, this); | ||
| })); | ||
@@ -1109,13 +1141,13 @@ } | ||
| value: function updateUniqueName(uniqueName) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee21() { | ||
| return _regenerator2.default.wrap(function _callee21$(_context21) { | ||
| return __awaiter(this, void 0, void 0, _regenerator2.default.mark(function _callee23() { | ||
| return _regenerator2.default.wrap(function _callee23$(_context23) { | ||
| while (1) { | ||
| switch (_context21.prev = _context21.next) { | ||
| switch (_context23.prev = _context23.next) { | ||
| case 0: | ||
| if (!(this.state.uniqueName !== uniqueName)) { | ||
| _context21.next = 3; | ||
| _context23.next = 3; | ||
| break; | ||
| } | ||
| _context21.next = 3; | ||
| _context23.next = 3; | ||
| return this.services.session.addCommand('editUniqueName', { | ||
@@ -1127,10 +1159,10 @@ channelSid: this.sid, | ||
| case 3: | ||
| return _context21.abrupt("return", this); | ||
| return _context23.abrupt("return", this); | ||
| case 4: | ||
| case "end": | ||
| return _context21.stop(); | ||
| return _context23.stop(); | ||
| } | ||
| } | ||
| }, _callee21, this); | ||
| }, _callee23, this); | ||
| })); | ||
@@ -1137,0 +1169,0 @@ } |
@@ -114,3 +114,3 @@ /// <reference types="node" /> | ||
| */ | ||
| add(identity: string): any; | ||
| add(identity: string): Promise<any>; | ||
| /** | ||
@@ -117,0 +117,0 @@ * Advance last consumed Channel's Message index to current consumption horizon. |
@@ -306,6 +306,8 @@ "use strict"; | ||
| add(identity) { | ||
| if (!identity || typeof identity !== 'string') { | ||
| return Promise.reject(new Error('Channel.add requires an <String>identity parameter')); | ||
| } | ||
| return this.membersEntity.add(identity); | ||
| return __awaiter(this, void 0, void 0, function* () { | ||
| if (!identity || typeof identity !== 'string') { | ||
| throw new Error('Channel.add requires an <String>identity parameter'); | ||
| } | ||
| return this.membersEntity.add(identity); | ||
| }); | ||
| } | ||
@@ -439,6 +441,8 @@ /** | ||
| invite(identity) { | ||
| if (typeof identity !== 'string' || !identity.length) { | ||
| return Promise.reject(new Error('Channel.invite requires an <String>identity parameter')); | ||
| } | ||
| return this.membersEntity.invite(identity); | ||
| return __awaiter(this, void 0, void 0, function* () { | ||
| if (typeof identity !== 'string' || !identity.length) { | ||
| throw new Error('Channel.invite requires an <String>identity parameter'); | ||
| } | ||
| return this.membersEntity.invite(identity); | ||
| }); | ||
| } | ||
@@ -531,8 +535,6 @@ /** | ||
| if (!attributes) { | ||
| let err = new Error('Attributes can\'t be null'); | ||
| return Promise.reject(err); | ||
| throw new Error('Attributes can\'t be null'); | ||
| } | ||
| else if (attributes.constructor !== Object) { | ||
| let err = new Error('Attributes must be a valid JSON object.'); | ||
| return Promise.reject(err); | ||
| throw new Error('Attributes must be a valid JSON object.'); | ||
| } | ||
@@ -539,0 +541,0 @@ yield this.services.session.addCommand('editAttributes', { |
| { | ||
| "name": "twilio-chat", | ||
| "version": "0.13.0-dev-build.343", | ||
| "version": "0.13.0-dev-build.344", | ||
| "description": "Twilio Chat service client library", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by0.15%
2004150
- Lines of code
- increased by0.15%
39979
No dependency changes