mirror of
				https://github.com/pelican-dev/panel.git
				synced 2025-11-04 16:46:51 +01:00 
			
		
		
		
	
		
			
				
	
	
		
			72 lines
		
	
	
		
			2.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			72 lines
		
	
	
		
			2.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						|
 | 
						|
namespace App\Services\Nodes;
 | 
						|
 | 
						|
use Illuminate\Support\Str;
 | 
						|
use App\Models\Node;
 | 
						|
use Illuminate\Database\ConnectionInterface;
 | 
						|
use App\Repositories\Daemon\DaemonConfigurationRepository;
 | 
						|
use App\Exceptions\Http\Connection\DaemonConnectionException;
 | 
						|
use App\Exceptions\Service\Node\ConfigurationNotPersistedException;
 | 
						|
 | 
						|
class NodeUpdateService
 | 
						|
{
 | 
						|
    /**
 | 
						|
     * NodeUpdateService constructor.
 | 
						|
     */
 | 
						|
    public function __construct(
 | 
						|
        private ConnectionInterface $connection,
 | 
						|
        private DaemonConfigurationRepository $configurationRepository,
 | 
						|
    ) {
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Update the configuration values for a given node on the machine.
 | 
						|
     *
 | 
						|
     * @throws \Throwable
 | 
						|
     */
 | 
						|
    public function handle(Node $node, array $data, bool $resetToken = false): Node
 | 
						|
    {
 | 
						|
        if ($resetToken) {
 | 
						|
            $data['daemon_token'] = encrypt(Str::random(Node::DAEMON_TOKEN_LENGTH));
 | 
						|
            $data['daemon_token_id'] = Str::random(Node::DAEMON_TOKEN_ID_LENGTH);
 | 
						|
        }
 | 
						|
 | 
						|
        [$updated, $exception] = $this->connection->transaction(function () use ($data, $node) {
 | 
						|
            /** @var \App\Models\Node $updated */
 | 
						|
            $updated = $node->replicate()->forceFill($data)->save();
 | 
						|
 | 
						|
            try {
 | 
						|
                // If we're changing the FQDN for the node, use the newly provided FQDN for the connection
 | 
						|
                // address. This should alleviate issues where the node gets pointed to a "valid" FQDN that
 | 
						|
                // isn't actually running the daemon software, and therefore you can't actually change it
 | 
						|
                // back.
 | 
						|
                //
 | 
						|
                // This makes more sense anyways, because only the Panel uses the FQDN for connecting, the
 | 
						|
                // node doesn't actually care about this.
 | 
						|
                $node->fqdn = $updated->fqdn;
 | 
						|
 | 
						|
                $this->configurationRepository->setNode($node)->update($updated);
 | 
						|
            } catch (DaemonConnectionException $exception) {
 | 
						|
                logger()->warning($exception, ['node_id' => $node->id]);
 | 
						|
 | 
						|
                // Never actually throw these exceptions up the stack. If we were able to change the settings
 | 
						|
                // but something went wrong with daemon we just want to store the update and let the user manually
 | 
						|
                // make changes as needed.
 | 
						|
                //
 | 
						|
                // This avoids issues with proxies such as Cloudflare which will see daemon as offline and then
 | 
						|
                // inject their own response pages, causing this logic to get fucked up.
 | 
						|
                return [$updated, true];
 | 
						|
            }
 | 
						|
 | 
						|
            return [$updated, false];
 | 
						|
        });
 | 
						|
 | 
						|
        if ($exception) {
 | 
						|
            throw new ConfigurationNotPersistedException(trans('exceptions.node.daemon_off_config_updated'));
 | 
						|
        }
 | 
						|
 | 
						|
        return $updated;
 | 
						|
    }
 | 
						|
}
 |