php-resta / resta-core

src/resta/Worker/WorkerManager.php

Spacing +8 added lines, -8 removed lines

@@ -21,7 +21,7 @@ 
     public function execute()
     {
         //we check the presence of worker on container.
-        if($this->isWorkerAvailable()){
+        if ($this->isWorkerAvailable()) {
             $this->{$this->getApply()}();
         }
     }
@@ -35,7 +35,7 @@ 
     {
         $this->isWorkerClosure();
 
-        if($this->resolve instanceof \Closure){
+        if ($this->resolve instanceof \Closure) {
             $resolve = $this->resolve;
             echo $resolve($this->getData()).''.PHP_EOL;
             $this->pause();
@@ -51,7 +51,7 @@ 
     {
         $this->isWorkerObject();
 
-        if($this->resolve instanceof WorkerContracts){
+        if ($this->resolve instanceof WorkerContracts) {
             $this->resolve->handle();
             echo $this->getWorker().' Worker : Ok'.PHP_EOL;
             $this->pause($this->resolve->getSleep());
@@ -66,11 +66,11 @@ 
     public function isWorkerClosure()
     {
         //we check the presence of worker on container.
-        if($this->isWorkerAvailable()){
+        if ($this->isWorkerAvailable()) {
 
             // if worker comes as an object, this object will be executed.
             // worker can have a closure function.
-            if(is_callable($worker = $this->worker[$this->getWorker()])) {
+            if (is_callable($worker = $this->worker[$this->getWorker()])) {
                 $this->resolve = $worker;
             }
         }
@@ -84,12 +84,12 @@ 
     public function isWorkerObject()
     {
         //we check the presence of worker on container.
-        if($this->isWorkerAvailable()){
+        if ($this->isWorkerAvailable()) {
 
             // if worker comes as an object, this object will be executed.
             // worker can have a closure function.
-            if(!is_callable($worker = $this->worker[$this->getWorker()]) && Utils::isNamespaceExists($worker)) {
-                $this->resolve = $this->app->resolve($worker,['data'=>$this->getData()]);
+            if (!is_callable($worker = $this->worker[$this->getWorker()]) && Utils::isNamespaceExists($worker)) {
+                $this->resolve = $this->app->resolve($worker, ['data'=>$this->getData()]);
             }
         }
     }

src/resta/Worker/DefaultJob.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
      * @param ApplicationContracts $app
      * @param WorkerManagerContracts $worker
      */
-    public function __construct(ApplicationContracts $app,WorkerManagerContracts $worker)
+    public function __construct(ApplicationContracts $app, WorkerManagerContracts $worker)
     {
         parent::__construct($app);
 
@@ -32,7 +32,7 @@ 
      */
     public function execute()
     {
-        while(1){
+        while (1) {
             $this->worker->executeObject();
             $this->worker->executeClosure();
         }

src/resta/Worker/WorkerManagerAbstract.php

Spacing +11 added lines, -11 removed lines

@@ -24,11 +24,11 @@ 
      * @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..');
         }
 
@@ -44,7 +44,7 @@ 
      */
     public function getApply()
     {
-        if(isset($this->args['apply'])){
+        if (isset($this->args['apply'])) {
             return $this->args['apply'];
         }
 
@@ -58,7 +58,7 @@ 
      */
     public function getData()
     {
-        if(isset($this->args['data'])){
+        if (isset($this->args['data'])) {
             return $this->args['data'];
         }
 
@@ -72,7 +72,7 @@ 
      */
     public function getPauseValue()
     {
-        if(isset($this->args['pause'])){
+        if (isset($this->args['pause'])) {
             return $this->args['pause'];
         }
 
@@ -86,7 +86,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;
         }
 
@@ -108,12 +108,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);
         }
     }
@@ -128,8 +128,8 @@ 
     public function __call($name, $arguments)
     {
         $job = __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');

Braces +1 added lines, -2 removed lines

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

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

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
      */

     public function run()

     {

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

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

     }

 

     /**

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

         }

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