Function setupAnalysisHandler

apps/hash-api/src/analysis/setup-analysis-handler.ts:54–105

(app: Express, cache: Keyv)

 * storage (the data plane). Artifact bytes never pass through the API.
 */
export const setupAnalysisHandler = (app: Express, cache: Keyv) => {
  ensureAnalysesRegistered();

  app.post("/api/analysis", analysisRateLimiter, async (req, res) => {
    const { user } = req;
    if (!user) {
      res.status(401).json({ error: "Authentication required" });
      return;
    }

    const body = req.body as AnalysisRequest | undefined;
    if (!body || !Array.isArray(body.requests)) {
      res.status(400).json({
        error: "Request body must be { requests: AnalysisInvocation[] }",
      });
      return;
    }

    if (body.requests.length > MAX_BATCH_SIZE) {
      res
        .status(400)
        .json({ error: `Too many requests (max ${MAX_BATCH_SIZE})` });
      return;
    }

    const { graphApi, uploadProvider } = req.context;

    const results = await Promise.all(
      body.requests.map((invocation) =>
        resolveInvocation({
          invocation,
          actorId: user.accountId,
          graphApi,
          uploadProvider,
          cache,
        }),
      ),
    );

    for (const [index, result] of results.entries()) {
      const invocation = body.requests[index]!;
      telemetry.track(req, "analysis_run", {
        analysis: invocation.analysis,
        webId: invocation.webId,
        status: result.status,
        artifactCount: result.artifacts?.length ?? 0,
      });
    }

    res.json({ results } satisfies AnalysisResponse);
  });
};