Identical blocks of code found in 2 locations. Consider refactoring.

Open

        foreach ($messages as $message) {
            foreach ($paths as $fieldName => $qname) {
                if (!$message->has($fieldName)) {
                    continue;
                }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        foreach ($messages as $message) {
            foreach ($paths as $fieldName => $qname) {
                if (!$message->has($fieldName)) {
                    continue;
                }

• Read up
  Read up

Function doPipeNodes has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

    private function doPipeNodes(SchemaQName $qname, array $context): \Generator
    {
        static $alreadyPiped = [];

        $tableName = $context['table_name'] ?? $this->tableManager->getNodeTableName($qname, $context);

• Read up
  Read up

Method findNodeRefs has 79 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function findNodeRefs(IndexQuery $query, array $context = []): IndexQueryResult
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->tableManager->getNodeTableName($query->getQName(), $context);
        $table = $this->tableManager->getNodeTable($query->getQName());

Function findNodeRefs has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    public function findNodeRefs(IndexQuery $query, array $context = []): IndexQueryResult
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->tableManager->getNodeTableName($query->getQName(), $context);
        $table = $this->tableManager->getNodeTable($query->getQName());

• Read up
  Read up

Function addEmbeddedNodeRefs has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    public function addEmbeddedNodeRefs(array $messages, array $paths, string $namespace = self::DEFAULT_NAMESPACE): void
    {
        $nodeRefs = [];

        if (array_is_list($paths)) {

• Read up
  Read up

Function addEmbeddedNodeRefs has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    public function addEmbeddedNodeRefs(array $messages, array $paths): void
    {
        $nodeRefs = [];

        if (array_is_list($paths)) {

• Read up
  Read up

File ElasticaNcrSearch.php has 288 lines of code (exceeds 250 allowed). Consider refactoring.

Open

<?php
declare(strict_types=1);

namespace Gdbots\Ncr\Search\Elastica;

Method getNodes has 70 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function getNodes(array $nodeRefs, bool $consistent = false, array $context = []): array
    {
        if (empty($nodeRefs)) {
            return [];
        } elseif (count($nodeRefs) === 1) {

Method searchNodes has 69 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function searchNodes(Message $request, ParsedQuery $parsedQuery, Message $response, array $qnames = [], array $context = []): void
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $skipValidation = filter_var($context['skip_validation'] ?? true, FILTER_VALIDATE_BOOLEAN);
        $client = $this->getClientForRead($context);

Function getNode has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    final public function getNode(NodeRef $nodeRef, bool $consistent = false, array $context = []): Message
    {
        $cacheKey = $this->getCacheKey($nodeRef, $context);
        $cacheItem = null;

• Read up
  Read up

Method createQuery has 64 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function createQuery(IndexQuery $query): array
    {
        $filterables = $this->getFilterableAttributes();
        $params = [
            'IndexName'                 => $this->getName(),

Method indexNodes has 59 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function indexNodes(array $nodes, array $context = []): void
    {
        if (empty($nodes)) {
            return;
        }

Method createIndex has 58 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function createIndex(Client $client, SchemaQName $qname, array $context = []): Index
    {
        static $created = [];

        $indexName = $this->getIndexName($qname, $context);

Method getNode has 56 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function getNode(NodeRef $nodeRef, bool $consistent = false, array $context = []): Message
    {
        $context = $this->enrichContext(__FUNCTION__, $context);
        $tableName = $this->tableManager->getNodeTableName($nodeRef->getQName(), $context);

Method create has 54 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    final public function create(DynamoDbClient $client, string $tableName): void
    {
        try {
            $client->describeTable(['TableName' => $tableName]);
            return;

Method putNode has 50 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function putNode(Message $node, ?string $expectedEtag = null, array $context = []): void
    {
        $node->freeze();
        $nodeRef = $node->generateNodeRef();

Method updateNode has 49 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function updateNode(Message $command): void
    {
        /** @var NodeRef $nodeRef */
        $nodeRef = $command->get('node_ref');
        $this->assertNodeRefMatches($nodeRef);

Method deleteNodes has 49 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function deleteNodes(array $nodeRefs, array $context = []): void
    {
        if (empty($nodeRefs)) {
            return;
        }

Method derefNodes has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function derefNodes(Message $node, array $fields, ?string $return = null): array
    {
        $nodeRefs = [];
        foreach ($fields as $field) {
            if (!$node->has($field)) {