Jobs\Controller\ConsoleController

Complexity

Total Complexity

25

Size/Duplication

Total Lines	197
Duplicated Lines	0 %

Test Coverage

Coverage

36.7%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	factory()	0	4	1
A	listExpiredJobs()	0	24	5
A	__construct()	0	4	1
A	pushFetchExternalImagesJobAction()	0	5	1
B	setpermissionsAction()	0	44	8
B	expireJobsAction()	0	97	9

<?php

/**
 * YAWIK
 *
 * @filesource
 * @copyright https://yawik.org/COPYRIGHT.php
 * @license   MIT
 */

/** ConsoleController of Jobs */
namespace Jobs\Controller;

use Core\Queue\LazyJob;
use Core\Repository\RepositoryService;
use Interop\Container\ContainerInterface;
use Jobs\Entity\StatusInterface;
use Jobs\Queue\FindJobsWithExternalImageJob;
use Laminas\Mvc\Console\Controller\AbstractConsoleController;
use Laminas\ProgressBar\ProgressBar;
use Core\Console\ProgressBar as CoreProgressBar;
use Laminas\ProgressBar\Adapter\Console as ConsoleAdapter;
use Laminas\Console\ColorInterface as ConsoleColor;
use Auth\Entity\UserInterface;

class ConsoleController extends AbstractConsoleController
{
    /**
     * @var RepositoryService
     */
    private $repositories;

    public function __construct(
        RepositoryService $repositories
    ) {
        $this->repositories = $repositories;
    }

    public static function factory(ContainerInterface $container)
    {
        return new self(
            $container->get('repositories')
        );
    }

    public function expireJobsAction()
    {
        $repositories = $this->repositories;
        /* @var \Jobs\Repository\Job $jobsRepo */
        $jobsRepo     = $repositories->get('Jobs/Job');
        $days = (int) $this->params('days');
        $limit = (string) $this->params('limit');
        $info = $this->params('info');
        $console = $this->console;

        if (!$days) {
            return 'Invalid value for --days. Must be integer.';
        }

        $date = new \DateTime('today');
        $date->sub(new \DateInterval('P' . $days . 'D'));

        $query        = [
            '$and' => [
                ['status.name' => StatusInterface::ACTIVE],
                ['$or' => [
                    ['datePublishStart.date' => ['$lt' => $date]],
                    ['datePublishEnd.date' => ['$lt' => new \DateTime('today midnight')]],
                ]],
                ['$or' => [
                    ['isDeleted' => ['$exists' => false]],
                    ['isDeleted' => false],
                ]]
            ]
        ];

        $offset = 0;
        if ($limit && false !== strpos($limit, ',')) {
            list($limit, $offset) = explode(',', $limit);
        }

        $jobs = $jobsRepo->findBy($query, null, (int) $limit, (int) $offset);
        $count = count($jobs);

        if (0 === $count) {
            $console->writeLine('No jobs found.', ConsoleColor::GREEN);
        }

        if ($info) {
            $output = count($jobs).' Jobs';
            if ($offset) {
                $output .= ' starting from ' . $offset;
            }
            $console->writeLine($output, ConsoleColor::YELLOW);
            $this->listExpiredJobs($jobs);
            return;
        }

//        foreach ($repositories->getEventManager()->getListeners('preUpdate') as $listener) {
//            $repositories->getEventManager()->removeEventListener('preUpdate', $listener);
//        }
//
        $console->writeLine("$count jobs found, which have to expire ...\n", ConsoleColor::GREEN);

        $progress     = new ProgressBar(
            new ConsoleAdapter(
                array(
                'elements' => array(
                    ConsoleAdapter::ELEMENT_TEXT,
                    ConsoleAdapter::ELEMENT_BAR,
                    ConsoleAdapter::ELEMENT_PERCENT,
                    ConsoleAdapter::ELEMENT_ETA
                ),
                'textWidth' => 20,
                'barLeftChar' => '-',
                'barRightChar' => ' ',
                'barIndicatorChar' => '>',
                )
            ),
            0,
            count($jobs)
        );

        $i = 0;

        /* @var \Jobs\Entity\Job $job */
        foreach ($jobs as $job) {
            $progress->update($i++, 'Job ' . $i . ' / ' . $count);

            $job->changeStatus('expired');

            if (0 == $i % 500) {
                $progress->update($i, 'Write to database...');
                $repositories->flush();
            }
        }
        $progress->update($i, 'Write to database...');
        $repositories->flush();
        $progress->update($i, 'Done');
        $progress->finish();

        return PHP_EOL;
    }

    public function setpermissionsAction()
    {
        $repositories = $this->repositories;
        $repository   = $repositories->get('Jobs/Job');
        $userRep      = $repositories->get('Auth/User');
        $jobs         = $repository->findAll();
        $count        = count($jobs);
        $progress     = new CoreProgressBar($count);
        $i            = 0;
        /* @var Job $job */
        foreach ($jobs as $job) {
            $progress->update($i++, 'Job ' . $i . ' / ' . $count);

            $permissions = $job->getPermissions();
            $user        = $job->getUser();
            if (!$user instanceof UserInterface) {
                continue;
            }
            try {
                $group       = $user->getGroup($job->getCompany());

The method getGroup() does not exist on Auth\Entity\UserInterface. Did you maybe mean getGroups()?

            } catch (\Exception $e) {
                continue;
            }
            if ($group) {
                $permissions->grant($group, 'view');
            }
            foreach ($job->getApplications() as $application) {
                $progress->update($i, 'set app perms...');
                $perms = $application->getPermissions();
                $perms->inherit($permissions);
                $jobUser = $userRep->findOneByEmail($job->getContactEmail());

The method findOneByEmail() does not exist on Doctrine\Common\Persistence\ObjectRepository. Did you maybe mean findOneBy()?

                if ($jobUser) {
                    $perms->grant($jobUser, 'change');
                }
            }
            if (0 == $i % 500) {
                $progress->update($i, 'write to database...');
                $repositories->flush();
            }
        }
        $progress->update($i, 'write to database...');
        $repositories->flush();
        $progress->finish();
        return PHP_EOL;
    }

    private function listExpiredJobs($jobs)
    {
        $console = $this->console;
        /* @var \Jobs\Entity\JobInterface $job */
        foreach ($jobs as $job) {
            $id = $job->getId();
            $org = $job->getOrganization();
            if ($org) {
                $org = $org->getName();
            } else {
                $org = $job->getCompany();
            }

            $publishStart = is_null($job->getDatePublishStart()) ? 'N/A':$job->getDatePublishStart()->format('Y-m-d');
            $publishEnd = is_null($job->getDatePublishEnd()) ? 'N/A':$job->getDatePublishEnd()->format('Y-m-d');
            $output = sprintf(
                '%s   %s   %s   %-30s   %-20s' . PHP_EOL,
                $id,
                $publishStart,
                $publishEnd,
                substr($job->getTitle(), 0, 30),
                substr($org, 0, 20)
            );
            $console->writeLine($output, ConsoleColor::GREEN);
        }
    }

    public function pushFetchExternalImagesJobAction()
    {
        $this->queue('default')->pushJob(FindJobsWithExternalImageJob::create());

The method pushJob() does not exist on Laminas\Stdlib\DispatchableInterface. It seems like you code against a sub-type of Laminas\Stdlib\DispatchableInterface such as Laminas\Mvc\Controller\AbstractController.

The method queue() does not exist on Jobs\Controller\ConsoleController. Since you implemented __call, consider adding a @method annotation.

        return 'Job pushed to queue.';
    }
}