console/packages/web/app/pages/api/slack/callback.ts

import { stringify } from 'node:querystring';
import { NextApiRequest, NextApiResponse } from 'next';
import { env } from '@/env/backend';
import { graphql } from '@/lib/api/utils';
import { getLogger } from '@/server-logger';

async function fetchData({
  url,
  headers,
  body,
}: {
  url: string;
  headers: Record<string, any>;
  body: string;
}) {
  const response = await fetch(url, {
    headers,
    method: 'POST',
    body,
  } as any);

  return response.json();
}

export default async function slackCallback(req: NextApiRequest, res: NextApiResponse) {
  const logger = getLogger(req);

  if (env.slack === null) {
    throw new Error('The Slack integration is not enabled.');
  }

  const { code } = req.query;
  const orgId = req.query.state;

  logger.info('Fetching data from Slack API (orgId=%s)', orgId);

  const slackResponse = await fetchData({
    url: 'https://slack.com/api/oauth.v2.access',
    headers: {
      'content-type': 'application/x-www-form-urlencoded',
    },
    body: stringify({
      client_id: env.slack.clientId,
      client_secret: env.slack.clientSecret,
      code,
    }),
  });

  const token = slackResponse.access_token;

  await graphql({
    url: env.graphqlPublicEndpoint,
    headers: {
      ...req.headers,
      'content-type': 'application/json',
      'graphql-client-name': 'Hive App',
      'graphql-client-version': env.release,
    },
    operationName: 'addSlackIntegration',
    query: /* GraphQL */ `
      mutation addSlackIntegration($input: AddSlackIntegrationInput!) {
        addSlackIntegration(input: $input)
      }
    `,
    variables: {
      input: {
        organization: orgId,
        token,
      },
    },
  });
  res.redirect(`/${orgId}/view/settings`);
}