Function createCatalogApiRouter

server/src/routes/catalog-api.ts:60–577

(config: CatalogApiConfig)

// ── Router factory ──────────────────────────────────────────────

export function createCatalogApiRouter(config: CatalogApiConfig): Router {
  const router = Router();
  const { requireAuth: authMiddleware, requireAdmin: adminAuthMiddleware } = config;

  // ── POST /api/registry/resolve ──────────────────────────────

  router.post('/resolve', async (req, res) => {
    try {
      const parsed = ResolveRequestSchema.safeParse(req.body);
      if (!parsed.success) {
        return res.status(400).json({ error: 'Invalid request', details: parsed.error.issues });
      }

      const { identifiers, provenance, mode } = parsed.data;

      // resolve mode requires authentication
      if (mode === 'resolve' && !req.user) {
        return res.status(401).json({ error: 'Authentication required for resolve mode' });
      }

      const memberId = req.user?.email ?? 'anonymous';
      const result = await catalogDb.resolveIdentifiers(
        identifiers,
        mode as ResolveMode,
        memberId,
        provenance as Provenance
      );

      return res.json(result);
    } catch (err) {
      logger.error(`Resolve error: ${err instanceof Error ? err.message : String(err)}`);
      return res.status(500).json({ error: 'Internal server error' });
    }
  });

  // ── GET /api/registry/catalog ───────────────────────────────

  router.get('/catalog', async (req, res) => {
    try {
      const filters = {
        classification: req.query.classification as string | undefined,
        source: req.query.source as string | undefined,
        status: req.query.status as string | undefined,
        identifier_type: req.query.identifier_type as string | undefined,
        search: req.query.search as string | undefined,
        min_resolves: req.query.min_resolves ? parseInt(req.query.min_resolves as string, 10) : undefined,
        active_since: req.query.active_since as string | undefined,
        limit: req.query.limit ? parseInt(req.query.limit as string, 10) : undefined,
        cursor: req.query.cursor as string | undefined,
      };

      const result = await catalogDb.listProperties(filters);

      // For each property, include its identifiers
      const entries = await Promise.all(
        result.properties.map(async (prop) => {
          const full = await catalogDb.getProperty(prop.property_rid);
          return {