Added shutdown kernel event (#37)

AsyncHttpKernel.php

@@ -16,6 +16,7 @@
 namespace Drift\HttpKernel;
 
 use Drift\HttpKernel\Event\PreloadEvent;
+use Drift\HttpKernel\Event\ShutdownEvent;
 use Drift\HttpKernel\Exception\AsyncEventDispatcherNeededException;
 use Exception;
 use React\Promise\PromiseInterface;
@@ -101,6 +102,16 @@ public function preload(): PromiseInterface
             ->asyncDispatch(new PreloadEvent(), AsyncKernelEvents::PRELOAD);
     }
 
+    /**
+     * Shutdown kernel.
+     */
+    public function shutdown(): PromiseInterface
+    {
+        return $this
+            ->dispatcher
+            ->asyncDispatch(new ShutdownEvent(), AsyncKernelEvents::SHUTDOWN);
+    }
+
     /**
      * Handles a Request to convert it to a Response.
      *

AsyncKernel.php

@@ -63,6 +63,16 @@ public function preload(): PromiseInterface
             ->preload();
     }
 
+    /**
+     * Shutdown kernel.
+     */
+    public function shutdown(): PromiseInterface
+    {
+        return $this
+            ->getHttpKernel()
+            ->shutdown();
+    }
+
     /**
      * Handles a Request to convert it to a Response.
      *

AsyncKernelEvents.php

@@ -22,9 +22,20 @@ final class AsyncKernelEvents
      * the first request is handled.
      *
      * This event allows you to load services in the dependency injection, to
-     * preload clients...
+     * preload clients, and so on.
      *
      * @Event("Drift\HttpKernel\Event\PreloadEvent")
      */
     const PRELOAD = 'kernel.preload';
+
+    /**
+     * The SHUTDOWN event occurs once the kernel is asked to be closed
+     * gracefully.
+     *
+     * This event allows you to flush elements from memory, close connections
+     * and so on.
+     *
+     * @Event("Drift\HttpKernel\Event\ShutdownEvent")
+     */
+    const SHUTDOWN = 'kernel.shutdown';
 }

Event/ShutdownEvent.php

@@ -0,0 +1,25 @@
+<?php
+
+/*
+ * This file is part of the DriftPHP Project
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ *
+ * Feel free to edit as you please, and have fun.
+ *
+ * @author Marc Morera <yuhu@mmoreram.com>
+ */
+
+declare(strict_types=1);
+
+namespace Drift\HttpKernel\Event;
+
+use Symfony\Contracts\EventDispatcher\Event;
+
+/**
+ * Class TerminateEvent.
+ */
+class ShutdownEvent extends Event
+{
+}

PeriodicTimer/PeriodicTimer.php

@@ -52,10 +52,7 @@ public function addServiceCall(
             });
     }
 
-    /**
-     *
-     */
-    function onKernelPreload()
+    public function onKernelPreload()
     {
         // Just an empty method to be called.
         // The main goal are the previous calls

Tests/Listener.php

@@ -17,6 +17,7 @@
 
 use Drift\HttpKernel\Event\DomainEventEnvelope;
 use Drift\HttpKernel\Event\PreloadEvent;
+use Drift\HttpKernel\Event\ShutdownEvent;
 use Drift\HttpKernel\Tests\Event\Event1;
 use React\Promise\PromiseInterface;
 use function React\Promise\resolve;
@@ -169,6 +170,16 @@ public function handlePreload(PreloadEvent $event)
         $_GET['preloaded'] = true;
     }
 
+    /**
+     * Handle shutdown.
+     *
+     * @param ShutdownEvent $event
+     */
+    public function handleShutdown(ShutdownEvent $event)
+    {
+        $_GET['shutdown'] = true;
+    }
+
     /**
      * Handle event1.
      *