Listener for removing temporary files, which was created during uploa…

…ding

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 ## [Unreleased](https://github.com/laravel/octane/compare/v1.2.1...1.x)
 
+### Changed
+
+- Removes temporary files, which was created during uploading _(should be enabled manually)_
+
 ## [v1.2.1](https://github.com/laravel/octane/compare/v1.2.1...v1.2.1) - 2022-02-08
 
 ### Changed

config/octane.php

@@ -78,7 +78,7 @@
         ],
 
         RequestTerminated::class => [
-            //
+            // \Laravel\Octane\Listeners\CleanupUploadedFiles::class,
         ],
 
         TaskReceived::class => [

src/Listeners/CleanupUploadedFiles.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Laravel\Octane\Listeners;
+
+/**
+ * @link https://github.com/spiral/roadrunner-laravel/issues/84
+ */
+class CleanupUploadedFiles
+{
+    /**
+     * Handle the event.
+     *
+     * @param  mixed $event
+     * @return void
+     */
+    public function handle($event): void
+    {
+        foreach ($event->request->files->all() as $file) {
+            if ($file instanceof \SplFileInfo) {
+                if (\is_string($path = $file->getRealPath())) {
+                    \clearstatcache(true, $path);
+
+                    if (\is_file($path)) {
+                        \unlink($path);
+                    }
+                }
+            }
+        }
+    }
+}

tests/Listeners/CleanupUploadedFilesTest.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+use Illuminate\Support\Str;
+use Laravel\Octane\Tests\TestCase;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\File\UploadedFile;
+
+/**
+ * @covers \Laravel\Octane\Listeners\CleanupUploadedFiles
+ */
+class CleanupUploadedFilesTest extends TestCase
+{
+    public function test_files_removed()
+    {
+        try {
+            [$file1path, $file2path, $file3path] = [
+                \tempnam($tmpDir = \sys_get_temp_dir(), $prefix = 'unit-'),
+                \tempnam($tmpDir, $prefix),
+                \tempnam($tmpDir, $prefix),
+            ];
+
+            ($request = Request::create('http://127.0.0.1:123/foo'))->files->add([
+                new UploadedFile($file1path, Str::random()),
+                new UploadedFile($file2path, Str::random()),
+                new UploadedFile($file3path, Str::random()),
+            ]);
+
+            $this->assertTrue(\rename($file3path, $file3newPath = $file3path . Str::random()));
+
+            $this->assertFileExists($file1path);
+            $this->assertFileExists($file2path);
+            $this->assertFileExists($file3newPath);
+
+            $event = new \stdClass();
+            $event->request = $request;
+
+            (new CleanupUploadedFiles)->handle($event);
+
+            $this->assertFileDoesNotExist($file1path);
+            $this->assertFileDoesNotExist($file2path);
+            $this->assertFileExists($file3newPath); // still exists
+        } finally {
+            foreach ([$file1path, $file2path, $file3newPath] as $fileName) {
+                if (\is_file($fileName)) {
+                    \unlink($fileName);
+                }
+            }
+        }
+    }
+}