php-resta / resta-core

src/resta/Exception/ExceptionExtender.php

Spacing +5 added lines, -5 removed lines

@@ -22,14 +22,14 @@ 
      * @param ApplicationContracts $app
      * @param array $result
      */
-    public function __construct(ApplicationContracts $app,$result=array())
+    public function __construct(ApplicationContracts $app, $result = array())
     {
         parent::__construct($app);
 
         $this->result = $result;
 
-        foreach($this->extender as $item){
-            if(method_exists($this,$item)){
+        foreach ($this->extender as $item) {
+            if (method_exists($this, $item)) {
                 $this->{$item}();
             }
         }
@@ -54,8 +54,8 @@ 
     {
         // we will look at the requestExpected container value to show
         // the expected values ​​for the request object in the exception output.
-        if($this->app->has('requestExpected') && config('app.requestWithError')===true){
-            if($requestExpected = $this->app->get('requestExpected')){
+        if ($this->app->has('requestExpected') && config('app.requestWithError')===true) {
+            if ($requestExpected = $this->app->get('requestExpected')) {
                 $this->result['request']['expected'] = $requestExpected;
             }
         }

src/resta/Container/ContainerInstanceResolver.php

Spacing +5 added lines, -5 removed lines

@@ -25,26 +25,26 @@
      * @param null|string $name

      * @return array

      */

-    public function container($name=null)

+    public function container($name = null)

     {

         //check container value for kernel

-        if(isset($this->instances['container'])){

+        if (isset($this->instances['container'])) {

 

             // if methoda is a null parameter,

             // then we send direct container values.

-            if(is_null($name)){

+            if (is_null($name)) {

                 return (array)$this->instances['container'];

             }

 

             // if there is an existing value in the container as the method parameter,

             // we send this value directly in the container.

-            if(isset($this->container()[$name])){

+            if (isset($this->container()[$name])) {

                 return $this->container()[$name];

             }

 

             // if there is no $name value in the container as the method parameter,

             // we check this value directly in the core object.

-            if(property_exists(core(),$name)){

+            if (property_exists(core(), $name)) {

                 return core()->{$name};

             }

 

src/resta/Support/Macro.php

Spacing +18 added lines, -18 removed lines

@@ -32,15 +32,15 @@ 
      * @param callable $callback

      * @return mixed|null

      */

-    public function call($macro,callable $callback)

+    public function call($macro, callable $callback)

     {

-        if(!is_null($macro)){

+        if (!is_null($macro)) {

 

             //get macro class from kernel macros

             $macroCall = config('kernel.macros.'.$macro);

 

             //if macroCall class is available and an object.

-            if(!is_null($macroCall) && Utils::isNamespaceExists($macroCall)){

+            if (!is_null($macroCall) && Utils::isNamespaceExists($macroCall)) {

                 return $macroCall;

             }

         }

@@ -54,7 +54,7 @@ 
      * @param bool $static

      * @return bool

      */

-    protected function checkMacroConditions($static=false)

+    protected function checkMacroConditions($static = false)

     {

         return is_string($this->macro) &&

             Utils::isNamespaceExists($this->macro) &&

@@ -67,9 +67,9 @@ 
      * @param bool $static

      * @return bool

      */

-    protected function checkMacroInstanceOf($static=false)

+    protected function checkMacroInstanceOf($static = false)

     {

-        if($static){

+        if ($static) {

             return true;

         }

         return $this->app->resolve($this->macro) instanceof MacroAbleContracts;

@@ -82,11 +82,11 @@ 
      * @param callable $callback

      * @return mixed

      */

-    public function get($method,callable $callback)

+    public function get($method, callable $callback)

     {

-        if($this->isMacro){

+        if ($this->isMacro) {

 

-            if(method_exists($resolve = $this->app->resolve($this->macro),$method)){

+            if (method_exists($resolve = $this->app->resolve($this->macro), $method)) {

                 return $resolve->macro($this->class);

             }

         }

@@ -110,11 +110,11 @@ 
      * @param $class

      * @return $this

      */

-    public function isMacro($class,$static=false)

+    public function isMacro($class, $static = false)

     {

         // if the macro class is a valid object,

         // then this macro will return a boolean value if it has the specified methode.

-        if($this->checkMacroConditions($static)){

+        if ($this->checkMacroConditions($static)) {

 

             $this->isMacro  = true;

             $this->class    = $class;

@@ -142,10 +142,10 @@ 
      * @param $method

      * @return mixed

      */

-    public function with($macro,$concrete,$method=null)

+    public function with($macro, $concrete, $method = null)

     {

-        if($this->macro === null){

-            return $this($macro)->isMacro($concrete)->get($method,function() use($concrete){

+        if ($this->macro===null) {

+            return $this($macro)->isMacro($concrete)->get($method, function() use($concrete){

                 return $concrete;

             });

         }

@@ -159,9 +159,9 @@ 
      * @param $method

      * @return mixed

      */

-    public function withStatic($macro,$concrete)

+    public function withStatic($macro, $concrete)

     {

-        return $this($macro)->isMacro($concrete,true)->get(null,is_callable($concrete) ?

+        return $this($macro)->isMacro($concrete, true)->get(null, is_callable($concrete) ?

             $concrete : function() use($concrete){

                 return $concrete;

             });

@@ -173,9 +173,9 @@ 
      * @param null|string $macro

      * @return $this

      */

-    public function __invoke($macro=null)

+    public function __invoke($macro = null)

     {

-        if($macro!==null){

+        if ($macro!==null) {

             $this->macro = $macro;

         }

         return $this;

src/resta/Foundation/PathManager/StaticPathRepository.php

Spacing +35 added lines, -35 removed lines

@@ -12,9 +12,9 @@ 
      * @param null $app

      * @return string

      */

-    public function app($app=null)

+    public function app($app = null)

     {

-        $app=($app===null) ? $this->appDetector() : $app;

+        $app = ($app===null) ? $this->appDetector() : $app;

         return StaticPathModel::appPath().''.DIRECTORY_SEPARATOR.''.Str::slashToBackSlash($app);

     }

 

@@ -38,7 +38,7 @@ 
      * @param null $app

      * @return string

      */

-    public function appCall($app=null)

+    public function appCall($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$controller;

     }

@@ -56,9 +56,9 @@ 
      * @param null $app

      * @return string

      */

-    public function appConfig($app=null)

+    public function appConfig($app = null)

     {

-        if(isset(core()->paths['config'])){

+        if (isset(core()->paths['config'])) {

             return core()->paths['config'];

         }

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$config;

@@ -68,7 +68,7 @@ 
      * @param null $app

      * @return string

      */

-    public function appHelpers($app=null)

+    public function appHelpers($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$helpers;

     }

@@ -101,7 +101,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appFactory($app=null)

+    public function appFactory($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$factory;

     }

@@ -111,7 +111,7 @@ 
      */

     public function appKernel()

     {

-        $kernel     = $this->app().''.DIRECTORY_SEPARATOR.''.StaticPathList::$kernel;

+        $kernel = $this->app().''.DIRECTORY_SEPARATOR.''.StaticPathList::$kernel;

 

         return $kernel;

     }

@@ -121,7 +121,7 @@ 
      */

     public function appProvider()

     {

-        $kernel     = $this->app().''.DIRECTORY_SEPARATOR.''.StaticPathList::$kernel.''.DIRECTORY_SEPARATOR.''.StaticPathList::$provider;

+        $kernel = $this->app().''.DIRECTORY_SEPARATOR.''.StaticPathList::$kernel.''.DIRECTORY_SEPARATOR.''.StaticPathList::$provider;

 

         return $kernel;

     }

@@ -146,7 +146,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appLogger($app=null)

+    public function appLogger($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.'ServiceLogManager';

     }

@@ -155,7 +155,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appMiddleware($app=null)

+    public function appMiddleware($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$middleware;

     }

@@ -164,7 +164,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appMigration($app=null)

+    public function appMigration($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$migration;

     }

@@ -173,7 +173,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appModel($app=null)

+    public function appModel($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$model;

     }

@@ -182,7 +182,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appException($app=null)

+    public function appException($app = null)

     {

         return $this->appVersion().''.DIRECTORY_SEPARATOR.''.StaticPathList::$exception;

     }

@@ -191,7 +191,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appOptionalEvents($app=null)

+    public function appOptionalEvents($app = null)

     {

         return $this->appVersion().''.DIRECTORY_SEPARATOR.''.StaticPathList::$events;

     }

@@ -200,7 +200,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appOptionalJob($app=null)

+    public function appOptionalJob($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$optional.''.DIRECTORY_SEPARATOR.''.StaticPathList::$job;

     }

@@ -209,7 +209,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appOptionalListeners($app=null)

+    public function appOptionalListeners($app = null)

     {

         return $this->appVersion().''.DIRECTORY_SEPARATOR.''.StaticPathList::$listeners;

     }

@@ -218,7 +218,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appOptionalSubscribers($app=null)

+    public function appOptionalSubscribers($app = null)

     {

         return $this->appVersion().''.DIRECTORY_SEPARATOR.''.StaticPathList::$listeners.''.DIRECTORY_SEPARATOR.''.StaticPathList::$subscribers;

     }

@@ -236,7 +236,7 @@ 
      */

     public function appRepository()

     {

-        $repository     = $this->app().''.DIRECTORY_SEPARATOR.''.StaticPathList::$repository;

+        $repository = $this->app().''.DIRECTORY_SEPARATOR.''.StaticPathList::$repository;

 

         return $repository;

     }

@@ -253,7 +253,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appOptionalSource($app=null)

+    public function appOptionalSource($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$optional.''.DIRECTORY_SEPARATOR.''.StaticPathList::$sourcePath;

     }

@@ -262,7 +262,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appOptionalWebservice($app=null)

+    public function appOptionalWebservice($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$optional.''.DIRECTORY_SEPARATOR.''.StaticPathList::$webservice;

     }

@@ -279,7 +279,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appServiceAnnotations($app=null)

+    public function appServiceAnnotations($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$serviceAnnotations;

     }

@@ -288,7 +288,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appServiceContainer($app=null)

+    public function appServiceContainer($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.'ServiceContainerController';

     }

@@ -297,7 +297,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appServiceEventDispatcher($app=null)

+    public function appServiceEventDispatcher($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.'ServiceEventDispatcherManager';

     }

@@ -306,7 +306,7 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appServiceMiddleware($app=null)

+    public function appServiceMiddleware($app = null)

     {

         return $this->appVersion($app).''.DIRECTORY_SEPARATOR.''.StaticPathList::$serviceMiddleware;

     }

@@ -333,9 +333,9 @@ 
      * @param null $app

      * @return mixed

      */

-    public function appVersion($app=null)

+    public function appVersion($app = null)

     {

-        if(defined('app')){

+        if (defined('app')) {

 

             $prefixGroup = Str::slashToBackSlash(StaticPathList::$projectPrefixGroup);

 

@@ -379,19 +379,19 @@ 
      * @param bool $bool

      * @return mixed

      */

-    public function controller($controller=null,$bool=false)

+    public function controller($controller = null, $bool = false)

     {

         $namespaceController = ($controller===null) ? app()->namespace()->controller()

-            : app()->namespace()->controller($controller,true);

+            : app()->namespace()->controller($controller, true);

 

-        if($bool){

-            $namespaceControllerExplode = explode("\\",$namespaceController);

+        if ($bool) {

+            $namespaceControllerExplode = explode("\\", $namespaceController);

             array_pop($namespaceControllerExplode);

 

-            $namespaceController = implode("\\",$namespaceControllerExplode);

+            $namespaceController = implode("\\", $namespaceControllerExplode);

         }

 

-        return Utils::getPathFromNamespace($namespaceController,false);

+        return Utils::getPathFromNamespace($namespaceController, false);

     }

 

     /**

@@ -415,9 +415,9 @@ 
      * @param $arg

      * @return mixed

      */

-    public function __call($name,$arg)

+    public function __call($name, $arg)

     {

-        $appCall='app'.ucfirst($name);

+        $appCall = 'app'.ucfirst($name);

         return $this->{$appCall}();

     }

 

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

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

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();

     }

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(!isset($this->argument['worker'])){

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

+        if (!isset($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);

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';
         }
     }