@codefresh-io/pipeline-autobot/index.js

const fs = require('fs');
const Promise = require('bluebird');
const path = require('path');

const Analyzer = require('./analyzer');

const clone = require('./analyzer/steps/clone');
const build = require('./analyzer/steps/build');
const push = require('./analyzer/steps/push');
const packageJson = require('./analyzer/steps/package.json');
const sendToSlack = require('./analyzer/steps/slack.notifier');


const stages = require('./analyzer/header/stages');
const stagesEnricher = require('./analyzer/enricher/stages');
const codefreshYaml = require('./analyzer/transform/codefresh.yaml');

function isValidContext(context){
    const { credentials, repo: { repoOwner, repoName }} = context;
    return credentials && repoOwner && repoName;
}

async function _defaultYaml(){
    const defaultYaml = await Promise.fromCallback((cb) => fs.readFile(path.resolve(__dirname, 'default.yaml'), cb));
    return defaultYaml.toString();
}

module.exports = {

    'onboarding': async (context) => {

        const  analyzer = new Analyzer();

        // if user logged in with google for example and havent repo info
        if(!isValidContext(context)){
            return _defaultYaml();
        }
        try{
            await analyzer.init(context);
        }
        catch (e) {
            console.error(e);
            return _defaultYaml();
        }
        return analyzer
            .step(clone)
            .step(build)
            .step(push)
            .header(stages)
            .enrich(stagesEnricher)
            .resolve();
    },

    'api': async (context) => {
        const  analyzer = new Analyzer();

        await analyzer.init(context);
        return analyzer
            .step(clone)
            .step(build)
            .step(push)
            .step(packageJson)
            .step(sendToSlack)
            .header(stages)
            .enrich(stagesEnricher)
            .transform(codefreshYaml)
            .resolve();
    }

};