| Conditions | 2 |
| Paths | 2 |
| Total Lines | 25 |
| Code Lines | 14 |
| Lines | 0 |
| Ratio | 0 % |
| Changes | 1 | ||
| Bugs | 0 | Features | 0 |
| 1 | <?php |
||
| 29 | public function activeJobIndexAction() |
||
| 30 | { |
||
| 31 | /* @var RepositoryService $repositories */ |
||
| 32 | /* @var \Jobs\Repository\Job $jobRepo */ |
||
| 33 | /* @var \Doctrine\ODM\MongoDB\Cursor $jobs */ |
||
| 34 | /* @var \Solr\Listener\JobEventSubscriber $jobSubscriber */ |
||
| 35 | $sl = $this->serviceLocator; |
||
| 36 | $repositories = $sl->get('repositories'); |
||
| 37 | $jobRepo = $repositories->get('Jobs/Job'); |
||
| 38 | $jobSubscriber = $sl->get('Solr/Listener/JobEventSubscriber'); |
||
| 39 | |||
| 40 | $jobs = $jobRepo->findActiveJob(); |
||
| 41 | $count = $jobs->count(); |
||
| 42 | |||
| 43 | $progressBar = $this->createProgressBar($count); |
||
| 44 | $i = 1; |
||
| 45 | foreach($jobs as $job){ |
||
| 46 | /* @var Job $job */ |
||
| 47 | $jobSubscriber->consoleIndex($job); |
||
| 48 | $progressBar->update($i, 'Job '.$i.' / '.$count); |
||
| 49 | $i++; |
||
| 50 | } |
||
| 51 | |||
| 52 | return PHP_EOL; |
||
| 53 | } |
||
| 54 | |||
| 59 | } |