php-resta / resta-core

src/resta/Worker/JobAbstract.php

Spacing +4 added lines, -4 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,15 +41,15 @@ 
      */
     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';
         }
     }

src/resta/Worker/SupervisorJob.php

Spacing +2 added lines, -2 removed lines

@@ -115,8 +115,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, '
 [program:'.$this->app()->get('WORKER').']
 process_name=%(program_name)s_%(process_num)02d
 command=php '.root.'/api worker start '.$this->app->get('PROJECT_NAME').' worker:'.$this->worker->getWorker().' apply:default

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

Spacing +20 added lines, -20 removed lines

@@ -31,13 +31,13 @@ 
     public function start()

     {

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

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

-        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', $workerName);

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

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

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

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

 

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

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

     }

 

     /**

@@ -46,13 +46,13 @@ 
     public function stop()

     {

         $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',true);

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

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

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

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

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

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

 

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

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

     }

 

     /**

@@ -61,13 +61,13 @@ 
     public function status()

     {

         $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', $workerName);

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

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

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

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

 

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

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

     }

 

     /**

@@ -75,7 +75,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);

         }

@@ -84,7 +84,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);

src/resta/Console/Source/Project/Project.php

Spacing +8 added lines, -8 removed lines

@@ -14,7 +14,7 @@ 
     /**

      * @var $type

      */

-    public $type='project';

+    public $type = 'project';

 

     /**

      * @var array

@@ -31,7 +31,7 @@ 
     /**

      * @var $commandRule

      */

-    public $commandRule=[];

+    public $commandRule = [];

 

     /**

      * @method create

@@ -46,15 +46,15 @@ 
         $this->argument['exceptionNamespace']   = app()->namespace()->exception();

         $this->argument['resourcePath']         = app()->path()->appResourche();

 

-        $recursiveDefaultDirectory = explode("\\",$this->argument['project']);

+        $recursiveDefaultDirectory = explode("\\", $this->argument['project']);

         $this->argument['applicationName'] = pos($recursiveDefaultDirectory);

         $recursiveDefaultDirectory[] = 'V1';

         $recursiveDefaultDirectoryList = [];

 

-        foreach (array_slice($recursiveDefaultDirectory,1) as $defaultDirectory){

+        foreach (array_slice($recursiveDefaultDirectory, 1) as $defaultDirectory) {

 

-            $recursiveDefaultDirectoryList[]=$defaultDirectory;

-            $this->directory[$defaultDirectory.'Path'] = $this->projectPath().''.implode("/",$recursiveDefaultDirectoryList);

+            $recursiveDefaultDirectoryList[] = $defaultDirectory;

+            $this->directory[$defaultDirectory.'Path'] = $this->projectPath().''.implode("/", $recursiveDefaultDirectoryList);

         }

 

         //$this->directory['optionalDir'] = $this->optional();

@@ -80,7 +80,7 @@ 
         //$this->directory['sourceDir']               = $this->sourceDir();

         //$this->directory['sourceSupportDir']        = $this->sourceSupportDir();

         //$this->directory['sourceSupportTraitDir']   = $this->sourceSupportDir().'/Traits';

-        $this->directory['exceptionDir']            = app()->path()->exception();

+        $this->directory['exceptionDir'] = app()->path()->exception();

 

         //set project directory

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

@@ -133,7 +133,7 @@ 
         $this->touch['app/gitignore']               = $this->projectPath().'/.gitignore';

         $this->touch['app/composer']                = $this->projectPath().'/composer.json';

         $this->touch['test/index']                  = $this->storage().'/index.html';

-        $this->touch['exception/authenticate']      = $this->directory['exceptionDir'] .'/AuthenticateException.php';

+        $this->touch['exception/authenticate']      = $this->directory['exceptionDir'].'/AuthenticateException.php';

 

         //set project touch

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