f89e074dd1
Governed substrate for autonomous agents: scoped identity (passports), audited actions, MCP workspace. Infra IPs and secrets redacted for public release.
84 lines
2.8 KiB
JavaScript
84 lines
2.8 KiB
JavaScript
// PES Event Controller — CRM → PES event bridge
|
|
|
|
import { success, error, badRequest } from '../../../utils/response.js';
|
|
import { apiLogger } from '../../../utils/logger.js';
|
|
import * as pesBridge from '../../../services/pes/bridge.js';
|
|
|
|
// Valid CRM event types that PES understands
|
|
const VALID_EVENT_TYPES = [
|
|
'ticket_created', // New ticket → PES alert
|
|
'ticket_resolved', // Ticket resolved → PES happy
|
|
'agent_completed', // Agent finished job → PES fetch
|
|
'agent_failed', // Agent failed → PES concern
|
|
'deployment_success', // Deploy OK → PES celebrate
|
|
'deployment_failed', // Deploy failed → PES bug_detected
|
|
'user_login', // Owner logged in → PES greeting
|
|
'user_logout', // Owner left → PES lonely
|
|
'error_spike', // Error rate up → PES alert
|
|
'custom', // Custom event with data
|
|
];
|
|
|
|
export default function registerEventRoutes(router) {
|
|
/**
|
|
* POST /api/v3/pes/events
|
|
* Push a CRM event for PES to consume
|
|
*/
|
|
router.post('/events', async (req, res) => {
|
|
try {
|
|
const { type, data } = req.body;
|
|
if (!type) return badRequest(res, 'Event type is required');
|
|
if (!VALID_EVENT_TYPES.includes(type)) {
|
|
return badRequest(res, `Invalid event type. Valid: ${VALID_EVENT_TYPES.join(', ')}`);
|
|
}
|
|
|
|
const pushed = pesBridge.pushEvent(type, {
|
|
...data,
|
|
source: 'crm',
|
|
userId: req.user?.id,
|
|
userName: req.user?.name,
|
|
});
|
|
|
|
if (!pushed) {
|
|
return error(res, 'PES_EVENT_FAILED', 'Failed to push event to PES', 500);
|
|
}
|
|
|
|
apiLogger.info({ type, userId: req.user?.id }, 'CRM event pushed to PES');
|
|
return success(res, { pushed: true, type });
|
|
} catch (err) {
|
|
apiLogger.error({ err }, 'PES event push error');
|
|
return error(res, 'PES_ERROR', err.message, 500);
|
|
}
|
|
});
|
|
|
|
/**
|
|
* GET /api/v3/pes/events/pending
|
|
* Get pending events (for PES polling)
|
|
*/
|
|
router.get('/events/pending', async (req, res) => {
|
|
try {
|
|
const events = pesBridge.getPendingEvents();
|
|
return success(res, events);
|
|
} catch (err) {
|
|
apiLogger.error({ err }, 'PES pending events error');
|
|
return error(res, 'PES_ERROR', err.message, 500);
|
|
}
|
|
});
|
|
|
|
/**
|
|
* POST /api/v3/pes/events/consume
|
|
* Mark events as consumed (PES calls this after processing)
|
|
*/
|
|
router.post('/events/consume', async (req, res) => {
|
|
try {
|
|
const { eventIds } = req.body;
|
|
if (!Array.isArray(eventIds) || eventIds.length === 0) {
|
|
return badRequest(res, 'eventIds array is required');
|
|
}
|
|
pesBridge.consumeEvents(eventIds);
|
|
return success(res, { consumed: eventIds.length });
|
|
} catch (err) {
|
|
apiLogger.error({ err }, 'PES consume events error');
|
|
return error(res, 'PES_ERROR', err.message, 500);
|
|
}
|
|
});
|
|
}
|