Graviton\RestBundle\Tests\Controller\AsyncLockingTest::testAsyncLock()

Complexity

Conditions	2
Paths	2

Size

Total Lines	80
Code Lines	45

Duplication

Lines	9
Ratio	11.25 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function testAsyncLock()
    {
        /**
         * create test entry
         */
        $client = static::createRestClient();
        $statusEntry = new \stdClass();
        $statusEntry->id = 'locktest';
        $statusEntry->status = [];
        $defaultStatus = new \stdClass();
        $defaultStatus->workerId = 'hans';
        $defaultStatus->status = 'opened';
        $statusEntry->status[] = $defaultStatus;

        $client->put('/event/status/locktest', $statusEntry);
        $this->assertSame(Response::HTTP_NO_CONTENT, $client->getResponse()->getStatusCode());

        /**
         * the patch we will send
         */
        $patchJson = json_encode(
            [
                [
                    'op' => 'replace',
                    'path' => '/status/0/status',
                    'value' => 'ignored'
                ],
                [
                    'op' => 'add',
                    'path' => '/status/0/action',
                    'value' => [
                        '$ref' => 'http://localhost/event/action/default'
                    ]
                ],
                [
                    'op' => 'add',
                    'path' => '/information/-',
                    'value' => [
                        'workerId' => 'hans',
                        'type' => 'info',
                        'content' => 'addedInfo'
                    ]
                ]
            ]
        );

        $promiseStack = [];
        $deferred = new \React\Promise\Deferred();

        $i = 0;
        while ($i < 30) {
            $promise = $deferred->promise();

            $promise->then(
                function () use ($patchJson) {
                    $client = static::createRestClient();
                    $client->request('PATCH', '/event/status/locktest', [], [], [], $patchJson);
                    $this->assertSame(Response::HTTP_OK, $client->getResponse()->getStatusCode());
                }
            );

            $promiseStack[] = $promise;
            $i++;
        }

        \React\Promise\all($promiseStack)->then(
            function () {
                // after all is done; check entry
                $client = static::createRestClient();
                $client->request('GET', '/event/status/locktest');
                $result = $client->getResults();

                $this->assertSame(30, count($result->information));
                $this->assertSame(1, count($result->status));
            }
        );

        // start the whole thing
        $deferred->resolve();
    }
}