@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | public function isTV(): bool |
101 | 101 | { |
102 | 102 | if (preg_match('/Daily[\-_\.]Show|Nightly News|^\[[a-zA-Z\.\-]+\].*[\-_].*\d{1,3}[\-_. ](([\[\(])(h264-)?\d{3,4}([pi])([\]\)])\s?(\[AAC\])?|\[[a-fA-F0-9]{8}\]|(8|10)BIT|hi10p)(\[[a-fA-F0-9]{8}\])?|(\d\d-){2}[12]\d{3}|[12]\d{3}(\.\d\d){2}|\d+x\d+|\.e\d{1,3}\.|s\d{1,4}[._ -]?[ed]\d{1,3}([ex]\d{1,3}|[\-.\w ])|[._ -](\dx\d\d|C4TV|Complete[._ -]Season|DSR|([DHPS])DTV|EP[._ -]?\d{1,3}|S\d{1,3}.+Extras|SUBPACK|Season[._ -]\d{1,2})([._ -]|$)|TVRIP|TV[._ -](19|20)\d\d|Troll(HD|UHD)/i', $this->releaseName) |
103 | - && ! preg_match('/[._ -](flac|imageset|mp3|xxx)[._ -]|[ .]exe$/i', $this->releaseName)) { |
|
103 | + && !preg_match('/[._ -](flac|imageset|mp3|xxx)[._ -]|[ .]exe$/i', $this->releaseName)) { |
|
104 | 104 | switch (true) { |
105 | 105 | case $this->isOtherTV(): |
106 | 106 | case $this->categorizeForeign && $this->isForeignTV(): |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | { |
138 | 138 | if (preg_match('/[._ -]S\d{1,3}.+(EP\d{1,3}|Extras|SUBPACK)[._ -]|News/i', $this->releaseName) |
139 | 139 | //special case for "Have.I.Got.News.For.You" tv show |
140 | - && ! preg_match('/[._ -]Got[._ -]News[._ -]For[._ -]You/i', $this->releaseName) |
|
140 | + && !preg_match('/[._ -]Got[._ -]News[._ -]For[._ -]You/i', $this->releaseName) |
|
141 | 141 | ) { |
142 | 142 | $this->tmpCat = Category::TV_OTHER; |
143 | 143 | |
@@ -224,7 +224,7 @@ discard block |
||
224 | 224 | |
225 | 225 | return true; |
226 | 226 | } |
227 | - if (! $this->catWebDL && preg_match('/web[._ -]dl|web-?rip/i', $this->releaseName)) { |
|
227 | + if (!$this->catWebDL && preg_match('/web[._ -]dl|web-?rip/i', $this->releaseName)) { |
|
228 | 228 | $this->tmpCat = Category::TV_HD; |
229 | 229 | |
230 | 230 | return true; |
@@ -284,7 +284,7 @@ discard block |
||
284 | 284 | |
285 | 285 | public function isMovie(): bool |
286 | 286 | { |
287 | - if (preg_match('/[._ -]AVC|[BH][DR]RIP|(Bluray|Blu-Ray)|BD[._ -]?(25|50)?|\bBR\b|Camrip|[._ -]\d{4}[._ -].+(720p|1080p|Cam|HDTS|2160p)|DIVX|[._ -]DVD[._ -]|DVD-?(5|9|R|Rip)|Untouched|VHSRip|XVID|[._ -](DTS|TVrip|webrip|WEBDL|WEB-DL)[._ -]|\b(2160)p\b.*\b(Netflix|Amazon|NF|AMZN|Disney)\b/i', $this->releaseName) && ! preg_match('/s\d{1,3}[._ -]?[ed]\d{1,3}|auto(cad|desk)|divx[._ -]plus|[._ -]exe$|[._ -](jav|XXX)[._ -]|SWE6RUS|\wXXX(1080p|720p|DVD)|Xilisoft|\.S[0-9]\d{1,3}\./i', $this->releaseName)) { |
|
287 | + if (preg_match('/[._ -]AVC|[BH][DR]RIP|(Bluray|Blu-Ray)|BD[._ -]?(25|50)?|\bBR\b|Camrip|[._ -]\d{4}[._ -].+(720p|1080p|Cam|HDTS|2160p)|DIVX|[._ -]DVD[._ -]|DVD-?(5|9|R|Rip)|Untouched|VHSRip|XVID|[._ -](DTS|TVrip|webrip|WEBDL|WEB-DL)[._ -]|\b(2160)p\b.*\b(Netflix|Amazon|NF|AMZN|Disney)\b/i', $this->releaseName) && !preg_match('/s\d{1,3}[._ -]?[ed]\d{1,3}|auto(cad|desk)|divx[._ -]plus|[._ -]exe$|[._ -](jav|XXX)[._ -]|SWE6RUS|\wXXX(1080p|720p|DVD)|Xilisoft|\.S[0-9]\d{1,3}\./i', $this->releaseName)) { |
|
288 | 288 | return match (true) { |
289 | 289 | $this->categorizeForeign && $this->isMovieForeign(), $this->isMovieDVD(), $this->isMovieX265(), $this->isMovieUHD(), $this->catWebDL && $this->isMovieWEBDL(), $this->isMovieSD(), $this->isMovie3D(), $this->isMovieBluRay(), $this->isMovieHD(), $this->isMovieOther() => true, |
290 | 290 | default => false, |
@@ -346,7 +346,7 @@ discard block |
||
346 | 346 | public function isMovieBluRay(): bool |
347 | 347 | { |
348 | 348 | if (preg_match('/bluray-|[._ -]bd?[._ -]?(25|50)|blu-ray|Bluray\s-\sUntouched|[._ -]untouched[._ -]/i', $this->releaseName) |
349 | - && ! preg_match('/SecretUsenet\.com$/i', $this->releaseName)) { |
|
349 | + && !preg_match('/SecretUsenet\.com$/i', $this->releaseName)) { |
|
350 | 350 | $this->tmpCat = Category::MOVIE_BLURAY; |
351 | 351 | |
352 | 352 | return true; |
@@ -373,7 +373,7 @@ discard block |
||
373 | 373 | |
374 | 374 | public function isMovieUHD(): bool |
375 | 375 | { |
376 | - if (! preg_match('/(S\d+).*(2160p).*(Netflix|Amazon).*(TrollUHD|NTb|VLAD)/i', $this->releaseName) && stripos($this->releaseName, '2160p') !== false) { |
|
376 | + if (!preg_match('/(S\d+).*(2160p).*(Netflix|Amazon).*(TrollUHD|NTb|VLAD)/i', $this->releaseName) && stripos($this->releaseName, '2160p') !== false) { |
|
377 | 377 | $this->tmpCat = Category::MOVIE_UHD; |
378 | 378 | |
379 | 379 | return true; |
@@ -502,7 +502,7 @@ discard block |
||
502 | 502 | public function isXxx(): bool |
503 | 503 | { |
504 | 504 | switch (true) { |
505 | - case ! preg_match('/\bXXX\b|(a\.b\.erotica|ClubSeventeen|Cum(ming|shot)|Err?oticax?|Porn(o|lation)?|Imageset|PICTURESET|JAV Uncensored|lesb(ians?|os?)|mastur(bation|e?bate)|My_Stepfather_Made_Me|nympho?|OLDER ANGELS|pictures\.erotica\.anime|sexontv|slut|Squirt|SWE6RUS|Transsexual|whore)/i', $this->releaseName): |
|
505 | + case !preg_match('/\bXXX\b|(a\.b\.erotica|ClubSeventeen|Cum(ming|shot)|Err?oticax?|Porn(o|lation)?|Imageset|PICTURESET|JAV Uncensored|lesb(ians?|os?)|mastur(bation|e?bate)|My_Stepfather_Made_Me|nympho?|OLDER ANGELS|pictures\.erotica\.anime|sexontv|slut|Squirt|SWE6RUS|Transsexual|whore)/i', $this->releaseName): |
|
506 | 506 | return false; |
507 | 507 | case $this->isXxxPack(): |
508 | 508 | case $this->isXxxClipSD(): |
@@ -527,7 +527,7 @@ discard block |
||
527 | 527 | |
528 | 528 | public function isXxx264(): bool |
529 | 529 | { |
530 | - if (preg_match('/720p|1080(hd|[ip])|[xh][^a-z0-9]?264/i', $this->releaseName) && ! preg_match('/\bwmv\b/i', $this->releaseName) && stripos($this->releaseName, 'SDX264XXX') === false) { |
|
530 | + if (preg_match('/720p|1080(hd|[ip])|[xh][^a-z0-9]?264/i', $this->releaseName) && !preg_match('/\bwmv\b/i', $this->releaseName) && stripos($this->releaseName, 'SDX264XXX') === false) { |
|
531 | 531 | $this->tmpCat = Category::XXX_X264; |
532 | 532 | |
533 | 533 | return true; |
@@ -699,7 +699,7 @@ discard block |
||
699 | 699 | |
700 | 700 | public function isGame3DS(): bool |
701 | 701 | { |
702 | - if (preg_match('/\b3DS\b[^max]|[\._-]3ds|nintendo.+3ds|[_\.]3DS-/i', $this->releaseName) && ! preg_match('/3ds max/i', $this->releaseName) && preg_match('/(EUR|FR|GAME|HOL|JP|JPN|NL|NTSC|PAL|KS|USA|ASIA)/i', $this->releaseName)) { |
|
702 | + if (preg_match('/\b3DS\b[^max]|[\._-]3ds|nintendo.+3ds|[_\.]3DS-/i', $this->releaseName) && !preg_match('/3ds max/i', $this->releaseName) && preg_match('/(EUR|FR|GAME|HOL|JP|JPN|NL|NTSC|PAL|KS|USA|ASIA)/i', $this->releaseName)) { |
|
703 | 703 | $this->tmpCat = Category::GAME_3DS; |
704 | 704 | |
705 | 705 | return true; |
@@ -902,7 +902,7 @@ discard block |
||
902 | 902 | public function isMusic(): bool |
903 | 903 | { |
904 | 904 | return match (true) { |
905 | - $this->isMusicVideo(), $this->isAudiobook(), $this->isMusicLossless(), $this->isMusicMP3(), $this->isMusicPodcast(),$this->isMusicOther() => true, |
|
905 | + $this->isMusicVideo(), $this->isAudiobook(), $this->isMusicLossless(), $this->isMusicMP3(), $this->isMusicPodcast(), $this->isMusicOther() => true, |
|
906 | 906 | default => false, |
907 | 907 | }; |
908 | 908 | } |
@@ -999,7 +999,7 @@ discard block |
||
999 | 999 | public function isMusicOther(): bool |
1000 | 1000 | { |
1001 | 1001 | if (preg_match('/(19|20)\d\d\-(C4)$|[._ -]\d?CD[._ -](19|20)\d\d|\(\d\-?CD\)|\-\dcd\-|\d[._ -]Albums|Albums.+(EP)|Bonus.+Tracks|Box.+?CD.+SET|Discography|D\.O\.M|Greatest\sSongs|Live.+(Bootleg|Remastered)|Music.+Vol|([\(\[\s])NMR([\)\]\s])|Promo.+CD|Reggaeton|Tiesto.+Club|Vinyl\s2496|\WV\.A\.|^\(VA\s|^VA[._ -]/i', $this->releaseName)) { |
1002 | - if (! $this->isMusicForeign()) { |
|
1002 | + if (!$this->isMusicForeign()) { |
|
1003 | 1003 | $this->tmpCat = Category::MUSIC_OTHER; |
1004 | 1004 | } |
1005 | 1005 | |
@@ -1050,7 +1050,7 @@ discard block |
||
1050 | 1050 | public function isComic(): bool |
1051 | 1051 | { |
1052 | 1052 | switch (true) { |
1053 | - case ! preg_match('/[\. ](cbr|cbz)|[\( ]c2c|cbr|cbz[\) ]|comix|^\(comic|[\.\-_\(\[ ]comics?[._ -]|comic.+book|covers.+digital|DC.+(Adventures|Universe)|digital.+(son|zone)|Graphic.+Novel|[\.\-_h ]manga|Total[._ -]Marvel/i', $this->releaseName): |
|
1053 | + case !preg_match('/[\. ](cbr|cbz)|[\( ]c2c|cbr|cbz[\) ]|comix|^\(comic|[\.\-_\(\[ ]comics?[._ -]|comic.+book|covers.+digital|DC.+(Adventures|Universe)|digital.+(son|zone)|Graphic.+Novel|[\.\-_h ]manga|Total[._ -]Marvel/i', $this->releaseName): |
|
1054 | 1054 | return false; |
1055 | 1055 | case $this->isBookForeign(): |
1056 | 1056 | break; |
@@ -1065,7 +1065,7 @@ discard block |
||
1065 | 1065 | public function isTechnicalBook(): bool |
1066 | 1066 | { |
1067 | 1067 | switch (true) { |
1068 | - case ! preg_match('/^\(?(atz|bb|css|c ?t|Drawing|Gabler|IOS|Iphone|Lynda|Manning|Medic(al|ine)|MIT|No[._ -]Starch|Packt|Peachpit|Pragmatic|Revista|Servo|SmartBooks|Spektrum|Strata|Sybex|Syngress|Vieweg|Wiley|Woods|Wrox)[._ -]|[._ -](Ajax|CSS|DIY|Javascript|(My|Postgre)?SQL|XNA)[._ -]|3DS\.\-_ ]Max|Academic|Adobe|Algebra|Analysis|Appleworks|Archaeology|Bitdefender|Birkhauser|Britannica|[._ -]C\+\+|C[._ -](\+\+|Sharp|Plus)|Chemistry|Circuits|Cook(book|ing)|(Beginners?|Complete|Communications|Definitive|Essential|Hackers?|Practical|Professionals?)[._ -]Guide|Developer|Diagnostic|Disassembl(er|ing|y)|Debugg(er|ing)|Dreamweaver|Economics|Education|Electronics|Enc([iy])clopedia|Engineer(ing|s)|Essays|Exercizes|For.+Beginners|Focal[._ -]Press|For[._ -]Dummies|FreeBSD|Fundamentals[._ -]of[._ -]|(Galileo|Island)[._ -]Press|Geography|Grammar|Guide[._ -](For|To)|Hacking|Google|Handboo?k|How[._ -](It|To)|Intoduction[._ -]to|Iphone|jQuery|Lessons[._ -]In|Learning|LibreOffice|Linux|Manual|Marketing|Masonry|Mathematic(al|s)?|Medical|Microsoft|National[._ -]Academies|Nero[._ -]\d+|OReilly|OS[._ -]X[._ -]|Official[._ -]Guide|Open(GL|Office)|Pediatric|Periodic.+Table|Photoshop|Physics|Power(PC|Point|Shell)|Programm(ers?|ier||ing)|Raspberry.+Pi|Remedies|Service\s?Manual|SitePoint|Sketching|Statistics|Stock.+Market|Students|Theory|Training|Tutsplus|Ubuntu|Understanding[._ -](and|Of|The)|Visual[._ -]Studio|Textbook|VMWare|wii?max|Windows[._ -](8|7|Vista|XP)|^Wood[._ -]|Woodwork|WordPress|Work(book|shop)|Youtube/i', $this->releaseName): |
|
1068 | + case !preg_match('/^\(?(atz|bb|css|c ?t|Drawing|Gabler|IOS|Iphone|Lynda|Manning|Medic(al|ine)|MIT|No[._ -]Starch|Packt|Peachpit|Pragmatic|Revista|Servo|SmartBooks|Spektrum|Strata|Sybex|Syngress|Vieweg|Wiley|Woods|Wrox)[._ -]|[._ -](Ajax|CSS|DIY|Javascript|(My|Postgre)?SQL|XNA)[._ -]|3DS\.\-_ ]Max|Academic|Adobe|Algebra|Analysis|Appleworks|Archaeology|Bitdefender|Birkhauser|Britannica|[._ -]C\+\+|C[._ -](\+\+|Sharp|Plus)|Chemistry|Circuits|Cook(book|ing)|(Beginners?|Complete|Communications|Definitive|Essential|Hackers?|Practical|Professionals?)[._ -]Guide|Developer|Diagnostic|Disassembl(er|ing|y)|Debugg(er|ing)|Dreamweaver|Economics|Education|Electronics|Enc([iy])clopedia|Engineer(ing|s)|Essays|Exercizes|For.+Beginners|Focal[._ -]Press|For[._ -]Dummies|FreeBSD|Fundamentals[._ -]of[._ -]|(Galileo|Island)[._ -]Press|Geography|Grammar|Guide[._ -](For|To)|Hacking|Google|Handboo?k|How[._ -](It|To)|Intoduction[._ -]to|Iphone|jQuery|Lessons[._ -]In|Learning|LibreOffice|Linux|Manual|Marketing|Masonry|Mathematic(al|s)?|Medical|Microsoft|National[._ -]Academies|Nero[._ -]\d+|OReilly|OS[._ -]X[._ -]|Official[._ -]Guide|Open(GL|Office)|Pediatric|Periodic.+Table|Photoshop|Physics|Power(PC|Point|Shell)|Programm(ers?|ier||ing)|Raspberry.+Pi|Remedies|Service\s?Manual|SitePoint|Sketching|Statistics|Stock.+Market|Students|Theory|Training|Tutsplus|Ubuntu|Understanding[._ -](and|Of|The)|Visual[._ -]Studio|Textbook|VMWare|wii?max|Windows[._ -](8|7|Vista|XP)|^Wood[._ -]|Woodwork|WordPress|Work(book|shop)|Youtube/i', $this->releaseName): |
|
1069 | 1069 | return false; |
1070 | 1070 | case $this->isBookForeign(): |
1071 | 1071 | break; |
@@ -1080,7 +1080,7 @@ discard block |
||
1080 | 1080 | public function isMagazine(): bool |
1081 | 1081 | { |
1082 | 1082 | switch (true) { |
1083 | - case ! preg_match('/[a-z\-\._ ][._ -](January|February|March|April|May|June|July|August|September|October|November|December)[._ -](\d{1,2},)?20\d\d[._ -]|^\(.+[ .]\d{1,2}[ .]20\d\d[ .].+\.scr|[._ -](Catalogue|FHM|NUTS|Pictorial|Tatler|XXX)[._ -]|^\(?(Allehanda|Club|Computer([a-z0-9]+)?|Connect \d+|Corriere|ct|Diario|Digit(al)?|Esquire|FHM|Gadgets|Galileo|Glam|GQ|Infosat|Inked|Instyle|io|Kicker|Liberation|New Scientist|NGV|Nuts|Popular|Professional|Reise|Sette(tv)?|Springer|Stuff|Studentlitteratur|Vegetarian|Vegetable|Videomarkt|Wired)[._ -]|Brady(.+)?Games|Catalog|Columbus.+Dispatch|Correspondenten|Corriere[._ -]Della[._ -]Sera|Cosmopolitan|Dagbladet|Digital[._ -]Guide|Economist|Eload ?24|ExtraTime|Fatto[._ -]Quotidiano|Flight[._ -](International|Journal)|Finanzwoche|France.+Football|Foto.+Video|Games?(Master|Markt|tar|TM)|Gardening|Gazzetta|Globe[._ -]And[._ -]Mail|Guitar|Heimkino|Hustler|La.+(Lettura|Rblica|Stampa)|Le[._ -](Monde|Temps)|Les[._ -]Echos|e?Magazin(es?)?|Mac(life|welt)|Marie.+Claire|Maxim|Men.+(Health|Fitness)|Motocross|Motorcycle|Mountain[._ -]Bike|MusikWoche|National[._ -]Geographic|New[._ -]Yorker|PC([._ -](Gamer|Welt|World)|Games|Go|Tip)|Penthouse|Photograph(er|ic)|Playboy|Posten|Quotidiano|(Golf|Readers?).+Digest|SFX[._ -]UK|Recipe(.+Guide|s)|SkyNews|Sport[._ -]?Week|Strategy.+Guide|TabletPC|Tattoo[._ -]Life|The[._ -]Guardian|Tageszeitung|Tid(bits|ning)|Top[._ -]Gear[._ -]|Total[._ -]Guitar|Travel[._ -]Guides?|Tribune[._ -]De[._ -]|US[._ -]Weekly|USA[._ -]Today|TruePDF|Vogue|Verlag|Warcraft|Web.+Designer|What[._ -]Car|Zeitung/i', $this->releaseName): |
|
1083 | + case !preg_match('/[a-z\-\._ ][._ -](January|February|March|April|May|June|July|August|September|October|November|December)[._ -](\d{1,2},)?20\d\d[._ -]|^\(.+[ .]\d{1,2}[ .]20\d\d[ .].+\.scr|[._ -](Catalogue|FHM|NUTS|Pictorial|Tatler|XXX)[._ -]|^\(?(Allehanda|Club|Computer([a-z0-9]+)?|Connect \d+|Corriere|ct|Diario|Digit(al)?|Esquire|FHM|Gadgets|Galileo|Glam|GQ|Infosat|Inked|Instyle|io|Kicker|Liberation|New Scientist|NGV|Nuts|Popular|Professional|Reise|Sette(tv)?|Springer|Stuff|Studentlitteratur|Vegetarian|Vegetable|Videomarkt|Wired)[._ -]|Brady(.+)?Games|Catalog|Columbus.+Dispatch|Correspondenten|Corriere[._ -]Della[._ -]Sera|Cosmopolitan|Dagbladet|Digital[._ -]Guide|Economist|Eload ?24|ExtraTime|Fatto[._ -]Quotidiano|Flight[._ -](International|Journal)|Finanzwoche|France.+Football|Foto.+Video|Games?(Master|Markt|tar|TM)|Gardening|Gazzetta|Globe[._ -]And[._ -]Mail|Guitar|Heimkino|Hustler|La.+(Lettura|Rblica|Stampa)|Le[._ -](Monde|Temps)|Les[._ -]Echos|e?Magazin(es?)?|Mac(life|welt)|Marie.+Claire|Maxim|Men.+(Health|Fitness)|Motocross|Motorcycle|Mountain[._ -]Bike|MusikWoche|National[._ -]Geographic|New[._ -]Yorker|PC([._ -](Gamer|Welt|World)|Games|Go|Tip)|Penthouse|Photograph(er|ic)|Playboy|Posten|Quotidiano|(Golf|Readers?).+Digest|SFX[._ -]UK|Recipe(.+Guide|s)|SkyNews|Sport[._ -]?Week|Strategy.+Guide|TabletPC|Tattoo[._ -]Life|The[._ -]Guardian|Tageszeitung|Tid(bits|ning)|Top[._ -]Gear[._ -]|Total[._ -]Guitar|Travel[._ -]Guides?|Tribune[._ -]De[._ -]|US[._ -]Weekly|USA[._ -]Today|TruePDF|Vogue|Verlag|Warcraft|Web.+Designer|What[._ -]Car|Zeitung/i', $this->releaseName): |
|
1084 | 1084 | return false; |
1085 | 1085 | case $this->isBookForeign(): |
1086 | 1086 | break; |
@@ -1106,7 +1106,7 @@ discard block |
||
1106 | 1106 | public function isEBook(): bool |
1107 | 1107 | { |
1108 | 1108 | switch (true) { |
1109 | - case ! preg_match('/^ePub|[._ -](Ebook|E?\-book|\) WW|Publishing)|[\.\-_\(\[ ](azw|epub|html|mobi|pdf|rtf|tif|txt)[\.\-_\)\] ]|[\. ](azw|doc|epub|mobi|pdf)(?![\w .])|\.ebook-\w$/i', $this->releaseName): |
|
1109 | + case !preg_match('/^ePub|[._ -](Ebook|E?\-book|\) WW|Publishing)|[\.\-_\(\[ ](azw|epub|html|mobi|pdf|rtf|tif|txt)[\.\-_\)\] ]|[\. ](azw|doc|epub|mobi|pdf)(?![\w .])|\.ebook-\w$/i', $this->releaseName): |
|
1110 | 1110 | return false; |
1111 | 1111 | case $this->isBookForeign(): |
1112 | 1112 | break; |
@@ -273,14 +273,14 @@ discard block |
||
273 | 273 | $this->processWork(); |
274 | 274 | $maxWork = \count($this->work); |
275 | 275 | foreach ($this->work as $group) { |
276 | - $pool->add(function () use ($group) { |
|
276 | + $pool->add(function() use ($group) { |
|
277 | 277 | return $this->_executeCommand(PHP_BINARY.' misc/update/backfill.php '.$group->name.(isset($group->max) ? (' '.$group->max) : '')); |
278 | - }, 2000000)->then(function ($output) use ($group, $maxWork) { |
|
278 | + }, 2000000)->then(function($output) use ($group, $maxWork) { |
|
279 | 279 | echo $output; |
280 | 280 | $this->colorCli->primary('Task #'.$maxWork.' Backfilled group '.$group->name); |
281 | - })->catch(function (\Throwable $exception) { |
|
281 | + })->catch(function(\Throwable $exception) { |
|
282 | 282 | echo $exception->getMessage(); |
283 | - })->catch(static function (SerializableException $serializableException) { |
|
283 | + })->catch(static function(SerializableException $serializableException) { |
|
284 | 284 | //we do nothing here just catch the error and move on |
285 | 285 | }); |
286 | 286 | $maxWork--; |
@@ -346,7 +346,7 @@ discard block |
||
346 | 346 | ); |
347 | 347 | |
348 | 348 | $count = 0; |
349 | - if (! empty($data) && isset($data[0]->name)) { |
|
349 | + if (!empty($data) && isset($data[0]->name)) { |
|
350 | 350 | $this->safeBackfillGroup = $data[0]->name; |
351 | 351 | |
352 | 352 | $count = ($data[0]->our_first - $data[0]->their_first); |
@@ -368,14 +368,14 @@ discard block |
||
368 | 368 | |
369 | 369 | $this->processWork(); |
370 | 370 | foreach ($queues as $queue) { |
371 | - $pool->add(function () use ($queue) { |
|
371 | + $pool->add(function() use ($queue) { |
|
372 | 372 | return $this->_executeCommand($this->dnr_path.$queue.'"'); |
373 | - }, 2000000)->then(function ($output) { |
|
373 | + }, 2000000)->then(function($output) { |
|
374 | 374 | echo $output; |
375 | 375 | $this->colorCli->primary('Backfilled group '.$this->safeBackfillGroup); |
376 | - })->catch(function (\Throwable $exception) { |
|
376 | + })->catch(function(\Throwable $exception) { |
|
377 | 377 | echo $exception->getMessage(); |
378 | - })->catch(static function (SerializableException $serializableException) { |
|
378 | + })->catch(static function(SerializableException $serializableException) { |
|
379 | 379 | //we do nothing here just catch the error and move on |
380 | 380 | }); |
381 | 381 | } |
@@ -408,14 +408,14 @@ discard block |
||
408 | 408 | |
409 | 409 | $this->processWork(); |
410 | 410 | foreach ($this->work as $group) { |
411 | - $pool->add(function () use ($group) { |
|
411 | + $pool->add(function() use ($group) { |
|
412 | 412 | return $this->_executeCommand(PHP_BINARY.' misc/update/update_binaries.php '.$group->name.' '.$group->max); |
413 | - }, 2000000)->then(function ($output) use ($group, $maxWork) { |
|
413 | + }, 2000000)->then(function($output) use ($group, $maxWork) { |
|
414 | 414 | echo $output; |
415 | 415 | $this->colorCli->primary('Task #'.$maxWork.' Updated group '.$group->name); |
416 | - })->catch(function (\Throwable $exception) { |
|
416 | + })->catch(function(\Throwable $exception) { |
|
417 | 417 | echo $exception->getMessage(); |
418 | - })->catch(static function (SerializableException $serializableException) { |
|
418 | + })->catch(static function(SerializableException $serializableException) { |
|
419 | 419 | //we do nothing here just catch the error and move on |
420 | 420 | }); |
421 | 421 | $maxWork--; |
@@ -442,7 +442,7 @@ discard block |
||
442 | 442 | ORDER BY a.last_record DESC' |
443 | 443 | ); |
444 | 444 | |
445 | - if (! empty($this->work)) { |
|
445 | + if (!empty($this->work)) { |
|
446 | 446 | $i = 1; |
447 | 447 | $queues = []; |
448 | 448 | foreach ($this->work as $group) { |
@@ -475,16 +475,16 @@ discard block |
||
475 | 475 | $this->processWork(); |
476 | 476 | foreach ($queues as $queue) { |
477 | 477 | preg_match('/alt\..+/i', $queue, $hit); |
478 | - $pool->add(function () use ($queue) { |
|
478 | + $pool->add(function() use ($queue) { |
|
479 | 479 | return $this->_executeCommand($this->dnr_path.$queue.'"'); |
480 | - }, 2000000)->then(function ($output) use ($hit) { |
|
481 | - if (! empty($hit)) { |
|
480 | + }, 2000000)->then(function($output) use ($hit) { |
|
481 | + if (!empty($hit)) { |
|
482 | 482 | echo $output; |
483 | 483 | $this->colorCli->primary('Updated group '.$hit[0]); |
484 | 484 | } |
485 | - })->catch(function (\Throwable $exception) { |
|
485 | + })->catch(function(\Throwable $exception) { |
|
486 | 486 | echo $exception->getMessage(); |
487 | - })->catch(static function (SerializableException $serializableException) { |
|
487 | + })->catch(static function(SerializableException $serializableException) { |
|
488 | 488 | //we do nothing here just catch the error and move on |
489 | 489 | }); |
490 | 490 | } |
@@ -547,14 +547,14 @@ discard block |
||
547 | 547 | |
548 | 548 | $this->processWork(); |
549 | 549 | foreach ($this->work as $queue) { |
550 | - $pool->add(function () use ($queue) { |
|
550 | + $pool->add(function() use ($queue) { |
|
551 | 551 | return $this->_executeCommand(PHP_BINARY.' misc/update/tmux/bin/groupfixrelnames.php "'.$queue.'"'.' true'); |
552 | - }, 2000000)->then(function ($output) use ($maxWork) { |
|
552 | + }, 2000000)->then(function($output) use ($maxWork) { |
|
553 | 553 | echo $output; |
554 | 554 | $this->colorCli->primary('Task #'.$maxWork.' Finished fixing releases names'); |
555 | - })->catch(function (\Throwable $exception) { |
|
555 | + })->catch(function(\Throwable $exception) { |
|
556 | 556 | echo $exception->getMessage(); |
557 | - })->catch(static function (SerializableException $serializableException) { |
|
557 | + })->catch(static function(SerializableException $serializableException) { |
|
558 | 558 | //we do nothing here just catch the error and move on |
559 | 559 | }); |
560 | 560 | $maxWork--; |
@@ -575,7 +575,7 @@ discard block |
||
575 | 575 | foreach ($work as $group) { |
576 | 576 | try { |
577 | 577 | $query = DB::select(sprintf('SELECT id FROM collections WHERE groups_id = %d LIMIT 1', $group->id)); |
578 | - if (! empty($query)) { |
|
578 | + if (!empty($query)) { |
|
579 | 579 | $uGroups[] = ['id' => $group->id, 'name' => $group->name]; |
580 | 580 | } |
581 | 581 | } catch (\PDOException $e) { |
@@ -593,14 +593,14 @@ discard block |
||
593 | 593 | |
594 | 594 | $this->processWork(); |
595 | 595 | foreach ($uGroups as $group) { |
596 | - $pool->add(function () use ($group) { |
|
596 | + $pool->add(function() use ($group) { |
|
597 | 597 | return $this->_executeCommand($this->dnr_path.'releases '.$group['id'].'"'); |
598 | - }, 2000000)->then(function ($output) use ($maxWork) { |
|
598 | + }, 2000000)->then(function($output) use ($maxWork) { |
|
599 | 599 | echo $output; |
600 | 600 | $this->colorCli->primary('Task #'.$maxWork.' Finished performing release processing'); |
601 | - })->catch(function (\Throwable $exception) { |
|
601 | + })->catch(function(\Throwable $exception) { |
|
602 | 602 | echo $exception->getMessage(); |
603 | - })->catch(static function (SerializableException $serializableException) { |
|
603 | + })->catch(static function(SerializableException $serializableException) { |
|
604 | 604 | //we do nothing here just catch the error and move on |
605 | 605 | }); |
606 | 606 | $maxWork--; |
@@ -637,16 +637,16 @@ discard block |
||
637 | 637 | $this->processWork(); |
638 | 638 | foreach ($releases as $release) { |
639 | 639 | if ($type !== '') { |
640 | - $pool->add(function () use ($release, $type) { |
|
640 | + $pool->add(function() use ($release, $type) { |
|
641 | 641 | return $this->_executeCommand(PHP_BINARY.' misc/update/postprocess.php '.$type.$release->id); |
642 | - }, 2000000)->then(function ($output) use ($desc, $count) { |
|
642 | + }, 2000000)->then(function($output) use ($desc, $count) { |
|
643 | 643 | echo $output; |
644 | 644 | $this->colorCli->primary('Finished task #'.$count.' for '.$desc); |
645 | - })->catch(function (\Throwable $exception) { |
|
645 | + })->catch(function(\Throwable $exception) { |
|
646 | 646 | echo $exception->getMessage(); |
647 | - })->catch(static function (SerializableException $serializableException) { |
|
647 | + })->catch(static function(SerializableException $serializableException) { |
|
648 | 648 | //we do nothing here just catch the error and move on |
649 | - })->timeout(function () use ($count) { |
|
649 | + })->timeout(function() use ($count) { |
|
650 | 650 | $this->colorCli->notice('Task #'.$count.': Timeout occurred.'); |
651 | 651 | }); |
652 | 652 | $count--; |
@@ -894,15 +894,15 @@ discard block |
||
894 | 894 | $pool = Pool::create()->concurrency($maxProcess)->timeout(config('nntmux.multiprocessing_max_child_time')); |
895 | 895 | $this->processWork(); |
896 | 896 | foreach ($this->work as $group) { |
897 | - $pool->add(function () use ($group) { |
|
897 | + $pool->add(function() use ($group) { |
|
898 | 898 | return $this->_executeCommand($this->dnr_path.'update_per_group '.$group->id.'"'); |
899 | - }, 2000000)->then(function ($output) use ($group) { |
|
899 | + }, 2000000)->then(function($output) use ($group) { |
|
900 | 900 | echo $output; |
901 | 901 | $name = UsenetGroup::getNameByID($group->id); |
902 | 902 | $this->colorCli->primary('Finished updating binaries, processing releases and additional postprocessing for group:'.$name); |
903 | - })->catch(function (\Throwable $exception) { |
|
903 | + })->catch(function(\Throwable $exception) { |
|
904 | 904 | echo $exception->getMessage(); |
905 | - })->catch(static function (SerializableException $serializableException) { |
|
905 | + })->catch(static function(SerializableException $serializableException) { |
|
906 | 906 | echo $serializableException->asThrowable()->getMessage(); |
907 | 907 | }); |
908 | 908 | } |
@@ -918,7 +918,7 @@ discard block |
||
918 | 918 | { |
919 | 919 | $process = Process::fromShellCommandline($command); |
920 | 920 | $process->setTimeout(1800); |
921 | - $process->run(function ($type, $buffer) { |
|
921 | + $process->run(function($type, $buffer) { |
|
922 | 922 | if ($type === Process::ERR) { |
923 | 923 | echo $buffer; |
924 | 924 | } |