flux-querybuilder/src/QueryBuilder.php

<?php

namespace Arendsen\FluxQueryBuilder;

use Arendsen\FluxQueryBuilder\Expression\KeyValue;
use Arendsen\FluxQueryBuilder\Function\Filter;
use Arendsen\FluxQueryBuilder\Function\From;
use Arendsen\FluxQueryBuilder\Function\Range;
use Arendsen\FluxQueryBuilder\Function\Reduce;
use Arendsen\FluxQueryBuilder\Function\Sort;
use Arendsen\FluxQueryBuilder\Function\Map;
use Arendsen\FluxQueryBuilder\Function\Group;
use Arendsen\FluxQueryBuilder\Function\Limit;
use Exception;

class QueryBuilder {

    const FLUX_PART_FROM = 'from';
    const FLUX_PART_RANGE = 'range';
    const FLUX_PART_FILTERS = 'filters';
    const FLUX_PART_REDUCE = 'reduce';
    const FLUX_PART_MAP = 'map';
    const FLUX_PART_SORT = 'sort';
    const FLUX_PART_GROUP = 'group';
    const FLUX_PART_LIMIT = 'limit';

    const PARTS = [
        self::FLUX_PART_FROM,
        self::FLUX_PART_RANGE,
        self::FLUX_PART_REDUCE,
        self::FLUX_PART_FILTERS,
        self::FLUX_PART_MAP,
        self::FLUX_PART_SORT,
        self::FLUX_PART_GROUP,
        self::FLUX_PART_LIMIT,
    ];

    const REQUIRED_INPUT_FROM = 'from';
    const REQUIRED_INPUT_MEASUREMENT = 'measurement';
    const REQUIRED_INPUT_RANGE = 'range';

    const REQUIRED_INPUT = [
        self::REQUIRED_INPUT_FROM,
        self::REQUIRED_INPUT_MEASUREMENT,
        self::REQUIRED_INPUT_RANGE,
    ];

    /**
     * @var array $fluxQuery
     */
    private $fluxQueryParts = [];

    /**
     * @var array $requiredData
     */
    private $requiredData = [];
    
    public function from(array $from): QueryBuilder
    {
        $this->addRequiredData(self::REQUIRED_INPUT_FROM, $from);
        $this->addToQuery(
            self::FLUX_PART_FROM,
            new From($from)
        );
        return $this;
    }

    public function fromBucket(string $bucket): QueryBuilder
    {
        $this->from(['bucket' => $bucket]);
        return $this;
    }

    public function fromMeasurement(string $measurement): QueryBuilder
    {
        $this->addRequiredData(self::REQUIRED_INPUT_MEASUREMENT, $measurement);
        $this->addToQueryArray(
            self::FLUX_PART_FILTERS,
            new Filter(KeyValue::setEqualTo('_measurement', $measurement))
        );
        return $this;
    }

    public function addFilter(KeyValue $keyValue): QueryBuilder
    {
        $this->addToQueryArray(
            self::FLUX_PART_FILTERS,
            new Filter($keyValue)
        );
        return $this;
    }

    public function addRange(array $range): QueryBuilder
    {
        $this->addRequiredData(self::REQUIRED_INPUT_RANGE, $range);
        $this->addToQuery(
            self::FLUX_PART_RANGE,
            new Range($range)
        );
        return $this;
    }

    public function addRangeStart(string $rangeStart): QueryBuilder
    {
        $this->addRange(['start' => $rangeStart]);
        return $this;
    }

    public function addReduce(array $settings, array $identity): QueryBuilder
    {
        $this->addToQueryArray(
            self::FLUX_PART_REDUCE,
            new Reduce($settings, $identity)
        );
        return $this;
    }

    public function addSort(array $columns, $desc): QueryBuilder
    {
        $this->addToQueryArray(
            self::FLUX_PART_SORT,
            new Sort($columns, $desc)
        );
        return $this;
    }

    public function addMap(string $query): QueryBuilder
    {
        $this->addToQueryArray(
            self::FLUX_PART_MAP,
            new Map($query)
        );
        return $this;
    }

    public function addGroup(array $columns, $mode = 'by'): QueryBuilder
    {
        $this->addToQueryArray(
            self::FLUX_PART_GROUP,
            new Group($columns, $mode)
        );
        return $this;
    }

    public function addLimit(int $limit): QueryBuilder
    {
        $this->addToQueryArray(
            self::FLUX_PART_LIMIT,
            new Limit($limit)
        );
        return $this;
    }

    protected function addToQuery($key, $query)
    {
        $this->fluxQueryParts[$key] = $query;
    }

    protected function addToQueryArray($key, $query)
    {
        $this->fluxQueryParts[$key][] = $query;
    }

    public function build(): string
    {
        $this->checkRequired();

        $query = '';

        foreach(self::PARTS as $part)
        {
            if(isset($this->fluxQueryParts[$part]))
            {
                if(is_array($this->fluxQueryParts[$part]))
                {
                    foreach($this->fluxQueryParts[$part] as $filter) {
                        $query .= $filter;
                    }
                }
                else
                {
                    $query .= $this->fluxQueryParts[$part];
                }
            }
        }

        return $query;
    }

    protected function addRequiredData(string $key, $value) {
        $this->requiredData[$key] = $value;
    }

    protected function checkRequired()
    {
        foreach(self::REQUIRED_INPUT as $input) {
            if(!isset($this->requiredData[$input]))
            {
                throw new Exception('You need to define the "' . $input . '" part of the query!');
            }
        }
    }

}