flux-querybuilder/tests/Functions/AggregateWindowTest.php

<?php

declare( strict_types=1 );

namespace Tests\Functions;

use Hosterra\FluxBuilder\Functions\AggregateWindow;
use Hosterra\FluxBuilder\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() );
	}
}