feat(server): Set-up hooks on lifecycle events

src/Bridge/Symfony/Bundle/DependencyInjection/SwooleExtension.php

@@ -12,7 +12,6 @@
 use K911\Swoole\Bridge\Symfony\HttpKernel\DebugHttpKernelRequestHandler;
 use K911\Swoole\Server\Config\Socket;
 use K911\Swoole\Server\Configurator\ConfiguratorInterface;
-use K911\Swoole\Server\Configurator\WithWorkerStartHandler;
 use K911\Swoole\Server\HttpServerConfiguration;
 use K911\Swoole\Server\RequestHandler\AdvancedStaticFilesServer;
 use K911\Swoole\Server\RequestHandler\RequestHandlerInterface;
@@ -120,13 +119,6 @@ private function registerHttpServerConfiguration(array $config, ContainerBuilder
             ->addArgument($settings);
 
         $this->registerHttpServerHMR($hmr, $container);
-
-        if ($container->has(WorkerStartHandlerInterface::class)) {
-            $container->register(WithWorkerStartHandler::class)
-                ->setAutowired(true)
-                ->setAutoconfigured(true)
-                ->setPublic(false);
-        }
     }
 
     private function registerHttpServerHMR(string $hmr, ContainerBuilder $container): void
@@ -136,18 +128,16 @@ private function registerHttpServerHMR(string $hmr, ContainerBuilder $container)
         }
 
         if ('inotify' === $hmr) {
-            $container->register(HotModuleReloaderInterface::class, InotifyHMR::class)
-                ->setAutowired(true)
+            $container->autowire(HotModuleReloaderInterface::class, InotifyHMR::class)
                 ->setAutoconfigured(true)
                 ->setPublic(false);
         }
 
-        if (!$container->has(WorkerStartHandlerInterface::class)) {
-            $container->register(WorkerStartHandlerInterface::class, HMRWorkerStartHandler::class)
-                ->setAutowired(true)
-                ->setAutoconfigured(true)
-                ->setPublic(false);
-        }
+        $container->autowire(HMRWorkerStartHandler::class)
+            ->setAutoconfigured(false)
+            ->setPublic(false)
+            ->setArgument('$decorated', new Reference(HMRWorkerStartHandler::class.'.inner'))
+            ->setDecoratedService(WorkerStartHandlerInterface::class);
     }
 
     private function resolveAutoHMR(): string

src/Bridge/Symfony/Bundle/Resources/config/services.yaml

@@ -33,10 +33,35 @@ services:
 
     'K911\Swoole\Server\HttpServer':
 
+    'K911\Swoole\Server\WorkerHandler\WorkerStartHandlerInterface':
+        class: K911\Swoole\Server\WorkerHandler\NoOpWorkerStartHandler
+
+    'K911\Swoole\Server\LifecycleHandler\ServerStartHandlerInterface':
+        class: K911\Swoole\Server\LifecycleHandler\NoOpServerStartHandler
+
+    'K911\Swoole\Server\LifecycleHandler\ServerShutdownHandlerInterface':
+        class: K911\Swoole\Server\LifecycleHandler\NoOpServerShutdownHandler
+
+    'K911\Swoole\Server\LifecycleHandler\ServerManagerStartHandlerInterface':
+        class: K911\Swoole\Server\LifecycleHandler\NoOpServerManagerStartHandler
+
+    'K911\Swoole\Server\LifecycleHandler\ServerManagerStopHandlerInterface':
+        class: K911\Swoole\Server\LifecycleHandler\NoOpServerManagerStopHandler
+
     'K911\Swoole\Server\HttpServerConfiguration':
 
     'K911\Swoole\Server\Configurator\WithHttpServerConfiguration':
 
+    'K911\Swoole\Server\Configurator\WithServerShutdownHandler':
+
+    'K911\Swoole\Server\Configurator\WithServerStartHandler':
+
+    'K911\Swoole\Server\Configurator\WithServerManagerStartHandler':
+
+    'K911\Swoole\Server\Configurator\WithServerManagerStopHandler':
+
+    'K911\Swoole\Server\Configurator\WithWorkerStartHandler':
+
     'K911\Swoole\Server\Configurator\CallableChainConfiguratorFactory':
 
     'swoole_bundle.server.http_server.configurator_collection':
@@ -61,4 +86,3 @@ services:
         autoconfigure: false
         arguments:
             $handler: '@K911\Swoole\Server\LifecycleHandler\SigIntHandler'
-

src/Server/Configurator/WithServerManagerStartHandler.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\Configurator;
+
+use K911\Swoole\Server\LifecycleHandler\ServerManagerStartHandlerInterface;
+use Swoole\Http\Server;
+
+final class WithServerManagerStartHandler implements ConfiguratorInterface
+{
+    private $handler;
+
+    public function __construct(ServerManagerStartHandlerInterface $handler)
+    {
+        $this->handler = $handler;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function configure(Server $server): void
+    {
+        $server->on('ManagerStart', [$this->handler, 'handle']);
+    }
+}

src/Server/Configurator/WithServerManagerStopHandler.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\Configurator;
+
+use K911\Swoole\Server\LifecycleHandler\ServerManagerStopHandlerInterface;
+use Swoole\Http\Server;
+
+final class WithServerManagerStopHandler implements ConfiguratorInterface
+{
+    private $handler;
+
+    public function __construct(ServerManagerStopHandlerInterface $handler)
+    {
+        $this->handler = $handler;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function configure(Server $server): void
+    {
+        $server->on('ManagerStop', [$this->handler, 'handle']);
+    }
+}

src/Server/Configurator/WithServerShutdownHandler.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\Configurator;
+
+use K911\Swoole\Server\LifecycleHandler\ServerShutdownHandlerInterface;
+use Swoole\Http\Server;
+
+final class WithServerShutdownHandler implements ConfiguratorInterface
+{
+    private $handler;
+
+    public function __construct(ServerShutdownHandlerInterface $handler)
+    {
+        $this->handler = $handler;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function configure(Server $server): void
+    {
+        $server->on('shutdown', [$this->handler, 'handle']);
+    }
+}

src/Server/LifecycleHandler/NoOpServerManagerStartHandler.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+final class NoOpServerManagerStartHandler implements ServerManagerStartHandlerInterface
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function handle(Server $server): void
+    {
+        // noop
+    }
+}

src/Server/LifecycleHandler/NoOpServerManagerStopHandler.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+final class NoOpServerManagerStopHandler implements ServerManagerStopHandlerInterface
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function handle(Server $server): void
+    {
+        // noop
+    }
+}

src/Server/LifecycleHandler/NoOpServerShutdownHandler.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+final class NoOpServerShutdownHandler implements ServerShutdownHandlerInterface
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function handle(Server $server): void
+    {
+        // noop
+    }
+}

src/Server/LifecycleHandler/NoOpServerStartHandler.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+final class NoOpServerStartHandler implements ServerStartHandlerInterface
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function handle(Server $server): void
+    {
+        // noop
+    }
+}

src/Server/LifecycleHandler/ServerManagerStartHandlerInterface.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+interface ServerManagerStartHandlerInterface
+{
+    /**
+     * Handle "OnManagerStart" event.
+     *
+     * Info: Handler is executed in manager process
+     *
+     * @param Server $server
+     */
+    public function handle(Server $server): void;
+}

src/Server/LifecycleHandler/ServerManagerStopHandlerInterface.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+interface ServerManagerStopHandlerInterface
+{
+    /**
+     * Handle "OnManagerStop" event.
+     *
+     * Info: Handler is executed in manager process
+     *
+     * @param Server $server
+     */
+    public function handle(Server $server): void;
+}

src/Server/LifecycleHandler/ServerShutdownHandlerInterface.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\LifecycleHandler;
+
+use Swoole\Server;
+
+interface ServerShutdownHandlerInterface
+{
+    /**
+     * Handle "OnShutdown" event.
+     *
+     * @param Server $server
+     */
+    public function handle(Server $server): void;
+}

src/Server/LifecycleHandler/SigIntHandler.php

@@ -9,12 +9,23 @@
 
 final class SigIntHandler implements ServerStartHandlerInterface
 {
+    private $decorated;
+
+    public function __construct(?ServerStartHandlerInterface $decorated = null)
+    {
+        $this->decorated = $decorated;
+    }
+
     /**
      * {@inheritdoc}
      */
     public function handle(Server $server): void
     {
         // 2 => SIGINT
         Process::signal(2, [$server, 'shutdown']);
+
+        if ($this->decorated instanceof ServerStartHandlerInterface) {
+            $this->decorated->handle($server);
+        }
     }
 }

src/Server/WorkerHandler/HMRWorkerStartHandler.php

@@ -11,18 +11,24 @@ final class HMRWorkerStartHandler implements WorkerStartHandlerInterface
 {
     private $hmr;
     private $interval;
+    private $decorated;
 
-    public function __construct(HotModuleReloaderInterface $hmr, int $interval = 2000)
+    public function __construct(HotModuleReloaderInterface $hmr, int $interval = 2000, ?WorkerStartHandlerInterface $decorated = null)
     {
         $this->hmr = $hmr;
         $this->interval = $interval;
+        $this->decorated = $decorated;
     }
 
     /**
      * {@inheritdoc}
      */
     public function handle(Server $worker, int $workerId): void
     {
+        if ($this->decorated instanceof WorkerStartHandlerInterface) {
+            $this->decorated->handle($worker, $workerId);
+        }
+
         if ($worker->taskworker) {
             return;
         }

src/Server/WorkerHandler/NoOpWorkerStartHandler.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K911\Swoole\Server\WorkerHandler;
+
+use Swoole\Server;
+
+final class NoOpWorkerStartHandler implements WorkerStartHandlerInterface
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function handle(Server $worker, int $workerId): void
+    {
+        // noop
+    }
+}

src/Server/WorkerHandler/WorkerStartHandlerInterface.php

@@ -14,11 +14,11 @@ interface WorkerStartHandlerInterface
      *
      * To differentiate between server worker and task worker use snippet:
      *
-     * ```php
-     * if($server->taskworker) {
-     *   echo "Hello from task worker process";
-     * }
-     * ```
+     *      ```php
+     *      if($server->taskworker) {
+     *        echo "Hello from task worker process";
+     *      }
+     *      ```
      *
      * @param Server $worker
      * @param int    $workerId