[2.x] Flushes Once::class on Operation Terminated (#821)

* Flushes once after `OperationTerminated`

* Apply fixes from StyleCI

* Fix code styling

---------

Co-authored-by: StyleCI Bot <[email protected]>
Co-authored-by: taylorotwell <[email protected]>

Author: 3 people

config/octane.php

@@ -15,6 +15,7 @@
 use Laravel\Octane\Listeners\DisconnectFromDatabases;
 use Laravel\Octane\Listeners\EnsureUploadedFilesAreValid;
 use Laravel\Octane\Listeners\EnsureUploadedFilesCanBeMoved;
+use Laravel\Octane\Listeners\FlushOnce;
 use Laravel\Octane\Listeners\FlushTemporaryContainerInstances;
 use Laravel\Octane\Listeners\FlushUploadedFiles;
 use Laravel\Octane\Listeners\ReportException;
@@ -101,6 +102,7 @@
         ],
 
         OperationTerminated::class => [
+            FlushOnce::class,
             FlushTemporaryContainerInstances::class,
             // DisconnectFromDatabases::class,
             // CollectGarbage::class,

src/Listeners/FlushOnce.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+use Illuminate\Support\Once;
+
+class FlushOnce
+{
+    /**
+     * Handle the event.
+     *
+     * @param  mixed  $event
+     */
+    public function handle($event): void
+    {
+        if (class_exists(Once::class)) {
+            Once::flush();
+        }
+    }
+}

tests/Listeners/FlushOnceTest.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+use Illuminate\Http\Request;
+use Illuminate\Support\Once;
+use Laravel\Octane\Tests\TestCase;
+
+class FlushOnceTest extends TestCase
+{
+    public function test_once_is_flushed()
+    {
+        if (! class_exists(Once::class)) {
+            $this->markTestSkipped('Once is only supported in Laravel 11+');
+        }
+
+        [$app, $worker] = $this->createOctaneContext([
+            Request::create('/', 'GET'),
+            Request::create('/', 'GET'),
+            Request::create('/', 'GET'),
+        ]);
+
+        $results = [];
+
+        $app['router']->middleware('web')->get('/', function () use (&$results) {
+            $results[] = my_rand();
+        });
+
+        $worker->run();
+
+        $this->assertTrue($results[0] !== $results[1]);
+        $this->assertTrue($results[0] !== $results[2]);
+        $this->assertTrue($results[1] !== $results[2]);
+    }
+}
+
+function my_rand()
+{
+    return once(fn () => rand(1, PHP_INT_MAX));
+}