119 lines
		
	
	
		
			4.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			119 lines
		
	
	
		
			4.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| 
 | |
| namespace App\Http\Controllers\Api\Remote\Servers;
 | |
| 
 | |
| use App\Enums\ServerState;
 | |
| use App\Models\Backup;
 | |
| use Illuminate\Http\Request;
 | |
| use App\Models\Server;
 | |
| use Illuminate\Http\JsonResponse;
 | |
| use App\Facades\Activity;
 | |
| use Illuminate\Database\ConnectionInterface;
 | |
| use App\Http\Controllers\Controller;
 | |
| use App\Services\Eggs\EggConfigurationService;
 | |
| use App\Http\Resources\Daemon\ServerConfigurationCollection;
 | |
| use App\Services\Servers\ServerConfigurationStructureService;
 | |
| 
 | |
| class ServerDetailsController extends Controller
 | |
| {
 | |
|     /**
 | |
|      * ServerConfigurationController constructor.
 | |
|      */
 | |
|     public function __construct(
 | |
|         protected ConnectionInterface $connection,
 | |
|         private ServerConfigurationStructureService $configurationStructureService,
 | |
|         private EggConfigurationService $eggConfigurationService
 | |
|     ) {
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Returns details about the server that allows daemon to self-recover and ensure
 | |
|      * that the state of the server matches the Panel at all times.
 | |
|      */
 | |
|     public function __invoke(Server $server): JsonResponse
 | |
|     {
 | |
|         return new JsonResponse([
 | |
|             'settings' => $this->configurationStructureService->handle($server),
 | |
|             'process_configuration' => $this->eggConfigurationService->handle($server),
 | |
|         ]);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Lists all servers with their configurations that are assigned to the requesting node.
 | |
|      */
 | |
|     public function list(Request $request): ServerConfigurationCollection
 | |
|     {
 | |
|         /** @var \App\Models\Node $node */
 | |
|         $node = $request->attributes->get('node');
 | |
| 
 | |
|         // Avoid run-away N+1 SQL queries by preloading the relationships that are used
 | |
|         // within each of the services called below.
 | |
|         $servers = Server::query()->with('allocations', 'egg', 'mounts', 'variables')
 | |
|             ->where('node_id', $node->id)
 | |
|             // If you don't cast this to a string you'll end up with a stringified per_page returned in
 | |
|             // the metadata, and then daemon will panic crash as a result.
 | |
|             ->paginate((int) $request->input('per_page', 50));
 | |
| 
 | |
|         return new ServerConfigurationCollection($servers);
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Resets the state of all servers on the node to be normal. This is triggered
 | |
|      * when daemon restarts and is useful for ensuring that any servers on the node
 | |
|      * do not get incorrectly stuck in installing/restoring from backup states since
 | |
|      * a daemon reboot would completely stop those processes.
 | |
|      *
 | |
|      * @throws \Throwable
 | |
|      */
 | |
|     public function resetState(Request $request): JsonResponse
 | |
|     {
 | |
|         $node = $request->attributes->get('node');
 | |
| 
 | |
|         // Get all the servers that are currently marked as restoring from a backup
 | |
|         // on this node that do not have a failed backup tracked in the audit logs table
 | |
|         // as well.
 | |
|         //
 | |
|         // For each of those servers we'll track a new audit log entry to mark them as
 | |
|         // failed and then update them all to be in a valid state.
 | |
|         $servers = Server::query()
 | |
|             ->with([
 | |
|                 'activity' => fn ($builder) => $builder
 | |
|                     ->where('activity_logs.event', 'server:backup.restore-started')
 | |
|                     ->latest('timestamp'),
 | |
|             ])
 | |
|             ->where('node_id', $node->id)
 | |
|             ->where('status', ServerState::RestoringBackup)
 | |
|             ->get();
 | |
| 
 | |
|         $this->connection->transaction(function () use ($node, $servers) {
 | |
|             /** @var \App\Models\Server $server */
 | |
|             foreach ($servers as $server) {
 | |
|                 /** @var \App\Models\ActivityLog|null $activity */
 | |
|                 $activity = $server->activity->first();
 | |
|                 if (!$activity) {
 | |
|                     continue;
 | |
|                 }
 | |
| 
 | |
|                 if ($subject = $activity->subjects()->where('subject_type', 'backup')->first()) {
 | |
|                     /** @var Backup $backup */
 | |
|                     $backup = $subject->subject;
 | |
|                     // Just create a new audit entry for this event and update the server state
 | |
|                     // so that power actions, file management, and backups can resume as normal.
 | |
|                     Activity::event('server:backup.restore-failed')
 | |
|                         ->subject($server, $backup)
 | |
|                         ->property('name', $backup->name)
 | |
|                         ->log();
 | |
|                 }
 | |
|             }
 | |
| 
 | |
|             // Update any server marked as installing or restoring as being in a normal state
 | |
|             // at this point in the process.
 | |
|             Server::query()->where('node_id', $node->id)
 | |
|                 ->whereIn('status', [ServerState::Installing, ServerState::RestoringBackup])
 | |
|                 ->update(['status' => null]);
 | |
|         });
 | |
| 
 | |
|         return new JsonResponse([], JsonResponse::HTTP_NO_CONTENT);
 | |
|     }
 | |
| }
 | 
