<?php
namespace Deployer;

require 'recipe/composer.php';

// Setup

import(__DIR__. '/inventory.yml');

// Hooks

after('deploy:failed', 'deploy:unlock');
after('deploy:vendors', 'deploy:d3OxidTasks');

/// Tasks

desc('Oxid related tasks');
task('deploy:d3OxidTasks', [
    'deploy:clear_paths'
]);

desc('run all database migrations');
task('shop:runMigration', [
    'shop:setShopsOffline',
    'shop:executeMigrations',
    'shop:setShopsOnline'
]);

desc('set shops offline');
task('shop:setShopsOffline', function() {
    if (has('bin/mysql') && strlen(get('bin/mysql')) &&
        has('db_name') && strlen(get('db_name')) &&
        has('db_conf_path') && strlen(get('db_conf_path')) && test("[ -f {{db_conf_path}} ]")
    ) {
        $query = "UPDATE oxshops SET oxactive = '0', OXREGISTERSUBJECT = CONCAT('..', OXREGISTERSUBJECT) WHERE oxactive = '1';";
        run('{{bin/mysql}} --defaults-extra-file={{db_conf_path}} {{db_name}} -e "'.$query.'"');
    } else {
        warning('missing config, task skipped');
    }
});

task('shop:runMigration:failed', function() {
    invoke('shop:setShopsOnline');
})->hidden();

fail('shop:runMigration', 'shop:runMigration:failed');

desc('execute OXID Doctrine migrations');
task('shop:executeMigrations', function () {
    if (test("[ -f {{current_path}}/vendor/bin/oe-eshop-doctrine_migration ]")) {
        run('{{bin/php}} {{current_path}}/vendor/bin/oe-eshop-doctrine_migration migrations:migrate');
    }
})->hidden();;

desc('set shops online');
task('shop:setShopsOnline', function() {
    if (has('bin/mysql') && strlen(get('bin/mysql')) &&
        has('db_name') && strlen(get('db_name')) &&
        has('db_conf_path') && strlen(get('db_conf_path')) && test("[ -f {{db_conf_path}} ]")
    ) {
        $query = "UPDATE oxshops SET oxactive = '1', OXREGISTERSUBJECT = SUBSTR(OXREGISTERSUBJECT, 3) WHERE oxactive = '0' AND OXREGISTERSUBJECT LIKE '..%';";
        run('{{bin/mysql}} --defaults-extra-file={{db_conf_path}} {{db_name}} -e "'.$query.'"');
    } else {
        warning('missing config, task skipped');
    }
});

desc('create database coniguration file');
task('setup:createDbConfig', function () {
    try {
        if (!has('db_conf_path') || !strlen(get('db_conf_path'))) {
            throw new \RuntimeException('missing db_conf_path option, task stopped');
        }
        if (!test('[ -d $(dirname "{{db_conf_path}}") ]')) {
            run('mkdir -p $(dirname "{{db_conf_path}}")');
            if (!test('[ -d $(dirname "{{db_conf_path}}") ]')) {
                throw new \RuntimeException('unable to create configured path {{db_conf_path}}, task stopped');
            }
        }
        if (!test("[ -f {{db_conf_path}} ]")) {
            run("touch {{db_conf_path}}");
        }
        if (test("[ -f {{db_conf_path}} ]")) {
            $db_host = ask('database host', 'localhost');
            $db_port = ask('database port', '3306');
            $db_user = ask('database user');
            $db_pass = askHiddenResponse('database password');
            run('printf "[mysql]\nuser='.$db_user.'\npassword=\"'.$db_pass.'\"\nhost='.$db_host.'\nport='.$db_port.'\n\n[mysqldump]\nuser='.$db_user.'\npassword=\"'.$db_pass.'\"\nhost='.$db_host.'\nport='.$db_port.'" > {{db_conf_path}}');
            info('config successful created');
        } else {
            throw new \RuntimeException('can not create {{db_conf_path}}, task stopped');
        }
    } catch(\RuntimeException $e) {
        warning($e->getMessage());
    }
});

desc('show version of current OXID installation');
task('shop:getVersion', function () {
    if (test("[ -f {{current_path}}/composer.lock ]")) {
        cd('{{current_path}}');
        info(
            run(
                '{{bin/composer}} show oxid-esales/oxideshop-ce | grep -ws "versions" | cut -d " " -f 4'
            )
        );
    }
});

desc('dump contents from source to destination database');
task('shop:cloneDatabase', function () {
    if (has('bin/mysql') && strlen(get('bin/mysql')) &&
        has('bin/mysqldump') && strlen(get('bin/mysqldump')) &&
        has('db_name') && strlen(get('db_name')) &&
        has('db_conf_path') && strlen(get('db_conf_path')) && test("[ -f {{db_conf_path}} ]")
    ) {
        info('Note: Use a dedicated read only user for accessing the source database.');
        info('Using the following source database:');
        $source_host = ask('source database host', 'localhost');
        $source_port = ask('source database port', '3306');
        $source_name = ask('source database name');
        $source_user = ask('source database user');
        $source_pass = askHiddenResponse('source database password');
        if (askConfirmation('Do you really want to clone from "'.$source_name.'" to "{{db_name}}"? The target database "{{db_name}}" will be overwritten!')) {
            info('cloning database');
            $auth = "-h".$source_host." -P".$source_port." -u".$source_user." -p'".$source_pass."'";
            run("{{bin/mysqldump}} ".$auth." --opt --no-create-db -f ".$source_name." $({{bin/mysql}} ".$auth." -ANe\"SET group_concat_max_len = 10485760; SELECT GROUP_CONCAT(table_name SEPARATOR ' ') FROM information_schema.tables WHERE table_schema='".$source_name."' AND engine IS NOT NULL;\") | {{bin/mysql}} --defaults-extra-file={{db_conf_path}} -f {{db_name}}");
        } else {
            info('abborted');
        }
    } else {
        warning('missing config, task skipped');
    }
});