Level23\Druid\Metadata\MetadataBuilder::timeBoundary()

Complexity

Conditions	15
Paths	288

Size

Total Lines	69
Code Lines	35

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	36
CRAP Score	15

Importance

Changes

0

<?php
    public function timeBoundary(
        string|DataSourceInterface $dataSource,
        null|string|TimeBound $bound = TimeBound::BOTH,
        \Closure $filterBuilder = null,
        ContextInterface $context = null
    ): DateTime|array {

        $query = [
            'queryType'  => 'timeBoundary',
            'dataSource' => is_string($dataSource) ? $dataSource : $dataSource->toArray(),
        ];

        if (is_string($bound)) {
            $bound = TimeBound::from($bound);
        }

        if (!empty($bound) && $bound != TimeBound::BOTH) {
            $query['bound'] = $bound->value;
        }

        if ($filterBuilder) {
            $builder = new FilterBuilder();
            call_user_func($filterBuilder, $builder);
            $filter = $builder->getFilter();

            if ($filter) {
                $query['filter'] = $filter->toArray();
            }
        }

        if ($context) {
            $query['context'] = $context->toArray();
        }

        $url = $this->client->config('broker_url') . '/druid/v2';

        /** @var array<int,null|array<string,string[]|string>> $response */
        $response = $this->client->executeRawRequest('post', $url, $query);

        if (!empty($response[0])
            && !empty($response[0]['result'])
            && is_array($response[0]['result'])
        ) {
            if (sizeof($response[0]['result']) == 1) {
                $dateString = reset($response[0]['result']);
                $date       = DateTime::createFromFormat('Y-m-d\TH:i:s.000\Z', $dateString);

                if (!$date) {

$date is of type DateTime, thus it always evaluated to true.

                    throw new Exception('Failed to parse time: ' . $dateString);
                }

                return $date;
            } else {
                $result = [];
                foreach ($response[0]['result'] as $key => $dateString) {
                    $date = DateTime::createFromFormat('Y-m-d\TH:i:s.000\Z', $dateString);

                    if (!$date) {
                        throw new Exception('Failed to parse time: ' . $dateString);
                    }

                    $result[$key] = $date;
                }

                return $result;
            }
        }

        throw new Exception('Received incorrect response: ' . var_export($response, true));
    }
}