f89e074dd1
Governed substrate for autonomous agents: scoped identity (passports), audited actions, MCP workspace. Infra IPs and secrets redacted for public release.
72 lines
2.2 KiB
JavaScript
72 lines
2.2 KiB
JavaScript
/**
|
|
* AgentJobService — Webhook Module
|
|
*
|
|
* handleWebhookResult — external agent session result submission.
|
|
*/
|
|
|
|
import { apiLogger } from '../../utils/logger.js';
|
|
import { saveStepMessage } from '../AgentLoopService.js';
|
|
import { setConversationProcessing } from '../chat/agent-execution-shared.js';
|
|
import { logAgentActivity } from '../AgentActivityLogger.js';
|
|
import { getJob } from './query.js';
|
|
import { completeJob, JOB_STATUS } from './shared.js';
|
|
|
|
/**
|
|
* Handle webhook result from external agent session.
|
|
* Called by POST /agents/jobs/:id/result endpoint.
|
|
*
|
|
* @param {number} jobId - Job database ID
|
|
* @param {string} resultMessage - Agent's response text
|
|
* @param {Object} metadata - Additional metadata
|
|
* @returns {Promise<{success: boolean, error?: string}>}
|
|
*/
|
|
export async function handleWebhookResult(jobId, resultMessage, metadata = {}) {
|
|
const job = await getJob(jobId);
|
|
if (!job) {
|
|
return { success: false, error: 'Job not found' };
|
|
}
|
|
|
|
if (job.status === JOB_STATUS.COMPLETED || job.status === JOB_STATUS.CANCELLED) {
|
|
return { success: false, error: `Job already ${job.status}` };
|
|
}
|
|
|
|
// Save the response to the conversation
|
|
if (resultMessage) {
|
|
const agentName = job.agent_name || 'AI Agent';
|
|
const messageMetadata = JSON.stringify({
|
|
agent_name: agentName,
|
|
agent_row_id: job.agent_row_id,
|
|
job_id: job.id,
|
|
source: 'webhook',
|
|
...metadata,
|
|
});
|
|
|
|
await saveStepMessage(job.conversation_id, {
|
|
content: resultMessage,
|
|
contentType: 'text',
|
|
role: 'assistant',
|
|
senderType: 'agent',
|
|
agentId: job.agent_row_id,
|
|
senderId: job.agent_user_id,
|
|
modelUsed: metadata.model || null,
|
|
metadata: messageMetadata,
|
|
});
|
|
}
|
|
|
|
// Mark job completed
|
|
await completeJob(jobId, resultMessage, metadata);
|
|
|
|
// Clear conversation processing state
|
|
await setConversationProcessing(job.conversation_id, false);
|
|
|
|
// Log activity
|
|
logAgentActivity({
|
|
agent_id: job.agent_name || 'unknown',
|
|
action: 'task_completed',
|
|
details: `Job ${jobId} completed via webhook (${resultMessage?.length || 0} chars)`,
|
|
success: true,
|
|
conversation_id: job.conversation_id,
|
|
});
|
|
|
|
return { success: true };
|
|
}
|