add RepositoryInterface

src/interfaces/RepositoryInterface.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace albertborsos\ddd\interfaces;
+
+use yii\db\ActiveRecordInterface;
+
+interface RepositoryInterface
+{
+    public static function find();
+
+    public static function findOne($condition);
+
+    public static function findAll($condition);
+
+    public static function updateAll($attributes, $condition = null);
+
+    public static function deleteAll($condition = null);
+
+    public function save(ActiveRecordInterface $model, $runValidation = true, $attributeNames = null);
+
+    public function insert(ActiveRecordInterface $model, $runValidation = true, $attributeNames = null);
+
+    public function update(ActiveRecordInterface $model, $runValidation = true, $attributeNames = null);
+
+    public function delete(ActiveRecordInterface $model);
+}

src/models/AbstractService.php

@@ -4,6 +4,7 @@
 
 use albertborsos\ddd\interfaces\BusinessObject;
 use albertborsos\ddd\interfaces\FormObject;
+use albertborsos\ddd\interfaces\RepositoryInterface;
 use yii\base\Component;
 use yii\helpers\ArrayHelper;
 use yii\web\Link;
@@ -31,14 +32,22 @@ abstract class AbstractService extends Component
      */
     private $_model;
 
-    public function __construct(FormObject $form = null, BusinessObject $model = null)
+    /**
+     * @var RepositoryInterface
+     */
+    private $_repository;
+
+    public function __construct(FormObject $form = null, BusinessObject $model = null, RepositoryInterface $repository = null)
     {
         if ($form) {
             $this->setForm($form);
         }
         if ($model) {
             $this->setModel($model);
         }
+        if ($repository) {
+            $this->setRepository($repository);
+        }
         parent::__construct([]);
     }
 
@@ -55,7 +64,6 @@ protected function getForm()
         return $this->_form;
     }
 
-
     /**
      * @return BusinessObject|ActiveRecord
      */
@@ -64,6 +72,14 @@ protected function getModel()
         return $this->_model;
     }
 
+    /**
+     * @return RepositoryInterface
+     */
+    protected function getRepository()
+    {
+        return $this->_repository;
+    }
+
     /**
      * @param $id
      */
@@ -95,4 +111,12 @@ private function setModel(BusinessObject $model)
     {
         $this->_model = $model;
     }
+
+    /**
+     * @param RepositoryInterface $repository
+     */
+    private function setRepository(RepositoryInterface $repository)
+    {
+        $this->_repository = $repository;
+    }
 }