<?php

namespace App\Jobs\Servers;

use App\Enums\ServerStatus;
use App\Models\Server;
use Illuminate\Contracts\Queue\ShouldBeEncrypted;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use Illuminate\Support\Str;
use Spatie\Ssh\Ssh;

class WaitForServerToConnect implements ShouldQueue, ShouldBeEncrypted
{
    use Queueable;

    public int $retryAfter = 15;
    public int $tries = 40;

    public function __construct(
        protected Server $server,
        protected string $rootPassword,
        protected string $sudoPassword,
    ) {
        //
    }

    public function handle(): void
    {
        $process = Ssh::create('root', $this->server->ipv4 ?? $this->server->ipv6)
            ->usePassword($this->rootPassword)
            ->disableStrictHostKeyChecking()
            ->setTimeout(10)
            ->execute('echo "Connected"');

        if (! $process->isSuccessful()) {
            if (str_contains($process->getErrorOutput(), 'Password change required')) {
                $newRootPassword = Str::random(24);
                Ssh::create('root', $this->server->ipv4 ?? $this->server->ipv6)
                    ->usePassword($this->rootPassword)
                    ->execute('echo "root:'.$newRootPassword.'" | chpasswd');

                $this->rootPassword = $newRootPassword;
                $this->release(15);
                return;
            }
            logger('root pw: ' . $this->rootPassword);
            logger('server not reachable');
            logger('exit code' . $process->getExitCode());
            logger('output');
            logger($process->getOutput());
            logger($process->getErrorOutput());
            $this->release(15);
            return;
        }

        $this->server->update([
            'status' => ServerStatus::UNPROVISIONED,
        ]);

        dispatch(new ProvisionServer($this->server, $this->rootPassword, $this->sudoPassword));
    }

    public function failed(\Throwable $exception): void
    {
        $this->server->update([
            'status' => ServerStatus::PROVIDER_TIMEOUT,
        ]);
    }
}