OcmController::assertIncomingSharingEnabled() - Code Metrics - Inspection of "[WIP] Federated sharing new spec" - owncloud/core - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#32303)

by Victor

created 2018-09-13 21:08 UTC

OcmController::assertIncomingSharingEnabled() A

↳ Parent: OcmController

Complexity

Conditions	3
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
nc	2
nop	0
dl	0
loc	7
rs	10
c	0
b	0
f	0

<?php
/**
 * @author Viktar Dubiniuk <[email protected]>
 *
 * @copyright Copyright (c) 2018, ownCloud GmbH
 * @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 OCA\FederatedFileSharing\Controller;

use OCA\FederatedFileSharing\Address;
use OCA\FederatedFileSharing\AddressHandler;
use OCA\FederatedFileSharing\FederatedShareProvider;
use OCA\FederatedFileSharing\Ocm\Exception\BadRequestException;
use OCA\FederatedFileSharing\Ocm\Exception\ForbiddenException;
use OCA\FederatedFileSharing\Ocm\Exception\NotImplementedException;
use OCA\FederatedFileSharing\Ocm\Notification\FileNotification;
use OCP\App\IAppManager;
use OCP\AppFramework\Http\JSONResponse;
use OCA\FederatedFileSharing\FedShareManager;
use OCA\FederatedFileSharing\Ocm\Exception\OcmException;
use OCP\AppFramework\Controller;
use OCP\AppFramework\Http;
use OCP\ILogger;
use OCP\IRequest;
use OCP\IURLGenerator;
use OCP\IUserManager;
use OCP\Share;
use OCP\Share\IShare;

/**
 * Class OcmController
 *
 * @package OCA\FederatedFileSharing\Controller
 */
class OcmController extends Controller {
	const API_VERSION = '1.0-proposal1';

	/**
	 * @var FederatedShareProvider
	 */
	private $federatedShareProvider;

	/**
	 * @var IURLGenerator
	 */
	protected $urlGenerator;

	/**
	 * @var IAppManager
	 */
	private $appManager;

	/**
	 * @var IUserManager
	 */
	protected $userManager;

	/**
	 * @var AddressHandler
	 */
	protected $addressHandler;

	/**
	 * @var FedShareManager
	 */
	protected $fedShareManager;

	/**
	 * @var ILogger
	 */
	protected $logger;

	/**
	 * OcmController constructor.
	 *
	 * @param string $appName
	 * @param IRequest $request
	 * @param FederatedShareProvider $federatedShareProvider
	 * @param IURLGenerator $urlGenerator
	 * @param IAppManager $appManager
	 * @param IUserManager $userManager
	 * @param AddressHandler $addressHandler
	 * @param FedShareManager $fedShareManager
	 * @param ILogger $logger
	 */
	public function __construct($appName,
									IRequest $request,
									FederatedShareProvider $federatedShareProvider,
									IURLGenerator $urlGenerator,
									IAppManager $appManager,
									IUserManager $userManager,
									AddressHandler $addressHandler,
									FedShareManager $fedShareManager,
									ILogger $logger
	) {
		parent::__construct($appName, $request);

		$this->federatedShareProvider = $federatedShareProvider;
		$this->urlGenerator = $urlGenerator;
		$this->appManager = $appManager;
		$this->userManager = $userManager;
		$this->addressHandler = $addressHandler;
		$this->fedShareManager = $fedShareManager;
		$this->logger = $logger;
	}

	/**
	 * @NoCSRFRequired
	 * @PublicPage
	 *
	 * EndPoint discovery
	 * Responds to /ocm-provider/ requests
	 *
	 * @return array
	 */
	public function discovery() {
		$endPoint = $this->urlGenerator->linkToRouteAbsolute(
			"{$this->appName}.ocm.index"
		);
		return [
			'enabled' => true,
			'apiVersion' => self::API_VERSION,
			'endPoint' => \rtrim($endPoint, '/'),
			'shareTypes' => [
				'name' => FileNotification::RESOURCE_TYPE_FILE,
				'protocols' => $this->getProtocols()
			]
		];
	}

	/**
	 * @NoCSRFRequired
	 * @PublicPage
	 *
	 * @param string $shareWith identifier of the user or group
	 * 							to share the resource with
	 * @param string $name name of the shared resource
	 * @param string $description share description (optional)
	 * @param string $providerId Identifier of the resource at the provider side
	 * @param string $owner identifier of the user that owns the resource
	 * @param string $ownerDisplayName display name of the owner
	 * @param string $sender Provider specific identifier of the user that wants
	 *							to share the resource
	 * @param string $senderDisplayName Display name of the user that wants
	 * 									to share the resource
	 * @param string $shareType Share type ('user' is supported atm)
	 * @param string $resourceType only 'file' is supported atm
	 * @param array $protocol
	 * 		[
	 * 			'name' => (string) protocol name. Only 'webdav' is supported atm,
	 * 			'options' => [
	 * 				protocol specific options
	 * 				only `webdav` options are supported atm
	 * 				e.g. `uri`,	`access_token`, `password`, `permissions` etc.
	 *
	 * 				For backward compatibility the webdav protocol will use
	 * 				the 'sharedSecret" as username and password
	 * 			]
	 *
	 * @return JSONResponse
	 */
	public function createShare($shareWith,
								$name,
								$description,

								$providerId,
								$owner,
								$ownerDisplayName,
								$sender,
								$senderDisplayName,
								$shareType,
								$resourceType,
								$protocol

	) {
		try {
			$this->assertIncomingSharingEnabled();
			$hasMissingParams = $this->hasNull(
				[$shareWith, $name, $providerId, $owner, $shareType, $resourceType]
			);
			if ($hasMissingParams
				|| !\is_array($protocol)
				|| !isset($protocol['name'])
				|| !isset($protocol['options'])
				|| !\is_array($protocol['options'])
				|| !isset($protocol['options']['sharedSecret'])
			) {
				throw new BadRequestException(
					'server can not add remote share, missing parameter'
				);
			}
			if (!\OCP\Util::isValidFileName($name)) {
				throw new BadRequestException(
					'The mountpoint name contains invalid characters.'
				);
			}

			$shareWithAddress = new Address($shareWith);
			$localShareWith = $shareWithAddress->getUserId();

			// FIXME this should be a method in the user management instead
			$this->logger->debug(
				"shareWith before, $localShareWith",
				['app' => $this->appName]
			);
			\OCP\Util::emitHook(
				'\OCA\Files_Sharing\API\Server2Server',
				'preLoginNameUsedAsUserName',
				['uid' => &$localShareWith]
			);
			$this->logger->debug(
				"shareWith after, $localShareWith",
				['app' => $this->appName]
			);

			if ($this->isSupportedProtocol($protocol['name']) === false) {
				throw new NotImplementedException(
					"Protocol {$protocol['name']} is not supported"
				);
			}

			if ($this->isSupportedShareType($shareType) === false) {
				throw new NotImplementedException(
					"ShareType {$shareType} is not supported"
				);
			}

			if ($this->isSupportedResourceType($resourceType) === false) {
				throw new NotImplementedException(
					"ResourceType {$resourceType} is not supported"
				);
			}

			if (!$this->userManager->userExists($localShareWith)) {
				throw new BadRequestException("User $localShareWith does not exist");
			}

			$ownerAddress = new Address($owner, $ownerDisplayName);
			$sharedByAddress = new Address($sender, $senderDisplayName);

			$this->fedShareManager->createShare(
				$ownerAddress,
				$sharedByAddress,
				$localShareWith,
				$providerId,
				$name,
				$protocol['options']['sharedSecret']
			);
		} catch (OcmException $e) {
			return new JSONResponse(
				['message' => $e->getMessage()],
				$e->getHttpStatusCode()
			);
		} catch (\Exception $e) {
			$this->logger->error(
				"server can not add remote share, {$e->getMessage()}",
				['app' => 'federatefilesharing']
			);
			return new JSONResponse(
				[
					'message' => "internal server error, was not able to add share from {$ownerAddress->getHostName()}"
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
				],
				Http::STATUS_INTERNAL_SERVER_ERROR
			);
		}
		return new JSONResponse(
			[],
			Http::STATUS_CREATED
		);
	}

	/**
	 * @NoCSRFRequired
	 * @PublicPage
	 *
	 * @param string $notificationType notification type (SHARE_REMOVED, etc)
	 * @param string $resourceType only 'file' is supported atm
	 * @param string $providerId Identifier of the resource at the provider side
	 * @param array $notification
	 * 		[
	 * 			optional additional parameters, depending on the notification
	 * 				and the resource type
	 * 		]
	 *
	 * @return JSONResponse
	 */
	public function processNotification($notificationType,
										$resourceType,
										$providerId,
										$notification
	) {
		try {
			$hasMissingParams = $this->hasNull(
				[$notificationType, $resourceType, $providerId]
			);
			if ($hasMissingParams || !\is_array($notification)) {
				throw new BadRequestException(
					'server can not add remote share, missing parameter'
				);
			}

			if ($this->isSupportedResourceType($resourceType) === false) {
				throw new NotImplementedException(
					"ResourceType {$resourceType} is not supported"
				);
			}
			// TODO: check permissions/preconditions in all cases
			switch ($notificationType) {
				case FileNotification::NOTIFICATION_TYPE_SHARE_ACCEPTED:

					$share = $this->getValidShare(
						$providerId, $notification['sharedSecret']
					);
					$this->fedShareManager->acceptShare($share);
					break;
				case FileNotification::NOTIFICATION_TYPE_SHARE_DECLINED:

					$share = $this->getValidShare(
						$providerId, $notification['sharedSecret']
					);
					$this->fedShareManager->declineShare($share);
					break;
				case FileNotification::NOTIFICATION_TYPE_REQUEST_RESHARE:
					$shareWithAddress = new Address($notification['shareWith']);
					$localShareWith = $shareWithAddress->getUserId();
					$share = $this->getValidShare(
						$providerId, $notification['sharedSecret']
					);
					// TODO: permissions not needed ???
					$this->fedShareManager->reShare(
						$share, $providerId, $localShareWith, 0
					);
					break;
				case FileNotification::NOTIFICATION_TYPE_RESHARE_CHANGE_PERMISSION:
					$permissions = $notification['permission'];
					// TODO: Map OCM permissions to numeric
					$share = $this->getValidShare(
						$providerId, $notification['sharedSecret']
					);
					$this->fedShareManager->updatePermissions($share, $permissions);
					break;
				case FileNotification::NOTIFICATION_TYPE_SHARE_UNSHARED:
					$this->fedShareManager->unshare(
						$providerId, $notification['sharedSecret']
					);
					break;
				case FileNotification::NOTIFICATION_TYPE_RESHARE_UNDO:

					$share = $this->getValidShare(
						$providerId, $notification['sharedSecret']
					);
					$this->fedShareManager->revoke($share);
					break;
				default:
					return new JSONResponse(
						['message' => "Notification of type {$notificationType} is not supported"],
						Http::STATUS_NOT_IMPLEMENTED
					);
			}
		} catch (OcmException $e) {
			return new JSONResponse(
				['message' => $e->getMessage()],
				$e->getHttpStatusCode()
			);
		} catch (Share\Exceptions\ShareNotFound $e) {
			return new JSONResponse(
				['message' => $e->getMessage()],
				Http::STATUS_BAD_REQUEST
			);
		} catch (\Exception $e) {
			$this->logger->error(
				"server can not process notification, {$e->getMessage()}",
				['app' => 'federatefilesharing']
			);
			return new JSONResponse(
				[
					'message' => "internal server error, was not able to process notification"
				],
				Http::STATUS_INTERNAL_SERVER_ERROR
			);
		}
		return new JSONResponse(
			[],
			Http::STATUS_CREATED
		);
	}

	/**
	 * Get list of supported protocols
	 *
	 * @return array
	 */
	protected function getProtocols() {
		return [
			'webdav' => '/public.php/webdav/'
		];
	}

	/**
	 * Make sure that incoming shares are enabled
	 *
	 * @return void
	 *
	 * @throws NotImplementedException
	 */
	protected function assertIncomingSharingEnabled() {
		if (!$this->appManager->isEnabledForUser('files_sharing')
			|| !$this->federatedShareProvider->isIncomingServer2serverShareEnabled()
		) {
			throw new NotImplementedException();
		}
	}

	/**
	 * Make sure that outgoing shares are enabled
	 *
	 * @return void
	 *
	 * @throws NotImplementedException
	 */
	protected function assertOutgoingSharingEnabled() {
		if (!$this->appManager->isEnabledForUser('files_sharing')
			|| !$this->federatedShareProvider->isOutgoingServer2serverShareEnabled()
		) {
			throw new NotImplementedException();
		}
	}

	/**
	 * Check if value is null or an array has any null item
	 *
	 * @param mixed $param
	 *
	 * @return bool
	 */
	protected function hasNull($param) {
		if (\is_array($param)) {
			return \in_array(null, $param, true);
		} else {
			return $param === null;
		}
	}

	/**
	 * Get share by id, validate it's type and token
	 *
	 * @param int $id
	 * @param string $sharedSecret
	 *
	 * @return IShare
	 *
	 * @throws BadRequestException
	 * @throws ForbiddenException
	 * @throws Share\Exceptions\ShareNotFound
	 */
	protected function getValidShare($id, $sharedSecret) {
		$share = $this->federatedShareProvider->getShareById($id);
		if ($share->getShareType() !== FederatedShareProvider::SHARE_TYPE_REMOTE) {
			throw new BadRequestException("Share with id {$id} des not exist");
		}

		if ($share->getToken() !== $sharedSecret) {
			throw new ForbiddenException("The secret doesn not match");
		}
		return $share;
	}

	/**
	 * @param string $resourceType
	 *
	 * @return bool
	 */
	protected function isSupportedResourceType($resourceType) {
		return $resourceType === FileNotification::RESOURCE_TYPE_FILE;
	}

	/**
	 * @param string $shareType
	 * @return bool
	 */
	protected function isSupportedShareType($shareType) {
		// TODO: make it a constant
		return $shareType === 'user';
	}

	/**
	 * @param string $protocolName
	 * @return bool
	 */
	protected function isSupportedProtocol($protocolName) {
		$supportedProtocols = $this->getProtocols();
		$supportedProtocolNames = \array_keys($supportedProtocols);
		return \in_array($protocolName, $supportedProtocolNames);
	}
}


1		<?php
2		/**
3		* @author Viktar Dubiniuk <[email protected]>
4		*
5		* @copyright Copyright (c) 2018, ownCloud GmbH
6		* @license AGPL-3.0
7		*
8		* This code is free software: you can redistribute it and/or modify
9		* it under the terms of the GNU Affero General Public License, version 3,
10		* as published by the Free Software Foundation.
11		*
12		* This program is distributed in the hope that it will be useful,
13		* but WITHOUT ANY WARRANTY; without even the implied warranty of
14		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15		* GNU Affero General Public License for more details.
16		*
17		* You should have received a copy of the GNU Affero General Public License, version 3,
18		* along with this program. If not, see <http://www.gnu.org/licenses/>
19		*
20		*/
21
22		namespace OCA\FederatedFileSharing\Controller;
23
24		use OCA\FederatedFileSharing\Address;
25		use OCA\FederatedFileSharing\AddressHandler;
26		use OCA\FederatedFileSharing\FederatedShareProvider;
27		use OCA\FederatedFileSharing\Ocm\Exception\BadRequestException;
28		use OCA\FederatedFileSharing\Ocm\Exception\ForbiddenException;
29		use OCA\FederatedFileSharing\Ocm\Exception\NotImplementedException;
30		use OCA\FederatedFileSharing\Ocm\Notification\FileNotification;
31		use OCP\App\IAppManager;
32		use OCP\AppFramework\Http\JSONResponse;
33		use OCA\FederatedFileSharing\FedShareManager;
34		use OCA\FederatedFileSharing\Ocm\Exception\OcmException;
35		use OCP\AppFramework\Controller;
36		use OCP\AppFramework\Http;
37		use OCP\ILogger;
38		use OCP\IRequest;
39		use OCP\IURLGenerator;
40		use OCP\IUserManager;
41		use OCP\Share;
42		use OCP\Share\IShare;
43
44		/**
45		* Class OcmController
46		*
47		* @package OCA\FederatedFileSharing\Controller
48		*/
49		class OcmController extends Controller {
50		const API_VERSION = '1.0-proposal1';
51
52		/**
53		* @var FederatedShareProvider
54		*/
55		private $federatedShareProvider;
56
57		/**
58		* @var IURLGenerator
59		*/
60		protected $urlGenerator;
61
62		/**
63		* @var IAppManager
64		*/
65		private $appManager;
66
67		/**
68		* @var IUserManager
69		*/
70		protected $userManager;
71
72		/**
73		* @var AddressHandler
74		*/
75		protected $addressHandler;
76
77		/**
78		* @var FedShareManager
79		*/
80		protected $fedShareManager;
81
82		/**
83		* @var ILogger
84		*/
85		protected $logger;
86
87		/**
88		* OcmController constructor.
89		*
90		* @param string $appName
91		* @param IRequest $request
92		* @param FederatedShareProvider $federatedShareProvider
93		* @param IURLGenerator $urlGenerator
94		* @param IAppManager $appManager
95		* @param IUserManager $userManager
96		* @param AddressHandler $addressHandler
97		* @param FedShareManager $fedShareManager
98		* @param ILogger $logger
99		*/
100	View Code Duplication	public function __construct($appName,
101		IRequest $request,
102		FederatedShareProvider $federatedShareProvider,
103		IURLGenerator $urlGenerator,
104		IAppManager $appManager,
105		IUserManager $userManager,
106		AddressHandler $addressHandler,
107		FedShareManager $fedShareManager,
108		ILogger $logger
109		) {
110		parent::__construct($appName, $request);
111
112		$this->federatedShareProvider = $federatedShareProvider;
113		$this->urlGenerator = $urlGenerator;
114		$this->appManager = $appManager;
115		$this->userManager = $userManager;
116		$this->addressHandler = $addressHandler;
117		$this->fedShareManager = $fedShareManager;
118		$this->logger = $logger;
119		}
120
121		/**
122		* @NoCSRFRequired
123		* @PublicPage
124		*
125		* EndPoint discovery
126		* Responds to /ocm-provider/ requests
127		*
128		* @return array
129		*/
130		public function discovery() {
131		$endPoint = $this->urlGenerator->linkToRouteAbsolute(
132		"{$this->appName}.ocm.index"
133		);
134		return [
135		'enabled' => true,
136		'apiVersion' => self::API_VERSION,
137		'endPoint' => \rtrim($endPoint, '/'),
138		'shareTypes' => [
139		'name' => FileNotification::RESOURCE_TYPE_FILE,
140		'protocols' => $this->getProtocols()
141		]
142		];
143		}
144
145		/**
146		* @NoCSRFRequired
147		* @PublicPage
148		*
149		* @param string $shareWith identifier of the user or group
150		* to share the resource with
151		* @param string $name name of the shared resource
152		* @param string $description share description (optional)
153		* @param string $providerId Identifier of the resource at the provider side
154		* @param string $owner identifier of the user that owns the resource
155		* @param string $ownerDisplayName display name of the owner
156		* @param string $sender Provider specific identifier of the user that wants
157		* to share the resource
158		* @param string $senderDisplayName Display name of the user that wants
159		* to share the resource
160		* @param string $shareType Share type ('user' is supported atm)
161		* @param string $resourceType only 'file' is supported atm
162		* @param array $protocol
163		* [
164		* 'name' => (string) protocol name. Only 'webdav' is supported atm,
165		* 'options' => [
166		* protocol specific options
167		* only `webdav` options are supported atm
168		* e.g. `uri`, `access_token`, `password`, `permissions` etc.
169		*
170		* For backward compatibility the webdav protocol will use
171		* the 'sharedSecret" as username and password
172		* ]
173		*
174		* @return JSONResponse
175		*/
176		public function createShare($shareWith,
177		$name,
178		$description,
		0 ignored issues – show Unused Code introduced 2018-08-10 16:39 UTC by Report Bug Copy Issue Report The parameter `$description` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
179		$providerId,
180		$owner,
181		$ownerDisplayName,
182		$sender,
183		$senderDisplayName,
184		$shareType,
185		$resourceType,
186		$protocol
187
188		) {
189		try {
190		$this->assertIncomingSharingEnabled();
191		$hasMissingParams = $this->hasNull(
192		[$shareWith, $name, $providerId, $owner, $shareType, $resourceType]
193		);
194		if ($hasMissingParams
195		\|\| !\is_array($protocol)
196		\|\| !isset($protocol['name'])
197		\|\| !isset($protocol['options'])
198		\|\| !\is_array($protocol['options'])
199		\|\| !isset($protocol['options']['sharedSecret'])
200		) {
201		throw new BadRequestException(
202		'server can not add remote share, missing parameter'
203		);
204		}
205		if (!\OCP\Util::isValidFileName($name)) {
206		throw new BadRequestException(
207		'The mountpoint name contains invalid characters.'
208		);
209		}
210
211		$shareWithAddress = new Address($shareWith);
212		$localShareWith = $shareWithAddress->getUserId();
213
214		// FIXME this should be a method in the user management instead
215		$this->logger->debug(
216		"shareWith before, $localShareWith",
217		['app' => $this->appName]
218		);
219		\OCP\Util::emitHook(
220		'\OCA\Files_Sharing\API\Server2Server',
221		'preLoginNameUsedAsUserName',
222		['uid' => &$localShareWith]
223		);
224		$this->logger->debug(
225		"shareWith after, $localShareWith",
226		['app' => $this->appName]
227		);
228
229		if ($this->isSupportedProtocol($protocol['name']) === false) {
230		throw new NotImplementedException(
231		"Protocol {$protocol['name']} is not supported"
232		);
233		}
234
235		if ($this->isSupportedShareType($shareType) === false) {
236		throw new NotImplementedException(
237		"ShareType {$shareType} is not supported"
238		);
239		}
240
241		if ($this->isSupportedResourceType($resourceType) === false) {
242		throw new NotImplementedException(
243		"ResourceType {$resourceType} is not supported"
244		);
245		}
246
247		if (!$this->userManager->userExists($localShareWith)) {
248		throw new BadRequestException("User $localShareWith does not exist");
249		}
250
251		$ownerAddress = new Address($owner, $ownerDisplayName);
252		$sharedByAddress = new Address($sender, $senderDisplayName);
253
254		$this->fedShareManager->createShare(
255		$ownerAddress,
256		$sharedByAddress,
257		$localShareWith,
258		$providerId,
259		$name,
260		$protocol['options']['sharedSecret']
261		);
262		} catch (OcmException $e) {
263		return new JSONResponse(
264		['message' => $e->getMessage()],
265		$e->getHttpStatusCode()
266		);
267		} catch (\Exception $e) {
268		$this->logger->error(
269		"server can not add remote share, {$e->getMessage()}",
270		['app' => 'federatefilesharing']
271		);
272		return new JSONResponse(
273		[
274		'message' => "internal server error, was not able to add share from {$ownerAddress->getHostName()}"
		0 ignored issues – show Bug introduced 2018-08-30 15:06 UTC by Report Bug Copy Issue Report The variable `$ownerAddress` does not seem to be defined for all execution paths leading up to this point. If you define a variable conditionally, it can happen that it is not defined for all execution paths. Let’s take a look at an example: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } // $x is potentially undefined here. echo $x; } In the above example, the variable `$x` is defined if you pass “foo” or “bar” as argument for `$a`. However, since the `switch` statement has no default case statement, if you pass any other value, the variable `$x` would be undefined. Available Fixes Check for existence of the variable explicitly: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } if (isset($x)) { // Make sure it's always set. echo $x; } } Define a default value for the variable: function myFunction($a) { $x = ''; // Set a default which gets overridden for certain paths. switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; } echo $x; } Add a value for the missing path: function myFunction($a) { switch ($a) { case 'foo': $x = 1; break; case 'bar': $x = 2; break; // We add support for the missing case. default: $x = ''; break; } echo $x; } Loading history...
275		],
276		Http::STATUS_INTERNAL_SERVER_ERROR
277		);
278		}
279		return new JSONResponse(
280		[],
281		Http::STATUS_CREATED
282		);
283		}
284
285		/**
286		* @NoCSRFRequired
287		* @PublicPage
288		*
289		* @param string $notificationType notification type (SHARE_REMOVED, etc)
290		* @param string $resourceType only 'file' is supported atm
291		* @param string $providerId Identifier of the resource at the provider side
292		* @param array $notification
293		* [
294		* optional additional parameters, depending on the notification
295		* and the resource type
296		* ]
297		*
298		* @return JSONResponse
299		*/
300		public function processNotification($notificationType,
301		$resourceType,
302		$providerId,
303		$notification
304		) {
305		try {
306		$hasMissingParams = $this->hasNull(
307		[$notificationType, $resourceType, $providerId]
308		);
309		if ($hasMissingParams \|\| !\is_array($notification)) {
310		throw new BadRequestException(
311		'server can not add remote share, missing parameter'
312		);
313		}
314
315		if ($this->isSupportedResourceType($resourceType) === false) {
316		throw new NotImplementedException(
317		"ResourceType {$resourceType} is not supported"
318		);
319		}
320		// TODO: check permissions/preconditions in all cases
321		switch ($notificationType) {
322	View Code Duplication	case FileNotification::NOTIFICATION_TYPE_SHARE_ACCEPTED:
		0 ignored issues – show Duplication introduced 2018-09-03 17:53 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
323		$share = $this->getValidShare(
324		$providerId, $notification['sharedSecret']
325		);
326		$this->fedShareManager->acceptShare($share);
327		break;
328	View Code Duplication	case FileNotification::NOTIFICATION_TYPE_SHARE_DECLINED:
		0 ignored issues – show Duplication introduced 2018-09-03 17:53 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
329		$share = $this->getValidShare(
330		$providerId, $notification['sharedSecret']
331		);
332		$this->fedShareManager->declineShare($share);
333		break;
334		case FileNotification::NOTIFICATION_TYPE_REQUEST_RESHARE:
335		$shareWithAddress = new Address($notification['shareWith']);
336		$localShareWith = $shareWithAddress->getUserId();
337		$share = $this->getValidShare(
338		$providerId, $notification['sharedSecret']
339		);
340		// TODO: permissions not needed ???
341		$this->fedShareManager->reShare(
342		$share, $providerId, $localShareWith, 0
343		);
344		break;
345		case FileNotification::NOTIFICATION_TYPE_RESHARE_CHANGE_PERMISSION:
346		$permissions = $notification['permission'];
347		// TODO: Map OCM permissions to numeric
348		$share = $this->getValidShare(
349		$providerId, $notification['sharedSecret']
350		);
351		$this->fedShareManager->updatePermissions($share, $permissions);
352		break;
353		case FileNotification::NOTIFICATION_TYPE_SHARE_UNSHARED:
354		$this->fedShareManager->unshare(
355		$providerId, $notification['sharedSecret']
356		);
357		break;
358	View Code Duplication	case FileNotification::NOTIFICATION_TYPE_RESHARE_UNDO:
		0 ignored issues – show Duplication introduced 2018-09-06 12:27 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
359		$share = $this->getValidShare(
360		$providerId, $notification['sharedSecret']
361		);
362		$this->fedShareManager->revoke($share);
363		break;
364		default:
365		return new JSONResponse(
366		['message' => "Notification of type {$notificationType} is not supported"],
367		Http::STATUS_NOT_IMPLEMENTED
368		);
369		}
370		} catch (OcmException $e) {
371		return new JSONResponse(
372		['message' => $e->getMessage()],
373		$e->getHttpStatusCode()
374		);
375		} catch (Share\Exceptions\ShareNotFound $e) {
376		return new JSONResponse(
377		['message' => $e->getMessage()],
378		Http::STATUS_BAD_REQUEST
379		);
380		} catch (\Exception $e) {
381		$this->logger->error(
382		"server can not process notification, {$e->getMessage()}",
383		['app' => 'federatefilesharing']
384		);
385		return new JSONResponse(
386		[
387		'message' => "internal server error, was not able to process notification"
388		],
389		Http::STATUS_INTERNAL_SERVER_ERROR
390		);
391		}
392		return new JSONResponse(
393		[],
394		Http::STATUS_CREATED
395		);
396		}
397
398		/**
399		* Get list of supported protocols
400		*
401		* @return array
402		*/
403		protected function getProtocols() {
404		return [
405		'webdav' => '/public.php/webdav/'
406		];
407		}
408
409		/**
410		* Make sure that incoming shares are enabled
411		*
412		* @return void
413		*
414		* @throws NotImplementedException
415		*/
416		protected function assertIncomingSharingEnabled() {
417		if (!$this->appManager->isEnabledForUser('files_sharing')
418		\|\| !$this->federatedShareProvider->isIncomingServer2serverShareEnabled()
419		) {
420		throw new NotImplementedException();
421		}
422		}
423
424		/**
425		* Make sure that outgoing shares are enabled
426		*
427		* @return void
428		*
429		* @throws NotImplementedException
430		*/
431		protected function assertOutgoingSharingEnabled() {
432		if (!$this->appManager->isEnabledForUser('files_sharing')
433		\|\| !$this->federatedShareProvider->isOutgoingServer2serverShareEnabled()
434		) {
435		throw new NotImplementedException();
436		}
437		}
438
439		/**
440		* Check if value is null or an array has any null item
441		*
442		* @param mixed $param
443		*
444		* @return bool
445		*/
446	View Code Duplication	protected function hasNull($param) {
447		if (\is_array($param)) {
448		return \in_array(null, $param, true);
449		} else {
450		return $param === null;
451		}
452		}
453
454		/**
455		* Get share by id, validate it's type and token
456		*
457		* @param int $id
458		* @param string $sharedSecret
459		*
460		* @return IShare
461		*
462		* @throws BadRequestException
463		* @throws ForbiddenException
464		* @throws Share\Exceptions\ShareNotFound
465		*/
466		protected function getValidShare($id, $sharedSecret) {
467		$share = $this->federatedShareProvider->getShareById($id);
468		if ($share->getShareType() !== FederatedShareProvider::SHARE_TYPE_REMOTE) {
469		throw new BadRequestException("Share with id {$id} des not exist");
470		}
471
472		if ($share->getToken() !== $sharedSecret) {
473		throw new ForbiddenException("The secret doesn not match");
474		}
475		return $share;
476		}
477
478		/**
479		* @param string $resourceType
480		*
481		* @return bool
482		*/
483		protected function isSupportedResourceType($resourceType) {
484		return $resourceType === FileNotification::RESOURCE_TYPE_FILE;
485		}
486
487		/**
488		* @param string $shareType
489		* @return bool
490		*/
491		protected function isSupportedShareType($shareType) {
492		// TODO: make it a constant
493		return $shareType === 'user';
494		}
495
496		/**
497		* @param string $protocolName
498		* @return bool
499		*/
500		protected function isSupportedProtocol($protocolName) {
501		$supportedProtocols = $this->getProtocols();
502		$supportedProtocolNames = \array_keys($supportedProtocols);
503		return \in_array($protocolName, $supportedProtocolNames);
504		}
505		}
506

owncloud / core

Pull Request — master (#32303)

OcmController::assertIncomingSharingEnabled() A

Complexity

Size

Duplication

Importance

Available Fixes

Duplication Side-by-Side

Filter issues like