import { BodyParams, Controller, Get, Inject, Post, Req, Res, UseBefore, } from '@tsed/common'; import axios from 'axios'; import { parseSlashCommand } from '@growi/slack'; import { Installation } from '~/entities/installation'; import { InstallationRepository } from '~/repositories/installation'; import { RelationRepository } from '~/repositories/relation'; import { OrderRepository } from '~/repositories/order'; import { InstallerService } from '~/services/InstallerService'; import { RegisterService } from '~/services/RegisterService'; import loggerFactory from '~/utils/logger'; import { AuthorizeCommandMiddleware, AuthorizeInteractionMiddleware } from '~/middlewares/authorizer'; import { AuthedReq } from '~/interfaces/authorized-req'; import { Relation } from '~/entities/relation'; const logger = loggerFactory('slackbot-proxy:controllers:slack'); @Controller('/slack') export class SlackCtrl { @Inject() installerService: InstallerService; @Inject() installationRepository: InstallationRepository; @Inject() relationRepository: RelationRepository; @Inject() orderRepository: OrderRepository; @Inject() registerService: RegisterService; @Get('/testsave') testsave(): void { const installation = new Installation(); installation.data = { team: undefined, enterprise: undefined, user: { id: '', token: undefined, scopes: undefined, }, }; // const installationRepository = getRepository(Installation); this.installationRepository.save(installation); } @Get('/install') async install(): Promise { const url = await this.installerService.installer.generateInstallUrl({ // Add the scopes your app needs scopes: [ 'channels:history', 'commands', 'groups:history', 'im:history', 'mpim:history', 'chat:write', ], }); return `` // eslint-disable-next-line max-len + 'Add to Slack' + ''; } @Post('/commands') @UseBefore(AuthorizeCommandMiddleware) async handleCommand(@Req() req: AuthedReq, @Res() res: Res): Promise { const { body, authorizeResult } = req; if (body.text == null) { return 'No text.'; } // Send response immediately to avoid opelation_timeout error // See https://api.slack.com/apis/connections/events-api#the-events-api__responding-to-events res.send(); const growiCommand = parseSlashCommand(body); // register if (growiCommand.growiCommandType === 'register') { await this.registerService.process(growiCommand, authorizeResult, body as {[key:string]:string}); return; } /* * forward to GROWI server */ const installationId = authorizeResult.enterpriseId || authorizeResult.teamId; // eslint-disable-next-line @typescript-eslint/no-non-null-assertion const installation = await this.installationRepository.findByTeamIdOrEnterpriseId(installationId!); const relations = await this.relationRepository.find({ installation: installation?.id }); await relations.map((relation: Relation) => { // generate API URL const url = new URL('/_api/v3/slack-bot/commands', relation.growiUri); return axios.post(url.toString(), { ...body, tokenPtoG: relation.tokenPtoG, growiCommand, }); }); } @Post('/interactions') @UseBefore(AuthorizeInteractionMiddleware) async handleInteraction(@Req() req: AuthedReq, @Res() res: Res): Promise { logger.info('receive interaction', req.body); logger.info('receive interaction', req.authorizeResult); return; } @Post('/events') async handleEvent(@BodyParams() body:{[key:string]:string}, @Res() res: Res): Promise { // eslint-disable-next-line max-len // see: https://api.slack.com/apis/connections/events-api#the-events-api__subscribing-to-event-types__events-api-request-urls__request-url-configuration--verification if (body.type === 'url_verification') { return body.challenge; } logger.info('receive event', body); return; } @Get('/oauth_redirect') async handleOauthRedirect(@Req() req: Req, @Res() res: Res): Promise { if (req.query.state === '') { res.writeHead(500, { 'Content-Type': 'text/html; charset=utf-8' }); res.end('' + '' + '' + '

Illegal state, try it again.

' + '' + 'Go to install page' + '' + ''); } await this.installerService.installer.handleCallback(req, res, { success: (installation, metadata, req, res) => { logger.info('Success to install', { installation, metadata }); const appPageUrl = `https://slack.com/apps/${installation.appId}`; res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' }); res.end('' + '' + '' + '

Congratulations!

' + '

GROWI Bot installation has succeeded.

' + `` + 'Access to Slack App detail page.' + '' + ''); }, failure: (error, installOptions, req, res) => { res.writeHead(500, { 'Content-Type': 'text/html; charset=utf-8' }); res.end('' + '' + '' + '

GROWI Bot installation failed

' + '

Please contact administrators of your workspace

' + 'Reference: ' + 'Manage app installation settings for your workspace' + '' + ''); }, }); } }