Function createContentRouter

server/src/routes/content.ts:985–1376

()

 * Returns a router to be mounted at /api/content
 */
export function createContentRouter(): Router {
  const router = Router();

  // GET /api/content/collections - Get available collections for content submission
  router.get('/collections', requireAuth, async (req, res) => {
    try {
      const user = req.user!;
      const pool = getPool();

      // Get public collections (anyone can submit)
      const publicResult = await pool.query(
        `SELECT id, slug, name, description
         FROM working_groups
         WHERE accepts_public_submissions = TRUE
         ORDER BY name`
      );

      // Get committees user is a member of (non-public ones)
      // Join with slack_user_mappings to handle users who were added as leader via Slack ID
      const memberResult = await pool.query(
        `SELECT wg.id, wg.slug, wg.name, wg.description,
                EXISTS(
                  SELECT 1 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
                  WHERE wgl.working_group_id = wg.id AND (wgl.user_id = $1 OR sm.workos_user_id = $1)
                ) as is_leader
         FROM working_group_memberships wgm
         JOIN working_groups wg ON wg.id = wgm.working_group_id
         WHERE wgm.workos_user_id = $1
           AND wg.accepts_public_submissions = FALSE
         ORDER BY wg.name`,
        [user.id]
      );

      const collections = [
        ...publicResult.rows.map(row => ({
          slug: row.slug,
          name: row.name,
          description: row.description,
          type: 'public' as const,
          can_publish_directly: false, // Public collections always require approval
        })),
        ...memberResult.rows.map(row => ({
          slug: row.slug,
          name: row.name,
          description: row.description,
          type: 'committee' as const,
          can_publish_directly: row.is_leader,
        })),
      ];

      res.json({ collections });
    } catch (error) {
      logger.error({ err: error }, 'GET /api/content/collections error');
      res.status(500).json({
        error: 'Failed to get collections',
      });
    }