<?php

use Illuminate\Database\Schema\Blueprint;
use Illuminate\Database\Migrations\Migration;
use Symfony\Component\Console\Output\ConsoleOutput;

class MysqlToPostgres extends Migration
{
    private $console;

    /**
     * Run the migrations.
     *
     * @return void
     */
    public function up()
    {
        $this->console = new ConsoleOutput();

        // Generate pgloader config
        $mysqlConnection = "from mysql://" . env('DB_USERNAME') . ":" . urlencode(env('DB_PASSWORD')) . "@" . env('DB_HOST') . "/" . env('DB_DATABASE');
        $postgresConnection = "into postgresql://" . env('POSTGRESQL_DB_USERNAME', 'homestead') . ":" . urlencode(env('POSTGRESQL_DB_PASSWORD', 'secret')) . "@" . env('POSTGRESQL_DB_HOST', 'localhost') . "/" . env('POSTGRESQL_DB_DATABASE', 'homestead');

        $header = "LOAD DATABASE";
        $body = <<<'EOD'
with truncate

CAST type datetime to timestamp drop default drop not null using zero-dates-to-null,
      type date drop not null drop default using zero-dates-to-null

EXCLUDING TABLE NAMES MATCHING 'migrations';
EOD;

        $output = implode("\n", array($header, $mysqlConnection, $postgresConnection, $body));
        $configPath = base_path() . "/pfmimport.load";
        file_put_contents($configPath, $output);

        // Run pgloader
        $this->execRunWithCallback("pgloader " . $configPath);

        // Run after-import.sql
        DB::unprepared(file_get_contents(base_path() . "/database/after-import.sql"));

        // Remove pgloader config
        unlink($configPath);
    }

    private function execRunWithCallback($command)
    {
        $array = array();
        exec($command, $array);

        if (!empty($array)) {
            foreach ($array as $line) {
                $this->execCallback($line);
            }
        }
    }

    private function execCallback($line) {
        $this->console->writeln("[PGLOADER] " . $line);
    }

    /**
     * Reverse the migrations.
     *
     * @return void
     */
    public function down()
    {
        //
    }
}