Application::userManagementHooks() - Code Metrics - Inspection of "Merge pull request #7916 from nextcloud/2fa_log" - nextcloud/server - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 8160d0...b9bbb8 )

by Morris

created 2018-01-25 14:57 UTC

Application::userManagementHooks() A

↳ Parent: Application

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	7
nc	1
nop	1
dl	0
loc	11
rs	9.4285
c	0
b	0
f	0

<?php
/**
 * @copyright Copyright (c) 2017 Joas Schilling <[email protected]>
 *
 * @author Bjoern Schiessle <[email protected]>
 * @author Joas Schilling <[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\AdminAudit\AppInfo;

use OC\Files\Filesystem;
use OC\Files\Node\File;
use OC\Group\Manager;
use OC\User\Session;
use OCA\AdminAudit\Actions\AppManagement;
use OCA\AdminAudit\Actions\Auth;
use OCA\AdminAudit\Actions\Console;
use OCA\AdminAudit\Actions\Files;
use OCA\AdminAudit\Actions\GroupManagement;
use OCA\AdminAudit\Actions\Security;
use OCA\AdminAudit\Actions\Sharing;
use OCA\AdminAudit\Actions\Trashbin;
use OCA\AdminAudit\Actions\UserManagement;
use OCA\AdminAudit\Actions\Versions;
use OCP\App\ManagerEvent;
use OCP\AppFramework\App;
use OCP\Authentication\TwoFactorAuth\IProvider;
use OCP\Console\ConsoleEvent;
use OCP\IGroupManager;
use OCP\ILogger;
use OCP\IPreview;
use OCP\IUserSession;
use OCP\Util;
use Symfony\Component\EventDispatcher\GenericEvent;

class Application extends App {

	public function __construct() {
		parent::__construct('admin_audit');
	}

	public function register() {
		$this->registerHooks();
	}

	/**
	 * Register hooks in order to log them
	 */
	protected function registerHooks() {
		$logger = $this->getContainer()->getServer()->getLogger();

		$this->userManagementHooks($logger);
		$this->groupHooks($logger);
		$this->authHooks($logger);

		$this->consoleHooks($logger);
		$this->appHooks($logger);

		$this->sharingHooks($logger);

		$this->fileHooks($logger);
		$this->trashbinHooks($logger);
		$this->versionsHooks($logger);

		$this->securityHooks($logger);
	}

	protected function userManagementHooks(ILogger $logger) {
		$userActions = new UserManagement($logger);

		Util::connectHook('OC_User', 'post_createUser',	$userActions, 'create');
		Util::connectHook('OC_User', 'post_deleteUser',	$userActions, 'delete');
		Util::connectHook('OC_User', 'changeUser',	$userActions, 'change');

		/** @var IUserSession|Session $userSession */
		$userSession = $this->getContainer()->getServer()->getUserSession();
		$userSession->listen('\OC\User', 'postSetPassword', [$userActions, 'setPassword']);
	}

	protected function groupHooks(ILogger $logger)  {
		$groupActions = new GroupManagement($logger);

		/** @var IGroupManager|Manager $groupManager */
		$groupManager = $this->getContainer()->getServer()->getGroupManager();
		$groupManager->listen('\OC\Group', 'postRemoveUser',  [$groupActions, 'removeUser']);
		$groupManager->listen('\OC\Group', 'postAddUser',  [$groupActions, 'addUser']);
		$groupManager->listen('\OC\Group', 'postDelete',  [$groupActions, 'deleteGroup']);
		$groupManager->listen('\OC\Group', 'postCreate',  [$groupActions, 'createGroup']);
	}

	protected function sharingHooks(ILogger $logger) {
		$shareActions = new Sharing($logger);

		Util::connectHook('OCP\Share', 'post_shared', $shareActions, 'shared');
		Util::connectHook('OCP\Share', 'post_unshare', $shareActions, 'unshare');
		Util::connectHook('OCP\Share', 'post_update_permissions', $shareActions, 'updatePermissions');
		Util::connectHook('OCP\Share', 'post_update_password', $shareActions, 'updatePassword');
		Util::connectHook('OCP\Share', 'post_set_expiration_date', $shareActions, 'updateExpirationDate');
		Util::connectHook('OCP\Share', 'share_link_access', $shareActions, 'shareAccessed');
	}

	protected function authHooks(ILogger $logger) {
		$authActions = new Auth($logger);

		Util::connectHook('OC_User', 'pre_login', $authActions, 'loginAttempt');
		Util::connectHook('OC_User', 'post_login', $authActions, 'loginSuccessful');
		Util::connectHook('OC_User', 'logout', $authActions, 'logout');
	}

	protected function appHooks(ILogger $logger) {

		$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
		$eventDispatcher->addListener(ManagerEvent::EVENT_APP_ENABLE, function(ManagerEvent $event) use ($logger) {
			$appActions = new AppManagement($logger);
			$appActions->enableApp($event->getAppID());
		});
		$eventDispatcher->addListener(ManagerEvent::EVENT_APP_ENABLE_FOR_GROUPS, function(ManagerEvent $event) use ($logger) {
			$appActions = new AppManagement($logger);
			$appActions->enableAppForGroups($event->getAppID(), $event->getGroups());
		});
		$eventDispatcher->addListener(ManagerEvent::EVENT_APP_DISABLE, function(ManagerEvent $event) use ($logger) {
			$appActions = new AppManagement($logger);
			$appActions->disableApp($event->getAppID());
		});

	}

	protected function consoleHooks(ILogger $logger) {
		$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
		$eventDispatcher->addListener(ConsoleEvent::EVENT_RUN, function(ConsoleEvent $event) use ($logger) {
			$appActions = new Console($logger);
			$appActions->runCommand($event->getArguments());
		});
	}

	protected function fileHooks(ILogger $logger) {
		$fileActions = new Files($logger);
		$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
		$eventDispatcher->addListener(
			IPreview::EVENT,
			function(GenericEvent $event) use ($fileActions) {
				/** @var File $file */
				$file = $event->getSubject();
				$fileActions->preview([
					'path' => substr($file->getInternalPath(), 5),
					'width' => $event->getArguments()['width'],
					'height' => $event->getArguments()['height'],
					'crop' => $event->getArguments()['crop'],
					'mode'  => $event->getArguments()['mode']
				]);
			}
		);

		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_post_rename,
			$fileActions,
			'rename'
		);
		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_post_create,
			$fileActions,
			'create'
		);
		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_post_copy,
			$fileActions,
			'copy'
		);
		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_post_write,
			$fileActions,
			'write'
		);
		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_post_update,
			$fileActions,
			'update'
		);
		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_read,
			$fileActions,
			'read'
		);
		Util::connectHook(
			Filesystem::CLASSNAME,
			Filesystem::signal_delete,
			$fileActions,
			'delete'
		);
	}

	protected function versionsHooks(ILogger $logger) {
		$versionsActions = new Versions($logger);
		Util::connectHook('\OCP\Versions', 'rollback', $versionsActions, 'rollback');
		Util::connectHook('\OCP\Versions', 'delete',$versionsActions, 'delete');
	}

	protected function trashbinHooks(ILogger $logger) {
		$trashActions = new Trashbin($logger);
		Util::connectHook('\OCP\Trashbin', 'preDelete', $trashActions, 'delete');
		Util::connectHook('\OCA\Files_Trashbin\Trashbin', 'post_restore', $trashActions, 'restore');
	}

	protected function securityHooks(ILogger $logger) {
		$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
		$eventDispatcher->addListener(IProvider::EVENT_SUCCESS, function(GenericEvent $event) use ($logger) {
			$security = new Security($logger);
			$security->twofactorSuccess($event->getSubject(), $event->getArguments());
		});
		$eventDispatcher->addListener(IProvider::EVENT_FAILED, function(GenericEvent $event) use ($logger) {
			$security = new Security($logger);
			$security->twofactorFailed($event->getSubject(), $event->getArguments());
		});
	}
}


1			<?php
2			/**
3			* @copyright Copyright (c) 2017 Joas Schilling <[email protected]>
4			*
5			* @author Bjoern Schiessle <[email protected]>
6			* @author Joas Schilling <[email protected]>
7			*
8			* @license GNU AGPL version 3 or any later version
9			*
10			* This program is free software: you can redistribute it and/or modify
11			* it under the terms of the GNU Affero General Public License as
12			* published by the Free Software Foundation, either version 3 of the
13			* License, or (at your option) any later version.
14			*
15			* This program is distributed in the hope that it will be useful,
16			* but WITHOUT ANY WARRANTY; without even the implied warranty of
17			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18			* GNU Affero General Public License for more details.
19			*
20			* You should have received a copy of the GNU Affero General Public License
21			* along with this program. If not, see <http://www.gnu.org/licenses/>.
22			*
23			*/
24
25			namespace OCA\AdminAudit\AppInfo;
26
27			use OC\Files\Filesystem;
28			use OC\Files\Node\File;
29			use OC\Group\Manager;
30			use OC\User\Session;
31			use OCA\AdminAudit\Actions\AppManagement;
32			use OCA\AdminAudit\Actions\Auth;
33			use OCA\AdminAudit\Actions\Console;
34			use OCA\AdminAudit\Actions\Files;
35			use OCA\AdminAudit\Actions\GroupManagement;
36			use OCA\AdminAudit\Actions\Security;
37			use OCA\AdminAudit\Actions\Sharing;
38			use OCA\AdminAudit\Actions\Trashbin;
39			use OCA\AdminAudit\Actions\UserManagement;
40			use OCA\AdminAudit\Actions\Versions;
41			use OCP\App\ManagerEvent;
42			use OCP\AppFramework\App;
43			use OCP\Authentication\TwoFactorAuth\IProvider;
44			use OCP\Console\ConsoleEvent;
45			use OCP\IGroupManager;
46			use OCP\ILogger;
47			use OCP\IPreview;
48			use OCP\IUserSession;
49			use OCP\Util;
50			use Symfony\Component\EventDispatcher\GenericEvent;
51
52			class Application extends App {
53
54			public function __construct() {
55			parent::__construct('admin_audit');
56			}
57
58			public function register() {
59			$this->registerHooks();
60			}
61
62			/**
63			* Register hooks in order to log them
64			*/
65			protected function registerHooks() {
66			$logger = $this->getContainer()->getServer()->getLogger();
67
68			$this->userManagementHooks($logger);
69			$this->groupHooks($logger);
70			$this->authHooks($logger);
71
72			$this->consoleHooks($logger);
73			$this->appHooks($logger);
74
75			$this->sharingHooks($logger);
76
77			$this->fileHooks($logger);
78			$this->trashbinHooks($logger);
79			$this->versionsHooks($logger);
80
81			$this->securityHooks($logger);
82			}
83
84			protected function userManagementHooks(ILogger $logger) {
85			$userActions = new UserManagement($logger);
86
87			Util::connectHook('OC_User', 'post_createUser', $userActions, 'create');
88			Util::connectHook('OC_User', 'post_deleteUser', $userActions, 'delete');
89			Util::connectHook('OC_User', 'changeUser', $userActions, 'change');
90
91			/** @var IUserSession\|Session $userSession */
92			$userSession = $this->getContainer()->getServer()->getUserSession();
93			$userSession->listen('\OC\User', 'postSetPassword', [$userActions, 'setPassword']);
94			}
95
96			protected function groupHooks(ILogger $logger) {
97			$groupActions = new GroupManagement($logger);
98
99			/** @var IGroupManager\|Manager $groupManager */
100			$groupManager = $this->getContainer()->getServer()->getGroupManager();
101			$groupManager->listen('\OC\Group', 'postRemoveUser', [$groupActions, 'removeUser']);
102			$groupManager->listen('\OC\Group', 'postAddUser', [$groupActions, 'addUser']);
103			$groupManager->listen('\OC\Group', 'postDelete', [$groupActions, 'deleteGroup']);
104			$groupManager->listen('\OC\Group', 'postCreate', [$groupActions, 'createGroup']);
105			}
106
107			protected function sharingHooks(ILogger $logger) {
108			$shareActions = new Sharing($logger);
109
110			Util::connectHook('OCP\Share', 'post_shared', $shareActions, 'shared');
111			Util::connectHook('OCP\Share', 'post_unshare', $shareActions, 'unshare');
112			Util::connectHook('OCP\Share', 'post_update_permissions', $shareActions, 'updatePermissions');
113			Util::connectHook('OCP\Share', 'post_update_password', $shareActions, 'updatePassword');
114			Util::connectHook('OCP\Share', 'post_set_expiration_date', $shareActions, 'updateExpirationDate');
115			Util::connectHook('OCP\Share', 'share_link_access', $shareActions, 'shareAccessed');
116			}
117
118			protected function authHooks(ILogger $logger) {
119			$authActions = new Auth($logger);
120
121			Util::connectHook('OC_User', 'pre_login', $authActions, 'loginAttempt');
122			Util::connectHook('OC_User', 'post_login', $authActions, 'loginSuccessful');
123			Util::connectHook('OC_User', 'logout', $authActions, 'logout');
124			}
125
126			protected function appHooks(ILogger $logger) {
127
128			$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
129			$eventDispatcher->addListener(ManagerEvent::EVENT_APP_ENABLE, function(ManagerEvent $event) use ($logger) {
130			$appActions = new AppManagement($logger);
131			$appActions->enableApp($event->getAppID());
132			});
133			$eventDispatcher->addListener(ManagerEvent::EVENT_APP_ENABLE_FOR_GROUPS, function(ManagerEvent $event) use ($logger) {
134			$appActions = new AppManagement($logger);
135			$appActions->enableAppForGroups($event->getAppID(), $event->getGroups());
136			});
137			$eventDispatcher->addListener(ManagerEvent::EVENT_APP_DISABLE, function(ManagerEvent $event) use ($logger) {
138			$appActions = new AppManagement($logger);
139			$appActions->disableApp($event->getAppID());
140			});
141
142			}
143
144			protected function consoleHooks(ILogger $logger) {
145			$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
146			$eventDispatcher->addListener(ConsoleEvent::EVENT_RUN, function(ConsoleEvent $event) use ($logger) {
147			$appActions = new Console($logger);
148			$appActions->runCommand($event->getArguments());
149			});
150			}
151
152			protected function fileHooks(ILogger $logger) {
153			$fileActions = new Files($logger);
154			$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
155			$eventDispatcher->addListener(
156			IPreview::EVENT,
157			function(GenericEvent $event) use ($fileActions) {
158			/** @var File $file */
159			$file = $event->getSubject();
160			$fileActions->preview([
161			'path' => substr($file->getInternalPath(), 5),
162			'width' => $event->getArguments()['width'],
163			'height' => $event->getArguments()['height'],
164			'crop' => $event->getArguments()['crop'],
165			'mode' => $event->getArguments()['mode']
166			]);
167			}
168			);
169
170			Util::connectHook(
171			Filesystem::CLASSNAME,
172			Filesystem::signal_post_rename,
173			$fileActions,
174			'rename'
175			);
176			Util::connectHook(
177			Filesystem::CLASSNAME,
178			Filesystem::signal_post_create,
179			$fileActions,
180			'create'
181			);
182			Util::connectHook(
183			Filesystem::CLASSNAME,
184			Filesystem::signal_post_copy,
185			$fileActions,
186			'copy'
187			);
188			Util::connectHook(
189			Filesystem::CLASSNAME,
190			Filesystem::signal_post_write,
191			$fileActions,
192			'write'
193			);
194			Util::connectHook(
195			Filesystem::CLASSNAME,
196			Filesystem::signal_post_update,
197			$fileActions,
198			'update'
199			);
200			Util::connectHook(
201			Filesystem::CLASSNAME,
202			Filesystem::signal_read,
203			$fileActions,
204			'read'
205			);
206			Util::connectHook(
207			Filesystem::CLASSNAME,
208			Filesystem::signal_delete,
209			$fileActions,
210			'delete'
211			);
212			}
213
214			protected function versionsHooks(ILogger $logger) {
215			$versionsActions = new Versions($logger);
216			Util::connectHook('\OCP\Versions', 'rollback', $versionsActions, 'rollback');
217			Util::connectHook('\OCP\Versions', 'delete',$versionsActions, 'delete');
218			}
219
220			protected function trashbinHooks(ILogger $logger) {
221			$trashActions = new Trashbin($logger);
222			Util::connectHook('\OCP\Trashbin', 'preDelete', $trashActions, 'delete');
223			Util::connectHook('\OCA\Files_Trashbin\Trashbin', 'post_restore', $trashActions, 'restore');
224			}
225
226			protected function securityHooks(ILogger $logger) {
227			$eventDispatcher = $this->getContainer()->getServer()->getEventDispatcher();
228			$eventDispatcher->addListener(IProvider::EVENT_SUCCESS, function(GenericEvent $event) use ($logger) {
229			$security = new Security($logger);
230			$security->twofactorSuccess($event->getSubject(), $event->getArguments());
231			});
232			$eventDispatcher->addListener(IProvider::EVENT_FAILED, function(GenericEvent $event) use ($logger) {
233			$security = new Security($logger);
234			$security->twofactorFailed($event->getSubject(), $event->getArguments());
235			});
236			}
237			}
238

nextcloud / server

Push — master ( 8160d0...b9bbb8 )

Application::userManagementHooks() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like