Function approveContentForUser

server/src/routes/content.ts:788–908

(
  user: ContentUser,
  contentId: string,
  opts: { publishImmediately?: boolean } = {}
)

 * Approve pending content - direct function call (no HTTP required).
 */
export async function approveContentForUser(
  user: ContentUser,
  contentId: string,
  opts: { publishImmediately?: boolean } = {}
): Promise<ContentReviewResult> {
  const publishImmediately = opts.publishImmediately ?? true;
  const pool = getPool();

  const contentResult = await pool.query(
    `SELECT p.*, wg.slug as committee_slug, wg.name as committee_name, wg.slack_channel_id
     FROM perspectives p
     LEFT JOIN working_groups wg ON wg.id = p.working_group_id
     WHERE p.id = $1`,
    [contentId]
  );

  if (contentResult.rows.length === 0) {
    return { success: false, error: 'not_found', error_message: `No content found with id: ${contentId}` };
  }

  const content = contentResult.rows[0];

  if (content.status !== 'pending_review') {
    return {
      success: false,
      error: 'invalid_status',
      error_message: `Content is not pending review (current status: ${content.status})`,
    };
  }

  const userIsAdmin = await isWebUserAAOAdmin(user.id);
  const userIsLead = content.working_group_id
    ? await isCommitteeLead(content.working_group_id, user.id)
    : false;

  if (!userIsAdmin && !userIsLead) {
    return {
      success: false,
      error: 'permission_denied',
      error_message: 'You do not have permission to approve this content',
    };
  }

  const newStatus: 'published' | 'draft' = publishImmediately ? 'published' : 'draft';
  const publishedAt = publishImmediately ? new Date().toISOString() : null;

  await pool.query(
    `UPDATE perspectives
     SET status = $1, published_at = $2,
         reviewed_by_user_id = $3, reviewed_at = NOW()
     WHERE id = $4`,
    [newStatus, publishedAt, user.id, contentId]
  );

  logger.info({
    contentId,
    reviewerId: user.id,
    newStatus,