midorikocak\nanodb\ArrayRepository

Complexity

Total Complexity

13

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	save()	0	19	2
A	read()	0	8	2
A	checkData()	0	4	2
A	readAll()	0	18	3
A	remove()	0	7	2
A	__construct()	0	11	2

<?php

declare(strict_types=1);

namespace midorikocak\nanodb;

use Exception;
use midorikocak\arraytools\ArrayValidator;

use function array_key_exists;
use function key;
use function reset;

/**
 * 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(array $constraints = [], array $columns = ['*']): array
    {
        $db = $this->db->select($this->tableName, $columns);

        if (!empty($constraints)) {
            $value = reset($constraints);
            $key = key($constraints);
            $db->where($key, $value);

            unset($constraints[key($constraints)]);

            foreach ($constraints as $key => $value) {
                $db->and($key, $value);
            }
        }

        $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;
    }
}