G2R\Adapter

Complexity

Total Complexity

19

Size/Duplication

Total Lines	179
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

70.49%

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	factory()	0	19	1
A	__construct()	0	4	1
B	run()	0	25	3
A	attachJobRunner()	0	8	1
A	loadProjectsConfig()	0	8	1
A	getProjectsConfig()	0	8	2
A	getJobRunner()	0	8	2
A	getHook()	0	10	2
A	getInput()	0	12	2
A	setHook()	0	4	1
A	setInput()	0	4	1
A	log()	0	6	2

<?php

namespace G2R;

use G2R\Config\ProjectConfig;
use G2R\Config\RundeckConfig;
use G2R\Exception\Exception;
use G2R\Gitlab\GitlabHook;
use G2R\Gitlab\HookResolver;
use G2R\Rundeck\JobRunner;
use Psr\Log\LoggerInterface;
use Psr\Log\LoggerTrait;

class Adapter
{
    use LoggerTrait;

    protected $logger;

    protected $jobRunner;

    protected $projectsConfig;

    protected $hook;

    protected $input;

    public static function factory(
        $rundeckConfig,
        $projectConfig,
        $logger = null
    ) {
        $adapter = new self($logger);

        // attach jobRunner
        $adapter->attachJobRunner(
            new JobRunner(new RundeckConfig($rundeckConfig))
        );

        // load the projects config
        $adapter->loadProjectsConfig(
            new ProjectConfig($projectConfig)
        );

        return $adapter;
    }

    /**
     * Eventually attach a Logger.
     *
     * @param LoggerInterface|null $logger
     */
    public function __construct(LoggerInterface $logger = null)
    {
        $this->logger = $logger;
    }

    /**
     * Run the adapter.
     *
     * @throws Exception
     */
    public function run()
    {
        $project = $this->getProjectsConfig()->getProject(
            $this->getHook()->getProjectName(),
            $this->getHook()->getRef()
        );

        // before we run the job, we want to make sure the build passed or
        // the runOnFail is true

        if ($this->getHook()->getBuildStatus() != 'success' &&
            !$project['runOnFail']
        ) {
            $this->warning(
                "The project config for {$this->getHook()->getProjectName()} ".
                "doesn't enable to run the job when the build failed"
            );

            return 0;
        }

        $this->info("Running the job {$project['jobId']}");

        return $this->getJobRunner()->run($project['jobId']);
    }

    /**
     * Load the rundeck job runner.
     *
     * @param JobRunner $jobRunner
     */
    public function attachJobRunner(JobRunner $jobRunner)
    {
        $this->info(
            "Job runner uses '{$jobRunner->getConfig()->getFilename()}' config"
        );

        $this->jobRunner = $jobRunner;
    }

    /**
     * Load the projects config.
     *
     * @param ProjectConfig $projectsConfig
     */
    public function loadProjectsConfig(ProjectConfig $projectsConfig)
    {
        $this->info(
            "Loading projects config file '{$projectsConfig->getFilename()}'"
        );

        $this->projectsConfig = $projectsConfig;
    }

    private function getProjectsConfig()
    {
        if (!isset($this->projectsConfig)) {
            throw new Exception('The projects config is missing');
        }

        return $this->projectsConfig;
    }

    private function getJobRunner()
    {
        if (!isset($this->jobRunner)) {
            throw new Exception('The Job runner is missing');
        }

        return $this->jobRunner;
    }

    /**
     * Get the hook.
     *
     * @return HookResolver
     */
    private function getHook()
    {
        if (!isset($this->hook)) {
            $this->hook = HookResolver::load($this->getInput());

            $this->debug('Hook handler type: '.get_class($this->hook));
        }

        return $this->hook;
    }

    /**
     * Get the input (php://input by default).
     *
     * @return string
     */
    private function getInput()
    {
        if (!isset($this->input)) {
            $this->debug('no input specified. Default php://input');

            $this->input = file_get_contents('php://input');

            $this->debug('input content: '.$this->input);
        }

        return $this->input;
    }

    public function setHook(GitlabHook $hook)
    {
        $this->hook = $hook;
    }

    public function setInput($input)
    {
        $this->input = $input;
    }

    /**
     * Call the logger.
     *
     * @param       $level
     * @param       $message
     * @param array $context
     */
    public function log($level, $message, array $context = [])
    {
        if ($this->logger) {
            $this->logger->log($level, $message, $context);
        }
    }
}