Confused-AIProduction Ready AI Agents, Shipped in TypeScript

import { createAgent, defineTool } from 'confused-ai';
import { createSqliteSessionStore } from 'confused-ai/session';
import { KnowledgeEngine, TextLoader, InMemoryVectorStore } from 'confused-ai/knowledge';
import { OpenAIEmbeddingProvider } from 'confused-ai/memory';
import { GuardrailValidator, createSensitiveDataRule } from 'confused-ai/guardrails';
import { createHttpService, listenService } from 'confused-ai/serve';
import { z } from 'zod';

// 1. Knowledge base from your docs
const knowledge = new KnowledgeEngine({
  embeddingProvider: new OpenAIEmbeddingProvider({ apiKey: process.env.OPENAI_API_KEY! }),
  vectorStore: new InMemoryVectorStore(),
});
await knowledge.ingest(await new TextLoader('./docs/policy.md').load());

// 2. Sessions, guardrails, and a custom tool
const sessions  = createSqliteSessionStore('./data/sessions.db');
const guardrails = new GuardrailValidator({ rules: [createSensitiveDataRule()] });

const lookupOrder = defineTool()
  .name('lookupOrder')
  .description('Look up an order by ID')
  .parameters(z.object({ orderId: z.string() }))
  .execute(async ({ orderId }) => db.orders.findById(orderId))
  .build();

// 3. One agent — everything wired up
const support = createAgent({
  name:         'SupportBot',
  instructions: 'You are a helpful support agent. Use the knowledge base for policies.',
  model: openai('gpt-4o-mini'),
  tools:        [lookupOrder],
  sessionStore: sessions,
  knowledgebase: knowledge,
  guardrails,
  budget:       { maxUsdPerRun: 0.10 },
  hooks: {
    afterRun: async (result) => {
      await analytics.track('support_run', { steps: result.steps });
      return result;
    },
  },
});

// 4. Serve over HTTP with OpenAPI, SSE streaming, and HITL approval endpoints
const service = createHttpService({
  agents: { support },
  openApi: { title: 'SupportBot API', version: '1.0.0' },
});

listenService(service, { port: 3000 });
// → GET  /v1/openapi.json
// → POST /v1/agents/support/run
// → GET  /v1/approvals        (pending HITL requests)
// → POST /v1/approvals/:id    (approve/reject)