Refactoring

.gitignore

@@ -0,0 +1 @@
+.idea/

lib/CoordinatorComponent.php

@@ -26,7 +26,7 @@ class CoordinatorComponent extends Component implements ICoordinatorComponent
     /**
      * @var string
      */
-    public $prefix = "db";
+    public $prefix = '';
     /**
      * @var array
      */
@@ -35,18 +35,19 @@ class CoordinatorComponent extends Component implements ICoordinatorComponent
     /**
      * @throws InvalidConfigException
      */
-    public function init() {
+    public function init()
+    {
         parent::init();
 
         if (!$this->component) {
-            throw new InvalidConfigException("Please set component for coordinator");
+            throw new InvalidConfigException('Please set component for coordinator');
         }
 
         foreach ($this->component as $value) {
             $coordinator = \Yii::createObject($value);
 
             if (!$coordinator instanceof ICoordinator) {
-                throw new InvalidConfigException("Component coordinator not implements ICoordinator interface.");
+                throw new InvalidConfigException('Component coordinator not implements ICoordinator interface.');
             }
 
             $this->coordinator[] = $coordinator;
@@ -60,7 +61,8 @@ public function init() {
      * @return array
      * @throws InvalidConfigException
      */
-    public function getShard(array $db, $data) {
+    public function getShard(array $db, $data)
+    {
         $data = (!is_array($data)) ? [$data] : $data;
 
         if (!$data) {
@@ -78,16 +80,16 @@ public function getShard(array $db, $data) {
             return [];
         }
 
-        $result = array_map(function(&$value) {
-            return $this->prefix.$value;
+        $result = array_map(function (&$value) {
+            return $this->prefix . $value;
         }, $params);
 
         $error = array_diff($result, $db);
 
         if ($error) {
-            throw new InvalidConfigException("Not found shard db in db project");
+            throw new InvalidConfigException('Not found shard db in db project');
         }
 
-        return (count($result) == 1) ? $result[0] : $result;
+        return (1 === count($result)) ? $result[0] : $result;
     }
 }

lib/DbCoordinator.php

@@ -9,7 +9,6 @@
 
 namespace axiles89\coordinator;
 
-
 use yii\base\Component;
 use yii\base\InvalidConfigException;
 use yii\db\Connection;
@@ -36,36 +35,43 @@ class DbCoordinator extends Component implements ICoordinator
     /**
      * @throws InvalidConfigException
      */
-    public function init() {
+    public function init()
+    {
         parent::init();
 
-        if (!$this->table or !isset($this->table['name']) or !isset($this->table['columnSearch']) or !isset($this->table['columnResult'])) {
-            throw new InvalidConfigException("Please set table for coordinator component");
+        if (!$this->table
+            || !array_key_exists('name', $this->table)
+            || !array_key_exists('columnSearch', $this->table)
+            || !array_key_exists('columnResult', $this->table)
+        ) {
+            throw new InvalidConfigException('Please set table for coordinator component');
         }
 
         if (!$this->connect) {
-            throw new InvalidConfigException("Please set connect for coordinator component");
+            throw new InvalidConfigException('Please set connect for coordinator component');
         }
 
         $this->db = \Yii::createObject($this->connect);
 
         if (!$this->db instanceof Connection) {
-            throw new InvalidConfigException("Component coordinator not implements Connection interface.");
+            throw new InvalidConfigException('Component coordinator not implements Connection interface.');
         }
     }
 
     /**
      * @param array $data
      * @return array
      */
-    public function execute(array $data) {
+    public
+    function execute(array $data)
+    {
         $result = [];
 
         if (!$data) {
             return $result;
         }
 
-        $return = $this->db->createCommand("SELECT {$this->table['columnResult']} FROM {$this->table['name']} WHERE {$this->table['columnSearch']} IN (".implode(",", $data).")")
+        $return = $this->db->createCommand("SELECT {$this->table['columnResult']} FROM {$this->table['name']} WHERE {$this->table['columnSearch']} IN (" . implode(',', $data) . ')')
             ->queryAll();
 
         foreach ($return as $value) {

lib/FunctionCoordinator.php

@@ -9,15 +9,14 @@
 
 namespace axiles89\coordinator;
 
-
 use yii\base\Component;
 use yii\base\InvalidConfigException;
 
 /**
  * Class FunctionCoordinator
  * @package axiles89\coordinator
  */
-class FunctionCoordinator  extends Component implements ICoordinator
+class FunctionCoordinator extends Component implements ICoordinator
 {
     /**
      * @var
@@ -27,19 +26,21 @@ class FunctionCoordinator  extends Component implements ICoordinator
     /**
      * @throws InvalidConfigException
      */
-    public function init() {
+    public function init()
+    {
         parent::init();
 
         if (!$this->function or !is_callable($this->function)) {
-            throw new InvalidConfigException("Please set callable function for coordinator component");
+            throw new InvalidConfigException('Please set callable function for coordinator component');
         }
     }
 
     /**
      * @param array $data
      * @return array
      */
-    public function execute(array $data) {
+    public function execute(array $data)
+    {
         $result = [];
 
         foreach ($data as $value) {

lib/RedisCoordinator.php

@@ -37,29 +37,31 @@ class RedisCoordinator extends Component implements ICoordinator
      * @throws InvalidConfigException
      * @throws \yii\base\InvalidConfigException
      */
-    public function init() {
+    public function init()
+    {
         parent::init();
 
         if (!$this->hashName) {
-            throw new InvalidCallException("Please set hashName for coordinator component");
+            throw new InvalidCallException('Please set hashName for coordinator component');
         }
 
         if (!$this->connect) {
-            throw new InvalidConfigException("Please set connect for coordinator component");
+            throw new InvalidConfigException('Please set connect for coordinator component');
         }
 
         $this->db = \Yii::createObject($this->connect);
 
         if (!$this->db instanceof Connection) {
-            throw new InvalidConfigException("Component coordinator not implements redis Connection interface.");
+            throw new InvalidConfigException('Component coordinator not implements redis Connection interface.');
         }
     }
 
     /**
      * @param array $data
      * @return array
      */
-    public function execute(array $data) {
+    public function execute(array $data)
+    {
         $result = [];
 
         if (!$data) {