@cto.ai/ops/lib/services/BuildSteps.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const tslib_1 = require("tslib");
const fs = tslib_1.__importStar(require("fs-extra"));
const path = tslib_1.__importStar(require("path"));
const debug_1 = tslib_1.__importDefault(require("debug"));
const CustomErrors_1 = require("../errors/CustomErrors");
const debug = debug_1.default('ops:BuildStepsService');
class BuildSteps {
    constructor() {
        this.isGlueCode = async (step) => {
            if (step === '') {
                return false;
            }
            return !this.isOpRun(step);
        };
        this.buildAndPublishGlueCode = async (step, teamID, teamName, accessToken, opPath, user, publishService, opService, featherClient, registryAuthService, config, isPublic, version) => {
            const indexJs = path.resolve(opPath, 'index.js');
            fs.writeFileSync(indexJs, `const { sdk } = require('@cto.ai/sdk')

    async function main() {
      sdk.log('${step}')
    }

    main()`);
            const rand = Math.random()
                .toString(36)
                .substring(7);
            const opName = `gluecode-${rand}`;
            const glueCodeOp = {
                bind: ['/tmp:/tmp', 'Dockerfile'],
                description: 'glue code',
                mountCwd: false,
                mountHome: false,
                name: opName,
                network: 'host',
                run: '/bin/sdk-daemon node /ops/index.js',
                src: ['Dockerfile', 'index.js', 'package.json', '.dockerignore'],
                isPublic: isPublic,
            };
            const glueCodeClone = JSON.parse(JSON.stringify(glueCodeOp));
            await opService.opsBuildLoop([glueCodeClone], path.resolve(__dirname, '../templates/workflowsteps/js'), config);
            const { data: apiOp } = await publishService.publishOpToAPI(glueCodeOp, version, teamID, accessToken, featherClient, true);
            const registryAuth = await registryAuthService
                .create(accessToken, teamName, glueCodeOp.name, version, false, true)
                .catch(err => {
                throw new CustomErrors_1.CouldNotGetRegistryToken(err);
            });
            await publishService.publishOpToRegistry(apiOp, registryAuth, teamName, accessToken, registryAuthService, version);
            return `ops run ${opName}`;
        };
    }
    isOpRun(step) {
        const processedStep = step
            .toLowerCase()
            .replace(/\s\s+/g, ' ')
            .trim();
        const opsRunPrefix = 'ops run';
        return processedStep.lastIndexOf(opsRunPrefix, 0) === 0;
    }
}
exports.BuildSteps = BuildSteps;