Hermes
283121edba
Resolves 24 conflicts between Hermes (DC-008/009/010 + response-helper
envelope standardization) and Krystie (DC-005 src/ refactor path fixes,
DC-006 TOTP integration, DC-007 new test suites, cloud backup
destinations).
Conflict resolutions:
- src/utils/logging.js: took ours (consumers depend on logError/
safeErrorMessage/createLogger exports)
- src/config/site.js: merged (her factored validateAndLogConfig +
applyConfigFields helpers)
- src/context/dns.js: took hers (admin/readonly role iteration for
write operations)
- src/utilities/backup-
manager.js: took hers (Dropbox/WebDAV/SFTP cloud feature)
- status/dist/*, status/
sw.js: took hers (minified bundles + newer SW cache)
Additional fix (post-merge regression):
- src/monitoring/health-checker.js: fixed DC-005 path miss —
'require(./platform-paths)' → 'require(../../platform-paths)'
Test status: 921/922 passing. One known failure in logging.test.js
(async file-handle timing) tracked as follow-up.
67 lines
2.4 KiB
JavaScript
67 lines
2.4 KiB
JavaScript
const express = require('express');
|
|
const { ok } = require('../src/utils/responses');
|
|
|
|
/**
|
|
* Workflows routes factory
|
|
* @param {Object} deps - Explicit dependencies
|
|
* @param {Object} deps.workflowEngine - WorkflowEngine instance
|
|
* @param {Object} deps.licenseManager - License manager for premium gating
|
|
* @param {Function} deps.asyncHandler - Async route handler wrapper
|
|
* @param {Function} deps.ok - Success response helper
|
|
* @returns {express.Router}
|
|
*/
|
|
module.exports = function({ workflowEngine, licenseManager, asyncHandler, ok }) {
|
|
const router = express.Router();
|
|
|
|
// Apply premium gating to all workflows routes
|
|
router.use(licenseManager.requirePremium('workflows'));
|
|
|
|
// ===== WORKFLOW MANAGEMENT ENDPOINTS =====
|
|
|
|
// List all bundled workflows
|
|
router.get('/workflows', asyncHandler(async (req, res) => {
|
|
const workflows = workflowEngine.listWorkflows();
|
|
ok(res, { workflows });
|
|
}, 'workflows-list'));
|
|
|
|
// Enable a workflow
|
|
router.post('/workflows/:workflowId/enable', asyncHandler(async (req, res) => {
|
|
const { workflowId } = req.params;
|
|
const result = workflowEngine.setWorkflowEnabled(workflowId, true);
|
|
ok(res, result);
|
|
}, 'workflows-enable'));
|
|
|
|
// Disable a workflow
|
|
router.post('/workflows/:workflowId/disable', asyncHandler(async (req, res) => {
|
|
const { workflowId } = req.params;
|
|
const result = workflowEngine.setWorkflowEnabled(workflowId, false);
|
|
ok(res, result);
|
|
}, 'workflows-disable'));
|
|
|
|
// Manually trigger a workflow
|
|
router.post('/workflows/:workflowId/run', asyncHandler(async (req, res) => {
|
|
const { workflowId } = req.params;
|
|
const triggerData = req.body || {};
|
|
triggerData.trigger = 'manual';
|
|
|
|
const result = await workflowEngine.executeWorkflow(workflowId, triggerData);
|
|
ok(res, { result });
|
|
}, 'workflows-run'));
|
|
|
|
// Get execution history for a workflow
|
|
router.get('/workflows/:workflowId/history', asyncHandler(async (req, res) => {
|
|
const { workflowId } = req.params;
|
|
const limit = parseInt(req.query.limit) || 50;
|
|
const history = workflowEngine.getHistory(workflowId, limit);
|
|
ok(res, { history });
|
|
}, 'workflows-history'));
|
|
|
|
// Get all workflow execution history
|
|
router.get('/workflows/history', asyncHandler(async (req, res) => {
|
|
const limit = parseInt(req.query.limit) || 100;
|
|
const history = workflowEngine.getHistory(null, limit);
|
|
ok(res, { history });
|
|
}, 'workflows-all-history'));
|
|
|
|
return router;
|
|
}; |