OCA\Circles\Service\EventsService

Complexity

Total Complexity

20

Size/Duplication

Total Lines	233
Duplicated Lines	36.91 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	onCircleCreation()	0	20	3
A	onCircleDestruction()	15	15	3
A	onCircleInvitation()	20	20	3
A	onCircleRequestInvitation()	19	19	3
A	onCircleNewMember()	16	16	3
A	onCircleMemberLeaving()	16	16	3
A	generateEvent()	0	8	1

<?php
/**
 * Circles - Bring cloud-users closer together.
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the COPYING file.
 *
 * @author Maxence Lange <maxence@pontapreta.net>
 * @copyright 2017
 * @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\Circles\Service;

use OCA\Circles\Db\CirclesRequest;
use OCA\Circles\Model\Circle;
use OCA\Circles\Model\Member;
use OCP\Activity\IManager;
use OCP\IUser;
use OCP\IUserManager;

class EventsService {


	/** @var string */
	private $userId;

	/** @var IManager */
	private $activityManager;

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

	/** @var CirclesRequest */
	private $circlesRequest;

	/** @var MiscService */
	private $miscService;


	/**
	 * Events constructor.
	 *
	 * @param string $userId
	 * @param IManager $activityManager
	 * @param IUserManager $userManager
	 * @param CirclesRequest $circlesRequest
	 * @param MiscService $miscService
	 */
	public function __construct(
		$userId, IManager $activityManager, IUserManager $userManager,
		CirclesRequest $circlesRequest, MiscService $miscService
	) {
		$this->userId = $userId;
		$this->activityManager = $activityManager;
		$this->userManager = $userManager;
		$this->circlesRequest = $circlesRequest;
		$this->miscService = $miscService;
	}


	/**
	 * onCircleCreation()
	 *
	 * Called when a circle is created.
	 * Broadcast an activity to the cloud
	 * We won't do anything if the circle is not PUBLIC or PRIVATE
	 *
	 * @param Circle $circle
	 */
	public function onCircleCreation(Circle $circle) {

		if ($circle->getType() !== Circle::CIRCLES_PUBLIC
			&& $circle->getType() !== Circle::CIRCLES_PRIVATE
		) {
			return;
		}

		$this->userManager->callForSeenUsers(
			function($user) use ($circle) {
				/** @var IUser $user */

				$event = $this->generateEvent('circles_creation');
				$event->setAffectedUser($user->getUID());
				$event->setSubject('create', ['circle' => json_encode($circle)]);

				$this->activityManager->publish($event);
			}
		);
	}


	/**
	 * onCircleDestruction()
	 *
	 * Called when a circle is destroyed.
	 * Broadcast an activity on its members.
	 * We won't do anything if the circle is PERSONAL
	 *
	 * @param Circle $circle
	 */
	public function onCircleDestruction(Circle $circle) {

This method seems to be duplicated in your project.

		if ($circle->getType() === Circle::CIRCLES_PERSONAL) {
			return;
		}

		$members = $this->circlesRequest->getMembers($circle->getId(), Member::LEVEL_MEMBER);
		foreach ($members AS $user) {

			$event = $this->generateEvent('circles_creation');
			$event->setAffectedUser($user->getUserId());
			$event->setSubject('delete', ['circle' => json_encode($circle)]);

			$this->activityManager->publish($event);
		}
	}


	/**
	 * onCircleInvitation()
	 *
	 * Called when a member is invited to a circle.
	 * Broadcast an activity to the invited member and to the moderators of the circle.
	 *
	 * @param Circle $circle
	 * @param Member $member
	 */
	public function onCircleInvitation(Circle $circle, Member $member) {

This method seems to be duplicated in your project.

		if ($circle->getType() !== Circle::CIRCLES_PRIVATE) {
			return;
		}

		$event = $this->generateEvent('circles_invitation');
		$event->setSubject(
			'invited', ['circle' => json_encode($circle), 'member' => json_encode($member)]
		);

		$event->setAffectedUser($member->getUserId());
		$this->activityManager->publish($event);

		$members = $this->circlesRequest->getMembers($circle->getId(), Member::LEVEL_MODERATOR);
		foreach ($members AS $user) {

			$event->setAffectedUser($user->getUserId());
			$this->activityManager->publish($event);
		}
	}


	/**
	 * onCircleRequestInvitation()
	 *
	 * Called when a member request an invitation to a private circle.
	 * Broadcast an activity to the requester and to the moderators of the circle.
	 *
	 * @param Circle $circle
	 * @param Member $member
	 */
	public function onCircleRequestInvitation(Circle $circle, Member $member) {

This method seems to be duplicated in your project.

		if ($circle->getType() !== Circle::CIRCLES_PRIVATE) {
			return;
		}

		$event = $this->generateEvent('circles_invitation');
		$event->setSubject(
			'request', ['circle' => json_encode($circle), 'member' => json_encode($member)]
		);

		$event->setAffectedUser($member->getUserId());
		$this->activityManager->publish($event);

		$members = $this->circlesRequest->getMembers($circle->getId(), Member::LEVEL_MODERATOR);
		foreach ($members AS $user) {
			$event->setAffectedUser($user->getUserId());
			$this->activityManager->publish($event);
		}
	}


	/**
	 * onCircleNewMember()
	 *
	 * Called when a member is added to a circle.
	 * Broadcast an activity to the new member and to the moderators of the circle.
	 * We won't do anything if the circle is PERSONAL
	 *
	 * @param Circle $circle
	 * @param Member $member
	 */
	public function onCircleNewMember(Circle $circle, Member $member) {

This method seems to be duplicated in your project.

		if ($circle->getType() === Circle::CIRCLES_PERSONAL) {
			return;
		}

		$event = $this->generateEvent('circles_population');
		$event->setSubject(
			'new_member', ['circle' => json_encode($circle), 'member' => json_encode($member)]
		);

		$members = $this->circlesRequest->getMembers($circle->getId(), Member::LEVEL_MODERATOR);
		foreach ($members AS $user) {
			$event->setAffectedUser($user->getUserId());
			$this->activityManager->publish($event);
		}
	}


	/**
	 * onCircleMemberLeaving()
	 *
	 * Called when a member is removed from a circle.
	 * Broadcast an activity to the new member and to the moderators of the circle.
	 * We won't do anything if the circle is PERSONAL
	 *
	 * @param Circle $circle
	 * @param Member $member
	 */
	public function onCircleMemberLeaving(Circle $circle, Member $member) {

This method seems to be duplicated in your project.

		if ($circle->getType() === Circle::CIRCLES_PERSONAL) {
			return;
		}

		$event = $this->generateEvent('circles_population');
		$event->setSubject(
			'remove_member', ['circle' => json_encode($circle), 'member' => json_encode($member)]
		);

		$members = $this->circlesRequest->getMembers($circle->getId(), Member::LEVEL_MODERATOR);
		foreach ($members AS $user) {
			$event->setAffectedUser($user->getUserId());
			$this->activityManager->publish($event);
		}
	}


	/**
	 * generateEvent()
	 * Create an Activity Event with the basic settings for the app.
	 *
	 * @param $type
	 *
	 * @return \OCP\Activity\IEvent
	 */
	private function generateEvent($type) {
		$event = $this->activityManager->generateEvent();
		$event->setApp('circles')
			  ->setType($type)
			  ->setAuthor($this->userId);

		return $event;
	}


}