Redislabs\Module\RedisGraph\RedisGraph

Complexity

Total Complexity

6

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	4	1
A	rawQuery()	0	4	1
A	query()	0	7	2
A	explain()	0	6	1
A	commit()	0	3	1

<?php

declare(strict_types=1);

namespace Redislabs\Module\RedisGraph;

use Redislabs\Interfaces\ModuleInterface;
use Redislabs\Module\ModuleTrait;
use Redislabs\Module\RedisGraph\Exception\InvalidQueryException;
use Redislabs\Module\RedisGraph\Interfaces\QueryInterface;
use Redislabs\Module\RedisGraph\Command\Query;

This use statement conflicts with another class in this namespace, Redislabs\Module\RedisGraph\Query. Consider defining an alias.

use Redislabs\Module\RedisGraph\Command\Explain;
use Redislabs\Module\RedisGraph\Command\Delete;

class RedisGraph implements ModuleInterface
{
    use ModuleTrait;

    protected static string $moduleName = 'RedisGraph';


    public function rawQuery(QueryInterface $query)
    {
        return $this->runCommand(
            Query::createCommandWithArguments($query)
        );
    }

    public function query(QueryInterface $query): Result
    {
        $response = $this->rawQuery($query);
        if (is_string($response)) {
            throw new InvalidQueryException($response);
        }
        return Result::createFromResponse($response);
    }

    public function delete(string $name): ?string
    {
        return $this->runCommand(
            Delete::createCommandWithArguments($name)
        );
    }

    public function explain(QueryInterface $query): string
    {
        $response =  $this->runCommand(
            Explain::createCommandWithArguments($query)
        );
        return implode(' ', $response);
    }

    public function commit(QueryInterface $query): Result
    {
        return $this->query($query);
    }
}