Redislabs\Module\RedisGraph\GraphConstructor

Complexity

Total Complexity

10

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getCommitQuery()	0	14	4
A	__construct()	0	2	1
A	addEdge()	0	3	1
A	addNode()	0	3	1
A	getCommitQueryWithMerge()	0	10	3

<?php

declare(strict_types=1);

namespace Redislabs\Module\RedisGraph;

use Redislabs\Module\RedisGraph\Interfaces\QueryInterface;

class GraphConstructor
{
    private array $nodes = [];
    private array $edges = [];

    public function __construct(private string $name)
    {
    }

    public function addNode(Node $node): void
    {
        $this->nodes[] = $node;
    }

    public function addEdge(Edge $edge): void
    {
        $this->edges[] = $edge;
    }

    public function getCommitQuery(): QueryInterface
    {
        $query = 'CREATE ';
        foreach ($this->nodes as $index => $node) {
            $query .= $node->toString() . ', ';
        }
        $edgeCount = count($this->edges);
        foreach ($this->edges as $index => $edge) {
            $query .= $edge->toString();
            if ($index < $edgeCount - 1) {
                $query .= ', ';
            }
        }
        return new Query($this->name, $query);
    }

    public function getCommitQueryWithMerge(): QueryInterface
    {
        $query = '';
        foreach ($this->nodes as $index => $node) {
            $query .= 'MERGE ' . $node->toString() . ' ';
        }
        foreach ($this->edges as $index => $edge) {
            $query .= 'MERGE ' . $edge->toString() . ' ';
        }
        return new Query($this->name, trim($query));
    }
}