v1.6.0 - gc collect cycles

Author: Asisyas

src/Facade/HttpRoadrunnerFacade.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+/*
+ *  This file is part of the Micro framework package.
+ *
+ *  (c) Stanislau Komar <kost@micro-php.net>
+ *
+ *  For the full copyright and license information, please view the LICENSE
+ *  file that was distributed with this source code.
+ */
+
+namespace Micro\Plugin\Http\Facade;
+
+use Micro\Plugin\Http\HttpRoadrunnerPluginConfigurationInterface;
+
+final readonly class HttpRoadrunnerFacade implements HttpRoadrunnerFacadeInterface
+{
+    public function __construct(
+        private HttpRoadrunnerPluginConfigurationInterface $httpRoadrunnerPluginConfiguration
+    ) {
+    }
+
+    public function getGcCollectCyclesCount(): int
+    {
+        return $this->httpRoadrunnerPluginConfiguration->getGcCollectCyclesCount();
+    }
+}

src/Facade/HttpRoadrunnerFacadeInterface.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+/*
+ *  This file is part of the Micro framework package.
+ *
+ *  (c) Stanislau Komar <kost@micro-php.net>
+ *
+ *  For the full copyright and license information, please view the LICENSE
+ *  file that was distributed with this source code.
+ */
+
+namespace Micro\Plugin\Http\Facade;
+
+interface HttpRoadrunnerFacadeInterface
+{
+    public function getGcCollectCyclesCount(): int;
+}

src/HttpRoadrunnerPlugin.php

@@ -13,11 +13,29 @@
 
 namespace Micro\Plugin\Http;
 
+use Micro\Component\DependencyInjection\Container;
+use Micro\Framework\Kernel\Plugin\ConfigurableInterface;
+use Micro\Framework\Kernel\Plugin\DependencyProviderInterface;
+use Micro\Framework\Kernel\Plugin\PluginConfigurationTrait;
 use Micro\Framework\Kernel\Plugin\PluginDependedInterface;
 use Micro\Plugin\EventEmitter\EventEmitterPlugin;
+use Micro\Plugin\Http\Facade\HttpRoadrunnerFacade;
+use Micro\Plugin\Http\Facade\HttpRoadrunnerFacadeInterface;
 
-final readonly class HttpRoadrunnerPlugin implements PluginDependedInterface
+/**
+ * @method HttpRoadrunnerPluginConfigurationInterface configuration()
+ */
+final class HttpRoadrunnerPlugin implements DependencyProviderInterface, PluginDependedInterface, ConfigurableInterface
 {
+    use PluginConfigurationTrait;
+
+    public function provideDependencies(Container $container): void
+    {
+        $container->register(HttpRoadrunnerFacadeInterface::class, function () {
+            return new HttpRoadrunnerFacade($this->configuration());
+        });
+    }
+
     public function getDependedPlugins(): iterable
     {
         return [

src/HttpRoadrunnerPluginConfiguration.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+/*
+ *  This file is part of the Micro framework package.
+ *
+ *  (c) Stanislau Komar <kost@micro-php.net>
+ *
+ *  For the full copyright and license information, please view the LICENSE
+ *  file that was distributed with this source code.
+ */
+
+namespace Micro\Plugin\Http;
+
+use Micro\Framework\Kernel\Configuration\PluginConfiguration;
+
+final class HttpRoadrunnerPluginConfiguration extends PluginConfiguration implements HttpRoadrunnerPluginConfigurationInterface
+{
+    public const CFG_GC_COLLECT_CYCLES_COUNT = 'MICRO_RR_GC_COLLECT_CYCLES_COUNT';
+
+    public const CFG_GC_COLLECT_CYCLES_COUNT_DEFAULT = 10;
+
+    public function getGcCollectCyclesCount(): int
+    {
+        return (int) $this->configuration
+            ->get(
+                self::CFG_GC_COLLECT_CYCLES_COUNT,
+                self::CFG_GC_COLLECT_CYCLES_COUNT_DEFAULT,
+                false
+            );
+    }
+}

src/HttpRoadrunnerPluginConfigurationInterface.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+/*
+ *  This file is part of the Micro framework package.
+ *
+ *  (c) Stanislau Komar <kost@micro-php.net>
+ *
+ *  For the full copyright and license information, please view the LICENSE
+ *  file that was distributed with this source code.
+ */
+
+namespace Micro\Plugin\Http;
+
+interface HttpRoadrunnerPluginConfigurationInterface
+{
+    public function getGcCollectCyclesCount(): int;
+}

src/Listener/ApplicationRoadrunnerStartedListener.php

@@ -18,6 +18,7 @@
 use Micro\Kernel\App\Business\Event\ApplicationReadyEvent;
 use Micro\Kernel\App\Business\Event\ApplicationReadyEventInterface;
 use Micro\Plugin\Http\Facade\HttpFacadeInterface;
+use Micro\Plugin\Http\Facade\HttpRoadrunnerFacadeInterface;
 use Nyholm\Psr7\Factory\Psr17Factory;
 use Spiral\RoadRunner;
 use Symfony\Bridge\PsrHttpMessage\Factory\HttpFoundationFactory;
@@ -26,7 +27,8 @@
 final readonly class ApplicationRoadrunnerStartedListener implements EventListenerInterface
 {
     public function __construct(
-        private HttpFacadeInterface $httpFacade
+        private HttpFacadeInterface $httpFacade,
+        private HttpRoadrunnerFacadeInterface $httpRoadrunnerFacade
     ) {
     }
 
@@ -50,13 +52,19 @@ public function on(EventInterface $event): void
 
         $worker = RoadRunner\Worker::create();
         $worker = new RoadRunner\Http\PSR7Worker($worker, $psr17Factory, $psr17Factory, $psr17Factory);
+        $i = 0;
+        $gcCollectStep = $this->httpRoadrunnerFacade->getGcCollectCyclesCount();
         while ($request = $worker->waitRequest()) {
             try {
                 $appRequest = $httpFoundationFactory->createRequest($request);
                 $appResponse = $this->httpFacade->execute($appRequest, false);
                 $worker->respond($httpMessageFactory->createResponse($appResponse));
             } catch (\Throwable $e) {
                 $worker->getWorker()->error((string) $e);
+            } finally {
+                if (++$i === $gcCollectStep) {
+                    gc_collect_cycles();
+                }
             }
         }
     }