feat: S3 restore

app/Events/S3DownloadFinished.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace App\Events;
+
+use App\Models\Server;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class S3DownloadFinished implements ShouldBroadcast
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    public int|string|null $userId = null;
+
+    public ?string $downloadPath = null;
+
+    public function __construct($teamId, $data = null)
+    {
+        if (is_null($data)) {
+            return;
+        }
+
+        // Get userId from event data (the user who triggered the download)
+        $this->userId = data_get($data, 'userId');
+        $this->downloadPath = data_get($data, 'downloadPath');
+
+        $containerName = data_get($data, 'containerName');
+        $serverId = data_get($data, 'serverId');
+
+        if (filled($containerName) && filled($serverId)) {
+            // Clean up the MinIO client container
+            $commands = [];
+            $commands[] = "docker stop {$containerName} 2>/dev/null || true";
+            $commands[] = "docker rm {$containerName} 2>/dev/null || true";
+            instant_remote_process($commands, Server::find($serverId), throwError: false);
+        }
+    }
+
+    public function broadcastOn(): ?array
+    {
+        if (is_null($this->userId)) {
+            return [];
+        }
+
+        return [
+            new PrivateChannel("user.{$this->userId}"),
+        ];
+    }
+
+    public function broadcastWith(): array
+    {
+        return [
+            'downloadPath' => $this->downloadPath,
+        ];
+    }
+}

app/Events/S3RestoreJobFinished.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace App\Events;
+
+use App\Models\Server;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class S3RestoreJobFinished
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    public function __construct($data)
+    {
+        $scriptPath = data_get($data, 'scriptPath');
+        $tmpPath = data_get($data, 'tmpPath');
+        $container = data_get($data, 'container');
+        $serverId = data_get($data, 'serverId');
+        $s3DownloadedFile = data_get($data, 's3DownloadedFile');
+
+        // Clean up temporary files from container
+        if (filled($scriptPath) && filled($tmpPath) && filled($container) && filled($serverId)) {
+            if (str($tmpPath)->startsWith('/tmp/')
+                && str($scriptPath)->startsWith('/tmp/')
+                && ! str($tmpPath)->contains('..')
+                && ! str($scriptPath)->contains('..')
+                && strlen($tmpPath) > 5  // longer than just "/tmp/"
+                && strlen($scriptPath) > 5
+            ) {
+                $commands[] = "docker exec {$container} sh -c 'rm {$scriptPath}'";
+                $commands[] = "docker exec {$container} sh -c 'rm {$tmpPath}'";
+                instant_remote_process($commands, Server::find($serverId), throwError: true);
+            }
+        }
+
+        // Clean up S3 downloaded file from server
+        if (filled($s3DownloadedFile) && filled($serverId)) {
+            if (str($s3DownloadedFile)->startsWith('/tmp/s3-restore-')
+                && ! str($s3DownloadedFile)->contains('..')
+                && strlen($s3DownloadedFile) > 16  // longer than just "/tmp/s3-restore-"
+            ) {
+                $commands = [];
+                $commands[] = "rm -f {$s3DownloadedFile}";
+                instant_remote_process($commands, Server::find($serverId), throwError: false);
+            }
+        }
+    }
+}