Overblog\GraphQLBundle\Tests\Error\ReactPromiseAdapterTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	4	1
A	testWaitWithNotSupportedPromise()	0	5	1
A	testWaitRejectedPromise()	0	5	1
B	testWaitAsyncPromise()	0	24	1

<?php

/*
 * This file is part of the OverblogGraphQLBundle package.
 *
 * (c) Overblog <http://github.com/overblog/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Overblog\GraphQLBundle\Tests\Error;

use GraphQL\Executor\Promise\Promise;
use Overblog\GraphQLBundle\Executor\Promise\Adapter\ReactPromiseAdapter;
use Symfony\Component\Process\PhpProcess;

class ReactPromiseAdapterTest extends \PHPUnit_Framework_TestCase
{
    /** @var ReactPromiseAdapter */
    private $adapter;

    public function setUp()
    {
        $this->adapter = new ReactPromiseAdapter();
    }

    /**
     * @expectedException \InvalidArgumentException
     * @expectedExceptionMessage The "Overblog\GraphQLBundle\Executor\Promise\Adapter\ReactPromiseAdapter::wait" method must be call with compatible a Promise.
     */
    public function testWaitWithNotSupportedPromise()
    {
        $noSupportedPromise = new Promise(new \stdClass(), $this->adapter);
        $this->adapter->wait($noSupportedPromise);
    }

    /**
     * @expectedException \Exception
     * @expectedExceptionMessage Promise has been rejected!
     */
    public function testWaitRejectedPromise()
    {
        $rejected = $this->adapter->createRejected(new \Exception('Promise has been rejected!'));
        $this->adapter->wait($rejected);
    }

    public function testWaitAsyncPromise()
    {
        $output = 'OK!';
        $process = new PhpProcess(<<<EOF
<?php
usleep(30);
echo '$output';
EOF
        );

        $promise = $this->adapter->create(function (callable $resolve) use (&$process) {
            $process->start(function () use ($resolve, &$process) {
                $output = $process->getOutput();
                $resolve($output);
            });
        });

        $this->assertEquals(
            $output,
            $this->adapter->wait($promise, function () use (&$process) {
                $process->wait();
            })
        );
    }
}