controller refactoring part 18

src/Domain/Files/Actions/MoveFileToExternalStorageAction.php

@@ -0,0 +1,66 @@
+<?php
+
+
+namespace Domain\Files\Actions;
+
+
+use Aws\Exception\MultipartUploadException;
+use Aws\S3\MultipartUploader;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Storage;
+use Symfony\Component\HttpKernel\Exception\HttpException;
+
+class MoveFileToExternalStorageAction
+{
+    /**
+     * Move file to external storage if is set
+     */
+    public function __invoke(
+        string $file, string $user_id
+    ): void {
+
+        $disk_local = \Storage::disk('local');
+
+        // Get file size
+        $filesize = $disk_local->size("files/$user_id/$file");
+
+        // If file is bigger than 5.2MB then run multipart upload
+        if ($filesize > 5242880) {
+            // Get driver
+            $driver = \Storage::getDriver();
+
+            // Get adapter
+            $adapter = $driver->getAdapter();
+
+            // Get client
+            $client = $adapter->getClient();
+
+            // Prepare the upload parameters.
+            // TODO: replace local files with temp folder
+            $uploader = new MultipartUploader($client, config('filesystems.disks.local.root') . "/files/$user_id/$file", [
+                'bucket' => $adapter->getBucket(),
+                'key'    => "files/$user_id/$file",
+            ]);
+
+            try {
+                // Upload content
+                $uploader->upload();
+            } catch (MultipartUploadException $e) {
+                // Write error log
+                Log::error($e->getMessage());
+
+                // Delete file after error
+                $disk_local->delete("files/$user_id/$file");
+
+                throw new HttpException(409, $e->getMessage());
+            }
+        } else {
+            // Stream file object to s3
+            // TODO: replace local files with temp folder
+            Storage::putFileAs("files/$user_id", config('filesystems.disks.local.root') . "/files/$user_id/$file", $file, 'private');
+        }
+
+        // Delete file after upload
+        $disk_local->delete("files/$user_id/$file");
+    }
+}