Add phpunit test cases

src/Server/Manager.php

@@ -236,10 +236,15 @@ public function onTask($server, $taskId, $srcWorkerId, $data)
                     && $data['action'] === Websocket::PUSH_ACTION) {
                     $this->pushMessage($server, $data['data'] ?? []);
                 }
-            } else {
-                (new SwooleTaskJob($this->container, $server, $data, $taskId, $srcWorkerId))->fire();
+            } elseif (is_string($data)) {
+                $decoded= json_decode($data, true);
+
+                if (JSON_ERROR_NONE === json_last_error() && $decoded['type'] === 'queue') {
+                    (new SwooleTaskJob($this->container, $server, $data, $taskId, $srcWorkerId))->fire();
+                }
             }
         } catch (Throwable $e) {
+            dump($e);
             $this->logServerError($e);
         }
     }

src/Task/SwooleTaskQueue.php

@@ -2,6 +2,7 @@
 
 namespace SwooleTW\Http\Task;
 
+use Exception;
 use Illuminate\Queue\Queue;
 use Illuminate\Contracts\Queue\Queue as QueueContract;
 
@@ -48,7 +49,7 @@ public function push($job, $data = '', $queue = null)
      */
     public function pushRaw($payload, $queue = null, array $options = [])
     {
-        return $this->swoole->task($payload, $queue);
+        return $this->swoole->task($payload, ! is_numeric($queue) ? 1 : (int) $queue);
     }
 
     /**
@@ -76,6 +77,7 @@ public function later($delay, $job, $data = '', $queue = null)
     protected function createObjectPayload($job)
     {
         return [
+            'type' => 'queue',
             'maxTries' => $job->tries ?? null,
             'job' => 'Illuminate\Queue\CallQueuedHandler@call',
             'timeout' => $job->timeout ?? null,

tests/Task/FakeJob.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace SwooleTW\Http\Tests\Task;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+
+class FakeJob implements ShouldQueue
+{
+    use InteractsWithQueue, Queueable, SerializesModels;
+
+    public function handle()
+    {
+        //
+    }
+}

tests/Task/SwooleJobTest.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace SwooleTW\Http\Tests\Task;
+
+use Mockery as m;
+use SwooleTW\Http\Tests\TestCase;
+use Illuminate\Container\Container;
+use SwooleTW\Http\Task\SwooleTaskJob;
+
+class SwooleJobTest extends TestCase
+{
+    public function testFireProperlyCallsTheJobHandler()
+    {
+        $job = $this->getJob();
+        $job->getContainer()->shouldReceive('make')->once()->with('foo')->andReturn($handler = m::mock('stdClass'));
+        $handler->shouldReceive('fire')->once()->with($job, ['data']);
+        $job->fire();
+    }
+
+    protected function getJob()
+    {
+        return new SwooleTaskJob(
+            m::mock(Container::class),
+            $this->getServer(),
+            json_encode(['job' => 'foo', 'data' => ['data'], 'attempts' => 1]),
+            1, 1
+        );
+    }
+
+    protected function getServer()
+    {
+        $server = m::mock('server');
+        $server->shouldReceive('on');
+        $server->taskworker = false;
+        $server->master_pid = -1;
+
+        return $server;
+    }
+}

tests/Task/SwooleQueueTest.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace SwooleTW\Http\Tests\Task;
+
+use Mockery as m;
+use SwooleTW\Http\Tests\TestCase;
+use SwooleTW\Http\Task\SwooleTaskQueue;
+
+class SwooleQueueTest extends TestCase
+{
+    public function testPushProperlyPushesJobOntoSwoole()
+    {
+        $server = $this->getServer();
+
+        $queue = new SwooleTaskQueue($server);
+        $server->shouldReceive('task');
+        $queue->push(new FakeJob);
+    }
+
+    protected function getServer()
+    {
+        $server = m::mock('server');
+        $server->shouldReceive('on');
+        $server->taskworker = false;
+        $server->master_pid = -1;
+
+        return $server;
+    }
+}
+
+