mirror of
https://github.com/catlog22/Claude-Code-Workflow.git
synced 2026-02-05 01:50:27 +08:00
- Added integration tests for adaptive RRF weights in hybrid search. - Enhanced query intent detection with new classifications: keyword, semantic, and mixed. - Introduced symbol boosting in search results based on explicit symbol matches. - Implemented embedding-based reranking with configurable options. - Added global symbol index for efficient symbol lookups across projects. - Improved file deletion handling on Windows to avoid permission errors. - Updated chunk configuration to increase overlap for better context. - Modified package.json test script to target specific test files. - Created comprehensive writing style guidelines for documentation. - Added TypeScript tests for query intent detection and adaptive weights. - Established performance benchmarks for global symbol indexing.
161 lines
4.3 KiB
JavaScript
161 lines
4.3 KiB
JavaScript
/**
|
|
* Basic MCP server tests
|
|
* Tests the MCP server functionality with mock requests
|
|
*/
|
|
|
|
import { describe, it, before, after } from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import { spawn } from 'node:child_process';
|
|
import { fileURLToPath } from 'node:url';
|
|
import { dirname, join } from 'node:path';
|
|
|
|
const __filename = fileURLToPath(import.meta.url);
|
|
const __dirname = dirname(__filename);
|
|
|
|
describe('MCP Server', () => {
|
|
let serverProcess;
|
|
|
|
before(async () => {
|
|
// Start the MCP server
|
|
const serverPath = join(__dirname, '../bin/ccw-mcp.js');
|
|
serverProcess = spawn('node', [serverPath], {
|
|
stdio: ['pipe', 'pipe', 'pipe']
|
|
});
|
|
|
|
// Wait for server to start
|
|
await new Promise((resolve) => {
|
|
serverProcess.stderr.once('data', (data) => {
|
|
const message = data.toString();
|
|
if (message.includes('started')) {
|
|
resolve();
|
|
}
|
|
});
|
|
});
|
|
});
|
|
|
|
after(() => {
|
|
if (serverProcess) {
|
|
serverProcess.kill();
|
|
}
|
|
});
|
|
|
|
it('should respond to tools/list request', async () => {
|
|
const request = {
|
|
jsonrpc: '2.0',
|
|
id: 1,
|
|
method: 'tools/list',
|
|
params: {}
|
|
};
|
|
|
|
// Send request
|
|
serverProcess.stdin.write(JSON.stringify(request) + '\n');
|
|
|
|
// Wait for response
|
|
const response = await new Promise((resolve, reject) => {
|
|
const timeout = setTimeout(() => {
|
|
reject(new Error('Request timeout'));
|
|
}, 5000);
|
|
|
|
serverProcess.stdout.once('data', (data) => {
|
|
clearTimeout(timeout);
|
|
try {
|
|
const response = JSON.parse(data.toString());
|
|
resolve(response);
|
|
} catch (error) {
|
|
reject(error);
|
|
}
|
|
});
|
|
});
|
|
|
|
assert.equal(response.jsonrpc, '2.0');
|
|
assert.equal(response.id, 1);
|
|
assert(response.result);
|
|
assert(Array.isArray(response.result.tools));
|
|
assert(response.result.tools.length > 0);
|
|
|
|
// Check that essential tools are present
|
|
const toolNames = response.result.tools.map(t => t.name);
|
|
assert(toolNames.includes('edit_file'));
|
|
assert(toolNames.includes('write_file'));
|
|
assert(toolNames.includes('smart_search'));
|
|
});
|
|
|
|
it('should respond to tools/call request', async () => {
|
|
const request = {
|
|
jsonrpc: '2.0',
|
|
id: 2,
|
|
method: 'tools/call',
|
|
params: {
|
|
name: 'get_modules_by_depth',
|
|
arguments: {}
|
|
}
|
|
};
|
|
|
|
// Send request
|
|
serverProcess.stdin.write(JSON.stringify(request) + '\n');
|
|
|
|
// Wait for response
|
|
const response = await new Promise((resolve, reject) => {
|
|
const timeout = setTimeout(() => {
|
|
reject(new Error('Request timeout'));
|
|
}, 5000);
|
|
|
|
serverProcess.stdout.once('data', (data) => {
|
|
clearTimeout(timeout);
|
|
try {
|
|
const response = JSON.parse(data.toString());
|
|
resolve(response);
|
|
} catch (error) {
|
|
reject(error);
|
|
}
|
|
});
|
|
});
|
|
|
|
assert.equal(response.jsonrpc, '2.0');
|
|
assert.equal(response.id, 2);
|
|
assert(response.result);
|
|
assert(Array.isArray(response.result.content));
|
|
assert(response.result.content.length > 0);
|
|
assert.equal(response.result.content[0].type, 'text');
|
|
});
|
|
|
|
it('should handle invalid tool name gracefully', async () => {
|
|
const request = {
|
|
jsonrpc: '2.0',
|
|
id: 3,
|
|
method: 'tools/call',
|
|
params: {
|
|
name: 'nonexistent_tool',
|
|
arguments: {}
|
|
}
|
|
};
|
|
|
|
// Send request
|
|
serverProcess.stdin.write(JSON.stringify(request) + '\n');
|
|
|
|
// Wait for response
|
|
const response = await new Promise((resolve, reject) => {
|
|
const timeout = setTimeout(() => {
|
|
reject(new Error('Request timeout'));
|
|
}, 5000);
|
|
|
|
serverProcess.stdout.once('data', (data) => {
|
|
clearTimeout(timeout);
|
|
try {
|
|
const response = JSON.parse(data.toString());
|
|
resolve(response);
|
|
} catch (error) {
|
|
reject(error);
|
|
}
|
|
});
|
|
});
|
|
|
|
assert.equal(response.jsonrpc, '2.0');
|
|
assert.equal(response.id, 3);
|
|
assert(response.result);
|
|
assert.equal(response.result.isError, true);
|
|
// Error could be "not enabled" (filtered by default tools) or "not found" (all tools enabled)
|
|
assert(response.result.content[0].text.includes('not enabled') || response.result.content[0].text.includes('not found'));
|
|
});
|
|
});
|