Basis\Runner

Complexity

Total Complexity

16

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

25%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	hasJob()	0	4	1
A	getJobClass()	0	14	3
A	dispatch()	0	15	3
A	castArguments()	0	13	3
B	getMapping()	0	25	5

<?php

namespace Basis;

use LogicException;
use League\Container\Container;
use ReflectionClass;
use ReflectionProperty;

class Runner
{
    private $app;
    private $mapping;

    public function __construct(Application $app)
    {
        $this->app = $app;
    }

    public function getMapping() : array
    {
        if (!$this->mapping) {
            $jobs = [];
            foreach ($this->app->get(Framework::class)->listClasses('Job') as $class) {
                $jobs[substr($class, strlen('Basis\\Job\\'))] = $class;
            }
            $serviceName = ucfirst($this->app->get(Config::class)['service']);
            foreach ($this->app->get(Filesystem::class)->listClasses('Job') as $class) {
                $jobs[$serviceName.'\\'.substr($class, strlen('Job\\'))] = $class;
                $jobs[substr($class, strlen('Job\\'))] = $class;
            }


            foreach ($jobs as $part => $class) {
                $nick = str_replace('\\', '.', $part);
                $jobs[$nick] = $class;
                $jobs[strtolower($nick)] = $class;
            }

            $this->mapping = $jobs;
        }

        return $this->mapping;
    }

    public function hasJob(string $nick) : bool
    {
        return array_key_exists($nick, $this->getMapping());
    }

    public function getJobClass(string $nick) : string
    {
        $mapping = $this->getMapping();
        if (!array_key_exists($nick, $mapping)) {
            throw new LogicException("No job $nick");
        }

        $class = $mapping[$nick];

        if (!class_exists($class)) {
            throw new LogicException("No class for job $nick");
        }
        return $class;
    }

    public function dispatch(string $nick, array $arguments = [])
    {
        $class = $this->getJobClass($nick);

        $instance = $this->app->get($class);
        if (array_key_exists(0, $arguments)) {
            $arguments = $this->castArguments($class, $arguments);
        }

        foreach ($arguments as $k => $v) {
            $instance->$k = $v;
        }

        return $this->app->call([$instance, 'run']);
    }

    private function castArguments(string $class, array $arguments) : array
    {
        $reflection = new ReflectionClass($class);
        $properties = $reflection->getProperties(ReflectionProperty::IS_PUBLIC);
        if (count($properties) == 1) {
            return [
                $properties[0]->getName() => count($arguments) == 1
                    ? $arguments[0]
                    : implode(' ', $arguments)
            ];
        }
        return $arguments;
    }
}