Function notifyPendingReview

server/src/routes/content.ts:150–308

* Notify reviewers that content has entered pending_review. * * Posts to both (a) the working group's Slack channel if one is configured * (keeps WG-specific review flows working) and (b) the system-wide editorial * review channel if one is configured (central queue for admins and * committee l

(
  workingGroupId: string,
  perspective: {
    id: string;
    title: string;
    slug: string;
    excerpt: string | null;
    content_type: string;
    content: string | null;
    proposed_at: string;
  },
  authorName: string,
  proposerUserId: string
)

 * that's fine, we just skip what's missing.
 */
async function notifyPendingReview(
  workingGroupId: string,
  perspective: {
    id: string;
    title: string;
    slug: string;
    excerpt: string | null;
    content_type: string;
    content: string | null;
    proposed_at: string;
  },
  authorName: string,
  proposerUserId: string
): Promise<void> {
  const pool = getPool();

  // Fetch the working group, committee leads, and channel config in one
  // round-trip so we can enrich the message with lead names. The leads
  // query only surfaces WorkOS-linked users — slack-only leads (leaders
  // added by Slack ID before mapping) won't appear in the `*Leads:*` line.
  // That matches the current data-integrity requirement; a reviewer seeing
  // a missing leads line just means the committee has unmapped leads.
  const [wgResult, leadersResult, editorialChannel] = await Promise.all([
    pool.query(
      `SELECT name, slack_channel_id FROM working_groups WHERE id = $1`,
      [workingGroupId]
    ),
    pool.query(
      `SELECT u.first_name, u.last_name, u.email
         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
         LEFT JOIN users u ON u.workos_user_id = COALESCE(sm.workos_user_id, wgl.user_id)
         WHERE wgl.working_group_id = $1
           AND u.workos_user_id IS NOT NULL
         LIMIT 10`,
      [workingGroupId]
    ),
    getEditorialChannel(),
  ]);

  if (wgResult.rows.length === 0) {
    logger.warn({ workingGroupId }, 'Working group not found for pending-review notification');
    return;
  }

  const { name: wgName, slack_channel_id: wgChannelId } = wgResult.rows[0];
  const editorialChannelId = editorialChannel.channel_id;

  if (!wgChannelId && !editorialChannelId) {
    logger.debug({ workingGroupId }, 'No Slack channels configured for pending-review notification');
    return;
  }

  const leadNames: string[] = leadersResult.rows
    .map(r => (r.first_name && r.last_name ? `${r.first_name} ${r.last_name}` : r.email?.split('@')[0] || null))
    .filter((n): n is string => !!n);

  const safeTitle = escapeSlackText(perspective.title, 180);