@@ -38,7 +38,7 @@ |
||
| 38 | 38 | /** |
| 39 | 39 | * Checks if a worker is active and registered at the Gearman Job Server. |
| 40 | 40 | * returns false if not. |
| 41 | - * @return bool |
|
| 41 | + * @return boolean|null |
|
| 42 | 42 | */ |
| 43 | 43 | public function workerExists(){ |
| 44 | 44 | try { |
@@ -130,7 +130,7 @@ discard block |
||
| 130 | 130 | * Processes and prepares the files for ocr. |
| 131 | 131 | * Sends the stuff to the gearman client in order to ocr async. |
| 132 | 132 | * |
| 133 | - * @param $language |
|
| 133 | + * @param string $language |
|
| 134 | 134 | * @param array $files |
| 135 | 135 | * @return string |
| 136 | 136 | */ |
@@ -199,7 +199,7 @@ discard block |
||
| 199 | 199 | * the gearman worker should call it automatically after each processing step. |
| 200 | 200 | * |
| 201 | 201 | * @param $statusId |
| 202 | - * @param $failed |
|
| 202 | + * @param boolean $failed |
|
| 203 | 203 | */ |
| 204 | 204 | public function complete($statusId, $failed){ |
| 205 | 205 | try{ |
@@ -334,12 +334,13 @@ discard block |
||
| 334 | 334 | |
| 335 | 335 | /** |
| 336 | 336 | * Inits the Gearman client and sends the task to the background worker (async) |
| 337 | - * @param $type |
|
| 337 | + * @param string $type |
|
| 338 | 338 | * @param $datadirectory |
| 339 | 339 | * @param $path |
| 340 | 340 | * @param $tempFile |
| 341 | 341 | * @param $language |
| 342 | 342 | * @param $statusId |
| 343 | + * @param OcrStatus $status |
|
| 343 | 344 | */ |
| 344 | 345 | private function sendGearmanJob($type, $datadirectory, $path, $tempFile, $language, $status, $occDir){ |
| 345 | 346 | try { |
@@ -120,7 +120,7 @@ discard block |
||
| 120 | 120 | } else { |
| 121 | 121 | throw new NotFoundException('No languages found.'); |
| 122 | 122 | } |
| 123 | - }catch(Exception $e){ |
|
| 123 | + } catch(Exception $e){ |
|
| 124 | 124 | $this->handleException($e); |
| 125 | 125 | } |
| 126 | 126 | } |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | // set the gearman running type |
| 153 | 153 | if($fInfo->getMimetype() === $this::MIMETYPE_PDF){ |
| 154 | 154 | $ftype = 'mypdf'; |
| 155 | - }else{ |
|
| 155 | + } else{ |
|
| 156 | 156 | $ftype = 'tess'; |
| 157 | 157 | } |
| 158 | 158 | |
@@ -164,10 +164,10 @@ discard block |
||
| 164 | 164 | $this->sendGearmanJob($ftype, $this->config->getSystemValue('datadirectory'), $fInfo->getPath(), $tempFile, $language, $status, \OC::$SERVERROOT); |
| 165 | 165 | } |
| 166 | 166 | return 'PROCESSING'; |
| 167 | - }else{ |
|
| 167 | + } else{ |
|
| 168 | 168 | throw new NotFoundException('Empty parameters.'); |
| 169 | 169 | } |
| 170 | - }catch(Exception $e){ |
|
| 170 | + } catch(Exception $e){ |
|
| 171 | 171 | $this->handleException($e); |
| 172 | 172 | } |
| 173 | 173 | } |
@@ -188,7 +188,7 @@ discard block |
||
| 188 | 188 | $pending = count($this->statusMapper->findAllPending($this->userId)); |
| 189 | 189 | |
| 190 | 190 | return ['processed' => $processed, 'failed' => $failed, 'pending' => $pending]; |
| 191 | - }catch (Exception $e){ |
|
| 191 | + } catch (Exception $e){ |
|
| 192 | 192 | $this->handleException($e); |
| 193 | 193 | } |
| 194 | 194 | } |
@@ -206,7 +206,7 @@ discard block |
||
| 206 | 206 | if(!$failed) { |
| 207 | 207 | $status->setStatus('PROCESSED'); |
| 208 | 208 | $this->statusMapper->update($status); |
| 209 | - }else{ |
|
| 209 | + } else{ |
|
| 210 | 210 | $status->setStatus('FAILED'); |
| 211 | 211 | $this->statusMapper->update($status); |
| 212 | 212 | } |
@@ -242,12 +242,12 @@ discard block |
||
| 242 | 242 | $this->view->file_put_contents($status->getNewName(), file_get_contents($status->getTempFile()));// don't need to extend with .pdf / it uses the tmp file to save |
| 243 | 243 | $this->statusMapper->delete($status); |
| 244 | 244 | exec('rm ' . $status->getTempFile()); |
| 245 | - }else{ |
|
| 245 | + } else{ |
|
| 246 | 246 | throw new NotFoundException('Temp file does not exist.'); |
| 247 | 247 | } |
| 248 | 248 | } |
| 249 | 249 | return count($processed); |
| 250 | - }catch (Exception $e){ |
|
| 250 | + } catch (Exception $e){ |
|
| 251 | 251 | $this->handleException($e); |
| 252 | 252 | } |
| 253 | 253 | } |
@@ -268,7 +268,7 @@ discard block |
||
| 268 | 268 | } |
| 269 | 269 | $this->logger->debug('Following status objects failed: '.json_encode($failed), ['app' => 'ocr']); |
| 270 | 270 | return $failed; |
| 271 | - }catch (Exception $e){ |
|
| 271 | + } catch (Exception $e){ |
|
| 272 | 272 | $this->handleException($e); |
| 273 | 273 | } |
| 274 | 274 | } |
@@ -340,7 +340,7 @@ discard block |
||
| 340 | 340 | private function getCorrectPath($file){ |
| 341 | 341 | if($file['path'] === '/'){ |
| 342 | 342 | $path = ''. '/' . $file['name']; |
| 343 | - }else{ |
|
| 343 | + } else{ |
|
| 344 | 344 | $path = $file['path']. '/' . $file['name']; |
| 345 | 345 | } |
| 346 | 346 | return $path; |
@@ -16,11 +16,11 @@ discard block |
||
| 16 | 16 | if ($success == 0 && !isset($_out[1])) { |
| 17 | 17 | //occ command which puts the file and cleans the tempfile |
| 18 | 18 | exec('php '.$workload->occdir.'/occ ocr:complete '.$workload->statusid.' false'); |
| 19 | - }else{ |
|
| 19 | + } else{ |
|
| 20 | 20 | //update status failed. |
| 21 | 21 | exec('php '.$workload->occdir.'/occ ocr:complete '.$workload->statusid.' true'); |
| 22 | 22 | } |
| 23 | - }else{ |
|
| 23 | + } else{ |
|
| 24 | 24 | //ocrmypdf |
| 25 | 25 | $command = 'ocrmypdf "' . $workload->datadirectory . $workload->path . '" "' . $workload->tempfile . '" -l ' . $workload->language . ' --skip-text'; |
| 26 | 26 | $success = -1; |
@@ -29,7 +29,7 @@ discard block |
||
| 29 | 29 | if ($success == 0 && !isset($_out[0])) { |
| 30 | 30 | //occ command which puts the file and cleans the tempfile |
| 31 | 31 | exec('php '.$workload->occdir.'/occ ocr:complete '.$workload->statusid.' false'); |
| 32 | - }else{ |
|
| 32 | + } else{ |
|
| 33 | 33 | //update status failed. |
| 34 | 34 | exec('php '.$workload->occdir.'/occ ocr:complete '.$workload->statusid.' true'); |
| 35 | 35 | } |
@@ -71,9 +71,9 @@ discard block |
||
| 71 | 71 | try{ |
| 72 | 72 | if($failed === 'false'){ |
| 73 | 73 | $failed = false; |
| 74 | - }elseif ($failed === 'true'){ |
|
| 74 | + } elseif ($failed === 'true'){ |
|
| 75 | 75 | $failed = true; |
| 76 | - }else{ |
|
| 76 | + } else{ |
|
| 77 | 77 | throw new ServiceException('Wrong Arguments.'); |
| 78 | 78 | } |
| 79 | 79 | $this->ocrService->complete($statusId, $failed); |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | $output->writeln('<error>Could not complete ocr for status id ' . $statusId . |
| 83 | 83 | ': ' . $e->getMessage() . |
| 84 | 84 | '</error> '); |
| 85 | - }else{ |
|
| 85 | + } else{ |
|
| 86 | 86 | $output->writeln('<error>Unexpected error for status id ' . $statusId . |
| 87 | 87 | ': ' . $e->getMessage() . |
| 88 | 88 | '</error> '); |