new SMB storage backend

apps/files_external/3rdparty/smb/Icewind/SMB/Connection.php

@@ -0,0 +1,86 @@
+<?php
+/**
+ * Copyright (c) 2013 Robin Appelman <[email protected]>
+ * This file is licensed under the Affero General Public License version 3 or
+ * later.
+ * See the COPYING-README file.
+ */
+
+namespace Icewind\SMB;
+
+class Connection extends RawConnection {
+	const DELIMITER = 'smb:';
+
+	/**
+	 * send input to smbclient
+	 *
+	 * @param string $input
+	 */
+	public function write($input) {
+		parent::write($input . PHP_EOL);
+	}
+
+	/**
+	 * get all unprocessed output from smbclient until the next prompt
+	 *
+	 * @throws ConnectionError
+	 * @return string
+	 */
+	public function read() {
+		if (!$this->isValid()) {
+			throw new ConnectionError();
+		}
+		$line = $this->readLine(); //first line is prompt
+		$this->checkConnectionError($line);
+
+		$output = array();
+		$line = $this->readLine();
+		$length = strlen(self::DELIMITER);
+		while (substr($line, 0, $length) !== self::DELIMITER) { //next prompt functions as delimiter
+			$output[] .= $line;
+			$line = parent::read();
+		}
+		return $output;
+	}
+
+	/**
+	 * read a single line of unprocessed output
+	 *
+	 * @return string
+	 */
+	public function readLine() {
+		return parent::read();
+	}
+
+	/**
+	 * check if the first line holds a connection failure
+	 *
+	 * @param $line
+	 * @throws AuthenticationException
+	 * @throws InvalidHostException
+	 */
+	private function checkConnectionError($line) {
+		$line = rtrim($line, ')');
+		if (substr($line, -23) === ErrorCodes::LogonFailure) {
+			throw new AuthenticationException();
+		}
+		if (substr($line, -26) === ErrorCodes::BadHostName) {
+			throw new InvalidHostException();
+		}
+		if (substr($line, -22) === ErrorCodes::Unsuccessful) {
+			throw new InvalidHostException();
+		}
+		if (substr($line, -28) === ErrorCodes::ConnectionRefused) {
+			throw new InvalidHostException();
+		}
+	}
+
+	public function close() {
+		$this->write('close' . PHP_EOL);
+	}
+
+	public function __destruct() {
+		$this->close();
+		parent::__destruct();
+	}
+}

apps/files_external/3rdparty/smb/Icewind/SMB/ErrorCodes.php

@@ -0,0 +1,52 @@
+<?php
+/**
+ * Copyright (c) 2012 Robin Appelman <[email protected]>
+ * This file is licensed under the Affero General Public License version 3 or
+ * later.
+ * See the COPYING-README file.
+ */
+
+namespace Icewind\SMB;
+
+class NotFoundException extends \Exception {
+}
+
+class AlreadyExistsException extends \Exception {
+}
+
+class NotEmptyException extends \Exception {
+}
+
+class ConnectionError extends \Exception {
+}
+
+class AuthenticationException extends \Exception {
+}
+
+class InvalidHostException extends \Exception {
+}
+
+class AccessDeniedException extends \Exception {
+}
+
+class InvalidTypeException extends \Exception {
+}
+
+class ErrorCodes {
+	/**
+	 * connection errors
+	 */
+	const LogonFailure = 'NT_STATUS_LOGON_FAILURE';
+	const BadHostName = 'NT_STATUS_BAD_NETWORK_NAME';
+	const Unsuccessful = 'NT_STATUS_UNSUCCESSFUL';
+	const ConnectionRefused = 'NT_STATUS_CONNECTION_REFUSED';
+
+	const PathNotFound = 'NT_STATUS_OBJECT_PATH_NOT_FOUND';
+	const NoSuchFile = 'NT_STATUS_NO_SUCH_FILE';
+	const ObjectNotFound = 'NT_STATUS_OBJECT_NAME_NOT_FOUND';
+	const NameCollision = 'NT_STATUS_OBJECT_NAME_COLLISION';
+	const AccessDenied = 'NT_STATUS_ACCESS_DENIED';
+	const DirectoryNotEmpty = 'NT_STATUS_DIRECTORY_NOT_EMPTY';
+	const FileIsADirectory = 'NT_STATUS_FILE_IS_A_DIRECTORY';
+	const NotADirectory = 'NT_STATUS_NOT_A_DIRECTORY';
+}

apps/files_external/3rdparty/smb/Icewind/SMB/RawConnection.php

@@ -0,0 +1,92 @@
+<?php
+/**
+ * Copyright (c) 2013 Robin Appelman <[email protected]>
+ * This file is licensed under the Affero General Public License version 3 or
+ * later.
+ * See the COPYING-README file.
+ */
+
+namespace Icewind\SMB;
+
+class RawConnection {
+	/**
+	 * @var resource[] $pipes
+	 *
+	 * $pipes[0] holds STDIN for smbclient
+	 * $pipes[1] holds STDOUT for smbclient
+	 */
+	private $pipes;
+
+	/**
+	 * @var resource $process
+	 */
+	private $process;
+
+
+	public function __construct($command) {
+		$descriptorSpec = array(
+			0 => array("pipe", "r"),
+			1 => array("pipe", "w"),
+			2 => array('file', '/dev/null', 'w')
+		);
+		setlocale(LC_ALL, Server::LOCALE);
+		$this->process = proc_open($command, $descriptorSpec, $this->pipes, null, array(
+			'CLI_FORCE_INTERACTIVE' => 'y', // Needed or the prompt isn't displayed!!
+			'LC_ALL' => Server::LOCALE
+		));
+		if (!$this->isValid()) {
+			throw new ConnectionError();
+		}
+	}
+
+	/**
+	 * check if the connection is still active
+	 *
+	 * @return bool
+	 */
+	public function isValid() {
+		if (is_resource($this->process)) {
+			$status = proc_get_status($this->process);
+			return $status['running'];
+		} else {
+			return false;
+		}
+	}
+
+	/**
+	 * send input to the process
+	 *
+	 * @param string $input
+	 */
+	public function write($input) {
+		fwrite($this->pipes[0], $input);
+		fflush($this->pipes[0]);
+	}
+
+	/**
+	 * read a line of output
+	 *
+	 * @return string
+	 */
+	public function read() {
+		return trim(fgets($this->pipes[1]));
+	}
+
+	/**
+	 * get all output until the process closes
+	 *
+	 * @return array
+	 */
+	public function readAll() {
+		$output = array();
+		while ($line = $this->read()) {
+			$output[] = $line;
+		}
+		return $output;
+	}
+
+	public function __destruct() {
+		proc_terminate($this->process);
+		proc_close($this->process);
+	}
+}

apps/files_external/3rdparty/smb/Icewind/SMB/Server.php

@@ -0,0 +1,134 @@
+<?php
+/**
+ * Copyright (c) 2013 Robin Appelman <[email protected]>
+ * This file is licensed under the Affero General Public License version 3 or
+ * later.
+ * See the COPYING-README file.
+ */
+
+namespace Icewind\SMB;
+
+class Server {
+	const CLIENT = 'smbclient';
+	const LOCALE = 'en_US.UTF-8';
+
+	/**
+	 * @var string $host
+	 */
+	private $host;
+
+	/**
+	 * @var string $user
+	 */
+	private $user;
+
+	/**
+	 * @var string $password
+	 */
+	private $password;
+
+	/**
+	 * @param string $host
+	 * @param string $user
+	 * @param string $password
+	 */
+	public function __construct($host, $user, $password) {
+		$this->host = $host;
+		$this->user = $user;
+		$this->password = $password;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getAuthString() {
+		return $this->user . '%' . $this->password;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getUser() {
+		return $this->user;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getPassword() {
+		return $this->password;
+	}
+
+	/**
+	 * return string
+	 */
+	public function getHost() {
+		return $this->host;
+	}
+
+	/**
+	 * @return Share[]
+	 * @throws \Icewind\SMB\AuthenticationException
+	 * @throws \Icewind\SMB\InvalidHostException
+	 */
+	public function listShares() {
+		$user = escapeshellarg($this->getUser());
+		$command = self::CLIENT . ' -U ' . $user . ' ' . '-gL ' . escapeshellarg($this->getHost());
+		$connection = new RawConnection($command);
+		$connection->write($this->getPassword() . PHP_EOL);
+		$output = $connection->readAll();
+
+		$line = $output[0];
+
+		// disregard password prompt
+		if (substr($line, 0, 6) == 'Enter ' and count($output) > 1) {
+			$line = $output[1];
+		}
+
+		$line = rtrim($line, ')');
+		if (substr($line, -23) === ErrorCodes::LogonFailure) {
+			throw new AuthenticationException();
+		}
+		if (substr($line, -26) === ErrorCodes::BadHostName) {
+			throw new InvalidHostException();
+		}
+		if (substr($line, -22) === ErrorCodes::Unsuccessful) {
+			throw new InvalidHostException();
+		}
+		if (substr($line, -28) === ErrorCodes::ConnectionRefused) {
+			throw new InvalidHostException();
+		}
+
+		$shareNames = array();
+		foreach ($output as $line) {
+			if (strpos($line, '|')) {
+				list($type, $name, $description) = explode('|', $line);
+				if (strtolower($type) === 'disk') {
+					$shareNames[$name] = $description;
+				}
+			}
+		}
+
+		$shares = array();
+		foreach ($shareNames as $name => $description) {
+			$shares[] = $this->getShare($name);
+		}
+		return $shares;
+	}
+
+	/**
+	 * @param string $name
+	 * @return Share
+	 */
+	public function getShare($name) {
+		return new Share($this, $name);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getTimeZone() {
+		$command = 'net time zone -S ' . escapeshellarg($this->getHost());
+		return exec($command);
+	}
+}