The communications platform that puts data protection first.
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
Rocket.Chat/app/slackbridge/server/SlackAPI.js

116 lines
3.5 KiB

import { HTTP } from 'meteor/http';
export class SlackAPI {
constructor(apiToken) {
this.apiToken = apiToken;
}
getChannels() {
const response = HTTP.get('https://slack.com/api/conversations.list', {
params: {
token: this.apiToken,
types: 'public_channel',
},
});
return response && response.data && Array.isArray(response.data.channels) && response.data.channels.length > 0
? response.data.channels
: [];
}
getGroups() {
const response = HTTP.get('https://slack.com/api/conversations.list', {
params: {
token: this.apiToken,
types: 'private_channel',
},
});
return response && response.data && Array.isArray(response.data.channels) && response.data.channels.length > 0
? response.data.channels
: [];
}
getRoomInfo(roomId) {
const response = HTTP.get('https://slack.com/api/conversations.info', {
params: {
token: this.apiToken,
channel: roomId,
include_num_members: true,
},
});
return response && response.data && response.statusCode === 200 && response.data.ok && response.data.channel;
}
getMembers(channelId) {
const { num_members } = this.getRoomInfo(channelId);
const MAX_MEMBERS_PER_CALL = 100;
let members = [];
let currentCursor = '';
for (let index = 0; index < num_members; index += MAX_MEMBERS_PER_CALL) {
const response = HTTP.get('https://slack.com/api/conversations.members', {
params: {
token: this.apiToken,
channel: channelId,
limit: MAX_MEMBERS_PER_CALL,
cursor: currentCursor,
},
});
if (response && response.data && response.statusCode === 200 && response.data.ok && Array.isArray(response.data.members)) {
members = members.concat(response.data.members);
const hasMoreItems = response.data.response_metadata && response.data.response_metadata.next_cursor;
if (hasMoreItems) {
currentCursor = response.data.response_metadata.next_cursor;
}
}
}
return members;
}
react(data) {
const response = HTTP.post('https://slack.com/api/reactions.add', { params: data });
return response && response.statusCode === 200 && response.data && response.data.ok;
}
removeReaction(data) {
const response = HTTP.post('https://slack.com/api/reactions.remove', { params: data });
return response && response.statusCode === 200 && response.data && response.data.ok;
}
removeMessage(data) {
const response = HTTP.post('https://slack.com/api/chat.delete', { params: data });
return response && response.statusCode === 200 && response.data && response.data.ok;
}
sendMessage(data) {
return HTTP.post('https://slack.com/api/chat.postMessage', { params: data });
}
updateMessage(data) {
const response = HTTP.post('https://slack.com/api/chat.update', { params: data });
return response && response.statusCode === 200 && response.data && response.data.ok;
}
getHistory(family, options) {
const response = HTTP.get(`https://slack.com/api/${ family }.history`, { params: Object.assign({ token: this.apiToken }, options) });
return response && response.data;
}
getPins(channelId) {
const response = HTTP.get('https://slack.com/api/pins.list', {
params: {
token: this.apiToken,
channel: channelId,
},
});
return response && response.data && response.statusCode === 200 && response.data.ok && response.data.items;
}
getUser(userId) {
const response = HTTP.get('https://slack.com/api/users.info', {
params: {
token: this.apiToken,
user: userId,
},
});
return response && response.data && response.statusCode === 200 && response.data.ok && response.data.user;
}
}