Graviton\RabbitMqBundle\Tests\Controller\EventStatusControllerTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	245
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	testInvalidStatus()	0	45	1
B	testInvalidInformationType()	0	46	1
A	testEventStatusActionStatus()	0	50	1
B	testEventStatusLinkResponseListener()	0	76	1

<?php
/**
 * functional test for /event/status
 */

namespace Graviton\RabbitMqBundle\Tests\Controller;

use Graviton\RabbitMqBundle\Producer\Dummy;
use Graviton\TestBundle\Test\RestTestCase;
use Symfony\Component\HttpFoundation\Response;

/**
 * Functional test for /event/status.
 *
 * @author   List of contributors <https://github.com/libgraviton/graviton/graphs/contributors>
 * @license  https://opensource.org/licenses/MIT MIT License
 * @link     http://swisscom.ch
 */
class EventStatusControllerTest extends RestTestCase
{

    /**
     * test to see if we can insert a status and if graviton complains about an invalid status
     *
     * @return void
     */
    public function testInvalidStatus()
    {
        $status = new \stdClass();
        $status->id = 'mynewstatus';
        $status->createDate = '2015-09-24T07:21:24+0000';
        $status->eventName = 'document.test.app.create';

        $statusEntry = new \stdClass();
        $statusEntry->workerId = 'testworker';
        $statusEntry->status = 'opened';
        $statusEntry->action = (object) [
            '$ref' => 'http://localhost/event/action/abba'
        ];

        $status->status = [$statusEntry];

        $client = static::createRestClient();
        $client->put('/event/status/mynewstatus', $status);

        $this->assertNull($client->getResults());
        $this->assertNull($client->getResponse()->headers->get('Location'));
        $this->assertEquals(204, $client->getResponse()->getStatusCode());

        // get our object again
        $client = static::createRestClient();
        $client->request('GET', '/event/status/mynewstatus');
        $results = $client->getResults();

        $this->assertEquals('opened', $results->status[0]->status);
        $this->assertEquals('http://localhost/event/action/abba', $results->status[0]->action->{'$ref'});

        // set invalid status
        $results->status[0]->status = 'thinking';

        $client = static::createRestClient();
        $client->put('/event/status/mynewstatus', $results);
        $results = $client->getResults();

        $this->assertEquals(400, $client->getResponse()->getStatusCode());
        $this->assertEquals("status[0].status", $results[0]->propertyPath);
        $this->assertContains(
            "Does not have a value in the enumeration [\"opened\",\"working\",\"ignored\",\"done\",\"failed\"]",
            $results[0]->message
        );
    }

    /**
     * test to see if we can insert a status and if graviton complains about an invalid status
     *
     * @return void
     */
    public function testInvalidInformationType()
    {
        $status = new \stdClass();
        $status->id = 'mynewstatus';
        $status->createDate = '2015-09-24T07:21:24+0000';
        $status->eventName = 'document.test.app.create';

        $informationEntry = new \stdClass();
        $informationEntry->workerId = 'testworker';
        $informationEntry->type = 'info';
        $informationEntry->content = 'see the attached document';
        $informationEntry->{'$ref'} = 'http://localhost/core/app/admin';

        $status->information = [$informationEntry];

        $client = static::createRestClient();
        $client->put('/event/status/mynewstatus', $status);

        $this->assertNull($client->getResults());
        $this->assertNull($client->getResponse()->headers->get('Location'));
        $this->assertEquals(204, $client->getResponse()->getStatusCode());

        // get our object again
        $client = static::createRestClient();
        $client->request('GET', '/event/status/mynewstatus');
        $results = $client->getResults();

        $this->assertEquals('testworker', $results->information[0]->workerId);
        $this->assertEquals('info', $results->information[0]->type);
        $this->assertEquals('see the attached document', $results->information[0]->content);
        $this->assertEquals('http://localhost/core/app/admin', $results->information[0]->{'$ref'});

        // set invalid information type
        $results->information[0]->type = 'bogus';

        $client = static::createRestClient();
        $client->put('/event/status/mynewstatus', $results);
        $results = $client->getResults();

        $this->assertEquals(400, $client->getResponse()->getStatusCode());
        $this->assertEquals("information[0].type", $results[0]->propertyPath);
        $this->assertContains(
            "Does not have a value in the enumeration [\"debug\",\"info\",\"warning\",\"error\"]",
            $results[0]->message
        );
    }

    /**
     * Event Status Action
     *
     * @return void
     */
    public function testEventStatusActionStatus()
    {
        // Create a action and translation
        $action = new \stdClass();
        $action->id = 'new-worker-action-id';
        $action->description = new \stdClass();
        $action->description->en = "Some translated action";

        $client = static::createRestClient();
        $client->put('/event/action/'.$action->id, $action);

        // Check result
        $this->assertEquals(204, $client->getResponse()->getStatusCode());

        // get our object again
        $client = static::createRestClient();
        $client->request('GET', '/event/action/'.$action->id);
        $results = $client->getResults();
        $this->assertEquals($action->description->en, $results->description->en);
        $this->assertEquals(200, $client->getResponse()->getStatusCode());

        // Creating the event
        $eventStatus = new \stdClass();
        $eventStatus->id = 'mynewstatus2';
        $eventStatus->createDate = '2015-09-24T07:21:24+0000';
        $eventStatus->eventName = 'document.test.app.create';

        $status = new \stdClass();
        $status->workerId = 'testworker';
        $status->status = 'opened';
        $status->action = new \stdClass();
        $status->action->{'$ref'} = 'http://localhost/event/action/'.$action->id;
        $eventStatus->status = [$status];

        // Save the status
        $client = static::createRestClient();
        $client->put('/event/status/mynewstatus2', $eventStatus);

        $this->assertNull($client->getResults());
        $this->assertNull($client->getResponse()->headers->get('Location'));
        $this->assertEquals(204, $client->getResponse()->getStatusCode());

        // get our object again, checking
        $client = static::createRestClient();
        $client->request('GET', '/event/status/mynewstatus2');
        $results = $client->getResults();

        $this->assertEquals('opened', $results->status[0]->status);
        $this->assertEquals('http://localhost/event/action/'.$action->id, $results->status[0]->action->{'$ref'});
    }


    /**
     * Verifies the correct workflow of the ResponseListener
     *
     * @return void
     */
    public function testEventStatusLinkResponseListener()
    {
        // Create a test worker
        $worker = new \stdClass();
        $worker->id = 'test-worker-listener';
        $worker->subscription = [];
        $event = new \stdClass();
        $event->event = 'document.core.app.create';
        $worker->subscription[] = $event;
        $event = new \stdClass();
        $event->event = 'document.core.app.update';
        $worker->subscription[] = $event;

        $client = static::createRestClient();
        $client->put('/event/worker/' . $worker->id, $worker);
        $response = $client->getResponse();
        $this->assertEquals(Response::HTTP_NO_CONTENT, $response->getStatusCode(), $response->getContent());

        $testApp = new \stdClass();
        $testApp->id = "test-event-app";
        $testApp->name = new \stdClass();
        $testApp->name->en = "test-event-app";
        $testApp->showInMenu = false;

        $client = static::createRestClient();
        /** @var Dummy $dbProducer */
        $dbProducer = $client->getContainer()->get('graviton.rabbitmq.jobproducer');
        $dbProducer->resetEventList();

        $client->put('/core/app/' . $testApp->id, $testApp);
        $response = $client->getResponse();
        $this->assertEquals(Response::HTTP_NO_CONTENT, $response->getStatusCode(), $response->getContent());
        // the worker relative our cannot be in the Link header
        $this->assertNotContains('backendalias:9443', $response->headers->get('link'));
        $this->assertContains('eventStatus', $response->headers->get('link'));

        /** @var Dummy $dbProducer */
        $events = $dbProducer->getEventList();

        $this->assertCount(1, $events);
        $data = json_decode($events[0], true);

        $this->assertEquals('document.core.app.update', $data['event']);
        $this->assertEquals('anonymous', $data['coreUserId']);
        $this->assertEquals('https://backendalias:9443/core/app/test-event-app', $data['document']['$ref']);
        $this->assertContains('https://backendalias:9443/event/status/', $data['status']['$ref']);

        // A failing event should not be published
        // using patch
        $patchObject = json_encode(
            [
                [
                    'op' => 'replace',
                    'path' => '/lastModified',
                    'value' => '2014-10-03T20:10:05+2000'
                ]
            ]
        );
        $client->request('PATCH', '/core/app/' . $testApp->id, [], [], [], $patchObject);
        $response = $client->getResponse();
        $this->assertEquals(Response::HTTP_NOT_MODIFIED, $response->getStatusCode(), $response->getContent());

        /** @var Dummy $dbProducer */
        $events = $dbProducer->getEventList();
        $this->assertCount(1, $events);

        // With a wrong param S
        $testApp->showInMenuS = false;
        $client->put('/core/app/' . $testApp->id, $testApp);
        $response = $client->getResponse();
        $this->assertEquals(Response::HTTP_BAD_REQUEST, $response->getStatusCode(), $response->getContent());

        /** @var Dummy $dbProducer */
        $events = $dbProducer->getEventList();
        $this->assertCount(1, $events);
    }
}