Manage agent configuration

mkdir agentium-admin-demo
cd agentium-admin-demo
npm init -y
npm pkg set type=module
npm install @agentium/core@4.0.0 @agentium/admin@4.0.0 @agentium/transport@4.0.0 express@5 better-sqlite3@11
npm install --save-dev typescript tsx @types/node @types/express

import express, { type RequestHandler } from "express";
import { Agent, modelRegistry, registry, SqliteStorage, type ModelProvider } from "@agentium/core";
import { createAdminRouter } from "@agentium/admin";
import { createAgentRouter } from "@agentium/transport";

const token = process.env.ADMIN_TOKEN;
if (!token) throw new Error("Set ADMIN_TOKEN before starting the demo");

// A local fixture proves configuration, routing, and persistence, not AI quality.
modelRegistry.register("fixture", (modelId): ModelProvider => ({
  providerId: "fixture",
  modelId,
  async generate() {
    return {
      message: { role: "assistant", content: "Your configured Agent is reachable." },
      usage: { promptTokens: 0, completionTokens: 0, totalTokens: 0 },
      finishReason: "stop",
      raw: null,
    };
  },
  async *stream() {
    yield { type: "text", text: "Your configured Agent is reachable." };
    yield { type: "finish", finishReason: "stop" };
  },
}));

const requireOperator: RequestHandler = (req, res, next) => {
  if (req.get("authorization") !== `Bearer ${token}`) {
    res.status(401).json({ error: "Operator credentials required" });
    return;
  }
  next();
};

const storage = new SqliteStorage("admin-demo.db");
const { router, hydrate } = createAdminRouter({ storage });
console.log("Restored configuration:", await hydrate());

const app = express();
app.use(express.json({ limit: "64kb" }));
app.use("/admin", requireOperator, router);
app.use("/api", requireOperator, createAgentRouter({ security: { mode: "local" } }));

const server = app.listen(3000, "127.0.0.1", () => {
  console.log("Operator API: http://127.0.0.1:3000/admin");
});

let stopping = false;
async function shutdown() {
  if (stopping) return;
  stopping = true;
  try {
    await new Promise<void>((resolve, reject) => {
      server.close((error) => error ? reject(error) : resolve());
    });
    for (const agent of registry.agents.values()) {
      if (agent instanceof Agent) await agent.close({ closeStorage: false });
    }
  } finally {
    await storage.close();
  }
}
for (const signal of ["SIGINT", "SIGTERM"] as const) {
  process.once(signal, () => {
    void shutdown().catch((error: unknown) => {
      console.error(error);
      process.exitCode = 1;
    });
  });
}

export ADMIN_TOKEN="local-demo-operator"
npx tsc --noEmit --strict --skipLibCheck --target ES2022 --module NodeNext --moduleResolution NodeNext server.ts
npx tsx server.ts

export ADMIN_TOKEN="local-demo-operator"
curl -i http://127.0.0.1:3000/admin/agents
curl -i http://127.0.0.1:3000/admin/agents \
  -H "Authorization: Bearer $ADMIN_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"name":"support","provider":"fixture","model":"local-v1","instructions":"Help with support requests."}'
curl http://127.0.0.1:3000/api/agents/support/run \
  -H "Authorization: Bearer $ADMIN_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"input":"Is my configured Agent available?"}'

curl http://127.0.0.1:3000/admin/agents -H "Authorization: Bearer $ADMIN_TOKEN"

import { createAdminRouter } from "@agentium/admin";
import { collectToolkitTools, type StorageDriver } from "@agentium/core";
import { CalculatorToolkit } from "@agentium/core/toolkits";

export function configureAdmin(storage: StorageDriver) {
  return createAdminRouter({
    storage,
    toolLibrary: collectToolkitTools([new CalculatorToolkit()]),
  });
}