@cto.ai/ops/lib/utils/yamlParser.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const tslib_1 = require("tslib");
const yaml = tslib_1.__importStar(require("yaml"));
const CustomErrors_1 = require("../errors/CustomErrors");
const checkCommandNecessryFields = (commandContents) => {
    if (!commandContents.run || typeof commandContents.run !== 'string') {
        throw new CustomErrors_1.IncompleteOpsYml('The run command must be included as a string');
    }
};
const checkWorkflowNecessryFields = (workflowContents) => {
    if (!workflowContents.steps || !workflowContents.steps.length) {
        throw new CustomErrors_1.IncompleteOpsYml('The run command must be included as a string');
    }
    workflowContents.steps.forEach(step => {
        if (!step || typeof step !== 'string') {
            throw new CustomErrors_1.IncompleteOpsYml('Each step should be a non-empty string');
        }
    });
};
const checkOpNecessaryFields = (opContents) => {
    if (!opContents.name || typeof opContents.name !== 'string') {
        throw new CustomErrors_1.IncompleteOpsYml('Op name must be a non-empty string');
    }
    if (!opContents.description || typeof opContents.description !== 'string') {
        throw new CustomErrors_1.IncompleteOpsYml('Op description must be a non-empty string');
    }
    if (!opContents.isPublic === undefined ||
        typeof opContents.isPublic !== 'boolean') {
        throw new CustomErrors_1.IncompleteOpsYml('Your ops.yml file is missing the public field, please add `public:false` to publish your op as private');
    }
    return true;
};
exports.parseYaml = (manifest) => {
    const yamlContents = manifest && yaml.parse(manifest);
    if (!yamlContents)
        throw new CustomErrors_1.IncompleteOpsYml('Ops.yml is empty');
    if (yamlContents.ops) {
        yamlContents.ops = yamlContents.ops.map(op => {
            const newOp = Object.assign({}, op);
            newOp.isPublic = newOp.public;
            delete newOp.public;
            checkOpNecessaryFields(newOp);
            checkCommandNecessryFields(newOp);
            return newOp;
        });
    }
    if (yamlContents.workflows) {
        yamlContents.workflows = yamlContents.workflows.map(wf => {
            const newWf = Object.assign({}, wf);
            newWf.isPublic = newWf.public;
            delete newWf.public;
            checkOpNecessaryFields(newWf);
            checkWorkflowNecessryFields(newWf);
            return newWf;
        });
    }
    return yamlContents;
};