<?php
/**
 * Created by PhpStorm.
 * User: sunil
 * Date: 9/29/18
 * Time: 4:30 PM
 */

namespace App\Console\Commands;

use App\Events\V1\EventSendDbBackupEmail;
use Aws\Glacier\GlacierClient;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Facades\Storage;
use Illuminate\Support\Facades\Mail;
use Illuminate\Console\Command;
use Symfony\Component\Process\Process;
use Symfony\Component\Process\Exception\ProcessFailedException;

class Glacier extends Command
{
    //php artisan backup:mysql --command=create
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'backup:glacier {--command= : <create|restore> command to execute} {--snapshot= : provide name of snapshot}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Daily MySQL Backup';

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        switch ($this->option('command'))
        {
            case 'create':
                $this->takeSnapShot();
                break;
            case 'restore':
                //$this->restoreSnapShot();
                break;

            default:
                $this->error("Invalid Option !!");
                break;
        }
    }

    /**
     * Function takes regular backup
     * for mysql database..
     *
     */
    private function takeSnapShot()
    {
        ini_set('max_execution_time', -1);
        set_time_limit(0);
        ini_set('memory_limit', '-1');

        // define target file
        $name = env('DB_DATABASE') . '_' . date("Y-m-d_Hi");
        $tempLocation     = '/tmp/' .$name. '.sql.gz';
        $targetFilePath   = '/mysql/' .$name. '.sql.gz';

        // run the cli job
        $process = new Process('mysqldump -h' ._env('DB_HOST_READONLY'). ' -u' ._env('DB_USERNAME'). ' -p' ._env('DB_PASSWORD'). ' ' ._env('DB_DATABASE'). ' --ignore-table='._env('DB_DATABASE').'.consumer_api_requests | gzip > ' .$tempLocation);
        $process->run();

        $client = GlacierClient::factory(array(
            'key'    => _env('GLACIER_KEY'),
            'secret' => _env('GLACIER_SECRET'),
            'region' => _env('GLACIER_REGION'),
            'version' => '2012-06-01',
        ));

        $result = $client->uploadArchive(array(
            'vaultName' => 'creditfair-customer-documents',
            'body'      => fopen(storage_path().'/payment.xml', 'r'),
        ));

        $archiveId = $result->get('archiveId');

        return 4;
    }

    /**
     * Function restore given snapshot
     * for mysql database
     */
    private function restoreSnapShot()
    {
        $snapshot = $this->option('snapshot');
        if(!$snapshot) {
            $this->error("snapshot option is required.");
        }

        try {

            // get file from s3
            $s3 = Storage::disk('s3');
            $found = $s3->get('/mysql/' .$snapshot. '.sql');
            $tempLocation = '/tmp/' .env('DB_DATABASE') . '_' . date("Y-m-d_Hi") . '.sql';

            // create a temp file
            $bytes_written = File::put($tempLocation, $found);
            if ($bytes_written === false) {
                $this->info("Error writing to file: " .$tempLocation);
            }

            // run the cli job
            $process = new Process("mysql -h " .env('DB_HOST'). " -u " .env('DB_USERNAME'). " -p" .env('DB_PASSWORD'). " ".env('DB_DATABASE'). " < {$tempLocation}");
            $process->run();

            //@unlink($tempLocation);
            if ($process->isSuccessful()) {
                $this->info("Restored snapshot: " .$snapshot);
            }
            else {
                throw new ProcessFailedException($process);
            }
        }
        catch (\Exception $e) {
            $this->info('File Not Found: '. $e->getMessage());
        }
    }
}