Redislabs\Module\RedisGraph\Edge

Complexity

Total Complexity

19

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	toStringWithMerge()	0	13	3
A	getProps()	0	10	3
A	getPropValueWithDataType()	0	7	2
A	create()	0	3	1
A	toString()	0	6	2
A	withProperties()	0	5	1
A	merge()	0	3	1
A	getType()	0	3	1
A	__construct()	0	12	1
A	toStringWithCreate()	0	13	3
A	getQueryPredicate()	0	3	1

<?php

declare(strict_types=1);

namespace Redislabs\Module\RedisGraph;

final class Edge
{
    private string $queryPredicate;
    private Node $sourceNode;
    private Node $destinationNode;
    private ?string $relation;
    private ?iterable $properties = [];

    public function __construct(
        string $queryPredicate,
        Node $sourceNode,
        ?string $relation,
        Node $destinationNode,
        ?iterable $properties = []
    ) {
        $this->queryPredicate = $queryPredicate;
        $this->sourceNode = $sourceNode;
        $this->destinationNode = $destinationNode;
        $this->relation = $relation;
        $this->properties = $properties;
    }

    public static function create(Node $sourceNode, string $relation, Node $destinationNode): self
    {
        return new self('CREATE', $sourceNode, $relation, $destinationNode);
    }
    public static function merge(Node $sourceNode, string $relation, Node $destinationNode): self
    {
        return new self('MERGE', $sourceNode, $relation, $destinationNode);
    }

    public function withProperties(iterable $properties): self
    {
        $new = clone $this;
        $new->properties = $properties;
        return $new;
    }

    public function getType(): string
    {
        return $this->queryPredicate;
    }

    public function toString(): string
    {
        if ($this->queryPredicate === 'MERGE') {
            return $this->toStringWithMerge();
        }
        return $this->toStringWithCreate();
    }

    public function toStringWithMerge(): string
    {
        $edgeString = '(' . $this->sourceNode->getAlias() . ')';
        $edgeString .= '-[';
        if ($this->relation !== null) {
            $edgeString .= ':' . $this->relation . ' ';
        }
        if ($this->properties) {
            $edgeString .= '{' . $this->getProps($this->properties) . '}';
        }
        $edgeString .= ']->';
        $edgeString .= '(' . $this->destinationNode->getAlias() . ')';
        return $edgeString;
    }

    public function toStringWithCreate(): string
    {
        $edgeString = '(' . $this->sourceNode->getAlias() . ':' . $this->sourceNode->getLabel() . ')';
        $edgeString .= '-[';
        if ($this->relation !== null) {
            $edgeString .= ':' . $this->relation . ' ';
        }
        if ($this->properties) {
            $edgeString .= '{' . $this->getProps($this->properties) . '}';
        }
        $edgeString .= ']->';
        $edgeString .= '(' . $this->destinationNode->getAlias() . ':' . $this->destinationNode->getLabel() . ')';
        return $edgeString;
    }

    private function getProps(iterable $properties): string
    {
        $props = '';
        foreach ($properties as $propKey => $propValue) {
            if ($props !== '') {
                $props .= ', ';
            }
            $props .= $propKey . ': ' . $this->getPropValueWithDataType($propValue);
        }
        return $props;
    }

    private function getPropValueWithDataType($propValue)
    {
        $type = gettype($propValue);
        if ($type === 'string') {
            return quotedString((string) $propValue);
        }
        return (int) $propValue;
    }

    public function getQueryPredicate(): string
    {
        return $this->queryPredicate;
    }
}