Merge branch 'develop' of https://github.com/swooletw/laravel-swoole into develop

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/Concerns/InteractsWithWebsocket.php

@@ -151,6 +151,23 @@ public function onClose($server, $fd, $reactorId)
         }
     }
 
+    /**
+     * Indicates if a packet is websocket push action.
+     *
+     * @param mixed
+     */
+    protected function isWebsocketPushPacket($packet)
+    {
+        if ( !is_array($packet)) {
+            return false;
+        }
+
+        return $this->isWebsocket
+            && array_key_exists('action', $packet)
+            && $packet['action'] === Websocket::PUSH_ACTION;
+    }
+
+
     /**
      * Push websocket message to clients.
      *

src/Server/Manager.php

@@ -18,6 +18,7 @@
 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;
 use Symfony\Component\Debug\Exception\FatalThrowableError;
 
@@ -28,6 +29,7 @@ class Manager
 {
     use InteractsWithWebsocket,
         InteractsWithSwooleTable,
+        InteractsWithSwooleQueue,
         WithApplication;
 
     /**