From 7e8126a42180accd4fbeff6d1b0a381c6fca3365 Mon Sep 17 00:00:00 2001
From: Alejandro Celaya <alejandro@alejandrocelaya.com>
Date: Fri, 19 Jul 2019 21:06:34 +0200
Subject: [PATCH] Added AsyncEventListenerTest

---
 .../test/Async/TaskRunnerTest.php             |  2 +-
 .../test/Listener/AsyncEventListenerTest.php  | 41 +++++++++++++++++++
 2 files changed, 42 insertions(+), 1 deletion(-)
 create mode 100644 module/EventDispatcher/test/Listener/AsyncEventListenerTest.php

diff --git a/module/EventDispatcher/test/Async/TaskRunnerTest.php b/module/EventDispatcher/test/Async/TaskRunnerTest.php
index a78a741b..0bf56d7c 100644
--- a/module/EventDispatcher/test/Async/TaskRunnerTest.php
+++ b/module/EventDispatcher/test/Async/TaskRunnerTest.php
@@ -21,7 +21,7 @@ class TaskRunnerTest extends TestCase
     private $logger;
     /** @var ObjectProphecy */
     private $container;
-    /** @var ObjectProphecy */
+    /** @var HttpServer */
     private $server;
     /** @var ObjectProphecy */
     private $task;
diff --git a/module/EventDispatcher/test/Listener/AsyncEventListenerTest.php b/module/EventDispatcher/test/Listener/AsyncEventListenerTest.php
new file mode 100644
index 00000000..554528cd
--- /dev/null
+++ b/module/EventDispatcher/test/Listener/AsyncEventListenerTest.php
@@ -0,0 +1,41 @@
+<?php
+declare(strict_types=1);
+
+namespace ShlinkioTest\Shlink\EventDispatcher\Listener;
+
+use PHPUnit\Framework\TestCase;
+use Shlinkio\Shlink\EventDispatcher\Listener\AsyncEventListener;
+use Shlinkio\Shlink\EventDispatcher\Listener\EventListenerTask;
+use stdClass;
+use Swoole\Http\Server as HttpServer;
+
+class AsyncEventListenerTest extends TestCase
+{
+    /** @var AsyncEventListener */
+    private $eventListener;
+    /** @var HttpServer */
+    private $server;
+    /** @var string */
+    private $regularListenerName;
+
+    public function setUp(): void
+    {
+        $this->regularListenerName = 'the_regular_listener';
+        $this->server = $this->createMock(HttpServer::class);
+
+        $this->eventListener = new AsyncEventListener($this->server, $this->regularListenerName);
+    }
+
+    /** @test */
+    public function enqueuesTaskWhenInvoked(): void
+    {
+        $event = new stdClass();
+
+        $this->server
+            ->expects($this->once())
+            ->method('task')
+            ->with(new EventListenerTask($this->regularListenerName, $event));
+
+        ($this->eventListener)($event);
+    }
+}