Socket::initScanner() - Code Metrics - Inspection of "Reject uploads when antivirus is unreachable" - owncloud/files_antivirus - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#195)

by Victor

created 2017-11-28 07:13 UTC

Socket::initScanner() B

↳ Parent: Socket

Complexity

Conditions	3
Paths	3

Size

Total Lines	25
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	3.4977

Importance

Changes

Metric	Value
dl	0
loc	25
ccs	13
cts	21
cp	0.619
rs	8.8571
c	0
b	0
f	0
cc	3
eloc	16
nc	3
nop	0
crap	3.4977

<?php
/**
 * Copyright (c) 2017 Viktar Dubiniuk <[email protected]>
 * This file is licensed under the Affero General Public License version 3 or
 * later.
 * See the COPYING-README file.
 */


namespace OCA\Files_Antivirus\Scanner;

use OCA\Files_Antivirus\AppConfig;
use OCP\ILogger;

class Socket extends External {

	/** @var string  */
	private $socket;

	/**
	 * Socket constructor.
	 *
	 * @param AppConfig $config
	 * @param ILogger $logger
	 * @throws InitException
	 */
	public function __construct(AppConfig $config, ILogger $logger) {
		parent::__construct($config, $logger);
		$this->socket = $this->appConfig->getAvSocket();
		if ($this->socket === '') {
			throw new InitException(
				'Socket mode requires a path to the unix socket but it is empty.'
			);
		}
	}

	/**
	 * @throws InitException
	 */
	public function initScanner(){
		parent::initScanner();
		$this->writeHandle = @stream_socket_client(
			'unix://' . $this->socket, $errorCode, $errorMessage, 5
		);
		if (!$this->getWriteHandle()) {
			throw new InitException(
				sprintf(
					'Could not connect to socket "%s": %s (code %d)',
					$this->socket,
					$errorMessage,
					$errorCode
				)
			);
		}

		if (@fwrite($this->getWriteHandle(), "nINSTREAM\n") === false) {
			throw new InitException(
				sprintf(
					'Writing to socket "%s" failed',
					$this->socket
				)
			);
		}
	}
}


1		<?php
2		/**
3		* Copyright (c) 2017 Viktar Dubiniuk <[email protected]>
4		* This file is licensed under the Affero General Public License version 3 or
5		* later.
6		* See the COPYING-README file.
7		*/
8
9
10		namespace OCA\Files_Antivirus\Scanner;
11
12		use OCA\Files_Antivirus\AppConfig;
13		use OCP\ILogger;
14
15		class Socket extends External {
16
17		/** @var string */
18		private $socket;
19
20		/**
21		* Socket constructor.
22		*
23		* @param AppConfig $config
24		* @param ILogger $logger
25		* @throws InitException
26		*/
27	1	public function __construct(AppConfig $config, ILogger $logger) {
28	1	parent::__construct($config, $logger);
29	1	$this->socket = $this->appConfig->getAvSocket();
30	1	if ($this->socket === '') {
31		throw new InitException(
32		'Socket mode requires a path to the unix socket but it is empty.'
33		);
34		}
35	1	}
36
37		/**
38		* @throws InitException
39		*/
40	1	public function initScanner(){
41	1	parent::initScanner();
42	1	$this->writeHandle = @stream_socket_client(
43	1	'unix://' . $this->socket, $errorCode, $errorMessage, 5
44	1	);
45	1	if (!$this->getWriteHandle()) {
46	1	throw new InitException(
47	1	sprintf(
48	1	'Could not connect to socket "%s": %s (code %d)',
49	1	$this->socket,
50	1	$errorMessage,
51		$errorCode
52	1	)
53	1	);
54		}
55
56		if (@fwrite($this->getWriteHandle(), "nINSTREAM\n") === false) {
57		throw new InitException(
58		sprintf(
59		'Writing to socket "%s" failed',
60		$this->socket
61		)
62		);
63		}
64		}
65		}
66

owncloud / files_antivirus

Pull Request — master (#195)

Socket::initScanner() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like