Watcher::__construct() - Code Metrics - Inspection of "Bump elliptic from 6.5.3 to 6.5.4" - matiasdelellis/facerecognition - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — dependabot/npm_and_yarn/ellipt... ( eb0fee )

unknown

created 2021-03-10 16:53 UTC

Watcher::__construct() A

↳ Parent: Watcher

Complexity

Conditions	1
Paths	1

Size

Total Lines	17
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	1

Importance

Changes	8
Bugs	1	Features	0

Metric	Value
cc	1
eloc	8
c	8
b	1
f	0
nc	1
nop	8
dl	0
loc	17
ccs	9
cts	9
cp	1
crap	1
rs	10

How to fix Many Parameters

<?php
/**
 * @copyright Copyright (c) 2016, Roeland Jago Douma <[email protected]>
 * @copyright Copyright (c) 2017-2020 Matias De lellis <[email protected]>
 *
 * @author Roeland Jago Douma <[email protected]>
 * @author Matias De lellis <[email protected]>
 *
 * @license GNU AGPL version 3 or any later version
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * 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
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
namespace OCA\FaceRecognition;

use OCP\Files\Folder;
use OCP\Files\Node;
use OCP\ILogger;
use OCP\IUserManager;

use OCA\FaceRecognition\Service\FaceManagementService;
use OCA\FaceRecognition\Service\FileService;
use OCA\FaceRecognition\Service\SettingsService;

use OCA\FaceRecognition\Db\Face;
use OCA\FaceRecognition\Db\Image;

use OCA\FaceRecognition\Db\FaceMapper;
use OCA\FaceRecognition\Db\ImageMapper;
use OCA\FaceRecognition\Db\PersonMapper;

class Watcher {

	/** @var ILogger Logger */
	private $logger;

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

	/** @var FaceMapper */
	private $faceMapper;

	/** @var ImageMapper */
	private $imageMapper;

	/** @var PersonMapper */
	private $personMapper;

	/** @var SettingsService */
	private $settingsService;

	/** @var FileService */
	private $fileService;

	/** @var FaceManagementService */
	private $faceManagementService;

	/**
	 * Watcher constructor.
	 *
	 * @param ILogger $logger
	 * @param IUserManager $userManager
	 * @param FaceMapper $faceMapper
	 * @param ImageMapper $imageMapper
	 * @param PersonMapper $personMapper
	 * @param SettingsService $settingsService
	 * @param FileService $fileService
	 * @param FaceManagementService $faceManagementService
	 */
	public function __construct(ILogger               $logger,
	                            IUserManager          $userManager,
	                            FaceMapper            $faceMapper,
	                            ImageMapper           $imageMapper,
	                            PersonMapper          $personMapper,
	                            SettingsService       $settingsService,
	                            FileService           $fileService,
	                            FaceManagementService $faceManagementService)
	{
		$this->logger                = $logger;
		$this->userManager           = $userManager;
		$this->faceMapper            = $faceMapper;
		$this->imageMapper           = $imageMapper;
		$this->personMapper          = $personMapper;
		$this->settingsService       = $settingsService;
		$this->fileService           = $fileService;
		$this->faceManagementService = $faceManagementService;
	}

	/**
	 * A node has been updated. We just store the file id
	 * with the current user in the DB
	 *
	 * @param Node $node
	 */
	public function postWrite(Node $node) {
		if (!$this->fileService->isAllowedNode($node)) {
			// Nextcloud sends the Hooks when create thumbnails for example.
			return;
		}

		if ($node instanceof Folder) {
			return;
		}

		$modelId = $this->settingsService->getCurrentFaceModel();
		if ($modelId === SettingsService::FALLBACK_CURRENT_MODEL) {
			$this->logger->debug("Skipping inserting file since there are no configured model");
			return;
		}

		$owner = null;
		if ($this->fileService->isUserFile($node)) {
			$owner = $node->getOwner()->getUid();
		} else {
			if (!\OC::$server->getUserSession()->isLoggedIn()) {
				$this->logger->debug('Skipping interting file ' . $node->getName() . ' since we cannot determine the owner.');
				return;
			}
			$owner = \OC::$server->getUserSession()->getUser()->getUID();
		}

		if (!$this->userManager->userExists($owner)) {
			$this->logger->debug(
				"Skipping inserting file " . $node->getName() . " because it seems that user  " . $owner . " doesn't exist");
			return;
		}

		$enabled = $this->settingsService->getUserEnabled($owner);
		if (!$enabled) {
			$this->logger->debug('The user ' . $owner . ' not have the analysis enabled. Skipping');
			return;
		}

		if ($node->getName() === FileService::NOMEDIA_FILE) {
			// If user added this file, it means all images in this and all child directories should be removed.
			// Instead of doing that here, it's better to just add flag that image removal should be done.
			$this->settingsService->setNeedRemoveStaleImages(true, $owner);
			return;
		}

		if ($node->getName() === FileService::FACERECOGNITION_SETTINGS_FILE) {
			// This file can enable or disable the analysis, so I have to look for new files and forget others.
			$this->settingsService->setNeedRemoveStaleImages(true, $owner);
			$this->settingsService->setUserFullScanDone(false, $owner);
			return;
		}

		if (!$this->settingsService->isAllowedMimetype($node->getMimeType())) {
			// The file is not an image or the model does not support it
			return;
		}

		if ($this->fileService->isUnderNoDetection($node)) {
			$this->logger->debug(
				"Skipping inserting image " . $node->getName() . " because is inside an folder that contains a .nomedia file");
			return;
		}

		$this->logger->debug("Inserting/updating image " . $node->getName() . " for face recognition");

		$image = new Image();
		$image->setUser($owner);
		$image->setFile($node->getId());
		$image->setModel($modelId);

		$imageId = $this->imageMapper->imageExists($image);
		if ($imageId === null) {
			// todo: can we have larger transaction with bulk insert?
			$this->imageMapper->insert($image);
		} else {
			$this->imageMapper->resetImage($image);
			// note that invalidatePersons depends on existence of faces for a given image,
			// and we must invalidate before we delete faces!
			$this->personMapper->invalidatePersons($imageId);

			// Fetch all faces to be deleted before deleting them, and then delete them
			$facesToRemove = $this->faceMapper->findByImage($imageId);
			$this->faceMapper->removeFromImage($imageId);

			// If any person is now without faces, remove those (empty) persons
			foreach ($facesToRemove as $faceToRemove) {
				if ($faceToRemove->getPerson() !== null) {
					$this->personMapper->removeIfEmpty($faceToRemove->getPerson());
				}
			}
		}
	}

	/**
	 * A node has been deleted. Remove faces with file id
	 * with the current user in the DB
	 *
	 * @param Node $node
	 */
	public function postDelete(Node $node) {
		if (!$this->fileService->isAllowedNode($node)) {
			// Nextcloud sends the Hooks when create thumbnails for example.
			return;
		}

		if ($node instanceof Folder) {
			return;
		}

		$modelId = $this->settingsService->getCurrentFaceModel();
		if ($modelId === SettingsService::FALLBACK_CURRENT_MODEL) {
			$this->logger->debug("Skipping deleting file since there are no configured model");
			return;
		}

		$owner = null;
		if ($this->fileService->isUserFile($node)) {
			$owner = $node->getOwner()->getUid();
		} else {
			if (!\OC::$server->getUserSession()->isLoggedIn()) {
				$this->logger->debug('Skipping deleting the file ' . $node->getName() .  ' since we cannot determine the owner');
				return;
			}
			$owner = \OC::$server->getUserSession()->getUser()->getUID();
		}

		$enabled = $this->settingsService->getUserEnabled($owner);
		if (!$enabled) {
			$this->logger->debug('The user ' . $owner . ' not have the analysis enabled. Skipping');
			return;
		}

		if ($node->getName() === FileService::NOMEDIA_FILE) {
			// If user deleted file named .nomedia, that means all images in this and all child directories should be added.
			// But, instead of doing that here, better option seem to be to just reset flag that image scan is not done.
			// This will trigger another round of image crawling in AddMissingImagesTask for this user and those images will be added.
			$this->settingsService->setUserFullScanDone(false, $owner);
			return;
		}

		if ($node->getName() === FileService::FACERECOGNITION_SETTINGS_FILE) {
			// This file can enable or disable the analysis, so I have to look for new files and forget others.
			$this->settingsService->setNeedRemoveStaleImages(true, $owner);
			$this->settingsService->setUserFullScanDone(false, $owner);
			return;
		}

		if (!$this->settingsService->isAllowedMimetype($node->getMimeType())) {
			// The file is not an image or the model does not support it
			return;
		}

		$this->logger->debug("Deleting image " . $node->getName() . " from face recognition");

		$image = new Image();
		$image->setUser($owner);
		$image->setFile($node->getId());
		$image->setModel($modelId);

		$imageId = $this->imageMapper->imageExists($image);
		if ($imageId !== null) {
			// note that invalidatePersons depends on existence of faces for a given image,
			// and we must invalidate before we delete faces!
			$this->personMapper->invalidatePersons($imageId);

			// Fetch all faces to be deleted before deleting them, and then delete them
			$facesToRemove = $this->faceMapper->findByImage($imageId);
			$this->faceMapper->removeFromImage($imageId);

			$image->setId($imageId);
			$this->imageMapper->delete($image);

			// If any person is now without faces, remove those (empty) persons
			foreach ($facesToRemove as $faceToRemove) {
				if ($faceToRemove->getPerson() !== null) {
					$this->personMapper->removeIfEmpty($faceToRemove->getPerson());
				}
			}
		}
	}

	/**
	 * A user has been deleted. Cleanup everything from this user.
	 *
	 * @param \OC\User\User $user Deleted user
	 */
	public function postUserDelete(\OC\User\User $user) {
filter:
    dependency_paths: ["lib/*"]
		$userId = $user->getUid();
		$this->faceManagementService->resetAllForUser($userId);
		$this->logger->info("Removed all face recognition data for deleted user " . $userId);
	}
}


1		<?php
2		/**
3		* @copyright Copyright (c) 2016, Roeland Jago Douma <[email protected]>
4		* @copyright Copyright (c) 2017-2020 Matias De lellis <[email protected]>
5		*
6		* @author Roeland Jago Douma <[email protected]>
7		* @author Matias De lellis <[email protected]>
8		*
9		* @license GNU AGPL version 3 or any later version
10		*
11		* This program is free software: you can redistribute it and/or modify
12		* it under the terms of the GNU Affero General Public License as
13		* published by the Free Software Foundation, either version 3 of the
14		* License, or (at your option) any later version.
15		*
16		* This program is distributed in the hope that it will be useful,
17		* but WITHOUT ANY WARRANTY; without even the implied warranty of
18		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19		* GNU Affero General Public License for more details.
20		*
21		* You should have received a copy of the GNU Affero General Public License
22		* along with this program. If not, see <http://www.gnu.org/licenses/>.
23		*
24		*/
25		namespace OCA\FaceRecognition;
26
27		use OCP\Files\Folder;
28		use OCP\Files\Node;
29		use OCP\ILogger;
30		use OCP\IUserManager;
31
32		use OCA\FaceRecognition\Service\FaceManagementService;
33		use OCA\FaceRecognition\Service\FileService;
34		use OCA\FaceRecognition\Service\SettingsService;
35
36		use OCA\FaceRecognition\Db\Face;
37		use OCA\FaceRecognition\Db\Image;
38
39		use OCA\FaceRecognition\Db\FaceMapper;
40		use OCA\FaceRecognition\Db\ImageMapper;
41		use OCA\FaceRecognition\Db\PersonMapper;
42
43		class Watcher {
44
45		/** @var ILogger Logger */
46		private $logger;
47
48		/** @var IUserManager */
49		private $userManager;
50
51		/** @var FaceMapper */
52		private $faceMapper;
53
54		/** @var ImageMapper */
55		private $imageMapper;
56
57		/** @var PersonMapper */
58		private $personMapper;
59
60		/** @var SettingsService */
61		private $settingsService;
62
63		/** @var FileService */
64		private $fileService;
65
66		/** @var FaceManagementService */
67		private $faceManagementService;
68
69		/**
70		* Watcher constructor.
71		*
72		* @param ILogger $logger
73		* @param IUserManager $userManager
74		* @param FaceMapper $faceMapper
75		* @param ImageMapper $imageMapper
76		* @param PersonMapper $personMapper
77		* @param SettingsService $settingsService
78		* @param FileService $fileService
79		* @param FaceManagementService $faceManagementService
80		*/
81	1	public function __construct(ILogger $logger,
82		IUserManager $userManager,
83		FaceMapper $faceMapper,
84		ImageMapper $imageMapper,
85		PersonMapper $personMapper,
86		SettingsService $settingsService,
87		FileService $fileService,
88		FaceManagementService $faceManagementService)
89		{
90	1	$this->logger = $logger;
91	1	$this->userManager = $userManager;
92	1	$this->faceMapper = $faceMapper;
93	1	$this->imageMapper = $imageMapper;
94	1	$this->personMapper = $personMapper;
95	1	$this->settingsService = $settingsService;
96	1	$this->fileService = $fileService;
97	1	$this->faceManagementService = $faceManagementService;
98	1	}
99
100		/**
101		* A node has been updated. We just store the file id
102		* with the current user in the DB
103		*
104		* @param Node $node
105		*/
106	28	public function postWrite(Node $node) {
107	28	if (!$this->fileService->isAllowedNode($node)) {
108		// Nextcloud sends the Hooks when create thumbnails for example.
109	28	return;
110		}
111
112	28	if ($node instanceof Folder) {
113	28	return;
114		}
115
116		$modelId = $this->settingsService->getCurrentFaceModel();
117		if ($modelId === SettingsService::FALLBACK_CURRENT_MODEL) {
118		$this->logger->debug("Skipping inserting file since there are no configured model");
119		return;
120		}
121
122		$owner = null;
123		if ($this->fileService->isUserFile($node)) {
124		$owner = $node->getOwner()->getUid();
125		} else {
126		if (!\OC::$server->getUserSession()->isLoggedIn()) {
127		$this->logger->debug('Skipping interting file ' . $node->getName() . ' since we cannot determine the owner.');
128		return;
129		}
130		$owner = \OC::$server->getUserSession()->getUser()->getUID();
131		}
132
133		if (!$this->userManager->userExists($owner)) {
134		$this->logger->debug(
135		"Skipping inserting file " . $node->getName() . " because it seems that user " . $owner . " doesn't exist");
136		return;
137		}
138
139		$enabled = $this->settingsService->getUserEnabled($owner);
140		if (!$enabled) {
141		$this->logger->debug('The user ' . $owner . ' not have the analysis enabled. Skipping');
142		return;
143		}
144
145		if ($node->getName() === FileService::NOMEDIA_FILE) {
146		// If user added this file, it means all images in this and all child directories should be removed.
147		// Instead of doing that here, it's better to just add flag that image removal should be done.
148		$this->settingsService->setNeedRemoveStaleImages(true, $owner);
149		return;
150		}
151
152		if ($node->getName() === FileService::FACERECOGNITION_SETTINGS_FILE) {
153		// This file can enable or disable the analysis, so I have to look for new files and forget others.
154		$this->settingsService->setNeedRemoveStaleImages(true, $owner);
155		$this->settingsService->setUserFullScanDone(false, $owner);
156		return;
157		}
158
159		if (!$this->settingsService->isAllowedMimetype($node->getMimeType())) {
160		// The file is not an image or the model does not support it
161		return;
162		}
163
164		if ($this->fileService->isUnderNoDetection($node)) {
165		$this->logger->debug(
166		"Skipping inserting image " . $node->getName() . " because is inside an folder that contains a .nomedia file");
167		return;
168		}
169
170		$this->logger->debug("Inserting/updating image " . $node->getName() . " for face recognition");
171
172		$image = new Image();
173		$image->setUser($owner);
174		$image->setFile($node->getId());
175		$image->setModel($modelId);
176
177		$imageId = $this->imageMapper->imageExists($image);
178		if ($imageId === null) {
179		// todo: can we have larger transaction with bulk insert?
180		$this->imageMapper->insert($image);
181		} else {
182		$this->imageMapper->resetImage($image);
183		// note that invalidatePersons depends on existence of faces for a given image,
184		// and we must invalidate before we delete faces!
185		$this->personMapper->invalidatePersons($imageId);
186
187		// Fetch all faces to be deleted before deleting them, and then delete them
188		$facesToRemove = $this->faceMapper->findByImage($imageId);
189		$this->faceMapper->removeFromImage($imageId);
190
191		// If any person is now without faces, remove those (empty) persons
192		foreach ($facesToRemove as $faceToRemove) {
193		if ($faceToRemove->getPerson() !== null) {
194		$this->personMapper->removeIfEmpty($faceToRemove->getPerson());
195		}
196		}
197		}
198		}
199
200		/**
201		* A node has been deleted. Remove faces with file id
202		* with the current user in the DB
203		*
204		* @param Node $node
205		*/
206		public function postDelete(Node $node) {
207		if (!$this->fileService->isAllowedNode($node)) {
208		// Nextcloud sends the Hooks when create thumbnails for example.
209		return;
210		}
211
212		if ($node instanceof Folder) {
213		return;
214		}
215
216		$modelId = $this->settingsService->getCurrentFaceModel();
217		if ($modelId === SettingsService::FALLBACK_CURRENT_MODEL) {
218		$this->logger->debug("Skipping deleting file since there are no configured model");
219		return;
220		}
221
222		$owner = null;
223		if ($this->fileService->isUserFile($node)) {
224		$owner = $node->getOwner()->getUid();
225		} else {
226		if (!\OC::$server->getUserSession()->isLoggedIn()) {
227		$this->logger->debug('Skipping deleting the file ' . $node->getName() . ' since we cannot determine the owner');
228		return;
229		}
230		$owner = \OC::$server->getUserSession()->getUser()->getUID();
231		}
232
233		$enabled = $this->settingsService->getUserEnabled($owner);
234		if (!$enabled) {
235		$this->logger->debug('The user ' . $owner . ' not have the analysis enabled. Skipping');
236		return;
237		}
238
239		if ($node->getName() === FileService::NOMEDIA_FILE) {
240		// If user deleted file named .nomedia, that means all images in this and all child directories should be added.
241		// But, instead of doing that here, better option seem to be to just reset flag that image scan is not done.
242		// This will trigger another round of image crawling in AddMissingImagesTask for this user and those images will be added.
243		$this->settingsService->setUserFullScanDone(false, $owner);
244		return;
245		}
246
247		if ($node->getName() === FileService::FACERECOGNITION_SETTINGS_FILE) {
248		// This file can enable or disable the analysis, so I have to look for new files and forget others.
249		$this->settingsService->setNeedRemoveStaleImages(true, $owner);
250		$this->settingsService->setUserFullScanDone(false, $owner);
251		return;
252		}
253
254		if (!$this->settingsService->isAllowedMimetype($node->getMimeType())) {
255		// The file is not an image or the model does not support it
256		return;
257		}
258
259		$this->logger->debug("Deleting image " . $node->getName() . " from face recognition");
260
261		$image = new Image();
262		$image->setUser($owner);
263		$image->setFile($node->getId());
264		$image->setModel($modelId);
265
266		$imageId = $this->imageMapper->imageExists($image);
267		if ($imageId !== null) {
268		// note that invalidatePersons depends on existence of faces for a given image,
269		// and we must invalidate before we delete faces!
270		$this->personMapper->invalidatePersons($imageId);
271
272		// Fetch all faces to be deleted before deleting them, and then delete them
273		$facesToRemove = $this->faceMapper->findByImage($imageId);
274		$this->faceMapper->removeFromImage($imageId);
275
276		$image->setId($imageId);
277		$this->imageMapper->delete($image);
278
279		// If any person is now without faces, remove those (empty) persons
280		foreach ($facesToRemove as $faceToRemove) {
281		if ($faceToRemove->getPerson() !== null) {
282		$this->personMapper->removeIfEmpty($faceToRemove->getPerson());
283		}
284		}
285		}
286		}
287
288		/**
289		* A user has been deleted. Cleanup everything from this user.
290		*
291		* @param \OC\User\User $user Deleted user
292		*/
293	28	public function postUserDelete(\OC\User\User $user) {
		0 ignored issues – show Bug introduced 2019-02-05 20:17 UTC by Report Bug Copy Issue Report The type `OC\User\User` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
294	28	$userId = $user->getUid();
295	28	$this->faceManagementService->resetAllForUser($userId);
296	28	$this->logger->info("Removed all face recognition data for deleted user " . $userId);
297	28	}
298		}
299

matiasdelellis / facerecognition

Push — dependabot/npm_and_yarn/ellipt... ( eb0fee )

Watcher::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Many Parameters

Many Parameters

Duplication Side-by-Side

Filter issues like