Complete tests, fix #41

phpstan.neon

@@ -1,3 +1,4 @@
 parameters:
     excludes_analyse:
         - tests/fixtures/foo.php
+        - src/Graphql/SubscriptionManager.php

src/Graphql/SubscriptionManager.php

@@ -59,13 +59,15 @@ public function handleSubscriptionStart(ConnectionInterface $conn, array $data)
                 'type' => Graphql\SUBSCRIPTION_SUCCESS,
                 'id'   => $data['id'],
             ];
+
+            $conn->send(json_encode($response));
         } catch (\Exception $exception) {
             $response = [
                 'type'    => Graphql\SUBSCRIPTION_FAIL,
                 'id'      => $data['id'],
                 'payload' => $exception->getMessage(),
             ];
-        } finally {
+
             $conn->send(json_encode($response));
         }
     }

src/Graphql/SubscriptionServer.php

@@ -9,6 +9,8 @@
 
 class SubscriptionServer implements MessageComponentInterface, WsServerInterface
 {
+    protected $manager;
+
     public function __construct(SubscriptionManager $manager)
     {
         $this->manager = $manager;

src/Ratchet/Ratchet.php

@@ -34,7 +34,7 @@ function init($port = null)
 
     Container\set(RATCHET_CONNECTIONS, new \SplObjectStorage());
 
-    $server->run();
+    return $server;
 }
 
 /**

tests/Unit/Ratchet/RatchetTest.php

@@ -3,11 +3,20 @@
 namespace Siler\Test\Unit;
 
 use Ratchet\ConnectionInterface;
+use Ratchet\Server\IoServer;
 use Siler\Container;
 use Siler\Ratchet;
 
 class RatchetTest extends \PHPUnit\Framework\TestCase
 {
+    public function testInit()
+    {
+        $server = Ratchet\init();
+
+        $this->assertInstanceOf(\SplObjectStorage::class, Container\get(Ratchet\RATCHET_CONNECTIONS));
+        $this->assertInstanceOf(IoServer::class, $server);
+    }
+
     public function testConnected()
     {
         $expected = function () {

tests/Unit/Route/RoutePsr7Test.php

@@ -35,6 +35,24 @@ public function testRoute()
         $this->assertEquals('foo', $actual);
     }
 
+    /**
+     * @runInSeparateProcess
+     * @preserveGlobalState disabled
+     */
+    public function testNullRoute()
+    {
+        $server = ['REQUEST_URI' => '/foo'];
+        $request = ServerRequestFactory::fromGlobals($server);
+
+        Route\psr7($request);
+
+        $actual = Route\get('/bar', function () {
+            return 'baz';
+        });
+
+        $this->assertNull($actual);
+    }
+
     public function teardown()
     {
         unset(Container\Container::getInstance()->values['psr7_request']);