ActivityObjectDomainTrait::get() - Code Metrics - Inspection of "events for domain objects" - keeko/core - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( abae3b...04c3fa )

by Thomas

created 2016-05-09 16:49 UTC

ActivityObjectDomainTrait::get() A

↳ Parent: ActivityObjectDomainTrait

Complexity

Conditions	3
Paths	3

Size

Total Lines	12
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	12
rs	9.4285
cc	3
eloc	8
nc	3
nop	1

<?php
namespace keeko\core\domain\base;

use keeko\core\model\ActivityObject;
use keeko\core\model\ActivityObjectQuery;
use keeko\framework\service\ServiceContainer;
use keeko\framework\domain\payload\PayloadInterface;
use phootwork\collection\Map;
use keeko\framework\domain\payload\Found;
use keeko\framework\domain\payload\NotFound;
use keeko\framework\utils\Parameters;
use keeko\framework\utils\NameUtils;
use keeko\core\event\ActivityObjectEvent;
use keeko\framework\domain\payload\Created;
use keeko\framework\domain\payload\Updated;
use keeko\framework\domain\payload\NotUpdated;
use keeko\framework\domain\payload\Deleted;
use keeko\framework\domain\payload\NotDeleted;

/**
 */
trait ActivityObjectDomainTrait {

	/**
	 */
	protected $pool;

	/**
	 * Creates a new ActivityObject with the provided data
	 * 
	 * @param mixed $data
	 * @return PayloadInterface
	 */
	public function create($data) {
		// hydrate
		$serializer = ActivityObject::getSerializer();
		$activityObject = $serializer->hydrate(new ActivityObject(), $data);

		// dispatch
		$event = new ActivityObjectEvent($activityObject);
		$dispatcher = $this->getServiceContainer()->getDispatcher();
		$dispatcher->dispatch(ActivityObjectEvent::PRE_CREATE, $event);
		$dispatcher->dispatch(ActivityObjectEvent::PRE_SAVE, $event);
		$activityObject->save();
		$dispatcher->dispatch(ActivityObjectEvent::POST_CREATE, $event);
		$dispatcher->dispatch(ActivityObjectEvent::POST_SAVE, $event);
		return new Created(['model' => $activityObject]);
	}

	/**
	 * Deletes a ActivityObject with the given id
	 * 
	 * @param mixed $id
	 * @return PayloadInterface
	 */
	public function delete($id) {
		// find
		$activityObject = $this->get($id);

		if ($activityObject === null) {
			return new NotFound(['message' => 'ActivityObject not found.']);
		}

		// delete
		$event = new ActivityObjectEvent($activityObject);
		$dispatcher = $this->getServiceContainer()->getDispatcher();
		$dispatcher->dispatch(ActivityObjectEvent::PRE_DELETE, $event);
		$activityObject->delete();

		if ($activityObject->isDeleted()) {
			$dispatcher->dispatch(ActivityObjectEvent::POST_DELETE, $event);
			return new Deleted(['model' => $activityObject]);
		}

		return new NotDeleted(['message' => 'Could not delete ActivityObject']);
	}

	/**
	 * Returns a paginated result
	 * 
	 * @param Parameters $params
	 * @return PayloadInterface
	 */
	public function paginate(Parameters $params) {
		$sysPrefs = $this->getServiceContainer()->getPreferenceLoader()->getSystemPreferences();
		$defaultSize = $sysPrefs->getPaginationSize();
		$page = $params->getPage('number');
		$size = $params->getPage('size', $defaultSize);

		$query = ActivityObjectQuery::create();

		// sorting
		$sort = $params->getSort(ActivityObject::getSerializer()->getSortFields());
		foreach ($sort as $field => $order) {
			$method = 'orderBy' . NameUtils::toStudlyCase($field);
			$query->$method($order);
		}

		// filtering
		$filter = $params->getFilter();
		if (!empty($filter)) {
			$this->applyFilter($query, $filter);
		}

		// paginate
		$activityObject = $query->paginate($page, $size);

		// run response
		return new Found(['model' => $activityObject]);
	}

	/**
	 * Returns one ActivityObject with the given id
	 * 
	 * @param mixed $id
	 * @return PayloadInterface
	 */
	public function read($id) {
		// read
		$activityObject = $this->get($id);

		// check existence
		if ($activityObject === null) {
			return new NotFound(['message' => 'ActivityObject not found.']);
		}

		return new Found(['model' => $activityObject]);
	}

	/**
	 * Updates a ActivityObject with the given idand the provided data
	 * 
	 * @param mixed $id
	 * @param mixed $data
	 * @return PayloadInterface
	 */
	public function update($id, $data) {
		// find
		$activityObject = $this->get($id);

		if ($activityObject === null) {
			return new NotFound(['message' => 'ActivityObject not found.']);
		}

		// hydrate
		$serializer = ActivityObject::getSerializer();
		$activityObject = $serializer->hydrate($activityObject, $data);

		// dispatch
		$event = new ActivityObjectEvent($activityObject);
		$dispatcher = $this->getServiceContainer()->getDispatcher();
		$dispatcher->dispatch(ActivityObjectEvent::PRE_UPDATE, $event);
		$dispatcher->dispatch(ActivityObjectEvent::PRE_SAVE, $event);
		$rows = $activityObject->save();
		$dispatcher->dispatch(ActivityObjectEvent::POST_UPDATE, $event);
		$dispatcher->dispatch(ActivityObjectEvent::POST_SAVE, $event);

		$payload = ['model' => $activityObject];

		if ($rows === 0) {
			return new NotUpdated($payload);
		}

		return new Updated($payload);
	}

	/**
	 * Implement this functionality at keeko\core\domain\ActivityObjectDomain
	 * 
	 * @param ActivityObjectQuery $query
	 * @param mixed $filter
	 * @return void
	 */
	abstract protected function applyFilter(ActivityObjectQuery $query, $filter);

	/**
	 * Returns one ActivityObject with the given id from cache
	 * 
	 * @param mixed $id
	 * @return ActivityObject|null
	 */
	protected function get($id) {
		if ($this->pool === null) {
			$this->pool = new Map();
		} else if ($this->pool->has($id)) {
			return $this->pool->get($id);
		}

		$activityObject = ActivityObjectQuery::create()->findOneById($id);
		$this->pool->set($id, $activityObject);

		return $activityObject;
	}

	/**
	 * Returns the service container
	 * 
	 * @return ServiceContainer
	 */
	abstract protected function getServiceContainer();
}


1			<?php
2			namespace keeko\core\domain\base;
3
4			use keeko\core\model\ActivityObject;
5			use keeko\core\model\ActivityObjectQuery;
6			use keeko\framework\service\ServiceContainer;
7			use keeko\framework\domain\payload\PayloadInterface;
8			use phootwork\collection\Map;
9			use keeko\framework\domain\payload\Found;
10			use keeko\framework\domain\payload\NotFound;
11			use keeko\framework\utils\Parameters;
12			use keeko\framework\utils\NameUtils;
13			use keeko\core\event\ActivityObjectEvent;
14			use keeko\framework\domain\payload\Created;
15			use keeko\framework\domain\payload\Updated;
16			use keeko\framework\domain\payload\NotUpdated;
17			use keeko\framework\domain\payload\Deleted;
18			use keeko\framework\domain\payload\NotDeleted;
19
20			/**
21			*/
22			trait ActivityObjectDomainTrait {
23
24			/**
25			*/
26			protected $pool;
27
28			/**
29			* Creates a new ActivityObject with the provided data
30			*
31			* @param mixed $data
32			* @return PayloadInterface
33			*/
34			public function create($data) {
35			// hydrate
36			$serializer = ActivityObject::getSerializer();
37			$activityObject = $serializer->hydrate(new ActivityObject(), $data);
38
39			// dispatch
40			$event = new ActivityObjectEvent($activityObject);
41			$dispatcher = $this->getServiceContainer()->getDispatcher();
42			$dispatcher->dispatch(ActivityObjectEvent::PRE_CREATE, $event);
43			$dispatcher->dispatch(ActivityObjectEvent::PRE_SAVE, $event);
44			$activityObject->save();
45			$dispatcher->dispatch(ActivityObjectEvent::POST_CREATE, $event);
46			$dispatcher->dispatch(ActivityObjectEvent::POST_SAVE, $event);
47			return new Created(['model' => $activityObject]);
48			}
49
50			/**
51			* Deletes a ActivityObject with the given id
52			*
53			* @param mixed $id
54			* @return PayloadInterface
55			*/
56			public function delete($id) {
57			// find
58			$activityObject = $this->get($id);
59
60			if ($activityObject === null) {
61			return new NotFound(['message' => 'ActivityObject not found.']);
62			}
63
64			// delete
65			$event = new ActivityObjectEvent($activityObject);
66			$dispatcher = $this->getServiceContainer()->getDispatcher();
67			$dispatcher->dispatch(ActivityObjectEvent::PRE_DELETE, $event);
68			$activityObject->delete();
69
70			if ($activityObject->isDeleted()) {
71			$dispatcher->dispatch(ActivityObjectEvent::POST_DELETE, $event);
72			return new Deleted(['model' => $activityObject]);
73			}
74
75			return new NotDeleted(['message' => 'Could not delete ActivityObject']);
76			}
77
78			/**
79			* Returns a paginated result
80			*
81			* @param Parameters $params
82			* @return PayloadInterface
83			*/
84			public function paginate(Parameters $params) {
85			$sysPrefs = $this->getServiceContainer()->getPreferenceLoader()->getSystemPreferences();
86			$defaultSize = $sysPrefs->getPaginationSize();
87			$page = $params->getPage('number');
88			$size = $params->getPage('size', $defaultSize);
89
90			$query = ActivityObjectQuery::create();
91
92			// sorting
93			$sort = $params->getSort(ActivityObject::getSerializer()->getSortFields());
94			foreach ($sort as $field => $order) {
95			$method = 'orderBy' . NameUtils::toStudlyCase($field);
96			$query->$method($order);
97			}
98
99			// filtering
100			$filter = $params->getFilter();
101			if (!empty($filter)) {
102			$this->applyFilter($query, $filter);
103			}
104
105			// paginate
106			$activityObject = $query->paginate($page, $size);
107
108			// run response
109			return new Found(['model' => $activityObject]);
110			}
111
112			/**
113			* Returns one ActivityObject with the given id
114			*
115			* @param mixed $id
116			* @return PayloadInterface
117			*/
118			public function read($id) {
119			// read
120			$activityObject = $this->get($id);
121
122			// check existence
123			if ($activityObject === null) {
124			return new NotFound(['message' => 'ActivityObject not found.']);
125			}
126
127			return new Found(['model' => $activityObject]);
128			}
129
130			/**
131			* Updates a ActivityObject with the given idand the provided data
132			*
133			* @param mixed $id
134			* @param mixed $data
135			* @return PayloadInterface
136			*/
137			public function update($id, $data) {
138			// find
139			$activityObject = $this->get($id);
140
141			if ($activityObject === null) {
142			return new NotFound(['message' => 'ActivityObject not found.']);
143			}
144
145			// hydrate
146			$serializer = ActivityObject::getSerializer();
147			$activityObject = $serializer->hydrate($activityObject, $data);
148
149			// dispatch
150			$event = new ActivityObjectEvent($activityObject);
151			$dispatcher = $this->getServiceContainer()->getDispatcher();
152			$dispatcher->dispatch(ActivityObjectEvent::PRE_UPDATE, $event);
153			$dispatcher->dispatch(ActivityObjectEvent::PRE_SAVE, $event);
154			$rows = $activityObject->save();
155			$dispatcher->dispatch(ActivityObjectEvent::POST_UPDATE, $event);
156			$dispatcher->dispatch(ActivityObjectEvent::POST_SAVE, $event);
157
158			$payload = ['model' => $activityObject];
159
160			if ($rows === 0) {
161			return new NotUpdated($payload);
162			}
163
164			return new Updated($payload);
165			}
166
167			/**
168			* Implement this functionality at keeko\core\domain\ActivityObjectDomain
169			*
170			* @param ActivityObjectQuery $query
171			* @param mixed $filter
172			* @return void
173			*/
174			abstract protected function applyFilter(ActivityObjectQuery $query, $filter);
175
176			/**
177			* Returns one ActivityObject with the given id from cache
178			*
179			* @param mixed $id
180			* @return ActivityObject\|null
181			*/
182			protected function get($id) {
183			if ($this->pool === null) {
184			$this->pool = new Map();
185			} else if ($this->pool->has($id)) {
186			return $this->pool->get($id);
187			}
188
189			$activityObject = ActivityObjectQuery::create()->findOneById($id);
190			$this->pool->set($id, $activityObject);
191
192			return $activityObject;
193			}
194
195			/**
196			* Returns the service container
197			*
198			* @return ServiceContainer
199			*/
200			abstract protected function getServiceContainer();
201			}
202

keeko / core

Push — master ( abae3b...04c3fa )

ActivityObjectDomainTrait::get() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like