TBolier\RethinkQL\IntegrationTest\Query\CursorTest

Complexity

Total Complexity

12

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testCursor()	0	10	1
A	insertDocuments()	0	21	2
B	testCursorBigDocuments()	0	22	6
B	insertBigDocuments()	0	38	3

<?php
declare(strict_types = 1);

namespace TBolier\RethinkQL\IntegrationTest\Query;

use TBolier\RethinkQL\Response\Cursor;
use TBolier\RethinkQL\Response\ResponseInterface;

class CursorTest extends AbstractTableTest
{
    /**
     * @throws \Exception
     */
    public function testCursor()
    {
        $this->insertDocuments();

        $response = $this->r()
            ->table('tabletest')
            ->count()
            ->run();

        $this->assertEquals(1000, $response->getData());
    }

    /**
     * @throws \Exception
     */
    public function testCursorBigDocuments()
    {
        $res = $this->r()->db()->tableList()->run();
        if (\is_array($res->getData()) && !\in_array('tabletest_big', $res->getData(), true)) {
            $this->r()->db()->tableCreate('tabletest_big')->run();
        }

        $this->insertBigDocuments();

        /** @var Cursor $response */
        $response = $this->r()->table('tabletest_big')->run();

        $documents = [];

        foreach ($response as $result) {
            $documents[] = $result;
        }
        $this->assertCount(10000, $documents);

        $res = $this->r()->db()->tableList()->run();
        if (\is_array($res->getData()) && \in_array('tabletest_big', $res->getData(), true)) {
            $this->r()->db()->tableDrop('tabletest_big')->run();
        }
    }

    /**
     * @return ResponseInterface
     * @throws \Exception
     */
    private function insertDocuments(): ResponseInterface
    {
        $documents = [];

        for ($i = 1; $i <= 1000; $i++) {
            $documents[] = [
                'id' => $i,
                'title' => 'Test document',
                'description' => 'My first document.',
            ];
        }

        /** @var ResponseInterface $res */
        $res = $this->r()
            ->table('tabletest')
            ->insert($documents)
            ->run();

        $this->assertEquals(1000, $res->getData()['inserted']);

        return $res;
    }

    /**
     * @return ResponseInterface
     * @throws \Exception
     */
    private function insertBigDocuments(): ResponseInterface
    {
        for ($i = 1; $i <= 100; $i++) {
            $documents = [];

            for ($x = 1; $x <= 100; $x++) {
                $documents[] = [
                    'Professor X' => 'Charles Francis Xavier',
                    'Cyclops' => 'Scott Summers',
                    'Iceman' => 'Robert Louis "Bobby" Drake',
                    'Angel' => 'Warren Kenneth Worthington III',
                    'Beast' => 'Henry Philip "Hank" McCoy',
                    'Marvel Girl/Phoenix' => 'Jean Elaine Grey/Jean Elaine Grey-Summers',
                    'Magnetrix/Polaris' => 'Lorna Sally Dane',
                    'Nightcrawler' => 'Kurt Wagner',
                    'Wolverine' => 'James "Logan" Howlett',
                    'Storm' => 'Ororo Monroe',
                    'Colossus' => 'Piotr Nikolaievitch "Peter" Rasputin',
                    'Sprite/Ariel/Shadowcat' => 'Katherine Anne "Kitty" Pryde',
                    'Rogue' => 'Anna Marie',
                    'Phoenix/Marvel Girl/Prestige' => 'Rachel Anne Grey-Summers',
                    'Psylocke' => 'Elizabeth "Betsy" Braddock',
                    'Gambit' => 'Rémy Etienne LeBeau',
                    'Jubilee' => 'Jubilation Lee',
                    'Bishop' => 'Lucas Bishop',
                ];
            }

            /** @var ResponseInterface $res */
            $res = $this->r()
                ->table('tabletest_big')
                ->insert($documents)
                ->run();

            $this->assertEquals(100, $res->getData()['inserted']);
        }

        return $res;

The variable $res does not seem to be defined for all execution paths leading up to this point.

    }
}