improve isSwooleQueuePacket function

Author: albertcht

src/Concerns/InteractsWithSwooleQueue.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace SwooleTW\Http\Concerns;
+
+use Swoole\Table;
+use SwooleTW\Http\Table\SwooleTable;
+
+trait InteractsWithSwooleQueue
+{
+    /**
+     * Indicates if a packet is swoole's queue job.
+     *
+     * @param mixed
+     */
+    protected function isSwooleQueuePacket($packet)
+    {
+        if (! is_string($packet)) {
+            return false;
+        }
+
+        $decoded = json_decode($packet, true);
+
+        return JSON_ERROR_NONE === json_last_error() && isset($decoded['job']);
+    }
+}

src/Server/Manager.php

@@ -14,12 +14,14 @@
 use Illuminate\Contracts\Container\Container;
 use Illuminate\Contracts\Debug\ExceptionHandler;
 use SwooleTW\Http\Concerns\InteractsWithWebsocket;
+use SwooleTW\Http\Concerns\InteractsWithSwooleQueue;
 use SwooleTW\Http\Concerns\InteractsWithSwooleTable;
 
 class Manager
 {
     use InteractsWithWebsocket,
         InteractsWithSwooleTable,
+        InteractsWithSwooleQueue,
         WithApplication;
 
     /**
@@ -233,12 +235,8 @@ public function onTask($server, $taskId, $srcWorkerId, $data)
             if ($this->isWebsocketPushPacket($data)) {
                 $this->pushMessage($server, $data['data'] ?? []);
             // push async task to queue
-            } elseif (is_string($data)) {
-                $decoded = json_decode($data, true);
-
-                if (JSON_ERROR_NONE === json_last_error() && isset($decoded['job'])) {
-                    (new SwooleTaskJob($this->container, $server, $data, $taskId, $srcWorkerId))->fire();
-                }
+            } elseif ($this->isSwooleQueuePacket($data)) {
+                (new SwooleTaskJob($this->container, $server, $data, $taskId, $srcWorkerId))->fire();
             }
         } catch (Throwable $e) {
             $this->logServerError($e);