Function buildHttpServer

src/api/server.ts:113–583

()

});

export function buildHttpServer() {
  const app = Fastify({
    logger: {
      level: config.LOG_LEVEL,
      base: {
        service: "sag"
      }
    }
  });

  app.get("/health", async () => ({
    ok: true,
    service: "sag"
  }));

  app.get("/api/model-call-logs", async (request) => {
    const query = request.query as { after?: string };
    const after = query.after ? Number(query.after) : 0;
    return listModelCallLogs(Number.isFinite(after) ? after : 0);
  });

  app.get("/sources", async (request) => {
    const query = request.query as { limit?: string; cursor?: string };
    return {
      sources: await graphService.listSources({
        limit: query.limit ? Number(query.limit) : undefined,
        cursor: query.cursor
      })
    };
  });

  app.get("/api/sources", async (request) => {
    const query = request.query as { limit?: string; cursor?: string };
    return {
      sources: await webuiService.listSources({
        limit: query.limit ? Number(query.limit) : undefined,
        cursor: query.cursor
      })
    };
  });

  app.get("/api/projects", async (request) => {
    const query = request.query as { limit?: string; cursor?: string; includeArchived?: string };
    return {
      projects: await webuiService.listProjects({
        limit: query.limit ? Number(query.limit) : undefined,
        cursor: query.cursor,
        includeArchived: query.includeArchived === "true"
      })
    };
  });

  app.post("/api/projects", async (request, reply) => {
    const input = projectSchema.parse(request.body);
    const project = await webuiService.createProject(input);
    return reply.code(201).send({ project });
  });