php-resta / resta-core

src/resta/Worker/WorkerManagerAbstract.php

Braces +1 added lines, -2 removed lines

@@ -112,8 +112,7 @@
     {
         if(is_null($pause)){
             sleep($this->getPauseValue());
-        }
-        else{
+        } else{
             sleep($pause);
         }
     }

Spacing +14 added lines, -14 removed lines

@@ -25,15 +25,15 @@ 
      * @param ApplicationContracts $app
      * @param array $args
      */
-    public function __construct(ApplicationContracts $app, $args=array())
+    public function __construct(ApplicationContracts $app, $args = array())
     {
         parent::__construct($app);
 
-        if($this->app->runningInConsole()===false){
+        if ($this->app->runningInConsole()===false) {
             exception()->runtime('The worker can only be run as cli..');
         }
 
-        if($this->app->has('WORKER')===false){
+        if ($this->app->has('WORKER')===false) {
             exception()->runtime('The worker console manipulation for WORKER container value');
         }
 
@@ -49,7 +49,7 @@ 
      */
     public function getApply()
     {
-        if(isset($this->args['apply'])){
+        if (isset($this->args['apply'])) {
             return $this->args['apply'];
         }
 
@@ -63,7 +63,7 @@ 
      */
     public function getData()
     {
-        if(isset($this->args['data'])){
+        if (isset($this->args['data'])) {
             return $this->args['data'];
         }
 
@@ -77,7 +77,7 @@ 
      */
     public function getPauseValue()
     {
-        if(isset($this->args['pause'])){
+        if (isset($this->args['pause'])) {
             return $this->args['pause'];
         }
 
@@ -91,7 +91,7 @@ 
      */
     public function getWorker()
     {
-        if(isset($this->args['worker'],$this->worker[$worker = strtolower($this->args['worker'])])){
+        if (isset($this->args['worker'], $this->worker[$worker = strtolower($this->args['worker'])])) {
             return $worker;
         }
 
@@ -113,12 +113,12 @@ 
      *
      * @param null|\int $pause
      */
-    public function pause($pause=null)
+    public function pause($pause = null)
     {
-        if(is_null($pause)){
+        if (is_null($pause)) {
             sleep($this->getPauseValue());
         }
-        else{
+        else {
             sleep($pause);
         }
     }
@@ -132,16 +132,16 @@ 
      */
     public function __call($name, $arguments)
     {
-        $job = $this->app->get('macro')->call(strtolower($this->getApply()).'Job',function() use($name){
+        $job = $this->app->get('macro')->call(strtolower($this->getApply()).'Job', function() use($name){
             return __NAMESPACE__.'\\'.ucfirst($name).'Job';
         });
 
-        if(Utils::isNamespaceExists($job)){
+        if (Utils::isNamespaceExists($job)) {
 
             /** @var JobContracts $resolve */
-            $resolve = $this->app->resolve($job,['worker'=>$this]);
+            $resolve = $this->app->resolve($job, ['worker'=>$this]);
 
-            if($resolve instanceof JobContracts){
+            if ($resolve instanceof JobContracts) {
                 return $resolve->execute();
             }
         }

src/resta/Console/Source/Worker/Worker.php

Spacing +39 added lines, -39 removed lines

@@ -31,14 +31,14 @@ 
      * @param string $method

      * @param bool $break

      */

-    private function allWorkers($method='start',$break=false)

+    private function allWorkers($method = 'start', $break = false)

     {

-        foreach(app()->get('worker') as $key=>$item){

+        foreach (app()->get('worker') as $key=>$item) {

             $this->argument['worker'] = ucfirst($key);

             $this->argument[$key] = ucfirst($key);

             $this->{$method}();

 

-            if($break) break;

+            if ($break) break;

         }

         exit();

     }

@@ -48,22 +48,22 @@ 
      */

     public function start()

     {

-        if(is_null($this->argument['worker'])){

+        if (is_null($this->argument['worker'])) {

             $this->allWorkers();

             exit();

         }

 

         $workerName = $this->projectName().'-'.$this->argument['worker'];

         app()->terminate('WORKER');

-        app()->register('WORKER',$workerName);

+        app()->register('WORKER', $workerName);

         app()->terminate('PROJECT_NAME');

-        app()->register('PROJECT_NAME',strtolower($this->projectName()));

-        app()->register('WORKER_START',true);

-        app()->register('WORKER_STOP',false);

-        app()->register('WORKER_STATUS',false);

-        app()->register('WORKER_CLEAR',false);

+        app()->register('PROJECT_NAME', strtolower($this->projectName()));

+        app()->register('WORKER_START', true);

+        app()->register('WORKER_STOP', false);

+        app()->register('WORKER_STATUS', false);

+        app()->register('WORKER_CLEAR', false);

 

-        app()->resolve(WorkerManager::class,['args'=>$this->argument])->execute();

+        app()->resolve(WorkerManager::class, ['args'=>$this->argument])->execute();

     }

 

     /**

@@ -71,22 +71,22 @@ 
      */

     public function stop()

     {

-        if(is_null($this->argument['worker'])){

+        if (is_null($this->argument['worker'])) {

             $this->allWorkers('stop');

             exit();

         }

 

         $workerName = $this->projectName().'-'.$this->argument['worker'];

         app()->terminate('WORKER');

-        app()->register('WORKER',$workerName);

+        app()->register('WORKER', $workerName);

         app()->terminate('PROJECT_NAME');

-        app()->register('PROJECT_NAME',strtolower($this->projectName()));

-        app()->register('WORKER_START',false);

-        app()->register('WORKER_STOP',true);

-        app()->register('WORKER_STATUS',false);

-        app()->register('WORKER_CLEAR',false);

+        app()->register('PROJECT_NAME', strtolower($this->projectName()));

+        app()->register('WORKER_START', false);

+        app()->register('WORKER_STOP', true);

+        app()->register('WORKER_STATUS', false);

+        app()->register('WORKER_CLEAR', false);

 

-        app()->resolve(WorkerManager::class,['args'=>$this->argument])->execute();

+        app()->resolve(WorkerManager::class, ['args'=>$this->argument])->execute();

     }

 

     /**

@@ -94,20 +94,20 @@ 
      */

     public function status()

     {

-        if(is_null($this->argument['worker'])){

-            $this->allWorkers('status',true);

+        if (is_null($this->argument['worker'])) {

+            $this->allWorkers('status', true);

             exit();

         }

 

         $workerName = $this->projectName().'-'.$this->argument['worker'];

-        app()->register('WORKER',$workerName);

-        app()->register('PROJECT_NAME',strtolower($this->projectName()));

-        app()->register('WORKER_START',false);

-        app()->register('WORKER_STOP',false);

-        app()->register('WORKER_STATUS',true);

-        app()->register('WORKER_CLEAR',false);

-

-        app()->resolve(WorkerManager::class,['args'=>$this->argument])->execute();

+        app()->register('WORKER', $workerName);

+        app()->register('PROJECT_NAME', strtolower($this->projectName()));

+        app()->register('WORKER_START', false);

+        app()->register('WORKER_STOP', false);

+        app()->register('WORKER_STATUS', true);

+        app()->register('WORKER_CLEAR', false);

+

+        app()->resolve(WorkerManager::class, ['args'=>$this->argument])->execute();

     }

 

     /**

@@ -115,22 +115,22 @@ 
      */

     public function clear()

     {

-        if(is_null($this->argument['worker'])){

+        if (is_null($this->argument['worker'])) {

             $this->allWorkers('clear');

             exit();

         }

 

         $workerName = $this->projectName().'-'.$this->argument['worker'];

         app()->terminate('WORKER');

-        app()->register('WORKER',$workerName);

+        app()->register('WORKER', $workerName);

         app()->terminate('PROJECT_NAME');

-        app()->register('PROJECT_NAME',strtolower($this->projectName()));

-        app()->register('WORKER_START',false);

-        app()->register('WORKER_STOP',false);

-        app()->register('WORKER_STATUS',false);

-        app()->register('WORKER_CLEAR',true);

+        app()->register('PROJECT_NAME', strtolower($this->projectName()));

+        app()->register('WORKER_START', false);

+        app()->register('WORKER_STOP', false);

+        app()->register('WORKER_STATUS', false);

+        app()->register('WORKER_CLEAR', true);

 

-        app()->resolve(WorkerManager::class,['args'=>$this->argument])->execute();

+        app()->resolve(WorkerManager::class, ['args'=>$this->argument])->execute();

     }

 

     /**

@@ -138,7 +138,7 @@ 
      */

     public function create()

     {

-        if(!file_exists(app()->path()->workers())){

+        if (!file_exists(app()->path()->workers())) {

             $this->directory['worker'] = app()->path()->workers();

             $this->file->makeDirectory($this);

         }

@@ -147,7 +147,7 @@ 
         $this->argument['workerClass'] = ucfirst($this->argument['worker']).'';

         $this->argument['projectName'] = strtolower($this->projectName());

 

-        $this->touch['worker/worker']= app()->path()->workers().'/'.$this->argument['worker'].'.php';

+        $this->touch['worker/worker'] = app()->path()->workers().'/'.$this->argument['worker'].'.php';

 

 

         $this->file->touch($this);

Braces +3 added lines, -1 removed lines

@@ -38,7 +38,9 @@
             $this->argument[$key] = ucfirst($key);

             $this->{$method}();

 

-            if($break) break;

+            if($break) {

+                break;

+            }

         }

         exit();

     }

src/resta/Worker/JobAbstract.php

Spacing +5 added lines, -5 removed lines

@@ -25,7 +25,7 @@ 
      * @param ApplicationContracts $app
      * @param WorkerManagerContracts $worker
      */
-    public function __construct(ApplicationContracts $app,WorkerManagerContracts $worker)
+    public function __construct(ApplicationContracts $app, WorkerManagerContracts $worker)
     {
         parent::__construct($app);
 
@@ -41,19 +41,19 @@ 
      */
     public function jobProcessor()
     {
-        if($this->app->get('WORKER_START')===true){
+        if ($this->app->get('WORKER_START')===true) {
             return 'start';
         }
 
-        if($this->app->get('WORKER_STOP')===true){
+        if ($this->app->get('WORKER_STOP')===true) {
             return 'stop';
         }
 
-        if($this->app->get('WORKER_STATUS')===true){
+        if ($this->app->get('WORKER_STATUS')===true) {
             return 'status';
         }
 
-        if($this->app->get('WORKER_CLEAR')===true){
+        if ($this->app->get('WORKER_CLEAR')===true) {
             return 'clear';
         }
     }

src/resta/Support/Process.php

Spacing +2 added lines, -2 removed lines

@@ -13,9 +13,9 @@
      * @param null|string $command
      * @return mixed|void
      */
-    public function command($command=null)
+    public function command($command = null)
     {
-        $process = new ProcessHandler($command,root.'');
+        $process = new ProcessHandler($command, root.'');
         $process->run();
 
         // executes after the command finishes

src/resta/Worker/SupervisorJob.php

Spacing +7 added lines, -7 removed lines

@@ -85,15 +85,15 @@ 
     {
         $list = [];
 
-        $status = array_filter(explode("\n",$this->process->command(config('supervisor.commands.workers'))),'strlen');
+        $status = array_filter(explode("\n", $this->process->command(config('supervisor.commands.workers'))), 'strlen');
 
-        foreach ($status as $item){
-            if(preg_match('@'.$this->app->get('PROJECT_NAME').'.*@is',$item,$array)){
+        foreach ($status as $item) {
+            if (preg_match('@'.$this->app->get('PROJECT_NAME').'.*@is', $item, $array)) {
                 $list[] = $item;
             }
         }
 
-        return implode(PHP_EOL,$list).''.PHP_EOL;
+        return implode(PHP_EOL, $list).''.PHP_EOL;
     }
 
     /**
@@ -105,7 +105,7 @@ 
     {
         $supervisorStatus = $this->process->command(config('supervisor.commands.status'));
 
-        if(false===$supervisorStatus){
+        if (false===$supervisorStatus) {
             $this->upSupervisor();
         }
         return $this->process->command(config('supervisor.commands.status'));
@@ -160,8 +160,8 @@ 
     {
         $path = config('supervisor.path').'/'.$this->app->get('WORKER').'.conf';
 
-        if(files()->exists($path)===false){
-            files()->put($path,'
+        if (files()->exists($path)===false) {
+            files()->put($path, '
 [group:'.$this->app->get('PROJECT_NAME').']
 [program:'.$this->app()->get('WORKER').']
 process_name=%(program_name)s_%(process_num)02d

src/resta/Database/Migration/Src/SchemaFacade.php

Spacing +13 added lines, -13 removed lines

@@ -21,20 +21,20 @@ 
     /**
      * @var array
      */
-    protected static $config=array();
+    protected static $config = array();
 
     /**
      * @var array $tables
      */
-    protected static $tables=array();
+    protected static $tables = array();
 
     /**
      * SchemaFacade constructor.
      */
-    public function __construct($config=array())
+    public function __construct($config = array())
     {
-        if(count($config)){
-            $this->schema=new Schema($config);
+        if (count($config)) {
+            $this->schema = new Schema($config);
         }
     }
 
@@ -42,9 +42,9 @@ 
      * @param array $params
      * @return SchemaFacadeContract
      */
-    public static function setConfig($params=array())
+    public static function setConfig($params = array())
     {
-        self::$config=$params;
+        self::$config = $params;
 
         return new static();
     }
@@ -53,9 +53,9 @@ 
      * @param array $tables
      * @return SchemaFacadeContract
      */
-    public static function tables($tables=array())
+    public static function tables($tables = array())
     {
-        self::$tables=$tables;
+        self::$tables = $tables;
 
         return new static();
     }
@@ -66,8 +66,8 @@ 
      */
     public static function getInstance()
     {
-        if(is_null(self::$instance)){
-            self::$instance=new self(self::$config);
+        if (is_null(self::$instance)) {
+            self::$instance = new self(self::$config);
         }
         return self::$instance;
     }
@@ -88,7 +88,7 @@ 
     {
         $schema = self::getSchema();
 
-        $schema->params['tables']=self::$tables;
+        $schema->params['tables'] = self::$tables;
 
         return $schema->pull();
     }
@@ -100,7 +100,7 @@ 
     {
         $schema = self::getSchema();
 
-        $schema->params['tables']=self::$tables;
+        $schema->params['tables'] = self::$tables;
 
         return $schema->push();
     }

src/resta/Database/Migration/Src/Schema.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
      * Schema constructor.
      * @param null $config
      */
-    public function __construct($config=null)
+    public function __construct($config = null)
     {
         $this->config           = $config;
         $this->driver           = $this->config['database']['driver'];

src/resta/Database/Migration/Src/SchemaCapsule.php

Spacing +6 added lines, -6 removed lines

@@ -37,7 +37,7 @@ 
      * @param $file
      * @param $table
      */
-    public function __construct($config,$file,$table)
+    public function __construct($config, $file, $table)
     {
         $this->config                       = $config;
         $this->file                         = $file;
@@ -52,7 +52,7 @@ 
      */
     public function alter(callable $callback)
     {
-        return $this->callbackWizardInstance(__FUNCTION__,$callback);
+        return $this->callbackWizardInstance(__FUNCTION__, $callback);
     }
 
     /**
@@ -61,7 +61,7 @@ 
      */
     public function create(callable $callback)
     {
-        return $this->callbackWizardInstance(__FUNCTION__,$callback);
+        return $this->callbackWizardInstance(__FUNCTION__, $callback);
     }
 
     /**
@@ -69,7 +69,7 @@ 
      */
     private function checkErrors($wizard)
     {
-        if(count($wizard->getNames())!==count($wizard->getTypes())){
+        if (count($wizard->getNames())!==count($wizard->getTypes())) {
             $wizard->setError('name and types are not equal');
         }
     }
@@ -105,11 +105,11 @@ 
      * @param $method
      * @return string
      */
-    private function callbackWizardInstance($method,callable $callback)
+    private function callbackWizardInstance($method, callable $callback)
     {
         $wizardInstance = $this->getWizardInstance($method);
 
-        $callbackReturn = call_user_func_array($callback,[$wizardInstance]);
+        $callbackReturn = call_user_func_array($callback, [$wizardInstance]);
 
         $this->checkErrors($wizardInstance);
 

src/resta/Database/Migration/Src/Connector/Mysql.php

Spacing +3 added lines, -3 removed lines

@@ -22,14 +22,14 @@
      */
     public function __construct($config)
     {
-        if(is_null(self::$instance)){
+        if (is_null(self::$instance)) {
 
             //get pdo dsn
-            $dsn=''.$config['driver'].':host='.$config['host'].';dbname='.$config['database'].'';
+            $dsn = ''.$config['driver'].':host='.$config['host'].';dbname='.$config['database'].'';
             $this->connection = new \PDO($dsn, $config['user'], $config['password']);
             $this->connection->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
 
-            self::$instance=true;
+            self::$instance = true;
         }
     }