Algolia\ScoutExtended\Searchable\ModelsResolver

Complexity

Total Complexity

15

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Test Coverage

Coverage

96.97%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
D	from()	0	57	15

<?php

declare(strict_types=1);

/**
 * This file is part of Scout Extended.
 *
 * (c) Algolia Team <contact@algolia.com>
 *
 *  For the full copyright and license information, please view the LICENSE
 *  file that was distributed with this source code.
 */

namespace Algolia\ScoutExtended\Searchable;

use function in_array;
use Laravel\Scout\Builder;
use Illuminate\Support\Arr;
use function call_user_func;
use Laravel\Scout\Searchable;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Database\Eloquent\SoftDeletes;

/**
 * @internal
 */
final class ModelsResolver
{
    /**
     * @var string[]
     */
    public static $metadata = [
        '_highlightResult',
        '_rankingInfo',
    ];

    /**
     * Get a set of models from the provided results.
     *
     * @param \Laravel\Scout\Builder $builder
     * @param  string|object $searchable
     * @param  array $results
     *
     * @return \Illuminate\Database\Eloquent\Collection
     */
    public function from(Builder $builder, $searchable, array $results): Collection
    {
        $instances = collect();
        $hits = collect($results['hits'])->keyBy('objectID');

        $models = [];
        foreach ($hits->keys() as $id) {
            $modelClass = ObjectIdEncrypter::decryptSearchable((string) $id);
            $modelKey = ObjectIdEncrypter::decryptSearchableKey((string) $id);
            if (! array_key_exists($modelClass, $models)) {
                $models[$modelClass] = [];
            }

            $models[$modelClass][] = $modelKey;
        }

        foreach ($models as $modelClass => $modelKeys) {
            $model = new $modelClass;

            if (in_array(Searchable::class, class_uses_recursive($model), true)) {
                if (! empty($models = $model->getScoutModelsByIds($builder, $modelKeys))) {
                    $instances = $instances->merge($models);
                }
            } else {
                $query = in_array(SoftDeletes::class, class_uses_recursive($model),
                    true) ? $model->withTrashed() : $model->newQuery();

                if ($builder->queryCallback) {
                    call_user_func($builder->queryCallback, $query);
                }

                $scoutKey = method_exists($model,
                    'getScoutKeyName') ? $model->getScoutKeyName() : $model->getQualifiedKeyName();
                if ($models = $query->whereIn($scoutKey, $modelKeys)->get()) {
                    $instances = $instances->merge($models);
                }
            }
        }

        $result = $searchable->newCollection();

        foreach ($hits as $id => $hit) {
            foreach ($instances as $instance) {
                if (ObjectIdEncrypter::encrypt($instance) === ObjectIdEncrypter::withoutPart((string) $id)) {
                    if (method_exists($instance, 'withScoutMetadata')) {
                        foreach (Arr::only($hit, self::$metadata) as $metadataKey => $metadataValue) {
                            $instance->withScoutMetadata($metadataKey, $metadataValue);
                        }
                    }

                    $result->push($instance);
                    break;
                }
            }
        }

        return $result;
    }
}