Billie/app/Jobs/NodeJS/NpmRunStart.php

<?php

namespace App\Jobs\NodeJS;

use App\Models\NodeJS\ExecutionStep;
use App\Models\NodeJS\Submission;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;
use Symfony\Component\Process\Exception\ProcessTimedOutException;
use Symfony\Component\Process\Process;

class NpmRunStart
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $submission;
    public $tempDir;
    public $command;
    /**
     * Create a new job instance.
     */
    public function __construct($submission, $tempDir, $command)
    {
        $this->submission = $submission;
        $this->tempDir = $tempDir;
        $this->command = $command;
    }

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        set_time_limit(60);

        $submission = $this->submission;
        $tempDir = $this->tempDir;
        $command = $this->command;


        Log::info("NPM run will run on folder {$this->tempDir}");
        $this->updateSubmissionStatus($submission, Submission::$PROCESSING, "NPM run start is processing");
        // Change port number in .env file
        $port = $this->getAvailablePort();
        if (!$port) {
            $this->updateSubmissionStatus($submission, Submission::$FAILED, "Failed to find an available port for the project");
            return;
        }
        Log::info("NPM run start is processing on port $port");
        $submission->updatePort($port);
        // Change port number in .env file
        $envPath = "$tempDir/.env";
        if (file_exists($envPath)) {
            $envContent = file_get_contents($envPath);
            $envContent = preg_replace('/PORT=\d+/', "PORT=$port", $envContent);
            file_put_contents($envPath, $envContent);
        }

        // Run NPM start command
        try {
            $env = [
                'PATH' => config('app.process_path') . ':' . getenv('PATH'),
            ];
            $process = new Process($command, $tempDir, $env, null, null);
            $process->start();
            $process->waitUntil(function ($type, $output) use ($port) {
                return strpos($output, "$port") !== false || strpos($output, "MongoNetworkError") !== false;
            }, 60000); // Wait for 60 seconds

            if (strpos($process->getOutput(), "$port") !== false) {
                Log::info("NPM run start is completed in folder {$tempDir} the application is running on port $port");
                $this->updateSubmissionStatus($submission, Submission::$COMPLETED, $process->getOutput());
            } else {
                Log::error("Failed to NPM run start in folder {$tempDir} due to error " .  $process->getOutput());
                $this->updateSubmissionStatus($submission, Submission::$FAILED, "Failed to start application on port $port");
            }
            Process::fromShellCommandline("npx kill-port $port")->run();
        } catch (ProcessTimedOutException $th) {
            $process->stop();
            Log::error("Failed to NPM run start in folder {$tempDir} due to timeout " .  $process->getOutput());
            $this->updateSubmissionStatus($submission, Submission::$FAILED, "Failed to start application on port $port due to timeout");
            Process::fromShellCommandline("npx kill-port $port")->run();
        } catch (\Throwable $th) {
            Log::error("Failed to NPM run start in folder {$tempDir}" . $th->getMessage());
            $this->updateSubmissionStatus($submission, Submission::$FAILED, "Failed to start application on port $port");
            Process::fromShellCommandline("npx kill-port $port")->run();
        }
    }

    /**
     * Get an available port number.
     *
     * @return int|null
     */
    private function getAvailablePort(): ?int
    {
        $minPort = 9000;
        $maxPort = 9999;
        for ($port = $minPort; $port <= $maxPort; $port++) {
            $fp = @fsockopen('localhost', $port, $errno, $errstr, 1);
            if (!$fp && Submission::where('port', $port)->doesntExist()) {
                return $port;
            } else {
                if (is_resource($fp)) {
                    fclose($fp);
                }
            }
        }
        return null;
    }

    /**
     * Update the submission status and result of a specific step.
     *
     * @param Submission $submission
     * @param string $status
     * @param string $output
     * @return void
     */
    private function updateSubmissionStatus(Submission $submission, string $status, string $output): void
    {
        $stepName = ExecutionStep::$NPM_RUN_START;
        if ($status != Submission::$PROCESSING) $submission->updateOneResult($stepName, $status, $output);
        if ($status != Submission::$COMPLETED) $submission->updateStatus($status);
    }
}