Function openRouterChatPlugin

demo/server/openrouter-chat.ts:247–301

(env: Record<string, string>)

}

export function openRouterChatPlugin(env: Record<string, string>): Plugin {
  return {
    name: "openrouter-chat-api",
    configureServer(server) {
      server.middlewares.use(async (req, res, next) => {
        if (req.url !== "/api/chat" || req.method !== "POST") {
          next();
          return;
        }

        const apiKey = env.OPENROUTER_API_KEY;
        const model = env.MODEL_NAME;

        if (!apiKey || !model) {
          res.statusCode = 500;
          res.setHeader("Content-Type", "application/json");
          res.end(
            JSON.stringify({
              error:
                "Missing OPENROUTER_API_KEY or MODEL_NAME in .env (project root)",
            }),
          );
          return;
        }

        try {
          const raw = await readBody(req);
          const { messages } = JSON.parse(raw) as {
            messages?: { role: string; content: string }[];
          };

          if (!Array.isArray(messages) || messages.length === 0) {
            res.statusCode = 400;
            res.end(JSON.stringify({ error: "messages array required" }));
            return;
          }

          await pipeOpenRouterStream(res, apiKey, model, messages);
        } catch (err) {
          if (!res.headersSent) {
            res.statusCode = 500;
            res.setHeader("Content-Type", "application/json");
            res.end(
              JSON.stringify({
                error: err instanceof Error ? err.message : "Chat failed",
              }),
            );
          } else {
            res.end();
          }
        }
      });
    },
  };
}