user zipping

src/Domain/Zip/Actions/ZipAction.php

@@ -0,0 +1,86 @@
+<?php
+
+
+namespace Domain\Zip\Actions;
+
+
+use Domain\Folders\Models\Folder;
+use Domain\Sharing\Models\Share;
+use Illuminate\Support\Collection;
+use Illuminate\Support\Facades\Auth;
+use Illuminate\Support\Facades\Storage;
+use STS\ZipStream\ZipStreamFacade as Zip;
+use ZipStream\ZipStream;
+
+class ZipAction
+{
+    public function __invoke(
+        Collection $folders,
+        Collection $files,
+        ?Share $shared = null
+    ): ZipStream {
+
+        // Get user id
+        $user_id = Auth::id() ?? $shared->user_id;
+
+        // Create zip
+        $zip = Zip::create('files.zip');
+
+        // Zip Files
+        $files->map(function ($file) use ($zip) {
+            // get file path
+            $filePath = "files/$file->user_id/$file->basename";
+
+            // Add file into zip
+            if (Storage::exists($filePath)) {
+                // local disk
+                if (is_storage_driver('local')) {
+                    $zip->add(Storage::path($filePath), $file->name);
+                }
+
+                // s3 client
+                if (is_storage_driver('s3')) {
+                    $bucketName = config('filesystems.disks.s3.bucket');
+
+                    $zip->add("s3://$bucketName/$filePath", $file->name);
+                }
+            }
+        });
+
+        // Zip Folders
+        $folders->map(function ($folder) use ($zip, $user_id) {
+            // Get folder
+            $requested_folder = Folder::with(['folders.files', 'files'])
+                ->where('id', $folder->id)
+                ->where('user_id', $user_id)
+                ->with('folders')
+                ->first();
+
+            $folderFiles = get_files_for_zip($requested_folder, collect([]));
+
+            foreach ($folderFiles as $file) {
+                // get file path
+                $filePath = "files/$user_id/{$file['basename']}";
+
+                // Add file into zip
+                if (Storage::exists($filePath)) {
+                    $zipDestination = "{$file['folder_path']}/{$file['name']}";
+
+                    // local disk
+                    if (is_storage_driver('local')) {
+                        $zip->add(Storage::path($filePath), $zipDestination);
+                    }
+
+                    // s3 client
+                    if (is_storage_driver('s3')) {
+                        $bucketName = config('filesystems.disks.s3.bucket');
+
+                        $zip->add("s3://$bucketName/$filePath", $zipDestination);
+                    }
+                }
+            }
+        });
+        
+        return $zip;
+    }
+}

src/Domain/Zip/Actions/ZipFilesAction.php

@@ -1,45 +0,0 @@
-<?php
-namespace Domain\Zip\Actions;
-
-use STS\ZipStream\ZipStream;
-use Domain\Sharing\Models\Share;
-use Illuminate\Support\Collection;
-use Illuminate\Support\Facades\File;
-use Illuminate\Support\Facades\Storage;
-use STS\ZipStream\ZipStreamFacade as Zip;
-
-class ZipFilesAction
-{
-    /**
-     * Zip selected files, and download it as response stream
-     */
-    public function __invoke(
-        File | Collection $files,
-        ?Share $shared = null,
-    ): ZipStream {
-        // Create zip
-        $zip = Zip::create('files.zip');
-
-        $files->map(function ($file) use ($zip) {
-            // get file path
-            $filePath = "files/$file->user_id/$file->basename";
-
-            // Add file into zip
-            if (Storage::exists($filePath)) {
-                // local disk
-                if (is_storage_driver('local')) {
-                    $zip->add(Storage::path($filePath), $file->name);
-                }
-
-                // s3 client
-                if (is_storage_driver('s3')) {
-                    $bucketName = config('filesystems.disks.s3.bucket');
-
-                    $zip->add("s3://$bucketName/$filePath", $file->name);
-                }
-            }
-        });
-
-        return $zip;
-    }
-}

src/Domain/Zip/Actions/ZipFolderAction.php

@@ -1,58 +0,0 @@
-<?php
-namespace Domain\Zip\Actions;
-
-use STS\ZipStream\ZipStream;
-use Domain\Sharing\Models\Share;
-use Domain\Folders\Models\Folder;
-use Illuminate\Support\Facades\Auth;
-use Illuminate\Support\Facades\Storage;
-use STS\ZipStream\ZipStreamFacade as Zip;
-
-class ZipFolderAction
-{
-    /**
-     * Zip requested folder
-     */
-    public function __invoke(
-        $id,
-        ?Share $shared = null
-    ): ZipStream {
-        $user_id = Auth::id() ?? $shared->user_id;
-
-        // Get folder
-        $requested_folder = Folder::with(['folders.files', 'files'])
-            ->where('id', $id)
-            ->where('user_id', $user_id)
-            ->with('folders')
-            ->first();
-
-        $files = get_files_for_zip($requested_folder, collect([]));
-
-        // Create zip
-        $zip = Zip::create('files.zip');
-
-        foreach ($files as $file) {
-            // get file path
-            $filePath = "files/$user_id/{$file['basename']}";
-
-            // Add file into zip
-            if (Storage::exists($filePath)) {
-                $zipDestination = "{$file['folder_path']}/{$file['name']}";
-
-                // local disk
-                if (is_storage_driver('local')) {
-                    $zip->add(Storage::path($filePath), $zipDestination);
-                }
-
-                // s3 client
-                if (is_storage_driver('s3')) {
-                    $bucketName = config('filesystems.disks.s3.bucket');
-
-                    $zip->add("s3://$bucketName/$filePath", $zipDestination);
-                }
-            }
-        }
-
-        return $zip;
-    }
-}

src/Domain/Zip/Controllers/ZipController.php

@@ -0,0 +1,65 @@
+<?php
+
+
+namespace Domain\Zip\Controllers;
+
+
+use App\Http\Controllers\Controller;
+use Domain\Files\Models\File;
+use Domain\Folders\Models\Folder;
+use Domain\Traffic\Actions\RecordDownloadAction;
+use Domain\Zip\Actions\ZipAction;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Auth;
+use STS\ZipStream\ZipStream;
+
+class ZipController extends Controller
+{
+    public function __construct(
+        public ZipAction $zip,
+        public RecordDownloadAction $recordDownload,
+    ) {}
+
+    public function __invoke(
+        Request $request,
+    ): ZipStream {
+
+        $user_id = Auth::id();
+        $items = explode(',', $request->get('items'));
+
+        $itemList = collect($items)
+            ->map(function ($chunk) {
+                $items = explode('|', $chunk);
+
+                return [
+                    'id'   => $items[0],
+                    'type' => $items[1],
+                ];
+            });
+
+        $folderIds = $itemList
+            ->where('type', 'folder')
+            ->pluck('id');
+
+        $fileIds = $itemList
+            ->where('type', 'file')
+            ->pluck('id');
+
+        $folders = Folder::whereUserId($user_id)
+            ->whereIn('id', $folderIds)
+            ->get();
+
+        $files = File::whereUserId($user_id)
+            ->whereIn('id', $fileIds)
+            ->get();
+
+        $zip = ($this->zip)($folders, $files);
+
+        ($this->recordDownload)(
+            file_size: $zip->predictZipSize(),
+            user_id: $user_id,
+        );
+
+        return $zip;
+    }
+}

src/Domain/Zip/Controllers/ZipFilesController.php

@@ -1,36 +0,0 @@
-<?php
-namespace Domain\Zip\Controllers;
-
-use Illuminate\Http\Request;
-use STS\ZipStream\ZipStream;
-use Domain\Files\Models\File;
-use App\Http\Controllers\Controller;
-use Illuminate\Support\Facades\Auth;
-use Domain\Zip\Actions\ZipFilesAction;
-use Domain\Traffic\Actions\RecordDownloadAction;
-
-class ZipFilesController extends Controller
-{
-    public function __construct(
-        private ZipFilesAction $zipFiles,
-        private RecordDownloadAction $recordDownload,
-    ) {
-    }
-
-    public function __invoke(
-        Request $request,
-    ): ZipStream {
-        $files = File::whereUserId(Auth::id())
-            ->whereIn('id', explode(',', $request->get('ids')))
-            ->get();
-
-        $zip = ($this->zipFiles)($files);
-
-        ($this->recordDownload)(
-            file_size: $zip->predictZipSize(),
-            user_id: Auth::id(),
-        );
-
-        return $zip;
-    }
-}

src/Domain/Zip/Controllers/ZipFolderController.php

@@ -1,38 +0,0 @@
-<?php
-namespace Domain\Zip\Controllers;
-
-use STS\ZipStream\ZipStream;
-use Domain\Folders\Models\Folder;
-use App\Http\Controllers\Controller;
-use Illuminate\Support\Facades\Auth;
-use Domain\Zip\Actions\ZipFolderAction;
-use Domain\Traffic\Actions\RecordDownloadAction;
-
-class ZipFolderController extends Controller
-{
-    public function __construct(
-        private ZipFolderAction $zipFolder,
-        private RecordDownloadAction $recordDownload,
-    ) {
-    }
-
-    public function __invoke(
-        string $id,
-    ): ZipStream {
-        $folder = Folder::whereUserId(Auth::id())
-            ->where('id', $id);
-
-        if (! $folder->exists()) {
-            response("Requested folder doesn't exists.", 404);
-        }
-
-        $zip = ($this->zipFolder)($id);
-
-        ($this->recordDownload)(
-            file_size: $zip->predictZipSize(),
-            user_id: Auth::id(),
-        );
-
-        return $zip;
-    }
-}