OCA\Files_Antivirus\Scanner\Local

Complexity

Total Complexity

7

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

92.31%

Importance

Changes	7
Bugs	2	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getWriteHandle()	0	3	1
A	prepareChunk()	0	3	1
A	__construct()	0	10	2
A	shutdownScanner()	0	10	1
A	initScanner()	0	15	2

<?php
/**
 * Copyright (c) 2014 Victor Dubiniuk <victor.dubiniuk@gmail.com>
 * This file is licensed under the Affero General Public License version 3 or
 * later.
 * See the COPYING-README file.
 */


namespace OCA\Files_Antivirus\Scanner;

class Local extends \OCA\Files_Antivirus\Scanner{
	
	/**
	 * @var string
	 */
	protected $avPath;
	
	/**
	 * STDIN and STDOUT descriptors
	 * @var array of resources
	 */
	private $pipes = array();
	
	/**
	 * Process handle
	 * @var resource
	 */
	private $process;
	
	public function __construct($config){
		$this->appConfig = $config;
		// get the path to the executable
		$this->avPath = escapeshellcmd($this->appConfig->getAvPath());

		// check that the executable is available
		if (!file_exists($this->avPath)) {
			throw new \RuntimeException('The antivirus executable could not be found at '.$this->avPath);
		}
	}
	
	public function initScanner(){
		parent::initScanner();
		
		// using 2>&1 to grab the full command-line output.
		$cmd = $this->avPath . " " . $this->appConfig->getCmdline() ." - 2>&1";
		$descriptorSpec = array(
			0 => array("pipe","r"), // STDIN
			1 => array("pipe","w")  // STDOUT
		);
		
		$this->process = proc_open($cmd, $descriptorSpec, $this->pipes);
		if (!is_resource($this->process)) {
			throw new \RuntimeException('Error starting process');
		}
	}
	
	protected function shutdownScanner(){
		fclose($this->pipes[0]);
		$output = stream_get_contents($this->pipes[1]);
		fclose($this->pipes[1]);
		
		$result = proc_close($this->process);
		
		\OCP\Util::writeLog('files_antivirus', 'Exit code :: ' . $result . ' Response :: ' . $output, \OCP\Util::DEBUG);
		$this->status->parseResponse($output, $result);
	}
	
	protected function getWriteHandle(){
		return $this->pipes[0];
	}
	
	protected function prepareChunk($data){
		return $data;
	}
}