<?php

use Illuminate\Database\Migrations\Migration;
use Symfony\Component\Process\Process;

class SetupLaravelQueueSupervisor extends Migration
{
    public function up()
    {
        $queue_worker = '[program:laravel-queue]
process_name=%(program_name)s_%(process_num)02d
command=php /var/www/ccsystem/artisan queue:work database --sleep=2 --tries=3 --timeout=120
directory=/var/www/ccsystem
autostart=true
autorestart=true
stopwaitsecs=20
startretries=200
stopasgroup=true
killasgroup=true
user=asterisk
numprocs=1
redirect_stderr=true
stdout_logfile=/var/www/queue-worker.log';

        if (is_dir('/etc/supervisord.d/')) {
            $extension = '.ini';
            $directory = '/etc/supervisord.d/';
            // Start and enable supervisord service
            (new Process(['systemctl', 'start', 'supervisord']))->run();
            (new Process(['systemctl', 'enable', 'supervisord']))->run();
        } elseif (is_dir('/etc/supervisor/conf.d/')) {
            $extension = '.conf';
            $directory = '/etc/supervisor/conf.d/';
        } else {
            throw new \Exception('Supervisor config directory not found.');
        }

        // Write the Supervisor config file
        file_put_contents($directory . 'laravel-queue' . $extension, $queue_worker);

        // Create log file and set proper permissions
        $logPath = '/var/www/queue-queue.log';
        (new Process(['touch', $logPath]))->run();
        (new Process(['chown', 'asterisk:asterisk', $logPath]))->run();

        // Reload Supervisor configuration and restart the process
        (new Process(['supervisorctl', 'reread']))->run();
        (new Process(['supervisorctl', 'update']))->run();
        (new Process(['supervisorctl', 'restart', 'laravel-queue']))->run();
    }

    public function down()
    {
        if (is_dir('/etc/supervisord.d/')) {
            $extension = '.ini';
            $directory = '/etc/supervisord.d/';
        } elseif (is_dir('/etc/supervisor/conf.d/')) {
            $extension = '.conf';
            $directory = '/etc/supervisor/conf.d/';
        } else {
            return;
        }

        // Remove Supervisor config and log file
        @unlink($directory . 'laravel-queue' . $extension);
        @unlink('/var/www/queue-queue.log');

        // Reload Supervisor configuration and stop the process
        (new Process(['supervisorctl', 'reread']))->run();
        (new Process(['supervisorctl', 'update']))->run();
        (new Process(['supervisorctl', 'stop', 'laravel-queue']))->run();
    }
}