15 分钟构建一个支持 RGB 的本地 AI 代理

import { createInterface } from 'node:readline/promises';
import { completion, cancel, loadModel, QWEN3_600M_INST_Q4 } from '@qvac/sdk';
import { Funnel, ToolRegistry, confirmReadback } from '@kaleidorg/mind';
import { McpToolSource } from '@kaleidorg/mind/mcp';
import { createQvacProvider } from '@kaleidorg/mind/qvac';

// 1. 通过 stdio 启动运行在 signet 上的 kaleido-mcp
const kaleido = new McpToolSource({
  id: 'kaleido',
  transport: {
    kind: 'stdio',
    command: 'npx',
    args: ['-y', 'kaleido-mcp'],
    env: {
      PATH: process.env.PATH,
      HOME: process.env.HOME,
      KALEIDO_NETWORK: 'signet',
      RLN_NODE_URL: 'http://localhost:3001',
    },
  },
});
await kaleido.connect();

// 2. 通过 QVAC 加载本地模型（首次运行时下载）
const modelId = await loadModel({
  modelSrc: QWEN3_600M_INST_Q4,
  modelType: 'llm',
  modelConfig: { ctx_size: 8192, tools: true },
});
const provider = createQvacProvider({ completion, cancel, getModelId: () => modelId });

// 3. 分层漏斗，任何花费之前都会弹出确认
const funnel = new Funnel({ provider, tools: new ToolRegistry([kaleido]) });
const rl = createInterface({ input: process.stdin, output: process.stdout });

while (true) {
  const text = await rl.question('\n> ');
  if (!text.trim()) continue;
  const out = await funnel.runTurn(text, {
    onConfirm: async (call) => {
      const answer = await rl.question(`${confirmReadback(call)} [y/N] `);
      return { approved: answer.trim().toLowerCase() === 'y' };
    },
  });
  console.log(out.text);
}

import { Funnel, confirmReadback } from '@kaleidorg/mind';
import { MockWallet, scriptedProvider } from '@kaleidorg/mind/testing';

const wallet = new MockWallet();
const funnel = new Funnel({ provider: scriptedProvider(), tools: wallet.registry() });

const out = await funnel.runTurn('what is my balance?', {
  onConfirm: async (call) => {
    console.log(confirmReadback(call));
    return { approved: true };
  },
});
console.log(out.text);