mmucklo / DtcQueueBundle

ODM/LiveJobsGridSource.php

<?php

namespace Dtc\QueueBundle\ODM;

use Doctrine\ODM\MongoDB\DocumentManager;

The type Doctrine\ODM\MongoDB\DocumentManager was not found. Maybe you did not declare it correctly or list all dependencies?

use Dtc\GridBundle\Grid\Column\GridColumn;

The type Dtc\GridBundle\Grid\Column\GridColumn was not found. Maybe you did not declare it correctly or list all dependencies?

use Dtc\GridBundle\Grid\Source\ColumnExtractionTrait;

The type Dtc\GridBundle\Grid\Source\ColumnExtractionTrait was not found. Maybe you did not declare it correctly or list all dependencies?

use Dtc\GridBundle\Grid\Source\DocumentGridSource;

The type Dtc\GridBundle\Grid\Source\DocumentGridSource was not found. Maybe you did not declare it correctly or list all dependencies?

use Dtc\QueueBundle\Model\BaseJob;

class LiveJobsGridSource extends DocumentGridSource
{
    use ColumnExtractionTrait;
    protected $jobManager;
    protected $running = false;
    private $columnSource;

    public function getId()
    {
        return 'dtc_queue.grid_source.jobs_'.($this->isRunning() ? 'running' : 'waiting').'.odm';
    }

    public function setRunning($flag)
    {
        $this->running = $flag;
    }

    public function isRunning()
    {
        return $this->running;
    }

    public function setColumnSource(\Dtc\GridBundle\Grid\Source\ColumnSource $columnSource)

The type Dtc\GridBundle\Grid\Source\ColumnSource was not found. Maybe you did not declare it correctly or list all dependencies?

    {
        $this->columnSource = $columnSource;
    }

    protected function getRunningQueryBuilder()
    {
        /** @var DocumentManager $documentManager */
        $documentManager = $this->jobManager->getObjectManager();
        $builder = $documentManager->createQueryBuilder($this->jobManager->getJobClass());
        $builder->field('status')->equals(BaseJob::STATUS_RUNNING);
        $builder->sort('startedAt', 'desc');
        $builder->limit($this->limit);
        $builder->skip($this->offset);

        return $builder;
    }

    public function __construct(JobManager $jobManager)
    {
        $this->jobManager = $jobManager;

        /** @var DocumentManager $documentManager */
        $documentManager = $jobManager->getObjectManager();
        parent::__construct($documentManager, $jobManager->getJobClass());
    }

    public function setColumns($columns)
    {
        if ($columns) {
            foreach ($columns as $column) {
                if ($column instanceof GridColumn) {
                    $column->setOption('sortable', false);
                }
            }
        }

        parent::setColumns($columns);
    }

    public function getColumns()
    {
        if ($columns = parent::getColumns()) {
            return $columns;
        }

        if (!$this->columnSource) {
            $this->autoDiscoverColumns();

            return parent::getColumns();
        }

        $columnSourceInfo = $this->columnSource->getColumnSourceInfo($this->objectManager, 'Dtc\QueueBundle\Document\Job', false);
        $this->setColumns($columnSourceInfo->columns);
        $this->setDefaultSort($columnSourceInfo->sort);
        $this->setIdColumn($columnSourceInfo->idColumn);

        return parent::getColumns();
    }

    public function getDefaultSort()
    {
        return null;
    }

    protected function getQueryBuilder()
    {
        if ($this->isRunning()) {
            return $this->getRunningQueryBuilder();
        }
        $builder = $this->jobManager->getJobQueryBuilder();
        $builder->limit($this->limit);
        $builder->skip($this->offset);

        return $builder;
    }
}