midorikocak / nanodb

src/ArrayRepository.php

<?php

declare(strict_types=1);

namespace midorikocak\nanodb;

use Exception;
use midorikocak\arraytools\ArrayValidator;
use midorikocak\querymaker\QueryInterface;

use function array_key_exists;

/**
 * Repository is a class that receives arrays as input data and returns array of arrays
 */
class ArrayRepository implements RepositoryInterface
{
    private DatabaseInterface $db;
    private ?ArrayValidator $validator;
    private $tableName;

    public function __construct(
        string $tableName,
        DatabaseInterface $db,
        ?array $schema = null,
        ?ArrayValidator $validator = null
    ) {
        $this->db = $db;
        $this->tableName = $tableName;
        $this->validator = $validator ?? new ArrayValidator();
        if ($schema) {
            $this->validator->schema($schema);
        }
    }

    private function checkData($data): void
    {
        if (!$this->validator->validate($data)) {

The method validate() does not exist on null.

            throw new Exception('Invalid data');
        }
    }

    /**
     * @inheritDoc
     */
    public function save($data): array
    {
        if (array_key_exists('id', $data)) {
            $this->checkData($data);

            $id = $data['id'];

            unset($data['id']);

            $this->db->update($this->tableName, $data)->where('id', $id)->execute();

            return $this->read($id);
        }

        $this->checkData($data);
        $this->db->insert($this->tableName, $data)->execute();

        $lastInsertId = $this->db->lastInsertId();
        return $this->db->select('users')->where('id', $lastInsertId)->fetch();
    }

    /**
     * @inheritDoc
     */
    public function read(?string $id = null): array
    {
        if ($id) {
            $this->db->select($this->tableName)->where('id', $id)->execute();
        } else {
            $this->db->select($this->tableName)->execute();
        }
        return $this->db->fetch();
    }

    public function readAll(?QueryInterface $query = null): array
    {
        if ($query !== null) {
            $db = $this->db->query($query);
        } else {
            $db = $this->db->select($this->tableName);
        }
        $db->execute();
        return $db->fetchAll();
    }

    /**
     * @inheritDoc
     */
    public function remove($data): int
    {
        if (array_key_exists('id', $data)) {
            $this->db->delete($this->tableName)->where('id', $data['id'])->execute();
            return $this->db->rowCount();
        }
        return 0;
    }
}