Remove worker concept

utopia-php · Jan 4, 2024 · ee4fc6d · ee4fc6d
1 parent d5e2929
commit ee4fc6d
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 60 deletions.
diff --git a/src/Http/Adapter.php b/src/Http/Adapter.php
@@ -5,7 +5,6 @@
 abstract class Adapter
 {
     abstract public function onStart(callable $callback);
-    abstract public function onWorkerStart(callable $callback);
     abstract public function onRequest(callable $callback);
     abstract public function start();
 }
diff --git a/src/Http/Adapter/FPM/Server.php b/src/Http/Adapter/FPM/Server.php
@@ -27,11 +27,6 @@ public function onStart(callable $callback)
         call_user_func($callback, $this);
     }
 
-    public function onWorkerStart(callable $callback)
-    {
-        call_user_func($callback, $this);
-    }
-
     public function start()
     {
         return;

diff --git a/src/Http/Adapter/Swoole/Server.php b/src/Http/Adapter/Swoole/Server.php
@@ -35,11 +35,6 @@ public function onRequest(callable $callback)
         });
     }
 
-    public function onWorkerStart(callable $callback)
-    {
-        call_user_func($callback, $this);
-    }
-
     public function onStart(callable $callback)
     {
         call_user_func($callback, $this);

diff --git a/src/Http/Http.php b/src/Http/Http.php
@@ -97,13 +97,6 @@ class Http
      */
     protected static array $startHooks = [];
 
-    /**
-     * Worker Start hooks
-     *
-     * @var Hook[]
-     */
-    protected static array $workerStartHooks = [];
-
     /**
      * Request hooks
      *
@@ -563,13 +556,6 @@ protected function getFileMimeType(string $uri): mixed
         return $this->files->getFileMimeType($uri);
     }
 
-    public static function onWorkerStart(): Hook
-    {
-        $hook = new Hook();
-        self::$workerStartHooks[] = $hook;
-        return $hook;
-    }
-
     public static function onStart(): Hook
     {
         $hook = new Hook();
@@ -623,40 +609,6 @@ public function start()
             }
         });
 
-        $this->server->onWorkerStart(function ($server, $workerId) {
-            $this->resources['utopia'] ??= [];
-            $this->resources['utopia']['server'] = $server;
-            $this->resources['utopia']['workerId'] = $workerId;
-
-            self::setResource('server', function () use ($server) {
-                return $server;
-            });
-            self::setResource('workerId', function () use ($workerId) {
-                return $workerId;
-            });
-
-            try {
-
-                foreach (self::$workerStartHooks as $hook) {
-                    $arguments = $this->getArguments($hook, 'utopia', [], []);
-                    \call_user_func_array($hook->getAction(), $arguments);
-                }
-            } catch(\Exception $e) {
-                self::setResource('error', fn () => $e);
-
-                foreach (self::$errors as $error) { // Global error hooks
-                    if (in_array('*', $error->getGroups())) {
-                        try {
-                            $arguments = $this->getArguments($error, 'utopia', [], []);
-                            \call_user_func_array($error->getAction(), $arguments);
-                        } catch (\Throwable $e) {
-                            throw new Exception('Error handler had an error: ' . $e->getMessage(), 500, $e);
-                        }
-                    }
-                }
-            }
-        });
-
         $this->server->start();
     }
 
@@ -1004,7 +956,6 @@ public static function reset(): void
         self::$init = [];
         self::$shutdown = [];
         self::$options = [];
-        self::$workerStartHooks = [];
         self::$startHooks = [];
     }
 }