Zenstruck\ScheduleBundle\Tests\Schedule\Task\Runner\PingTaskRunnerTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	creates_failure_on_500()	0	20	1
A	creates_failure_on_404()	0	20	1
A	createBuilder()	0	4	1
A	creates_successful_result()	0	18	1

<?php

namespace Zenstruck\ScheduleBundle\Tests\Schedule\Task\Runner;

use PHPUnit\Framework\TestCase;

The type PHPUnit\Framework\TestCase was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\HttpClient\Exception\ClientException;
use Symfony\Component\HttpClient\Exception\ServerException;
use Symfony\Component\HttpClient\MockHttpClient;
use Symfony\Component\HttpClient\Response\MockResponse;
use Zenstruck\ScheduleBundle\Schedule\Task\PingTask;
use Zenstruck\ScheduleBundle\Schedule\Task\Runner\PingTaskRunner;
use Zenstruck\ScheduleBundle\Tests\Fixture\MockScheduleBuilder;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class PingTaskRunnerTest extends TestCase
{
    /**
     * @test
     */
    public function creates_successful_result()
    {
        $context = self::createBuilder(
            new MockHttpClient(
                new MockResponse('response body', [
                    'response_headers' => [
                        'HTTP/1.1 200 OK',
                        'Server: Foo',
                    ],
                ])
            ))
            ->addTask(new PingTask('https://example.com'))
            ->run()
        ;

        $this->assertTrue($context->isSuccessful());
        $this->assertCount(1, $run = $context->getSuccessful());
        $this->assertSame("HTTP/1.1 200 OK\nServer: Foo\n\nresponse body", $run[0]->getOutput());
    }

    /**
     * @test
     */
    public function creates_failure_on_404()
    {
        $context = self::createBuilder(
            new MockHttpClient(
                new MockResponse('response body', [
                    'response_headers' => [
                        'HTTP/1.1 404 Not Found',
                        'Server: Foo',
                    ],
                ])
            ))
            ->addTask(new PingTask('https://example.com'))
            ->run()
        ;

        $this->assertFalse($context->isSuccessful());
        $this->assertTrue($context->isFailure());
        $this->assertCount(1, $run = $context->getFailures());
        $this->assertInstanceOf(ClientException::class, $run[0]->getException());
        $this->assertSame('ClientException: HTTP/1.1 404 Not Found returned for "https://example.com/".', $run[0]->getDescription());
    }

    /**
     * @test
     */
    public function creates_failure_on_500()
    {
        $context = self::createBuilder(
            new MockHttpClient(
                new MockResponse('response body', [
                    'response_headers' => [
                        'HTTP/1.1 500 Internal Server Error',
                        'Server: Foo',
                    ],
                ])
            ))
            ->addTask(new PingTask('https://example.com'))
            ->run()
        ;

        $this->assertFalse($context->isSuccessful());
        $this->assertTrue($context->isFailure());
        $this->assertCount(1, $run = $context->getFailures());
        $this->assertInstanceOf(ServerException::class, $run[0]->getException());
        $this->assertSame('ServerException: HTTP/1.1 500 Internal Server Error returned for "https://example.com/".', $run[0]->getDescription());
    }

    private static function createBuilder(MockHttpClient $httpClient): MockScheduleBuilder
    {
        return (new MockScheduleBuilder())
            ->addRunner(new PingTaskRunner($httpClient))
        ;
    }
}