devemio / elasticsearch-eloquent

src/Persistence/Persistence.php

<?php

namespace Isswp101\Persimmon\Persistence;

use Elasticsearch\Client;
use Exception;
use Isswp101\Persimmon\Contracts\PersistenceContract;
use Isswp101\Persimmon\DTO\Id;
use Isswp101\Persimmon\DTO\Path;
use Isswp101\Persimmon\DTO\SearchResponse;

final class Persistence implements PersistenceContract
{
    private Client $client;

    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    public function find(Path $path, array $columns = []): array|null

The type Isswp101\Persimmon\Persistence\null was not found. Maybe you did not declare it correctly or list all dependencies?

    {
        $params = [
            'index' => $path->getIndex(),
            'type' => $path->getType(),
            'id' => $path->getId()->value()
        ];

        if ($columns) {

The expression $columns of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

            $params['_source'] = $columns;
        }

        try {
            $response = $this->client->get($params);
        } catch (Exception) {
            return null;
        }

        return $response['_source'];
    }

    public function create(Path $path, array $attributes): Id
    {
        $params = [
            'index' => $path->getIndex(),
            'type' => $path->getType(),
            'id' => $path->getId()->value(),
            'body' => $attributes
        ];

        $response = $this->client->index($params);

        return new Id($response['_id']);
    }

    public function update(Path $path, array $attributes): Id
    {
        $params = [
            'index' => $path->getIndex(),
            'type' => $path->getType(),
            'id' => $path->getId()->value(),
            'body' => [
                'doc' => $attributes
            ]
        ];

        $this->client->update($params);

        return $path->getId();
    }

    public function delete(Path $path): void
    {
        $params = [
            'index' => $path->getIndex(),
            'type' => $path->getType(),
            'id' => $path->getId()->value(),
        ];

        $this->client->delete($params);
    }

    public function search(Path $path, array $query): SearchResponse
    {
        $params = [
            'index' => $path->getIndex(),
            'type' => $path->getType(),
            'body' => $query
        ];

        return new SearchResponse($this->client->search($params));
    }
}