This repository has been archived on 2022-08-14. You can view files and clone it, but cannot push or open issues or pull requests.
outline/server/api/hooks.js

98 lines
2.5 KiB
JavaScript
Raw Normal View History

// @flow
2016-08-23 06:37:01 +00:00
import Router from 'koa-router';
2018-02-25 04:44:13 +00:00
import { AuthenticationError, InvalidRequestError } from '../errors';
import { Authentication, Document, User } from '../models';
import { presentSlackAttachment } from '../presenters';
import * as Slack from '../slack';
2016-08-23 06:37:01 +00:00
const router = new Router();
router.post('hooks.unfurl', async ctx => {
const { challenge, token, event } = ctx.body;
if (challenge) return (ctx.body = ctx.body.challenge);
if (token !== process.env.SLACK_VERIFICATION_TOKEN)
2018-02-25 04:44:13 +00:00
throw new AuthenticationError('Invalid token');
// TODO: Everything from here onwards will get moved to an async job
2018-05-29 03:31:53 +00:00
const user = await User.find({
where: { service: 'slack', serviceId: event.user },
});
if (!user) return;
const auth = await Authentication.find({
2018-06-01 19:13:05 +00:00
where: { service: 'slack', teamId: user.teamId },
});
if (!auth) return;
// get content for unfurled links
let unfurls = {};
for (let link of event.links) {
const id = link.url.substr(link.url.lastIndexOf('/') + 1);
const doc = await Document.findById(id);
if (!doc || doc.teamId !== user.teamId) continue;
unfurls[link.url] = {
title: doc.title,
text: doc.getSummary(),
color: doc.collection.color,
};
}
await Slack.post('chat.unfurl', {
token: auth.token,
channel: event.channel,
ts: event.message_ts,
unfurls,
});
});
2017-04-27 04:47:03 +00:00
router.post('hooks.slack', async ctx => {
const { token, user_id, text } = ctx.body;
2016-08-23 06:37:01 +00:00
ctx.assertPresent(token, 'token is required');
ctx.assertPresent(user_id, 'user_id is required');
ctx.assertPresent(text, 'text is required');
2017-04-27 04:47:03 +00:00
if (token !== process.env.SLACK_VERIFICATION_TOKEN)
2018-02-25 04:44:13 +00:00
throw new AuthenticationError('Invalid token');
2016-08-23 06:37:01 +00:00
const user = await User.find({
where: {
2018-05-29 03:31:53 +00:00
service: 'slack',
serviceId: user_id,
2016-08-23 06:37:01 +00:00
},
});
2018-02-25 04:44:13 +00:00
if (!user) throw new InvalidRequestError('Invalid user');
2016-08-23 06:37:01 +00:00
const results = await Document.searchForUser(user, text, {
2016-08-23 06:37:01 +00:00
limit: 5,
});
if (results.length) {
const attachments = [];
for (const result of results) {
2018-08-05 07:51:47 +00:00
const queryIsInTitle = !!result.document.title
.toLowerCase()
.match(text.toLowerCase());
attachments.push(
presentSlackAttachment(
result.document,
queryIsInTitle ? undefined : result.context
)
);
}
ctx.body = {
text: `This is what we found for "${text}"…`,
attachments,
};
} else {
ctx.body = {
text: `No results for "${text}"`,
};
2016-08-23 06:37:01 +00:00
}
});
export default router;