Function handler

apps/web/pages/api/integration-oauth.ts:61–104

(
  request: NextApiRequest,
  response: NextApiResponse
)

}

export default async function handler(
  request: NextApiRequest,
  response: NextApiResponse
) {
  if (request.method === 'OPTIONS') {
    return preflight(request, response, ['GET']);
  }
  cors(request, response);

  const schema = z.object({
    community: z.enum(['discord', 'slack']),
    accountId: z.string().uuid(),
    syncOpt: z.enum(['since-all', 'since-date']).optional(),
    dateFrom: z.string().optional(),
  });

  const body = schema.parse(request.query);

  const permissions = await PermissionsService.get({
    request,
    response,
    params: {
      communityId: body.accountId,
    },
  });
  if (!permissions.manage) {
    throw new Error('Unauthorized');
  }

  if (body.syncOpt === 'since-date' && body.dateFrom) {
    const syncFrom = new Date(body.dateFrom);

    if (body.community === 'slack') {
      await handleSlack({ accountId: body.accountId, syncFrom });
    }
    if (body.community === 'discord') {
      await handleDiscord({ accountId: body.accountId, syncFrom });
    }
  }

  return response.json({
    url: integrationAuthorizer(body.community, body.accountId),
  });
}

async function handleSlack({
  accountId,