flux-querybuilder/tests/Functions/AggregateWindowTest.php

<?php

declare(strict_types=1);

namespace Tests\Functions;

use Arendsen\FluxQueryBuilder\Functions\AggregateWindow;
use Arendsen\FluxQueryBuilder\Type\FnType;
use PHPUnit\Framework\TestCase;

final class AggregateWindowFunctionTest extends TestCase
{
    public function testSimpleWindow()
    {
        $expression = new AggregateWindow('20s', 'mean');

        $query = '|> aggregateWindow(every: 20s, fn: mean) ';

        $this->assertEquals($query, $expression->__toString());
    }

    public function testAllParameters()
    {
        $expression = new AggregateWindow(
            '20s',
            FnType::params(['r'])->withBody('r._field == "test"'),
            [
                'period' => 'every',
                'offset' => '0s',
                'location' => 'location',
                'column' => '_value',
                'timeSrc' => '_stop',
                'timeDst' => '_time',
                'createEmpty' => false
            ]
        );

        $query = '|> aggregateWindow(every: 20s, period: every, offset: 0s, fn: (r) => r._field == "test", ' .
            'location: "location", ' . 'column: "_value", timeSrc: "_stop", timeDst: "_time", createEmpty: false) ';

        $this->assertEquals($query, $expression->__toString());
    }
}