51 lines
1.9 KiB
JavaScript
51 lines
1.9 KiB
JavaScript
const Router = require("@koa/router")
|
|
const controller = require("../controllers/workflow")
|
|
const authorized = require("../../middleware/authorized")
|
|
const joiValidator = require("../../middleware/joi-validator")
|
|
const { BUILDER } = require("../../utilities/accessLevels")
|
|
const Joi = require("joi")
|
|
|
|
const router = Router()
|
|
|
|
// prettier-ignore
|
|
function generateStepSchema(allowStepTypes) {
|
|
return Joi.object({
|
|
stepId: Joi.string().required(),
|
|
id: Joi.string().required(),
|
|
description: Joi.string().required(),
|
|
name: Joi.string().required(),
|
|
tagline: Joi.string().required(),
|
|
icon: Joi.string().required(),
|
|
params: Joi.object(),
|
|
// TODO: validate args a bit more deeply
|
|
args: Joi.object(),
|
|
type: Joi.string().required().valid(...allowStepTypes),
|
|
}).unknown(true)
|
|
}
|
|
|
|
// prettier-ignore
|
|
const workflowValidator = joiValidator.body(Joi.object({
|
|
live: Joi.bool(),
|
|
id: Joi.string().required(),
|
|
rev: Joi.string().required(),
|
|
name: Joi.string().required(),
|
|
type: Joi.string().valid("workflow").required(),
|
|
definition: Joi.object({
|
|
steps: Joi.array().required().items(generateStepSchema(["ACTION", "LOGIC"])),
|
|
trigger: generateStepSchema(["TRIGGER"]).required(),
|
|
}).required().unknown(true),
|
|
}).unknown(true))
|
|
|
|
router
|
|
.get("/api/workflows/trigger/list", authorized(BUILDER), controller.getTriggerList)
|
|
.get("/api/workflows/action/list", authorized(BUILDER), controller.getActionList)
|
|
.get("/api/workflows/logic/list", authorized(BUILDER), controller.getLogicList)
|
|
.get("/api/workflows", authorized(BUILDER), controller.fetch)
|
|
.get("/api/workflows/:id", authorized(BUILDER), controller.find)
|
|
.put("/api/workflows", authorized(BUILDER), workflowValidator, controller.update)
|
|
.post("/api/workflows", authorized(BUILDER), workflowValidator, controller.create)
|
|
.post("/api/workflows/:id/trigger", controller.trigger)
|
|
.delete("/api/workflows/:id/:rev", authorized(BUILDER), controller.destroy)
|
|
|
|
module.exports = router
|