TBolier\RethinkQL\IntegrationTest\Operation\ChangesTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testChangesUpdates()	0	25	3
A	testChangesCreate()	0	28	3
A	testChangesWithOptions()	0	18	1
A	testChangesCreateWithFilter()	0	21	1

<?php
declare(strict_types = 1);

namespace TBolier\RethinkQL\IntegrationTest\Operation;

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

class ChangesTest extends AbstractTableTest
{
    /**
     * @throws \Exception
     */
    public function testChangesCreate(): void
    {
        /** @var Cursor $feed */
        $feed = $this->r()
            ->table('tabletest')
            ->changes()
            ->run();

        $this->insertDocument(1);
        $this->insertDocument(2);
        $this->insertDocument(3);
        $this->insertDocument(4);
        $this->insertDocument(5);

        /** @var ResponseInterface $res */
        $i = 1;
        $old_val = $new_val = [];
        foreach ($feed as $change) {
            extract($change);

It seems like $change can also be of type null and string; however, parameter $var_array of extract() does only seem to accept array, maybe add an additional type check?

            $this->assertEmpty($old_val);
            $this->assertEquals($i, $new_val['id']);

            if ($i === 5) {
                break;
            }

            $i++;
        }
    }

    /**
     * @throws \Exception
     */
    public function testChangesUpdates(): void
    {
        /** @var Cursor $feed */
        $feed = $this->r()
            ->table('tabletest')
            ->changes()
            ->run();

        $this->insertDocument(777);

        $this->r()->table('tabletest')->filter(['id' => 777])->update(['description' => 'cool!'])->run();

        $i = 777;
        $old_val = $new_val = [];
        foreach ($feed as $change) {
            extract($change);

It seems like $change can also be of type null and string; however, parameter $var_array of extract() does only seem to accept array, maybe add an additional type check?

            if ($old_val !== null) {
                $this->assertEquals('A document description.', $old_val['description']);
                $this->assertEquals('cool!', $new_val['description']);

                break;
            } else {
                $this->assertEmpty($old_val);
                $this->assertEquals($i, $new_val['id']);
            }
        }
    }

    /**
     * @throws \Exception
     */
    public function testChangesWithOptions(): void
    {
        /** @var Cursor $feed */
        $feed = $this->r()
            ->table('tabletest')
            ->changes(['squash' => true])
            ->run();

        $this->insertDocument(1);
        $this->r()->table('tabletest')->filter(['id' => 1])->update(['description' => 'cool!'])->run();

        $old_val = $new_val = [];
        $change = $feed->current();
        extract($change);

It seems like $change can also be of type null and string; however, parameter $var_array of extract() does only seem to accept array, maybe add an additional type check?

        $this->assertEmpty($old_val);
        $this->assertEquals(1, $new_val['id']);
        $this->assertEquals('cool!', $new_val['description']);
    }

    /**
     * @throws \Exception
     */
    public function testChangesCreateWithFilter(): void
    {
        /** @var Cursor $feed */
        $feed = $this->r()
            ->table('tabletest')
            ->filter(['id' => 4])
            ->changes()
            ->run();

        $this->insertDocument(1);
        $this->insertDocument(2);
        $this->insertDocument(3);
        $this->insertDocument(4);
        $this->insertDocument(5);

        $old_val = $new_val = [];
        $change = $feed->current();
        extract($change);

It seems like $change can also be of type null and string; however, parameter $var_array of extract() does only seem to accept array, maybe add an additional type check?

        $this->assertEmpty($old_val);
        $this->assertEquals(4, $new_val['id']);
    }
}