Пакет @squadus/botsdk
содержит HTTP-клиент для осуществления запросов к серверу Squadus. Используется для разработки ботов, работающих с мессенджером Squadus.
Пакет @squadus/botsdk
поддерживается Node v14 и выше. Рекомендуется использовать последнюю версию
Node.
Для установки @squadus/botsdk выполните команду:
$ npm install @squadus/botsdk
Пакет @squadus/botsdk
экспортирует класс SquadusClient
. Для использования нужно создать экземпляр класса, передав в конструктор адрес сервера, токен и разрешенный путь до папки с файлами, которые разрешено прикреплять к сообщениям, а затем вызвать connect
.
import { SquadusClient } from '@squadus/botsdk';
// Создание клиента
const squadusClient = new SquadusClient({
token: 'a89cDxjI1l',
server: 'https://im.example.ru/',
allowedAttachmentsPath: './',
});
await squadusClient.connect();
Токен для авторизации можно сгенерировать вручную в веб- или настольном клиенте Squadus. Для этого необходимо:
- Войти в учетную запись бота.
- Перейти на странице «Настройки» в раздел «Токены личного доступа».
- На открывшейся странице ввести название токена.
- Установить флажок «Игнорировать двухфакторную аутентификацию».
- Нажать «Добавить».
Каждый из методов SquadusClient
относится к одной из сущностей:
room
;message
;subscription
.
Например, метод sendMessageByRid
используется для отправки сообщения.
Чтобы его вызвать, необходимо обратиться к нему следующим образом: squadusClient.message.sendMessageByRid()
, где
squadusClient
– инстанс классаSquadusClient
;message
– сущность, которая содержит в себе методы для совершения операций над комнатами;sendMessageByRid
– метод для отправки сообщений.
// При известном ID комнаты (канала, команды или прямого диалога с пользователем)
const roomId = '...';
(async () => {
const result = await squadusClient.message.sendMessageByRid({
msg: 'Hello world!',
rid: roomId,
});
console.log('Message is sent successfully');
})();
Некоторые методы, такие как connect
, getSettings
, не относятся ни к одной из сущностей. Такие методы можно вызвать напрямую из инстанса класса SquadusClient
.
Так же возможно использовать имя метода в виде строки, чтобы:
- динамически определять вызываемый метод,
- вызывать методы, которые недоступны в используемой версии клиента.
Для этого можно воспользоваться конструкцией: squadusClient.restClient.post(im.create, [options])
.
Приведенный выше метод может быть использован следующим образом:
(async () => {
const response = await squadusClient.restClient.post('im.create', {
username: 'new_user',
});
})();
Ошибки могут возникать по нескольким причинам: пользователь не имеет прав вызывать метод или передан неверный аргумент. В таких случаях возвращенный промис будет отклонен с ошибкой. Необходимо обработать ошибку и использовать содержащуюся в ней информацию, чтобы решить, как приложение, использующее пакет @squadus/botsdk
, будет функционировать дальше.
// Import ErrorCode from the package
import { SquadusClient, ErrorCode } from 'squadus/botsdk';
const { TOKEN, SERVER } = process.env;
const squadusClient = new SquadusClient({
token: TOKEN || '',
server: SERVER || '',
});
(async () => {
try {
await squadusClient.connect();
} catch (error) {
if (error === ErrorCode.AuthorizationError) {
console.log('Authorization error');
}
}
})();
Типы ошибок
Есть несколько типов ошибок из ErrorCode
, с которыми можно столкнуться:
-
ErrorCode.AuthorizationError
: запрос не может быть отправлен из-за ошибки в авторизации. Основная причина – непройденная авторизация или истекший токен. -
ErrorCode.NoSuchFileOrDirectory
: нет такого файла или директории. Ошибка может возникнуть при отправке файлов, если был неверно передан путь к файлу. -
ErrorCode.EmptyResult
: нет результата отправки. Если сообщение было отправлено с ошибочным id комнаты (rid
), то в ответе не будет сообщения. Значит сообщение не было доставлено. -
ErrorCode.InvalidUser
: ошибочный пользователь. Если производилась попытка создать комнату с пользователем, которого нет, комната создана не будет. -
ErrorCode.RoomNotFound
: комната не найдена. Если при добавлении или удалении пользователя используется неверныйrid
, возникнет такая ошибка. -
ErrorCode.CommonError
: общая ошибка. Если не было установлено причин ошибки, будет возвращенаCommonError
ошибка. -
ErrorCode.ChannelNameExists
: канал с указанным названием уже существует. -
ErrorCode.FileToLarge
: отправляемый файл привышает допустимый размер. -
ErrorCode.MessageSizeExceeded
: количество символов в отправляемом сообщении привышает установленный на сервере лимит. -
ErrorCode.MessageSizeExceeded
: количество символов в отправляемом сообщении привышает установленный на сервере лимит.
В таблице представлены описание методов, их аргументов и возвращаемых ими значений.
Метод | Группа | Аргументы | Ответ | Описание |
---|---|---|---|---|
connect() |
- | - | Promise<void> |
Выполняет авторизацию |
getSettings(settings) |
- | settings?: Array<SettingsName> |
RestResponse<SettingsResponseData> |
Возвращает значения настроек, имена которых были переданы в метод. Если не передавать имена, будут возвращены все настройки |
sendMessageByRid(params) |
message |
params: SendMessageByRidParams |
Promise<MessageResponseData> |
Выполняет отправку сообщения по идентификатору комнаты |
sendAttachment(params) |
message |
params: SendAttachmentSDKParams |
Promise<MessageResponseData> |
Выполняет отправку вложения по идентификатору комнаты |
createDirectRoom(username) |
room |
username: string |
Promise<DirectRoomResponseData | undefined> |
Создает личную переписку с пользователем, имя которого было передано в качестве аргумента |
addUsersToRoom(params) |
room |
params: AddUsersToRoomParams |
RestResponse<boolean> |
Добавляет пользователя в существующую комнату |
removeUserFromChannel(params) |
room |
params: RemoveUserFromChannelParams |
RestResponse<RemoveUserFromChannelResponseData> |
Удаляет пользователя из комнаты, в которой он состоит |
createChannel(params) |
room |
params: CreateChannelSDKParams |
RestResponse<ChannelData> |
Создает комнату с переданными параметрами |
setUserRole(params) |
room |
params: CreatePublicChannelSDKParams | CreatePrivateChannelSDKParams |
RestResponse<CreatePublicChannelResponseData | CreatePrivateChannelResponseData> |
Изменяет роль пользователя в комнате |
saveRoomSettings(params) |
room |
params: SaveRoomSettingsSDKParams |
RestResponse<SaveRoomSettingsData> |
Изменяет настройки комнаты по ее идентификатору |
onMessage(callback[, rid]) |
subscription |
callback: (msg: LastMessage) => void, rid?: string |
Promise<OnMessagesResponse> |
Вызывает переданную функцию с новым полученным сообщением в определенном чате rid или во всех |
onRoomChange(rid, callback) |
subscription |
rid: string, callback: (data: RoomEvent) => void |
Promise<OnRoomChangeResponse> |
Вызывает переданную функцию с каждым событием в чате |
onReaction(rid, msgId, callback) |
subscription |
rid: string, msgId: string, callback: (message: Message) => void |
Promise<onReactionResponse> |
Вызывает переданную функцию с сообщением при изменении его реакций |
onEvent(callback) |
subscription |
callback: (data: WsData) => void |
Subscription |
Вызывает переданную функцию со всеми событиями, полученными по протоколу WebSocket |
subscribe(collection, event) |
subscription |
collection: Collections, event: string |
Promise<WsSubscription> |
Позволяет произвольно подписаться на события, которые будут получены через onEvent |
close() |
subscription |
- | Promise<void> |
Закрывает соединение |
reopen() |
subscription |
- | Promise<void> |
Переоткрывает соединение |
subscribeNotifyUser() |
subscription |
- | Promise<(WsSubscription)[]> |
Осуществляет подписку на WebSocket-события, связанные с текущим пользователем |
subscribeLoggedNotify() |
subscription |
- | Promise<(WsSubscription)[]> |
Осуществляет подписку на WebSocket-события об изменениях авторизованных пользователей |
subscribeNotifyAll() |
subscription |
- | Promise<(WsSubscription)[]> |
Осуществляет подписку на общие для всех пользователей WebSocket-события |
unsubscribe(id) |
subscription |
id: string |
Promise<UnsubscribeResponseData> |
Позволяет отписываться от WebSocket-событий по id. Эти id молжно получить при подписке |
getUserInfoByUsername(username) |
- | username: string |
RestResponse<UserResponseData> |
Запрашивает информацию о пользователе по его имени |
sendMessageToThread(params) |
message |
params: SendMessageToThreadSDKParams |
Promise<MessageResponseData> |
Отправляет сообщение в цепочку ответов |
readThread(parentMessageId) |
room |
parentMessageId: string |
Promise<void> |
Помечает все сообщения внутри цепочки ответов с переданным parentMessageId как прочитанные |
В корне пакета @squadus/botsdk
находится папка examples
– это проект с несколькими примерами использования методов из таблицы 1.
С помощью приведенных примеров можно ознакомиться с использованием данного пакета на практике.
Чтобы выполнить код из папки examples
, необходимо:
- Установить зависимости из папки
examples
:cd examples && yarn
. - Внести токен пользователя (бота), от чьего имени будут осуществляться действия, адрес сервера и имя собеседника в файл
./examples/.env
.
SERVER="https://******"
TOKEN="******"
PARTNER_NAME="yourPartnerName"
- Запустите пример
yarn create-direct
. Если токен и адрес сервера указаны верно, а также пользователь, с которым создается диалог, существует, в консоль будет выведено сообщениеDirect dialog with ${partner_name} was created successfully
.
Примеры, которые помогут начать пользоваться @squadus/botsdk
:
Будет произведена авторизация.
Будут получены значения настроек с сервера для Accounts_AllowRealNameChange
и Accounts_AddGuestsToChats
.
Будет создан диалог с собеседником, указанным в файле .env
, если такой пользователь существует.
С собеседником, указанным в файле .env
, если такой пользователь существует, будет создан диалог. Затем ему будет отправлено сообщение с текстом Hi
.
С собеседником, указанным в файле .env
, если такой пользователь существует, будет создан диалог. Затем ему будет отправлено изображение example.png
из проекта с сообщением Image with logo
. Если изображение будет заменено на файл с размером, превышающим допустимый, в консоли появится сообщение об ошибке: File is too large
. Также файл должен находиться по пути, который соответствует параметру allowedAttachmentsPath
, указанному при создании squadusClient
.
Собеседник, указанный в файле .env
, если такой пользователь существует, будет добавлен в указанный канал. Затем он будет удален из него.
Будет создан приватный канал с именем, указанным в константе PRIVATE_CHANNEL_NAME
.
Будет создан открытый канал с именем, указанным в константе PUBLIC_CHANNEL_NAME
.
Будет создан открытый канал c пользователем. Затем пользователю будет назначена роль «Модератор».
Будет создан канал, затем имя канала будет изменено.
Ботом будет выполнена подписка на все новые сообщения, а также отдельная подписка на новые личные сообщения от пользователя, имя которого указано в переменной окружения PARTNER_NAME
. При получении ботом сообщения «Hi» от пользователя PARTNER_NAME
, будет отправлен ответ «Hello». При получении ботом сообщения «Bye» из любого чата, будет отправлен ответ «Bye». Через 20 секунд произойдет отписка от сообщений «Hi», через 40 секунд произойдет отписка от сообщений «Bye».
Ботом будет выполнена подписка на все новые сообщения. После получения ботом сообщения «start», бот отправит ответное сообщение, на реакции которого произойдет подписка ботом. Если поставить реакцию с эмоджи 👏 на это сообщение любым пользователем, в тот же чат бот отправит сообщение, содержащее эмоджи 🌄, если будет реакция с 😀, то сообщение с эмоджи ⚽. После отправки ботом сообщения на реакцию, бот отпишется от реакций на это сообщение.
Ботом будет выполнена подписка на события в личных сообщениях с пользователем, имя которого указано в переменной окружения PARTNER_NAME
.
Если пользователь PARTNER_NAME
или сам бот начал или прекратил печатать сообщение в этом чате, в консоль будет выведено сообщение об этом.
Будет отправлено сообщение, на основании идентификатора которого будет создана цепочка ответов.
Будет отправлено сообщение, на основании идентификатора которого будет создана цепочка ответов. Цепочка ответов будет отмечена как прочитанная пользователем, имя и токен которого указаны в переменных окружения PARTNER_NAME
и PARTNER_TOKEN
соответственно.