Tleckie\Async\Tests\ChildTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	15	1
A	handleException()	0	15	1
A	write()	0	10	1
A	setUp()	0	5	1

<?php

namespace Tleckie\Async\Tests;

use Exception;
use Opis\Closure\SerializableClosure;
use PHPUnit\Framework\TestCase;
use Tleckie\Async\Child;
use Tleckie\Async\Encoder;

/**
 * Class ChildTest
 *
 * @package Tleckie\Async\Tests
 * @author  Teodoro Leckie Westberg <teodoroleckie@gmail.com>
 */
class ChildTest extends TestCase
{
    /** @var Child */
    private Child $child;

    /** @var Encoder  */
    private Encoder $encoder;

    public function setUp(): void
    {
        $this->encoder = new Encoder();
        $this->child = new Child(
            $this->encoder
        );
    }

    /**
     * @test
     */
    public function handle(): void
    {
        $closure = function () {
            return 33;
        };

        $encode = $this->encoder->encode(new SerializableClosure($closure));

        $output = $this->encoder->decode(
            $this->child->handle($encode)->output()
        );

        static::assertEquals(33, $output);
        static::assertFalse($this->child->hasError());
        static::assertNull($this->child->exception());
    }

    /**
     * @test
     */
    public function handleException(): void
    {
        $closure = function () {
            throw new Exception('Test message');
        };

        $encode = $this->encoder->encode(new SerializableClosure($closure));

        $output = $this->encoder->decode(
            $this->child->handle($encode)->exception()
        );

        static::assertEquals('Test message', $output->getMessage());
        static::assertTrue($this->child->hasError());
        static::assertNull($this->child->output());
    }

    /**
     * @test
     */
    public function write(): void
    {
        $closure = function () {
            return 'Same return value';
        };

        $encode = $this->encoder->encode(new SerializableClosure($closure));

        $this->child->handle($encode);
        static::assertInstanceOf(Child::class, $this->child->write());
    }
}