Comodojo\Extender\Tasks\Runner

Complexity

Total Complexity

5

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
B	run()	0	44	4

<?php namespace Comodojo\Extender\Tasks;

use \Comodojo\Dispatcher\Components\Configuration;
use \Psr\Log\LoggerInterface;

/**
 * Job runner
 *
 * @package     Comodojo extender
 * @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
 * @license     GPL-3.0+
 *
 * LICENSE:
 * 
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

class Runner {
    
    protected $configuration;
    
    protected $logger;
    
    public function __construct(Configuration $configuration, LoggerInterface $logger) {
        
        // init components
        $this->configuration = $configuration;
        
        $this->logger = $logger;
        
    }
    
    public function run($id, $task, $class, $timestamp = null, $name = null) {
        
        $this->logger->info("Starting task $task ($id) ");

        try {

            // create a task instance

            $thetask = new $class(
                $this->configuration,
                $this->logger,
                $name,
                $timestamp,
                $id,
                $parameters

The variable $parameters does not exist. Did you forget to declare it?

            );

            // get the task pid (we are in singlethread mode)

            $pid = $thetask->pid;

            // run task

            $result = $thetask->start();
        
        } catch (TaskException $te) {

The class Comodojo\Extender\Tasks\TaskException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            $this->logger->notice("Job ".$job['name']."(".$job['id'].") ends with error");

The variable $job does not exist. Did you forget to declare it?

        
            return array($pid, $name, false, $start_timestamp, $te->getEndTimestamp(), $te->getMessage(), $id, $te->getWorklogId());

The variable $pid does not seem to be defined for all execution paths leading up to this point.

The variable $start_timestamp does not exist. Did you mean $timestamp?

        
        } catch (Exception $e) {

The class Comodojo\Extender\Tasks\Exception does not exist. Did you forget a USE statement, or did you not list all dependencies?

            $this->logger->notice("Job ".$job['name']."(".$job['id'].") ends with error");
        
            return array($pid, $name, false, $start_timestamp, null, $e->getMessage(), $id, null);

The variable $start_timestamp does not exist. Did you mean $timestamp?

        
        }

        $this->logger->notice("Job ".$job['name']."(".$job['id'].") ends with ".($result["success"] ? "success" : "failure"));

        return array($pid, $name, $result["success"], $start_timestamp, $result["timestamp"], $result["result"], $id, $result["worklogid"]);

The variable $start_timestamp does not exist. Did you mean $timestamp?

        
    }
    
}