php-resta / resta-core

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

Spacing +10 added lines, -10 removed lines

@@ -31,11 +31,11 @@ 
     public function run()

     {

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

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

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

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

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

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

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

 

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

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

     }

 

     /**

@@ -44,11 +44,11 @@ 
     public function stop()

     {

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

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

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

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

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

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

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

 

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

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

     }

 

     /**

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

         }

@@ -65,7 +65,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/Worker/SupervisorJob.php

Spacing +5 added lines, -5 removed lines

@@ -26,7 +26,7 @@ 
      * @param ApplicationContracts $app
      * @param WorkerManagerContracts $worker
      */
-    public function __construct(ApplicationContracts $app,WorkerManagerContracts $worker)
+    public function __construct(ApplicationContracts $app, WorkerManagerContracts $worker)
     {
         parent::__construct($app);
 
@@ -44,11 +44,11 @@ 
     {
         $this->isSupervisorRunning();
 
-        if($this->app->get('WORKER_STATUS')===true){
+        if ($this->app->get('WORKER_STATUS')===true) {
 
             $this->stopWorkerForSupervisor();
         }
-        else{
+        else {
 
             $this->putConfigurationFile();
 
@@ -121,8 +121,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 run '.$this->app->get('PROJECT_NAME').' worker:'.$this->worker->getWorker().'

Braces +1 added lines, -2 removed lines

@@ -47,8 +47,7 @@
         if($this->app->get('WORKER_STATUS')===true){
 
             $this->stopWorkerForSupervisor();
-        }
-        else{
+        } else{
 
             $this->putConfigurationFile();
 

src/resta/Worker/WorkerManagerAbstract.php

Indentation +1 added lines, -1 removed lines

@@ -132,7 +132,7 @@
     public function __call($name, $arguments)
     {
         $job = $this->app->get('macro')->call($this->getApply().'Worker',function() use($name){
-           return __NAMESPACE__.'\\'.ucfirst($name).'Job';
+            return __NAMESPACE__.'\\'.ucfirst($name).'Job';
         });
 
         if(Utils::isNamespaceExists($job)){

Spacing +13 added lines, -13 removed lines

@@ -24,15 +24,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');
         }
 
@@ -48,7 +48,7 @@ 
      */
     public function getApply()
     {
-        if(isset($this->args['apply'])){
+        if (isset($this->args['apply'])) {
             return $this->args['apply'];
         }
 
@@ -62,7 +62,7 @@ 
      */
     public function getData()
     {
-        if(isset($this->args['data'])){
+        if (isset($this->args['data'])) {
             return $this->args['data'];
         }
 
@@ -76,7 +76,7 @@ 
      */
     public function getPauseValue()
     {
-        if(isset($this->args['pause'])){
+        if (isset($this->args['pause'])) {
             return $this->args['pause'];
         }
 
@@ -90,7 +90,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;
         }
 
@@ -112,12 +112,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);
         }
     }
@@ -131,12 +131,12 @@ 
      */
     public function __call($name, $arguments)
     {
-        $job = $this->app->get('macro')->call($this->getApply().'Worker',function() use($name){
+        $job = $this->app->get('macro')->call($this->getApply().'Worker', function() use($name){
            return __NAMESPACE__.'\\'.ucfirst($name).'Job';
         });
 
-        if(Utils::isNamespaceExists($job)){
-            return $this->app->resolve($job,['worker'=>$this])->execute();
+        if (Utils::isNamespaceExists($job)) {
+            return $this->app->resolve($job, ['worker'=>$this])->execute();
         }
 
         exception()->runtime('Job Class not found');