require('require-yaml');
const gulp = require('gulp');
const runSequence = require('run-sequence');
const fs = require('fs-extra');
const exec = require('child_process').exec;
const PluginError = require('plugin-error');
const argv = require('minimist')(process.argv.slice(2));
const log = require('fancy-log');

// Configuration

const isWindows = /^win/.test(process.platform);

if (argv.NODE_ENV)
    process.env.NODE_ENV = argv.NODE_ENV;

const env = process.env.NODE_ENV ? process.env.NODE_ENV : 'development';

const langs = ['es', 'en'];
const srcDir = './client';
const servicesDir = './services';
const nginxDir = `${servicesDir}/nginx`;
const buildDir = `${nginxDir}/static`;

let proxyConf = require(`${nginxDir}/config.yml`);
let proxyEnvFile = `${nginxDir}/config.${env}.yml`;

if (fs.existsSync(proxyEnvFile))
    Object.assign(proxyConf, require(proxyEnvFile));

const defaultService = proxyConf.main;
const defaultPort = proxyConf.defaultPort;
const devServerPort = proxyConf.devServerPort;

// Development

gulp.task('default', () => {
    return gulp.start('services', 'client');
});

gulp.task('client', ['build-clean'], () => {
    return gulp.start('watch', 'routes', 'locales', 'webpack-dev-server');
});

gulp.task('services', async () => {
    await runSequenceP('docker-start', 'services-only', 'nginx');
});

gulp.task('services-only', async () => {
    const services = await getServices();
    for (let service of services)
        require(service.index).start(service.port);
});

gulp.task('e2e', ['docker-rebuild'], async () => {
    await runSequenceP('e2e-only');
});

gulp.task('e2e-only', () => {
    const jasmine = require('gulp-jasmine');
    return gulp.src('./e2e_tests.js')
    .pipe(jasmine({reporter: 'none'}));
});

gulp.task('clean', ['build-clean', 'nginx-clean']);

gulp.task('i', ['install']);

gulp.task('install', () => {
    const install = require('gulp-install');
    const print = require('gulp-print');

    let packageFiles = [];
    let services = fs.readdirSync(servicesDir);
    services.push('..');
    services.forEach(service => {
        packageFiles.push(`${servicesDir}/${service}/package.json`);
    });
    return gulp.src(packageFiles)
        .pipe(print(filepath => {
            return `Installing packages in ${filepath}`;
        }))
        .pipe(install({
            npm: ['--no-package-lock']
        }));
});

// Deployment

gulp.task('build', ['clean'], () => {
    return gulp.start('routes', 'locales', 'webpack', 'docker-compose', 'nginx-conf');
});

gulp.task('docker-compose', async () => {
    const yaml = require('js-yaml');

    let compose = await fs.readFile('./docker-compose.tpl.yml', 'utf8');
    let composeYml = yaml.safeLoad(compose);
    let services = await getServices();

    for (let service of services) {
        let dockerFile = `${__dirname}/services/${service.name}/Dockerfile`;

        // if (await fs.exists(`./services/${service.name}/Dockerfile`))
        //    dockerFile = 'Dockerfile';

        composeYml.services[service.name] = {
            environment: ['NODE_ENV=${NODE_ENV}'],
            container_name: `\${BRANCH_NAME}-${service.name}`,
            image: `${service.name}:\${TAG}`,
            build: {
                context: `./services`,
                dockerfile: dockerFile
            },
            ports: [`${service.port}:${defaultPort}`]
        };
        composeYml.services.nginx.links.push(
            `${service.name}:\${BRANCH_NAME}-${service.name}`
        );
    }

    let ymlString = yaml.safeDump(composeYml);
    await fs.writeFile('./docker-compose.yml', ymlString);
});

gulp.task('build-clean', () => {
    const del = require('del');
    const files = [
        `${buildDir}/*`,
        `!${buildDir}/templates`,
        `!${buildDir}/images`,
        `docker-compose.yml`
    ];
    return del(files, {force: true});
});

// Nginx & services

let nginxConf = 'temp/nginx.conf';
let nginxTemp = `${nginxDir}/temp`;

gulp.task('nginx', async () => {
    await runSequenceP('nginx-stop', 'nginx-start');
});

gulp.task('nginx-start', ['nginx-conf'], async () => {
    let nginxBin = await nginxGetBin();

    if (isWindows)
        nginxBin = `start /B ${nginxBin}`;

    log(`Application will be at http://${proxyConf.host}:${proxyConf.port}/`);
    await execP(`${nginxBin} -c "${nginxConf}" -p "${nginxDir}"`);
});

gulp.task('nginx-stop', async () => {
    try {
        let nginxBin = await nginxGetBin();
        await fs.stat(`${nginxTemp}/nginx.pid`);
        await execP(`${nginxBin} -c "${nginxConf}" -p "${nginxDir}" -s stop`);
    } catch (e) {}
});

gulp.task('nginx-conf', async () => {
    const mustache = require('mustache');

    if (!await fs.exists(nginxTemp))
        await fs.mkdir(nginxTemp);

    let params = {
        services: await getServices(),
        defaultService: defaultService,
        defaultPort: defaultPort,
        devServerPort: devServerPort,
        port: proxyConf.port,
        host: proxyConf.host
    };

    let confFile = `${nginxDir}/nginx.${env}.mst`;

    if (!await fs.exists(confFile))
        confFile = `${nginxDir}/nginx.mst`;

    let template = await fs.readFile(confFile, 'utf8');
    let nginxConf = mustache.render(template, params);

    await fs.writeFile(`${nginxTemp}/nginx.conf`, nginxConf);
});

gulp.task('nginx-clean', ['nginx-stop'], () => {
    const del = require('del');
    return del([`${nginxTemp}/*`], {force: true});
});

async function nginxGetBin() {
    if (isWindows)
        return 'nginx';
    try {
        let nginxBin = '/usr/sbin/nginx';
        await fs.stat(nginxBin);
        return nginxBin;
    } catch (e) {
        return 'nginx';
    }
}

async function getServices() {
    let services;
    let startPort = defaultPort + 1;
    services = [];

    const serviceDirs = await fs.readdir(servicesDir);
    const exclude = ['loopback'];

    for (let service of serviceDirs) {
        let index = `${servicesDir}/${service}/server/server.js`;
        if (!await fs.exists(index) || exclude.indexOf(service) !== -1) continue;

        let port = service == defaultService ? defaultPort : startPort++;
        services.push({
            name: service,
            index: index,
            port: port
        });
    }

    return services;
}

// Webpack

gulp.task('webpack', function(callback) {
    const webpack = require('webpack');

    const webpackConfig = require('./webpack.config.js');
    let configCopy = Object.create(webpackConfig);
    let compiler = webpack(configCopy);

    compiler.run(function(err, stats) {
        if (err) throw new PluginError('webpack', err);
        log('[webpack]', stats.toString({colors: true}));
        callback();
    });
});

gulp.task('webpack-dev-server', function() {
    const WebpackDevServer = require('webpack-dev-server');
    const webpack = require('webpack');

    const webpackConfig = require('./webpack.config.js');
    let configCopy = Object.create(webpackConfig);

    for (let entry in configCopy.entry) {
        configCopy.entry[entry]
            .unshift(`webpack-dev-server/client?http://127.0.0.1:${devServerPort}/`);
    }

    let compiler = webpack(configCopy);
    new WebpackDevServer(compiler, {
        publicPath: '/',
        contentBase: buildDir,
        quiet: false,
        noInfo: false,
        // hot: true,
        stats: {
            assets: true,
            colors: true,
            version: false,
            hash: false,
            timings: true,
            chunks: false,
            chunkModules: false
        }
    }).listen(devServerPort, '127.0.0.1', function(err) {
        if (err) throw new PluginError('webpack-dev-server', err);
    });
});

// Locale

let localeFiles = `${srcDir}/**/locale/*.yml`;

gulp.task('locales', function() {
    const extend = require('gulp-extend');
    const yaml = require('gulp-yaml');
    const merge = require('merge-stream');
    const modules = require('./client/modules.yml');

    let streams = [];

    for (let mod in modules)
        for (let lang of langs) {
            let localeFiles = `./client/${mod}/**/locale/${lang}.yml`;
            streams.push(gulp.src(localeFiles)
                .pipe(yaml())
                .pipe(extend(`${lang}.json`))
                .pipe(gulp.dest(`${buildDir}/locale/${mod}`)));
        }

    return merge(streams);
});

// Routes

let routeFiles = `${srcDir}/**/routes.json`;

gulp.task('routes', function() {
    const concat = require('gulp-concat');
    const wrap = require('gulp-wrap');

    return gulp.src(routeFiles)
        .pipe(concat('routes.js', {newLine: ','}))
        .pipe(wrap('var routes = [<%=contents%>\n];'))
        .pipe(gulp.dest(buildDir));
});

// Watch

gulp.task('watch', function() {
    gulp.watch(routeFiles, ['routes']);
    gulp.watch(localeFiles, ['locales']);
});

// Docker

gulp.task('docker-rebuild', async () => {
    try {
        await execP('docker rm -f dblocal');
    } catch (e) {}
    try {
        await execP('docker rmi dblocal:latest');
    } catch (e) {}

    await runSequenceP('docker-run');
});

gulp.task('docker-start', async () => {
    let result;

    try {
        result = await execP('docker container inspect -f "{{json .State}}" dblocal');
    } catch (err) {
        return await runSequenceP('docker-run');
    }

    switch (JSON.parse(result.stdout).Status) {
    case 'running':
        return;
    case 'exited':
        return await execP('docker start dblocal');
    default:
        throw new Error(`Unknown docker status: ${status}`);
    }
});

gulp.task('docker-run', async () => {
    try {
        await execP('docker image inspect -f "{{json .Id}}" dblocal');
    } catch (err) {
        await execP('docker build -t dblocal:latest ./services/db');
    }

    await execP('docker run -d --name dblocal -p 3306:3306 dblocal');
    await runSequenceP('docker-wait');
});

gulp.task('docker-wait', callback => {
    let maxInterval = 30 * 60000;
    let interval = 1000;
    let timer = 0;
    log('Waiting for MySQL init process...');
    let waitForLocaldb = setInterval(() => {
        if (timer < maxInterval) {
            timer += interval;
            exec('docker logs --tail 1 dblocal', (err, stdout, stderr) => {
                if (stderr.includes('starting as process 1') || err) {
                    clearInterval(waitForLocaldb);
                    callback(err);
                }
            });
        } else {
            clearInterval(waitForLocaldb);
            callback(new Error(`MySQL not initialized whithin ${maxInterval / 1000} secs`));
        }
    }, interval);
});

// Helpers

function execP(command) {
    return new Promise((resolve, reject) => {
        exec(command, (err, stdout, stderr) => {
            if (err)
                reject(err);
            else
                resolve({
                    stdout: stdout,
                    stderr: stderr
                });
        });
    });
}

function runSequenceP() {
    return new Promise((resolve, reject) => {
        let args = Array.prototype.slice.call(arguments);
        args.push(err => {
            if (err)
                reject(err);
            else
                resolve();
        });
        runSequence(...args);
    });
}