messaging-api-slack
Advanced tools
Comparing version 0.8.0 to 0.8.1
@@ -1,7 +0,7 @@ | ||
'use strict';Object.defineProperty(exports, "__esModule", { value: true });exports.SlackWebhookClient = exports.SlackOAuthClient = undefined; | ||
"use strict";Object.defineProperty(exports, "__esModule", { value: true });Object.defineProperty(exports, "SlackOAuthClient", { enumerable: true, get: function () {return _SlackOAuthClient.default;} });Object.defineProperty(exports, "SlackWebhookClient", { enumerable: true, get: function () {return _SlackWebhookClient.default;} });exports.default = void 0; | ||
var _SlackOAuthClient = require('./SlackOAuthClient');var _SlackOAuthClient2 = _interopRequireDefault(_SlackOAuthClient); | ||
var _SlackWebhookClient = require('./SlackWebhookClient');var _SlackWebhookClient2 = _interopRequireDefault(_SlackWebhookClient);function _interopRequireDefault(obj) {return obj && obj.__esModule ? obj : { default: obj };}exports. | ||
var _SlackOAuthClient = _interopRequireDefault(require("./SlackOAuthClient")); | ||
var _SlackWebhookClient = _interopRequireDefault(require("./SlackWebhookClient"));function _interopRequireDefault(obj) {return obj && obj.__esModule ? obj : { default: obj };}var _default = | ||
SlackOAuthClient = _SlackOAuthClient2.default;exports.SlackWebhookClient = _SlackWebhookClient2.default;exports.default = | ||
{ SlackOAuthClient: _SlackOAuthClient2.default, SlackWebhookClient: _SlackWebhookClient2.default }; | ||
{ SlackOAuthClient: _SlackOAuthClient.default, SlackWebhookClient: _SlackWebhookClient.default };exports.default = _default; |
@@ -1,10 +0,10 @@ | ||
'use strict';Object.defineProperty(exports, "__esModule", { value: true });var _extends = Object.assign || function (target) {for (var i = 1; i < arguments.length; i++) {var source = arguments[i];for (var key in source) {if (Object.prototype.hasOwnProperty.call(source, key)) {target[key] = source[key];}}}return target;}; | ||
"use strict";Object.defineProperty(exports, "__esModule", { value: true });exports.default = void 0; | ||
var _querystring = require('querystring');var _querystring2 = _interopRequireDefault(_querystring); | ||
var _querystring = _interopRequireDefault(require("querystring")); | ||
var _axiosError = require('axios-error');var _axiosError2 = _interopRequireDefault(_axiosError); | ||
var _axios = require('axios');var _axios2 = _interopRequireDefault(_axios); | ||
var _debug = require('debug');var _debug2 = _interopRequireDefault(_debug); | ||
var _lodash = require('lodash.omit');var _lodash2 = _interopRequireDefault(_lodash); | ||
var _urlJoin = require('url-join');var _urlJoin2 = _interopRequireDefault(_urlJoin);function _interopRequireDefault(obj) {return obj && obj.__esModule ? obj : { default: obj };}function _asyncToGenerator(fn) {return function () {var gen = fn.apply(this, arguments);return new Promise(function (resolve, reject) {function step(key, arg) {try {var info = gen[key](arg);var value = info.value;} catch (error) {reject(error);return;}if (info.done) {resolve(value);} else {return Promise.resolve(value).then(function (value) {step("next", value);}, function (err) {step("throw", err);});}}return step("next");});};} | ||
var _axiosError = _interopRequireDefault(require("axios-error")); | ||
var _axios = _interopRequireDefault(require("axios")); | ||
var _debug = _interopRequireDefault(require("debug")); | ||
var _lodash = _interopRequireDefault(require("lodash.omit")); | ||
var _urlJoin = _interopRequireDefault(require("url-join"));function _interopRequireDefault(obj) {return obj && obj.__esModule ? obj : { default: obj };}function ownKeys(object, enumerableOnly) {var keys = Object.keys(object);if (Object.getOwnPropertySymbols) {var symbols = Object.getOwnPropertySymbols(object);if (enumerableOnly) symbols = symbols.filter(function (sym) {return Object.getOwnPropertyDescriptor(object, sym).enumerable;});keys.push.apply(keys, symbols);}return keys;}function _objectSpread(target) {for (var i = 1; i < arguments.length; i++) {var source = arguments[i] != null ? arguments[i] : {};if (i % 2) {ownKeys(source, true).forEach(function (key) {_defineProperty(target, key, source[key]);});} else if (Object.getOwnPropertyDescriptors) {Object.defineProperties(target, Object.getOwnPropertyDescriptors(source));} else {ownKeys(source).forEach(function (key) {Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key));});}}return target;}function _defineProperty(obj, key, value) {if (key in obj) {Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true });} else {obj[key] = value;}return obj;} | ||
@@ -77,3 +77,3 @@ | ||
const debugRequest = (0, _debug2.default)('messaging-api-slack'); | ||
const debugRequest = (0, _debug.default)('messaging-api-slack'); | ||
@@ -97,3 +97,3 @@ function onRequest({ method, url, body }) { | ||
constructor(accessTokenOrConfig) { | ||
constructor(accessTokenOrConfig) {_defineProperty(this, "_axios", void 0);_defineProperty(this, "_token", void 0);_defineProperty(this, "_onRequest", void 0); | ||
let origin; | ||
@@ -114,3 +114,3 @@ if (accessTokenOrConfig && typeof accessTokenOrConfig === 'object') { | ||
// https://api.slack.com/web | ||
this._axios = _axios2.default.create({ | ||
this._axios = _axios.default.create({ | ||
baseURL: `${origin || 'https://slack.com'}/api/`, | ||
@@ -125,7 +125,7 @@ headers: { | ||
method: config.method, | ||
url: (0, _urlJoin2.default)(config.baseURL, config.url), | ||
headers: _extends({}, | ||
config.headers.common, | ||
config.headers[config.method], | ||
(0, _lodash2.default)(config.headers, [ | ||
url: (0, _urlJoin.default)(config.baseURL, config.url), | ||
headers: _objectSpread({}, | ||
config.headers.common, {}, | ||
config.headers[config.method], {}, | ||
(0, _lodash.default)(config.headers, [ | ||
'common', | ||
@@ -154,28 +154,28 @@ 'get', | ||
callMethod( | ||
async callMethod( | ||
method, | ||
_body = {}) | ||
{var _this = this;return _asyncToGenerator(function* () { | ||
try { | ||
const body = (0, _lodash2.default)(_body, ['token', 'accessToken']); | ||
body.token = _body.accessToken || _body.token || _this._token; | ||
{ | ||
try { | ||
const body = (0, _lodash.default)(_body, ['token', 'accessToken']); | ||
body.token = _body.accessToken || _body.token || this._token; | ||
const response = yield _this._axios.post( | ||
method, | ||
_querystring2.default.stringify(body));const | ||
const response = await this._axios.post( | ||
method, | ||
_querystring.default.stringify(body)); | ||
data = response.data,config = response.config,request = response.request; | ||
const { data, config, request } = response; | ||
if (!data.ok) { | ||
throw new _axiosError2.default(`Slack API - ${data.error}`, { | ||
config, | ||
request, | ||
response }); | ||
if (!data.ok) { | ||
throw new _axiosError.default(`Slack API - ${data.error}`, { | ||
config, | ||
request, | ||
response }); | ||
} | ||
} | ||
return data; | ||
} catch (err) { | ||
throw new _axiosError2.default(err.message, err); | ||
}})(); | ||
return data; | ||
} catch (err) { | ||
throw new _axiosError.default(err.message, err); | ||
} | ||
} | ||
@@ -192,3 +192,3 @@ | ||
{ | ||
return this.callMethod('channels.info', _extends({ | ||
return this.callMethod('channels.info', _objectSpread({ | ||
channel: channelId }, | ||
@@ -220,3 +220,3 @@ options)). | ||
{ | ||
return this.callMethod('conversations.info', _extends({ | ||
return this.callMethod('conversations.info', _objectSpread({ | ||
channel: channelId }, | ||
@@ -239,3 +239,3 @@ options)). | ||
{ | ||
return this.callMethod('conversations.members', _extends({ | ||
return this.callMethod('conversations.members', _objectSpread({ | ||
channel: channelId }, | ||
@@ -249,23 +249,23 @@ options)). | ||
getAllConversationMembers( | ||
async getAllConversationMembers( | ||
channelId, | ||
options = {}) | ||
{var _this2 = this;return _asyncToGenerator(function* () { | ||
let allMembers = []; | ||
let continuationCursor; | ||
{ | ||
let allMembers = []; | ||
let continuationCursor; | ||
do {var _ref = | ||
do { | ||
const { | ||
members, | ||
next | ||
// eslint-disable-next-line no-await-in-loop | ||
} = await this.getConversationMembers(channelId, _objectSpread({ | ||
cursor: continuationCursor }, | ||
options)); | ||
allMembers = allMembers.concat(members); | ||
continuationCursor = next; | ||
} while (continuationCursor); | ||
yield _this2.getConversationMembers(channelId, _extends({ | ||
cursor: continuationCursor }, | ||
options));const members = _ref.members,next = _ref.next; | ||
allMembers = allMembers.concat(members); | ||
continuationCursor = next; | ||
} while (continuationCursor); | ||
return allMembers;})(); | ||
return allMembers; | ||
} | ||
@@ -290,22 +290,22 @@ | ||
getAllConversationList( | ||
async getAllConversationList( | ||
options = {}) | ||
{var _this3 = this;return _asyncToGenerator(function* () { | ||
let allChannels = []; | ||
let continuationCursor; | ||
{ | ||
let allChannels = []; | ||
let continuationCursor; | ||
do { | ||
const _options = continuationCursor ? _extends({ | ||
cursor: continuationCursor }, options) : | ||
options;var _ref2 = | ||
do { | ||
const _options = continuationCursor ? _objectSpread({ | ||
cursor: continuationCursor }, options) : | ||
options; | ||
const { | ||
channels, | ||
next | ||
// eslint-disable-next-line no-await-in-loop | ||
} = await this.getConversationList(_options); | ||
allChannels = allChannels.concat(channels); | ||
continuationCursor = next; | ||
} while (continuationCursor); | ||
yield _this3.getConversationList(_options);const channels = _ref2.channels,next = _ref2.next; | ||
allChannels = allChannels.concat(channels); | ||
continuationCursor = next; | ||
} while (continuationCursor); | ||
return allChannels;})(); | ||
return allChannels; | ||
} | ||
@@ -339,3 +339,3 @@ | ||
if (typeof message === 'string') { | ||
return this.callMethod('chat.postMessage', _extends({ | ||
return this.callMethod('chat.postMessage', _objectSpread({ | ||
channel, | ||
@@ -346,5 +346,5 @@ text: message }, | ||
} | ||
return this.callMethod('chat.postMessage', _extends({ | ||
return this.callMethod('chat.postMessage', _objectSpread({ | ||
channel }, | ||
message, | ||
message, {}, | ||
options)); | ||
@@ -381,3 +381,3 @@ | ||
if (typeof message === 'string') { | ||
return this.callMethod('chat.postEphemeral', _extends({ | ||
return this.callMethod('chat.postEphemeral', _objectSpread({ | ||
channel, | ||
@@ -389,6 +389,6 @@ user, | ||
} | ||
return this.callMethod('chat.postEphemeral', _extends({ | ||
return this.callMethod('chat.postEphemeral', _objectSpread({ | ||
channel, | ||
user }, | ||
message, | ||
message, {}, | ||
options)); | ||
@@ -407,3 +407,3 @@ | ||
{ | ||
return this.callMethod('users.info', _extends({ user: userId }, options)).then( | ||
return this.callMethod('users.info', _objectSpread({ user: userId }, options)).then( | ||
data => data.user); | ||
@@ -439,17 +439,17 @@ | ||
getAllUserList(options = {}) {var _this4 = this;return _asyncToGenerator(function* () { | ||
let allUsers = []; | ||
let continuationCursor; | ||
async getAllUserList(options = {}) { | ||
let allUsers = []; | ||
let continuationCursor; | ||
do {var _ref3 = | ||
do { | ||
const { | ||
members: users, | ||
next | ||
// eslint-disable-next-line no-await-in-loop | ||
} = await this.getUserList(_objectSpread({ cursor: continuationCursor }, options)); | ||
allUsers = allUsers.concat(users); | ||
continuationCursor = next; | ||
} while (continuationCursor); | ||
yield _this4.getUserList(_extends({ cursor: continuationCursor }, options));const users = _ref3.members,next = _ref3.next; | ||
allUsers = allUsers.concat(users); | ||
continuationCursor = next; | ||
} while (continuationCursor); | ||
return allUsers;})(); | ||
return allUsers; | ||
}}exports.default = SlackOAuthClient; |
@@ -1,1 +0,1 @@ | ||
'use strict'; | ||
"use strict"; |
@@ -1,7 +0,7 @@ | ||
'use strict';Object.defineProperty(exports, "__esModule", { value: true });var _extends = Object.assign || function (target) {for (var i = 1; i < arguments.length; i++) {var source = arguments[i];for (var key in source) {if (Object.prototype.hasOwnProperty.call(source, key)) {target[key] = source[key];}}}return target;}; | ||
"use strict";Object.defineProperty(exports, "__esModule", { value: true });exports.default = void 0; | ||
var _axios = require('axios');var _axios2 = _interopRequireDefault(_axios); | ||
var _debug = require('debug');var _debug2 = _interopRequireDefault(_debug); | ||
var _lodash = require('lodash.omit');var _lodash2 = _interopRequireDefault(_lodash); | ||
var _urlJoin = require('url-join');var _urlJoin2 = _interopRequireDefault(_urlJoin);function _interopRequireDefault(obj) {return obj && obj.__esModule ? obj : { default: obj };} | ||
var _axios = _interopRequireDefault(require("axios")); | ||
var _debug = _interopRequireDefault(require("debug")); | ||
var _lodash = _interopRequireDefault(require("lodash.omit")); | ||
var _urlJoin = _interopRequireDefault(require("url-join"));function _interopRequireDefault(obj) {return obj && obj.__esModule ? obj : { default: obj };}function ownKeys(object, enumerableOnly) {var keys = Object.keys(object);if (Object.getOwnPropertySymbols) {var symbols = Object.getOwnPropertySymbols(object);if (enumerableOnly) symbols = symbols.filter(function (sym) {return Object.getOwnPropertyDescriptor(object, sym).enumerable;});keys.push.apply(keys, symbols);}return keys;}function _objectSpread(target) {for (var i = 1; i < arguments.length; i++) {var source = arguments[i] != null ? arguments[i] : {};if (i % 2) {ownKeys(source, true).forEach(function (key) {_defineProperty(target, key, source[key]);});} else if (Object.getOwnPropertyDescriptors) {Object.defineProperties(target, Object.getOwnPropertyDescriptors(source));} else {ownKeys(source).forEach(function (key) {Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key));});}}return target;}function _defineProperty(obj, key, value) {if (key in obj) {Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true });} else {obj[key] = value;}return obj;} | ||
@@ -25,3 +25,3 @@ | ||
const debugRequest = (0, _debug2.default)('messaging-api-slack'); | ||
const debugRequest = (0, _debug.default)('messaging-api-slack'); | ||
@@ -43,3 +43,3 @@ function onRequest({ method, url, body }) { | ||
constructor(urlOrConfig) { | ||
constructor(urlOrConfig) {_defineProperty(this, "_onRequest", void 0);_defineProperty(this, "_axios", void 0); | ||
let url; | ||
@@ -58,3 +58,3 @@ if (urlOrConfig && typeof urlOrConfig === 'object') { | ||
// https://api.slack.com/incoming-webhooks | ||
this._axios = _axios2.default.create({ | ||
this._axios = _axios.default.create({ | ||
baseURL: url, | ||
@@ -67,7 +67,7 @@ headers: { 'Content-Type': 'application/json' } }); | ||
method: config.method, | ||
url: (0, _urlJoin2.default)(config.baseURL, config.url), | ||
headers: _extends({}, | ||
config.headers.common, | ||
config.headers[config.method], | ||
(0, _lodash2.default)(config.headers, [ | ||
url: (0, _urlJoin.default)(config.baseURL, config.url), | ||
headers: _objectSpread({}, | ||
config.headers.common, {}, | ||
config.headers[config.method], {}, | ||
(0, _lodash.default)(config.headers, [ | ||
'common', | ||
@@ -74,0 +74,0 @@ 'get', |
{ | ||
"name": "messaging-api-slack", | ||
"description": "Messaging API client for Slack", | ||
"version": "0.8.0", | ||
"engines": { | ||
"node": ">=6" | ||
}, | ||
"license": "MIT", | ||
"repository": { | ||
@@ -12,4 +9,13 @@ "type": "git", | ||
}, | ||
"license": "MIT", | ||
"version": "0.8.1", | ||
"main": "lib/index.js", | ||
"dependencies": { | ||
"axios": "^0.19.0", | ||
"axios-error": "^0.8.1", | ||
"lodash.omit": "^4.5.0", | ||
"url-join": "^4.0.1" | ||
}, | ||
"devDependencies": { | ||
"axios-mock-adapter": "^1.17.0" | ||
}, | ||
"keywords": [ | ||
@@ -21,12 +27,6 @@ "bot", | ||
], | ||
"dependencies": { | ||
"axios": "^0.19.0", | ||
"axios-error": "^0.8.0", | ||
"lodash.omit": "^4.5.0", | ||
"url-join": "^4.0.0" | ||
"engines": { | ||
"node": ">=8" | ||
}, | ||
"devDependencies": { | ||
"axios-mock-adapter": "^1.15.0" | ||
}, | ||
"gitHead": "62a2ec0cb939605bf01a6054b9ccce9f9bb8e1d7" | ||
"gitHead": "622f5664634c26e752e4e54bd32dbc773271390f" | ||
} |
136191
3872
Updatedaxios-error@^0.8.1
Updatedurl-join@^4.0.1