Function newSlackIntegration

apps/web/services/accounts/slack.ts:8–108

({
  query,
  getSlackAccessToken = api.getSlackAccessToken,
  fetchTeamInfo = api.fetchTeamInfo,
  eventNewIntegration = integrationEvents.eventNewIntegration,
}: {
  query: any;
  getSlackAccessToken?: (
    code: string,
    clientId: string,
    clientSecret: string
  ) => Promise<any>;
  fetchTeamInfo?(token: string): Promise<any>;
  eventNewIntegration?(event: integrationEvents.NewMessageEvent): Promise<void>;
})

import { prisma } from '@linen/database';

export async function newSlackIntegration({
  query,
  getSlackAccessToken = api.getSlackAccessToken,
  fetchTeamInfo = api.fetchTeamInfo,
  eventNewIntegration = integrationEvents.eventNewIntegration,
}: {
  query: any;
  getSlackAccessToken?: (
    code: string,
    clientId: string,
    clientSecret: string
  ) => Promise<any>;
  fetchTeamInfo?(token: string): Promise<any>;
  eventNewIntegration?(event: integrationEvents.NewMessageEvent): Promise<void>;
}) {
  const accountId = query.state;

  const account = await prisma.accounts.findUnique({
    where: { id: accountId },
  });

  if (!account) {
    return 'https://www.linen.dev/500?error=account-not-found';
  }

  const url = getHomeUrl(serializeAccount(account) as SerializedAccount);

  try {
    if (query.error) {
      throw query.error;
    }

    const code = query.code;
    const accountId = query.state as string;
    const clientId = process.env.NEXT_PUBLIC_SLACK_CLIENT_ID;
    const clientSecret = process.env.SLACK_CLIENT_SECRET;

    const resp = await getSlackAccessToken(
      code as string,
      clientId as string,
      clientSecret as string
    );

    const body: SlackAuthorizationResponse = resp.body;
    if (!body.ok) {
      throw body;
    }

    const teamInfoResponse = await fetchTeamInfo(body.access_token);
    const communityUrl = teamInfoResponse?.body?.team?.url;

    const account = await prisma.accounts.update({
      where: {
        id: accountId,
      },
      data: {
        slackTeamId: body.team.id,
        communityUrl,