46 lines
		
	
	
		
			1.2 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			46 lines
		
	
	
		
			1.2 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| 
 | |
| namespace App\Services\Databases\Hosts;
 | |
| 
 | |
| use App\Models\DatabaseHost;
 | |
| use Illuminate\Database\DatabaseManager;
 | |
| use Illuminate\Database\ConnectionInterface;
 | |
| use App\Extensions\DynamicDatabaseConnection;
 | |
| 
 | |
| class HostUpdateService
 | |
| {
 | |
|     /**
 | |
|      * HostUpdateService constructor.
 | |
|      */
 | |
|     public function __construct(
 | |
|         private ConnectionInterface $connection,
 | |
|         private DatabaseManager $databaseManager,
 | |
|         private DynamicDatabaseConnection $dynamic,
 | |
|     ) {
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Update a database host and persist to the database.
 | |
|      *
 | |
|      * @throws \Throwable
 | |
|      */
 | |
|     public function handle(int $hostId, array $data): DatabaseHost
 | |
|     {
 | |
|         if (!empty(array_get($data, 'password'))) {
 | |
|             $data['password'] = encrypt($data['password']);
 | |
|         } else {
 | |
|             unset($data['password']);
 | |
|         }
 | |
| 
 | |
|         return $this->connection->transaction(function () use ($data, $hostId) {
 | |
|             /** @var DatabaseHost $host */
 | |
|             $host = DatabaseHost::query()->findOrFail($hostId);
 | |
|             $host->update($data);
 | |
|             $this->dynamic->set('dynamic', $host);
 | |
|             $this->databaseManager->connection('dynamic')->select('SELECT 1 FROM dual');
 | |
| 
 | |
|             return $host;
 | |
|         });
 | |
|     }
 | |
| }
 | 
