Function listPendingContentForUser

server/src/routes/content.ts:683–769

(
  user: ContentUser,
  opts: { committeeSlug?: string } = {}
)

 * Admins see all pending content; committee leads see only their committees' pending items.
 */
export async function listPendingContentForUser(
  user: ContentUser,
  opts: { committeeSlug?: string } = {}
): Promise<PendingContentResult> {
  const pool = getPool();
  const { committeeSlug } = opts;

  // Committees this user leads (direct workos_user_id or via slack mapping)
  const leaderResult = await pool.query(
    `SELECT wg.id
     FROM working_group_leaders wgl
     LEFT JOIN slack_user_mappings sm ON wgl.user_id = sm.slack_user_id AND sm.workos_user_id IS NOT NULL
     JOIN working_groups wg ON wg.id = wgl.working_group_id
     WHERE wgl.user_id = $1 OR sm.workos_user_id = $1`,
    [user.id]
  );
  const ledCommitteeIds = leaderResult.rows.map(c => c.id);
  const userIsAdmin = await isWebUserAAOAdmin(user.id);

  if (!userIsAdmin && ledCommitteeIds.length === 0) {
    return { items: [], summary: { total: 0, by_collection: {} } };
  }

  let query = `
    SELECT
      p.id, p.title, p.subtitle, p.excerpt, p.content, p.slug, p.content_type,
      p.external_url, p.external_site_name,
      p.proposer_user_id, p.proposed_at, p.working_group_id,
      wg.name as committee_name, wg.slug as committee_slug,
      u.first_name, u.last_name, u.email as proposer_email,
      (SELECT json_agg(json_build_object(
        'user_id', ca.user_id,
        'display_name', ca.display_name
      ) ORDER BY ca.display_order)
      FROM content_authors ca WHERE ca.perspective_id = p.id) as authors
    FROM perspectives p
    LEFT JOIN working_groups wg ON wg.id = p.working_group_id
    LEFT JOIN users u ON u.workos_user_id = p.proposer_user_id
    WHERE p.status = 'pending_review'
  `;
  const params: (string | string[])[] = [];

  if (!userIsAdmin) {
    params.push(ledCommitteeIds);
    query += ` AND p.working_group_id = ANY($${params.length})`;
  }
  if (committeeSlug) {
    params.push(committeeSlug);
    query += ` AND wg.slug = $${params.length}`;
  }
  query += ` ORDER BY p.proposed_at ASC`;

  const result = await pool.query(query, params);

  const items: PendingContentItem[] = result.rows.map(row => ({
    id: row.id,
    title: row.title,
    subtitle: row.subtitle,