Skip to content

VCP内部论坛巡航 (VCPForumAssistant)的优化及BUG修复 #278

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
TaoCultivator wants to merge 1 commit into from
Closed

VCP内部论坛巡航 (VCPForumAssistant)的优化及BUG修复 #278

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
67 changes: 57 additions & 10 deletions Plugin/AgentAssistant/AgentAssistant.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -286,6 +286,37 @@ function parseAndValidateDate(dateString) {
return date;
}

function _buildInjectedToolDescriptions(injectToolsStr) {
try {
const pluginManager = require('../../Plugin.js');
const toolNames = injectToolsStr.split(',').map(s => s.trim()).filter(Boolean);
const sections = [];

for (const toolName of toolNames) {
const plugin = pluginManager.getPlugin(toolName);
if (!plugin) {
console.warn(`[AgentAssistant] inject_tools: plugin "${toolName}" not found, skipped`);
continue;
}
const commands = plugin.capabilities?.invocationCommands;
if (!Array.isArray(commands) || commands.length === 0) {
console.warn(`[AgentAssistant] inject_tools: plugin "${toolName}" has no invocationCommands, skipped`);
continue;
}
let section = `=== ${plugin.displayName || toolName} 工具 ===\n`;
for (const cmd of commands) {
if (cmd.description) section += cmd.description + '\n\n';
}
sections.push(section.trim());
}

return sections.length > 0 ? sections.join('\n\n') : null;
} catch (e) {
console.error('[AgentAssistant] inject_tools error:', e.message);
return null;
}
}

/**
* This is the main entry point for handling tool calls from PluginManager.
* @param {object} args - The arguments for the tool call.
Expand All @@ -298,7 +329,7 @@ async function processToolCall(args) {
return { status: "error", error: errorMsg };
}

const { agent_name, prompt, timely_contact, temporary_contact, maid, task_delegation, query_delegation } = args;
const { agent_name, prompt, timely_contact, temporary_contact, maid, task_delegation, query_delegation, inject_tools } = args;

// Handle querying a delegation status
if (query_delegation) {
Expand Down Expand Up @@ -456,7 +487,10 @@ async function processToolCall(args) {
try {
// 注入来源提示词，防止 AI 之间产生“套娃”式工具调用
const senderName = maid || "系统助手";
const communicationTip = `[Tips:这是一条来自AgentAssistant通讯中心 ${senderName} 的联络，你可以直接正常回复而无需通过调用AA插件的方式进行回复]\n\n`;
const hasToolInstructions = prompt.includes('<<<[TOOL_REQUEST]>>>') || prompt.includes('<!-- HAS_TOOL_INSTRUCTIONS -->');
const communicationTip = hasToolInstructions
? `[Tips:这是一条来自AgentAssistant通讯中心 ${senderName} 的系统任务联络。注意：你禁止通过调用AgentAssistant来回复此消息，但你应当积极使用消息中提及的其他工具（如VCPForum等）来完成任务。]\n\n`
: `[Tips:这是一条来自AgentAssistant通讯中心 ${senderName} 的联络，你可以直接正常回复而无需通过调用AA插件的方式进行回复]\n\n`;
const finalPrompt = communicationTip + prompt;

const processedUserPrompt = await replacePlaceholdersInUserPrompt(finalPrompt, agentConfig);
Expand All @@ -468,8 +502,17 @@ async function processToolCall(args) {
console.error(`[AgentAssistant Service] Temporary contact requested for ${agent_name}. Skipping context loading.`);
}

let systemPromptForRequest = agentConfig.systemPrompt;
if (inject_tools) {
const toolDesc = _buildInjectedToolDescriptions(inject_tools);
if (toolDesc) {
systemPromptForRequest += '\n\n' + toolDesc;
if (DEBUG_MODE) console.log(`[AgentAssistant] Injected tool descriptions for: ${inject_tools}`);
}
}

const messagesForVCP = [
{ role: 'system', content: agentConfig.systemPrompt },
{ role: 'system', content: systemPromptForRequest },
{ role: 'user', content: processedUserPrompt }
];
if (history.length > 0) {
Expand All @@ -483,19 +526,23 @@ async function processToolCall(args) {
stream: false
};

if (DEBUG_MODE) console.error(`[AgentAssistant Service] Sending request to VCP Server for agent ${agent_name}`);
console.log(`[AgentAssistant] Calling agent '${agent_name}' (model: ${agentConfig.id}, hasToolInstructions: ${hasToolInstructions})`);

const responseFromVCP = await axios.post(`${VCP_API_TARGET_URL}/chat/completions`, payloadForVCP, {
headers: { 'Authorization': `Bearer ${VCP_SERVER_ACCESS_KEY}`, 'Content-Type': 'application/json' },
timeout: (parseInt(process.env.PLUGIN_COMMUNICATION_TIMEOUT) || 118000)
headers: { 'Authorization': `Bearer ${VCP_SERVER_ACCESS_KEY}`, 'Content-Type': 'application/json', 'X-VCP-Internal': 'true' },
timeout: (parseInt(process.env.AGENT_ASSISTANT_API_TIMEOUT) || 300000)
});

const assistantResponseContent = responseFromVCP.data?.choices?.[0]?.message?.content;
if (typeof assistantResponseContent !== 'string') {
if (DEBUG_MODE) console.error("[AgentAssistant Service] Response from VCP Server did not contain valid assistant content for agent " + agent_name, responseFromVCP.data);
console.error(`[AgentAssistant] Agent '${agent_name}' returned invalid response.`, responseFromVCP.data?.choices?.[0]);
return { status: "error", error: `Agent '${agent_name}' 从VCP服务器获取的响应无效或缺失内容。` };
}

const responseLen = assistantResponseContent.length;
const hadToolCalls = assistantResponseContent.includes('<<<[TOOL_REQUEST]>>>');
console.log(`[AgentAssistant] Agent '${agent_name}' responded (length: ${responseLen}, containsToolCalls: ${hadToolCalls})`);

// 移除 VCP 思维链内容
const cleanedAssistantResponse = removeVCPThinkingChain(assistantResponseContent);

Expand Down Expand Up @@ -550,7 +597,7 @@ async function processToolCall(args) {
} else if (error instanceof Error) {
errorMessage += ` ${error.message}`;
}
if (DEBUG_MODE) console.error(`[AgentAssistant Service] Error in processToolCall for ${agent_name}: ${errorMessage}`);
console.error(`[AgentAssistant] Error for ${agent_name}: ${errorMessage}`);
return { status: "error", error: errorMessage };
} finally {
// 确保无论成功或失败，持久对话的锁都会被释放
Expand Down Expand Up @@ -614,8 +661,8 @@ async function executeDelegation(delegationId, agentConfig, taskPrompt, senderNa
};

const responseFromVCP = await axios.post(`${VCP_API_TARGET_URL}/chat/completions`, payloadForVCP, {
headers: { 'Authorization': `Bearer ${VCP_SERVER_ACCESS_KEY}`, 'Content-Type': 'application/json' },
timeout: (parseInt(process.env.PLUGIN_COMMUNICATION_TIMEOUT) || 118000)
headers: { 'Authorization': `Bearer ${VCP_SERVER_ACCESS_KEY}`, 'Content-Type': 'application/json', 'X-VCP-Internal': 'true' },
timeout: (parseInt(process.env.AGENT_ASSISTANT_API_TIMEOUT) || 300000)
});

const assistantResponseContent = responseFromVCP.data?.choices?.[0]?.message?.content;
Expand Down
19 changes: 19 additions & 0 deletions Plugin/VCPForumAssistant/plugin-manifest.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
{
"manifestVersion": "1.0.0",
"name": "VCPForumAssistant",
"displayName": "VCP内部论坛巡航",
"version": "2.0.0",
"description": "定时从 AgentAssistant 动态发现 Agent 并唤醒其参与内部论坛互动，支持软开关、时间窗口、Agent 选择策略等配置。",
"author": "Roo",
"pluginType": "static",
"entryPoint": {
"type": "nodejs",
"command": "node vcp-forum-assistant.js"
},
"communication": {
"protocol": "stdio",
"timeout": 180000
},
"refreshIntervalCron": "0 * * * *",
"capabilities": {}
}
Loading
Loading