Function sessionLogPlugin

demo/server/session-log.ts:84–166

()

}

export function sessionLogPlugin(): Plugin {
  return {
    name: "chat-session-log",
    configureServer(server) {
      server.middlewares.use(async (req, res, next) => {
        const url = new URL(req.url ?? "/", "http://localhost");

        if (url.pathname === "/api/sessions" && req.method === "GET") {
          ensureSessionDir();
          res.setHeader("Content-Type", "application/json");
          res.end(JSON.stringify(listSessionSummaries()));
          return;
        }

        if (url.pathname !== "/api/session") {
          next();
          return;
        }

        ensureSessionDir();

        if (req.method === "GET") {
          const id = url.searchParams.get("id");
          const filePath = id
            ? path.join(SESSION_DIR, `${id}.json`)
            : CURRENT_FILE;

          if (!fs.existsSync(filePath)) {
            res.statusCode = 204;
            res.end();
            return;
          }
          res.setHeader("Content-Type", "application/json");
          res.end(fs.readFileSync(filePath, "utf8"));
          return;
        }

        if (req.method === "POST") {
          try {
            const raw = await readBody(req);
            const session = JSON.parse(raw) as { id?: string };
            if (!session?.id) {
              res.statusCode = 400;
              res.end(JSON.stringify({ error: "session.id required" }));
              return;
            }

            const payload = JSON.stringify(session, null, 2);
            fs.writeFileSync(CURRENT_FILE, payload, "utf8");
            fs.writeFileSync(
              path.join(SESSION_DIR, `${session.id}.json`),
              payload,
              "utf8",
            );

            res.statusCode = 200;
            res.setHeader("Content-Type", "application/json");
            res.end(JSON.stringify({ ok: true, path: SESSION_DIR }));