Method handleRequest

src/vector-mock.ts:75–116

(
    req: http.IncomingMessage,
    res: http.ServerResponse,
    pathname: string,
  )

  // ---- Mountable interface ----

  async handleRequest(
    req: http.IncomingMessage,
    res: http.ServerResponse,
    pathname: string,
  ): Promise<boolean> {
    // Only consume the request body for methods that carry a body,
    // avoiding double-consumption when the route doesn't match.
    let parsed: Record<string, unknown> = {};
    if (req.method !== "GET" && req.method !== "DELETE" && req.method !== "HEAD") {
      const body = await readBody(req);
      try {
        if (body) parsed = JSON.parse(body);
      } catch (parseErr) {
        const detail = parseErr instanceof Error ? parseErr.message : "unknown";
        res.writeHead(400, { "Content-Type": "application/json" });
        res.end(JSON.stringify({ error: `Malformed JSON body: ${detail}` }));
        return true;
      }
    }

    const handled = this.requestHandler(req, res, pathname, parsed);

    // Record vector operation metric
    if (handled && this.registry) {
      const { operation, provider } = classifyVectorRequest(req.method ?? "GET", pathname);
      this.registry.incrementCounter("aimock_vector_requests_total", { operation, provider });
    }

    // Journal the request after the handler completes
    if (handled && this.journal) {
      this.journal.add({
        method: req.method ?? "GET",
        path: req.url ?? "/",
        headers: flattenHeaders(req.headers),
        body: null,
        service: "vector",
        response: { status: res.statusCode, fixture: null },
      });
    }

    return handled;
  }

  health(): { status: string; collections: number } {
    return {