open-api-global-agent-invoke.test.js
2.56 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
/**
* POST /api/open/agents/:agentId/invoke — 全局 agent 的外部调用入口（不挂公司）。
* 只测路由层的同步校验分支（task 必填 / 拒绝 companyId:role 形态 / 本体不存在 404），
* 不触发真正的 AgentManager 执行（跟同文件里未测的 company-scoped 版本同一个覆盖范围）。
*/
import { describe, it, expect, beforeAll, afterAll } from 'vitest';
import express from 'express';
import http from 'http';
process.env.OPEN_API_KEYS = 'test-open-api-key';
let app, server, baseUrl;
function request(method, urlPath, body) {
return new Promise((resolve, reject) => {
const opts = {
method,
hostname: '127.0.0.1',
port: server.address().port,
path: urlPath,
headers: { 'Content-Type': 'application/json', 'X-API-Key': 'test-open-api-key' },
};
const req = http.request(opts, (res) => {
let data = '';
res.on('data', (d) => (data += d));
res.on('end', () => {
try { resolve({ status: res.statusCode, data: JSON.parse(data) }); }
catch { resolve({ status: res.statusCode, data }); }
});
});
req.on('error', reject);
if (body) req.write(JSON.stringify(body));
req.end();
});
}
describe('POST /api/open/agents/:agentId/invoke', () => {
beforeAll(async () => {
const openApiRouter = require('../../routes/open-api.js');
app = express();
app.use(express.json());
app.use('/api/open', openApiRouter);
await new Promise((resolve) => {
server = http.createServer(app).listen(0, resolve);
});
baseUrl = `http://127.0.0.1:${server.address().port}`;
});
afterAll(() => new Promise((resolve) => server.close(resolve)));
it('缺 task 字段 → 400', async () => {
const res = await request('POST', '/api/open/agents/master/invoke', {});
expect(res.status).toBe(400);
expect(res.data.error).toBe('Bad Request');
});
it('agentId 带 companyId: 前缀 → 400（提示改走 company-scoped 端点）', async () => {
const res = await request('POST', '/api/open/agents/acme:coo/invoke', { task: 'hi' });
expect(res.status).toBe(400);
expect(res.data.message).toMatch(/global agents only/);
});
it('本体不存在 → 404', async () => {
const res = await request('POST', '/api/open/agents/does-not-exist-xyz/invoke', { task: 'hi' });
expect(res.status).toBe(404);
});
// 202 成功路径不在这里测：请求一进来就会同步触发 _runGlobalAgentInvocation 起真实
// claude CLI 子进程（跟未测的 company-scoped 版本同一套执行路径），不适合放单测。
});