NNTmux / newznab-tmux

Blacklight/libraries/Forking.php

Spacing +38 added lines, -38 removed lines

@@ -273,14 +273,14 @@ 
         $this->processWork();
         $maxWork = \count($this->work);
         foreach ($this->work as $group) {
-            $pool->add(function () use ($group) {
+            $pool->add(function() use ($group) {
                 return $this->_executeCommand(PHP_BINARY.' misc/update/backfill.php '.$group->name.(isset($group->max) ? (' '.$group->max) : ''));
-            }, 2000000)->then(function ($output) use ($group, $maxWork) {
+            }, 2000000)->then(function($output) use ($group, $maxWork) {
                 echo $output;
                 $this->colorCli->primary('Task #'.$maxWork.' Backfilled group '.$group->name);
-            })->catch(function (\Throwable $exception) {
+            })->catch(function(\Throwable $exception) {
                 echo $exception->getMessage();
-            })->catch(static function (SerializableException $serializableException) {
+            })->catch(static function(SerializableException $serializableException) {
                 //we do nothing here just catch the error and move on
             });
             $maxWork--;
@@ -346,7 +346,7 @@ 
         );
 
         $count = 0;
-        if (! empty($data) && isset($data[0]->name)) {
+        if (!empty($data) && isset($data[0]->name)) {
             $this->safeBackfillGroup = $data[0]->name;
 
             $count = ($data[0]->our_first - $data[0]->their_first);
@@ -368,14 +368,14 @@ 
 
             $this->processWork();
             foreach ($queues as $queue) {
-                $pool->add(function () use ($queue) {
+                $pool->add(function() use ($queue) {
                     return $this->_executeCommand($this->dnr_path.$queue.'"');
-                }, 2000000)->then(function ($output) {
+                }, 2000000)->then(function($output) {
                     echo $output;
                     $this->colorCli->primary('Backfilled group '.$this->safeBackfillGroup);
-                })->catch(function (\Throwable $exception) {
+                })->catch(function(\Throwable $exception) {
                     echo $exception->getMessage();
-                })->catch(static function (SerializableException $serializableException) {
+                })->catch(static function(SerializableException $serializableException) {
                     //we do nothing here just catch the error and move on
                 });
             }
@@ -408,14 +408,14 @@ 
 
         $this->processWork();
         foreach ($this->work as $group) {
-            $pool->add(function () use ($group) {
+            $pool->add(function() use ($group) {
                 return $this->_executeCommand(PHP_BINARY.' misc/update/update_binaries.php '.$group->name.' '.$group->max);
-            }, 2000000)->then(function ($output) use ($group, $maxWork) {
+            }, 2000000)->then(function($output) use ($group, $maxWork) {
                 echo $output;
                 $this->colorCli->primary('Task #'.$maxWork.' Updated group '.$group->name);
-            })->catch(function (\Throwable $exception) {
+            })->catch(function(\Throwable $exception) {
                 echo $exception->getMessage();
-            })->catch(static function (SerializableException $serializableException) {
+            })->catch(static function(SerializableException $serializableException) {
                 //we do nothing here just catch the error and move on
             });
             $maxWork--;
@@ -442,7 +442,7 @@ 
 			ORDER BY a.last_record DESC'
         );
 
-        if (! empty($this->work)) {
+        if (!empty($this->work)) {
             $i = 1;
             $queues = [];
             foreach ($this->work as $group) {
@@ -475,16 +475,16 @@ 
             $this->processWork();
             foreach ($queues as $queue) {
                 preg_match('/alt\..+/i', $queue, $hit);
-                $pool->add(function () use ($queue) {
+                $pool->add(function() use ($queue) {
                     return $this->_executeCommand($this->dnr_path.$queue.'"');
-                }, 2000000)->then(function ($output) use ($hit) {
-                    if (! empty($hit)) {
+                }, 2000000)->then(function($output) use ($hit) {
+                    if (!empty($hit)) {
                         echo $output;
                         $this->colorCli->primary('Updated group '.$hit[0]);
                     }
-                })->catch(function (\Throwable $exception) {
+                })->catch(function(\Throwable $exception) {
                     echo $exception->getMessage();
-                })->catch(static function (SerializableException $serializableException) {
+                })->catch(static function(SerializableException $serializableException) {
                     //we do nothing here just catch the error and move on
                 });
             }
@@ -547,14 +547,14 @@ 
 
         $this->processWork();
         foreach ($this->work as $queue) {
-            $pool->add(function () use ($queue) {
+            $pool->add(function() use ($queue) {
                 return $this->_executeCommand(PHP_BINARY.' misc/update/tmux/bin/groupfixrelnames.php "'.$queue.'"'.' true');
-            }, 2000000)->then(function ($output) use ($maxWork) {
+            }, 2000000)->then(function($output) use ($maxWork) {
                 echo $output;
                 $this->colorCli->primary('Task #'.$maxWork.' Finished fixing releases names');
-            })->catch(function (\Throwable $exception) {
+            })->catch(function(\Throwable $exception) {
                 echo $exception->getMessage();
-            })->catch(static function (SerializableException $serializableException) {
+            })->catch(static function(SerializableException $serializableException) {
                 //we do nothing here just catch the error and move on
             });
             $maxWork--;
@@ -575,7 +575,7 @@ 
         foreach ($work as $group) {
             try {
                 $query = DB::select(sprintf('SELECT id FROM collections WHERE groups_id = %d LIMIT 1', $group->id));
-                if (! empty($query)) {
+                if (!empty($query)) {
                     $uGroups[] = ['id' => $group->id, 'name' => $group->name];
                 }
             } catch (\PDOException $e) {
@@ -593,14 +593,14 @@ 
 
         $this->processWork();
         foreach ($uGroups as $group) {
-            $pool->add(function () use ($group) {
+            $pool->add(function() use ($group) {
                 return $this->_executeCommand($this->dnr_path.'releases  '.$group['id'].'"');
-            }, 2000000)->then(function ($output) use ($maxWork) {
+            }, 2000000)->then(function($output) use ($maxWork) {
                 echo $output;
                 $this->colorCli->primary('Task #'.$maxWork.' Finished performing release processing');
-            })->catch(function (\Throwable $exception) {
+            })->catch(function(\Throwable $exception) {
                 echo $exception->getMessage();
-            })->catch(static function (SerializableException $serializableException) {
+            })->catch(static function(SerializableException $serializableException) {
                 //we do nothing here just catch the error and move on
             });
             $maxWork--;
@@ -637,16 +637,16 @@ 
         $this->processWork();
         foreach ($releases as $release) {
             if ($type !== '') {
-                $pool->add(function () use ($release, $type) {
+                $pool->add(function() use ($release, $type) {
                     return $this->_executeCommand(PHP_BINARY.' misc/update/postprocess.php '.$type.$release->id);
-                }, 2000000)->then(function ($output) use ($desc, $count) {
+                }, 2000000)->then(function($output) use ($desc, $count) {
                     echo $output;
                     $this->colorCli->primary('Finished task #'.$count.' for '.$desc);
-                })->catch(function (\Throwable $exception) {
+                })->catch(function(\Throwable $exception) {
                     echo $exception->getMessage();
-                })->catch(static function (SerializableException $serializableException) {
+                })->catch(static function(SerializableException $serializableException) {
                     //we do nothing here just catch the error and move on
-                })->timeout(function () use ($count) {
+                })->timeout(function() use ($count) {
                     $this->colorCli->notice('Task #'.$count.': Timeout occurred.');
                 });
                 $count--;
@@ -894,15 +894,15 @@ 
         $pool = Pool::create()->concurrency($maxProcess)->timeout(config('nntmux.multiprocessing_max_child_time'));
         $this->processWork();
         foreach ($this->work as $group) {
-            $pool->add(function () use ($group) {
+            $pool->add(function() use ($group) {
                 return $this->_executeCommand($this->dnr_path.'update_per_group  '.$group->id.'"');
-            }, 2000000)->then(function ($output) use ($group) {
+            }, 2000000)->then(function($output) use ($group) {
                 echo $output;
                 $name = UsenetGroup::getNameByID($group->id);
                 $this->colorCli->primary('Finished updating binaries, processing releases and additional postprocessing for group:'.$name);
-            })->catch(function (\Throwable $exception) {
+            })->catch(function(\Throwable $exception) {
                 echo $exception->getMessage();
-            })->catch(static function (SerializableException $serializableException) {
+            })->catch(static function(SerializableException $serializableException) {
                 echo $serializableException->asThrowable()->getMessage();
             });
         }
@@ -918,7 +918,7 @@ 
     {
         $process = Process::fromShellCommandline($command);
         $process->setTimeout(1800);
-        $process->run(function ($type, $buffer) {
+        $process->run(function($type, $buffer) {
             if (Process::ERR === $type) {
                 echo $buffer;
             }