Owncloud\Updater\Utils\OccRunner

Complexity

Total Complexity

16

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

38.32%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	setCanUseProcess()	0	3	1
A	runJson()	0	11	3
B	run()	0	23	6
B	runAsRequest()	0	27	2
A	getApplication()	0	5	1
A	runAsProcess()	0	12	2

<?php
/**
 * @author Victor Dubiniuk <dubiniuk@owncloud.com>
 *
 * @copyright Copyright (c) 2015, ownCloud, Inc.
 * @license AGPL-3.0
 *
 * This code is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License, version 3,
 * as published by the Free Software Foundation.
 *
 * 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, version 3,
 * along with this program.  If not, see <http://www.gnu.org/licenses/>
 *
 */

namespace Owncloud\Updater\Utils;

use GuzzleHttp\Client;
use Owncloud\Updater\Console\Application;
use Symfony\Component\Process\Process;
use Symfony\Component\Process\ProcessUtils;
use Symfony\Component\Process\Exception\ProcessFailedException;

/**
 * Class OccRunner
 *
 * @package Owncloud\Updater\Utils
 */
class OccRunner {
	/**
	 * @var Locator $locator
	 */
	protected $locator;

	/**
	 * @var bool
	 */
	protected $canUseProcess;

	/**
	 *
	 * @param Locator $locator
	 * @param bool $canUseProcess
	 */
	public function __construct(Locator $locator, $canUseProcess){
		$this->locator = $locator;
		$this->canUseProcess = $canUseProcess;
	}

	/**
	 * @param bool $canUseProcess
	 */
	public function setCanUseProcess($canUseProcess){
		$this->canUseProcess = $canUseProcess;
	}

	/**
	 * @param $command
	 * @param array $args
	 * @param bool $asJson
	 * @return string
	 */
	public function run($command, $args = [], $asJson = false){
		if ($this->canUseProcess){
			$extra = $asJson ? '--output=json' : '';
			$cmdLine = trim($command . ' ' . $extra);
			foreach ($args as $optionTitle => $optionValue){
				if (strpos($optionTitle, '--') === 0){
					$line = trim("$optionTitle=$optionValue");
				} else {
					$line = $optionValue;
				}
				$escapedLine = ProcessUtils::escapeArgument($line);

The method escapeArgument() does not seem to exist on object<Symfony\Component\Process\ProcessUtils>.

				$cmdLine .= " $escapedLine";
			}
			return $this->runAsProcess($cmdLine);
		} else {
			if ($asJson){
				$args['--output'] = 'json';
			}
			$response = $this->runAsRequest($command, $args);
			$decodedResponse = json_decode($response, true);
			return $decodedResponse['response'];
		}
	}

	/**
	 * @param $command
	 * @param array $args
	 * @return mixed
	 */
	public function runJson($command, $args = []){
		$plain = $this->run($command, $args, true);
		// trim response to always be a valid json. Capture everything between the first and the last curly brace
		preg_match_all('!(\{.*\})!ms', $plain, $matches);
		$clean = isset($matches[1][0]) ? $matches[1][0] : '';
		$decoded = json_decode($clean, true);
		if (!is_array($decoded)){
			throw new \UnexpectedValueException('Could not parse a response for ' . $command . '. Please check if the current shell user can run occ command. Raw output: ' . PHP_EOL . $plain);
		}
		return $decoded;
	}

	/**
	 * @param $command
	 * @param $args
	 * @return string
	 */
	protected function runAsRequest($command, $args){
		$application = $this->getApplication();
		$client = new Client();
		$endpointBase = $application->getEndpoint();
		$params = [
			'timeout' => 0,
			'json' => [
				'token' => $application->getAuthToken(),
				'params'=> $args
			]
		];
		
		// Skip SSL validation for localhost only as localhost never has a valid cert
		if (preg_match('/^https:\/\/localhost\/.*/i', $endpointBase)){
			$params['verify'] = false;
		}
		
		$request = $client->createRequest(
			'POST',
			$endpointBase . $command,
			$params
		);

		$response = $client->send($request);
		$responseBody = $response->getBody()->getContents();
		return $responseBody;
	}

	/**
	 * @return mixed
	 */
	protected function getApplication(){
		$container = Application::$container;
		$application = $container['application'];
		return $application;
	}

	/**
	 * @param $cmdLine
	 * @return string
	 */
	protected function runAsProcess($cmdLine){
		$occPath = $this->locator->getPathToOccFile();
		$cmd = "php $occPath --no-warnings $cmdLine";
		$process = new Process($cmd);
		$process->setTimeout(null);
		$process->run();

		if (!$process->isSuccessful()){
			throw new ProcessFailedException($process);
		}
		return $process->getOutput();
	}
}