Changed model to be jsonserialiazable and it's factory into repository

Added model, create and required/optional to repository
This commit is contained in:
2022-09-09 15:55:45 -04:00
parent 3811e8224b
commit 806b8e7b93
4 changed files with 122 additions and 13 deletions

View File

@ -47,6 +47,22 @@ abstract class Repository implements RepositoryInterface
{
return $this->factory;
}
protected string $model;
public function setModel(string $model_class): RepositoryInterface
{
$this->model = $model_class;
return $this;
}
public function getModel(): string
{
return $this->model;
}
public function getNewModel(): Model
{
$class = $this->getModel();
return (new $class())
->setRepository($this);
}
protected string $table;
public function setTable(string $table): RepositoryInterface
{
@ -74,7 +90,66 @@ abstract class Repository implements RepositoryInterface
{
return $this->columns;
}
protected array $required;
public function setRequired(array $columns): RepositoryInterface
{
foreach ($columns as $item) {
$this->addRequired($item);
}
return $this;
}
public function addRequired(string $column): RepositoryInterface
{
$this->required []= $column;
return $this;
}
public function getRequired(): array
{
if (isset($this->optional) and !isset($this->required)) {
return array_diff($this->getColumns(), $this->getOptional());
}
return $this->required ?? $this->getColumns();
}
protected array $optional;
public function setOptional(array $columns): RepositoryInterface
{
foreach ($columns as $item) {
$this->addColumn($item);
}
return $this;
}
public function addOptional(string $column): RepositoryInterface
{
$this->optional []= $column;
return $this;
}
public function getOptional(): array
{
if (isset($this->required) and !isset($this->optional)) {
return array_diff($this->getColumns(), $this->getRequired());
}
return $this->optional ?? [];
}
public function fillData(Model $model, array $data): Model
{
foreach ($this->getRequired() as $column) {
$m = 'set' . ucwords($column);
$model->{$m}($data[$column]);
}
foreach ($this->getOptional() as $column) {
if (isset($data[$column])) {
$m = 'set' . ucwords($column);
$model->{$m}($data[$column]);
}
}
return $model;
}
public function load(array $data): Model
{
return $this->fillData($this->getNewModel()
->setId($data['id']), $data);
}
public function save(Model $model): void
{
if (!$model->isDirty() and !$model->isNew()) {
@ -90,6 +165,11 @@ abstract class Repository implements RepositoryInterface
$query = $this->getQueryBuilder()->insert($this->getTable())->columns($this->getColumns())->values($cols);
$this->getConnection()->execute($query, $values);
}
public function create(array $data): Model
{
return $this->fillData($this->getNewModel()
->setNew(), $data);
}
public function edit(Model $model, array $data): Model
{
foreach ($this->getColumns() as $col) {