Application::deploidStructureInit() - Code Metrics - Inspection of "fix application oh mom" - userator/deploid - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed
Push — master ( e8758d...435d87 )

by Mihail
created 2018-11-11 12:32 UTC
Application::deploidStructureInit() C

↳ Parent: Application
Complexity

Conditions	14
Paths	22
Size

Total Lines	69
Code Lines	52
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	29
CRAP Score	21.7649
Importance

Changes
Metric	Value
cc	14
eloc	52
nc	22
nop	1
dl	0
loc	69
ccs	29
cts	44
cp	0.6591
crap	21.7649
rs	6.2666
c	0
b	0
f	0
How to fix Long Method Complexity

<?php

namespace Deploid;

use Symfony\Component\Console\Application as ConsoleApplication;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerInterface;
use Symfony\Component\Process\Process;

class Application extends ConsoleApplication implements LoggerAwareInterface {

	/** @var string */
	private $releaseNameFormat = 'Y-m-d_H-i-s';

	/** @var string */
	private $chmod = '0775';

	/** @var array */
	private $structure = [
		'dirs' => [
			'releases',
			'releases/first',
			'shared',
		],
		'files' => [
			'deploid.log',
		],
		'links' => [
			'current:releases/first',
		],
	];

	/** @var LoggerInterface */
	private $logger;

	/* mutators */

	public function getReleaseNameFormat() {
		return $this->releaseNameFormat;
	}

	public function setReleaseNameFormat($releaseNameFormat) {
		$this->releaseNameFormat = $releaseNameFormat;
	}

	public function getChmod() {
		return $this->chmod;
	}

	public function setChmod($chmod) {
		$this->chmod = $chmod;
	}

	/**
	 * @return LoggerInterface
	 */
	public function getLogger() {
		return $this->logger;
	}

	/**
	 * @param LoggerInterface $logger
	 * @return void
	 */
	public function setLogger(LoggerInterface $logger) {
		$this->logger = $logger;
	}

	public function getStructure() {
		return $this->structure;
	}

	public function setStructure(array $structure) {
		$this->structure = $structure;
	}

	public function makeStructure($path, array $structure) {
		if (empty($path)) throw new \InvalidArgumentException('empty path');
		if (empty($structure)) throw new \InvalidArgumentException('empty structure');

		foreach ($structure as $section => $items) {
			if (empty($items)) continue;
			foreach ($items as $item) {
				if (empty($item)) continue;
				if ($section == 'dirs') mkdir($path . DIRECTORY_SEPARATOR . $item, $this->chmod, true);
				if ($section == 'dirs') mkdir($path . DIRECTORY_SEPARATOR . $item, /** @scrutinizer ignore-type */ $this->chmod, true);
				if ($section == 'files') touch($path . DIRECTORY_SEPARATOR . $item);
				if ($section == 'links') symlink($path . DIRECTORY_SEPARATOR . (explode(':', $item)[1]), $path . DIRECTORY_SEPARATOR . (explode(':', $item)[0]));
			}
		}

		return true;
	}

	/* tools */

	/**
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidStructureValidate($path) {
		$payload = new Payload();

		$path = $this->absolutePath($path, getcwd());

		$releasesDir = realpath($path) . DIRECTORY_SEPARATOR . 'releases';
		if (!is_dir($releasesDir)) {
			$payload->setType(Payload::STRUCTURE_VALIDATE_FAIL);
			$payload->setMessage('directory "' . $releasesDir . '" does not exist');
			$payload->setCode(255);
			return $payload;
		}

		$sharedDir = realpath($path) . DIRECTORY_SEPARATOR . 'shared';
		if (!is_dir($sharedDir)) {
			$payload->setType(Payload::STRUCTURE_VALIDATE_FAIL);
			$payload->setMessage('directory "' . $sharedDir . '" does not exist');
			$payload->setCode(255);
			return $payload;
		}

		$logFile = realpath($path) . DIRECTORY_SEPARATOR . 'deploid.log';
		if (!is_file($logFile)) {
			$payload->setType(Payload::STRUCTURE_VALIDATE_FAIL);
			$payload->setMessage('file "' . $logFile . '" does not exist');
			$payload->setCode(255);
			return $payload;
		}

		$payload->setType(Payload::STRUCTURE_VALIDATE_SUCCESS);
		$payload->setMessage('structure is valid');
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidStructureInit($path) {
		$payload = new Payload();

		if (!strlen($path)) {
			$payload->setType(Payload::STRUCTURE_INIT_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());
		$messages = [];

		if (!is_dir($path)) {
			if (mkdir($path, $this->chmod, true)) {
			if (mkdir($path, /** @scrutinizer ignore-type */ $this->chmod, true)) {
				$messages[] = 'directory "' . realpath($path) . '" created';
			} else {
				$payload->setType(Payload::STRUCTURE_INIT_FAIL);
				$payload->setMessage('directory "' . $path . '" does not created');
				$payload->setCode(255);
				return $payload;
			}
		}

		foreach ($structure as $section => $items) {

			if (empty($items)) continue;
			foreach ($items as $item) {
				if (empty($item)) continue;
				if ($section == 'dirs') {
					$dir = $path . DIRECTORY_SEPARATOR . $item;
					if (mkdir($dir, $this->chmod, true)) {
						$messages[] = 'directory "' . realpath($dir) . '" created';
					} else {
						$payload->setType(Payload::STRUCTURE_INIT_FAIL);
						$payload->setMessage('directory "' . $dir . '" does not created');
						$payload->setCode(255);
						return $payload;
					}
				}
				if ($section == 'files') {
					$file = $path . DIRECTORY_SEPARATOR . $item;
					if (touch($file)) {
						$messages[] = 'file "' . realpath($file) . '" created';
					} else {
						$payload->setType(Payload::STRUCTURE_INIT_FAIL);
						$payload->setMessage('file"' . $file . '" does not created');
						$payload->setCode(255);
						return $payload;
					}
				}
				if ($section == 'links') {
					$target = $path . DIRECTORY_SEPARATOR . (explode(':', $item)[1]);
					$link = $path . DIRECTORY_SEPARATOR . (explode(':', $item)[0]);
					if (symlink($target, $link)) {
						$messages[] = 'link "' . realpath($link) . '" created';
					} else {
						$payload->setType(Payload::STRUCTURE_INIT_FAIL);
						$payload->setMessage('link ' . $link . '" does not created');
						$payload->setCode(255);
						return $payload;
					}
				}
			}
		}

		$payload->setType(Payload::STRUCTURE_INIT_SUCCESS);
		$payload->setMessage($messages);
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidStructureClean($path) {
		$payload = new Payload();

		if (!strlen($path)) {
			$payload->setType(Payload::STRUCTURE_CLEAN_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$paths = glob(realpath($path) . DIRECTORY_SEPARATOR . '*');

		$paths = array_filter($paths, function ($path) {
			return !in_array(basename($path), $this->structure['dirs'] + $this->structure['links'] + $this->structure['files']);
		});

		foreach ($paths as $pathname) {
			if (is_file($pathname)) {
				unlink($pathname);
			} else if (is_link($pathname)) {
				unlink($pathname);
			} else if (is_dir($pathname)) {
				rmdir($pathname);
			}
		}

		$payload->setType(Payload::STRUCTURE_CLEAN_SUCCESS);
		$payload->setMessage(array_merge(['cleaned items:'], $paths));
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $release
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseExist($release, $path) {
		$payload = new Payload();

		if (!strlen($release)) {
			$payload->setType(Payload::RELEASE_EXIST_FAIL);
			$payload->setMessage('empty release name');
			$payload->setCode(255);
			return $payload;
		}

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_EXIST_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$releaseDir = $path . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . $release;
		if (!is_dir($releaseDir)) {
			$payload->setType(Payload::RELEASE_EXIST_FAIL);
			$payload->setMessage('release "' . $release . '" does not exist');
			$payload->setCode(255);
			return $payload;
		}

		$payload->setType(Payload::RELEASE_EXIST_SUCCESS);
		$payload->setMessage('release "' . $release . '" exist');
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $release
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseCreate($release, $path) {
		$payload = new Payload();

		if (!strlen($release)) {
			$payload->setType(Payload::RELEASE_CREATE_FAIL);
			$payload->setMessage('empty release name');
			$payload->setCode(255);
			return $payload;
		}

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_CREATE_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$releaseDir = realpath($path) . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . $release;

		if (!mkdir($releaseDir, $this->chmod, true)) {
		if (!mkdir($releaseDir, /** @scrutinizer ignore-type */ $this->chmod, true)) {
			$payload->setType(Payload::RELEASE_CREATE_FAIL);
			$payload->setMessage('release "' . $release . '" does not created');
			$payload->setCode(255);
			return $payload;
		}

		$payload->setType(Payload::RELEASE_CREATE_SUCCESS);
		$payload->setMessage('release "' . $release . '" created');
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $release
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseRemove($release, $path) {
		$payload = new Payload();

		if (!strlen($release)) {
			$payload->setType(Payload::RELEASE_REMOVE_FAIL);
			$payload->setMessage('empty release name');
			$payload->setCode(255);
			return $payload;
		}

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_REMOVE_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$proccess = new Process('rm -r ' . realpath($path) . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . $release);
		$proccess->run();

		if (!$proccess->isSuccessful()) {
			$payload->setType(Payload::RELEASE_REMOVE_FAIL);
			$payload->setMessage($proccess->getErrorOutput());
			$payload->setCode($proccess->getExitCode());
			return $payload;
		}

		$payload->setType(Payload::RELEASE_REMOVE_SUCCESS);
		$payload->setMessage('release "' . ($release == '*' ? 'all' : $release) . '" removed');
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseList($path) {
		$payload = new Payload();

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_LIST_FAIL);
			$payload->setMessage('path "' . $path . '" invalid');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$dirs = glob(realpath($path) . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . '*', GLOB_ONLYDIR);

		if (empty($dirs)) {
			$payload->setType(Payload::RELEASE_LIST_FAIL);
			$payload->setMessage('release not found');
			$payload->setCode(0);
			return $payload;
		}

		$dirs = array_map(function ($path) {
			return basename($path);
		}, $dirs);

		$payload->setType(Payload::RELEASE_LIST_SUCCESS);
		$payload->setMessage($dirs);
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseLatest($path) {
		$payload = new Payload();

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_LATEST_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$dirs = glob(realpath($path) . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . '*', GLOB_ONLYDIR);

		if (empty($dirs)) {
			$payload->setType(Payload::RELEASE_LATEST_FAIL);
			$payload->setMessage('release not found');
			$payload->setCode(255);
			return $payload;
		}

		$dirs = array_map(function ($path) {
			return basename($path);
		}, $dirs);

		if (!rsort($dirs)) {
			$payload->setType(Payload::RELEASE_LATEST_FAIL);
			$payload->setMessage('fail sorted');
			$payload->setCode(255);
			return $payload;
		}

		$payload->setType(Payload::RELEASE_LATEST_SUCCESS);
		$payload->setMessage(current($dirs));
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseCurrent($path) {
		$payload = new Payload();

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_CURRENT_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$link = realpath($path) . DIRECTORY_SEPARATOR . 'current';

		if (!file_exists($link)) {
			$payload->setType(Payload::RELEASE_CURRENT_FAIL);
			$payload->setMessage('current release does not exist');
			$payload->setCode(255);
			return $payload;
		}

		if (!is_link($link)) {
			$payload->setType(Payload::RELEASE_CURRENT_FAIL);
			$payload->setMessage('link to current release does not exist');
			$payload->setCode(255);
			return $payload;
		}

		$linkpath = readlink($link);

		if (!$linkpath) {
			$payload->setType(Payload::RELEASE_CURRENT_FAIL);
			$payload->setMessage('fail read link to current release');
			$payload->setCode(255);
			return $payload;
		}

		$payload->setType(Payload::RELEASE_CURRENT_SUCCESS);
		$payload->setMessage(basename($linkpath));
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param string $release
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseSetup($release, $path) {
		$payload = new Payload();

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_SETUP_FAIL);
			$payload->setMessage('path "' . $path . '" invalid');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$releaseDir = realpath($path) . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . $release;
		$currentDir = realpath($path) . DIRECTORY_SEPARATOR . 'current';

		$proccess = new Process('ln -sfn ' . $releaseDir . ' ' . $currentDir);
		$proccess->run();

		if (!$proccess->isSuccessful()) {
			$payload->setType(Payload::RELEASE_SETUP_FAIL);
			$payload->setMessage($proccess->getErrorOutput());
			$payload->setCode($proccess->getExitCode());
			return $payload;
		}

		$payload->setType(Payload::RELEASE_SETUP_SUCCESS);
		$payload->setMessage('release "' . $release . '" setup');
		$payload->setCode(0);
		return $payload;
	}

	/**
	 * @param int $quantity
	 * @param string $path
	 * @return \Deploid\Payload
	 */
	public function deploidReleaseRotate($quantity, $path) {
		$payload = new Payload();

		if (!$quantity || $quantity < 1) {
			$payload->setType(Payload::RELEASE_ROTATE_FAIL);
			$payload->setMessage('empty or invalid quantity');
			$payload->setCode(255);
			return $payload;
		}

		if (!strlen($path)) {
			$payload->setType(Payload::RELEASE_ROTATE_FAIL);
			$payload->setMessage('empty path');
			$payload->setCode(255);
			return $payload;
		}

		$path = $this->absolutePath($path, getcwd());

		$releases = glob(realpath($path) . DIRECTORY_SEPARATOR . 'releases' . DIRECTORY_SEPARATOR . '*', GLOB_ONLYDIR);

		if (count($releases) <= $quantity) {
			$payload->setType(Payload::RELEASE_ROTATE_SUCCESS);
			$payload->setMessage('not found releases to rotate');
			$payload->setCode(0);
		}

		foreach (array_reverse($releases) as $idx => $release) {
			if ($idx <= ($quantity - 1)) continue;
			$proccess = new Process('rm -r ' . $release);
			$proccess->run();
		}

		$payload->setType(Payload::RELEASE_ROTATE_SUCCESS);
		$payload->setMessage('releases are rotated');
		$payload->setCode(0);
		return $payload;
	}

	public function absolutePath($path, $cwd) {
		if (empty($path)) throw new \InvalidArgumentException('empty path');
		if (empty($cwd)) throw new \InvalidArgumentException('empty cwd');

		if ($path[0] == '/') return $path;

		return $cwd . DIRECTORY_SEPARATOR . $path;
	}

}
userator / deploid

Push — master ( e8758d...435d87 )

Application::deploidStructureInit() C

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like
