Boot trigger processes on main worker start (#331)

* Boot trigger processes on main worker start

* Rename listener

* Revert "Rename listener"

This reverts commit 3f8653a992d0d814baf0677f500ee88f5d3bacff.

* Rename

* Remove listener from ConfigProvider

---------

Co-authored-by: Deeka Wong <[email protected]>

src/ConfigProvider.php

@@ -31,7 +31,7 @@ public function __invoke(): array
                 Command\TriggersCommand::class,
             ],
             'listeners' => [
-                Listener\OnBootApplicationListener::class,
+                // Listener\BindTriggerProcessesListener::class,
             ],
             'publish' => [
                 [

src/Listener/BindTriggerProcessesListener.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of friendsofhyperf/components.
+ *
+ * @link     https://github.com/friendsofhyperf/components
+ * @document https://github.com/friendsofhyperf/components/blob/main/README.md
+ * @contact  [email protected]
+ */
+
+namespace FriendsOfHyperf\Trigger\Listener;
+
+use FriendsOfHyperf\Trigger\ConsumerManager;
+use FriendsOfHyperf\Trigger\SubscriberManager;
+use FriendsOfHyperf\Trigger\TriggerManager;
+use Hyperf\Event\Contract\ListenerInterface;
+use Hyperf\Framework\Event\MainWorkerStart;
+use Hyperf\Server\Event\MainCoroutineServerStart;
+
+class BindTriggerProcessesListener implements ListenerInterface
+{
+    public function __construct(
+        protected SubscriberManager $subscriberManager,
+        protected TriggerManager $triggerManager,
+        protected ConsumerManager $consumerManager
+    ) {
+    }
+
+    public function listen(): array
+    {
+        return [
+            MainWorkerStart::class,
+            MainCoroutineServerStart::class,
+        ];
+    }
+
+    /**
+     * @param MainWorkerStart|MainCoroutineServerStart $event
+     */
+    public function process(object $event): void
+    {
+        $this->subscriberManager->register();
+        $this->triggerManager->register();
+        $this->consumerManager->run();
+    }
+}

src/Listener/OnBootApplicationListener.php

@@ -11,35 +11,9 @@
 
 namespace FriendsOfHyperf\Trigger\Listener;
 
-use FriendsOfHyperf\Trigger\ConsumerManager;
-use FriendsOfHyperf\Trigger\SubscriberManager;
-use FriendsOfHyperf\Trigger\TriggerManager;
-use Hyperf\Event\Contract\ListenerInterface;
-use Hyperf\Framework\Event\BootApplication;
-
-class OnBootApplicationListener implements ListenerInterface
+/**
+ * @deprecated v3.0, will be removed in v3.1, please use StartTriggerListener instead.
+ */
+class OnBootApplicationListener extends BindTriggerProcessesListener
 {
-    public function __construct(
-        protected SubscriberManager $subscriberManager,
-        protected TriggerManager $triggerManager,
-        protected ConsumerManager $consumerManager
-    ) {
-    }
-
-    public function listen(): array
-    {
-        return [
-            BootApplication::class,
-        ];
-    }
-
-    /**
-     * @param BootApplication $event
-     */
-    public function process(object $event): void
-    {
-        $this->subscriberManager->register();
-        $this->triggerManager->register();
-        $this->consumerManager->run();
-    }
 }