Application::consoleHooks() - Code Metrics - Inspection of "Merge pull request #5580 from nextcloud/admin-audi..." - nextcloud/server - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 7d58bb...687957 )

by Morris

created 2017-07-05 14:16 UTC

Application::consoleHooks() A

↳ Parent: Application

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php
/**
 * @copyright Copyright (c) 2017 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\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\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);
	}

	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');
	}
}


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

nextcloud / server

Push — master ( 7d58bb...687957 )

Application::consoleHooks() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like