@@ -18,5 +18,8 @@ |
||
18 | 18 | { |
19 | 19 | public function get(UserId $id) : User; |
20 | 20 | |
21 | + /** |
|
22 | + * @return void |
|
23 | + */ |
|
21 | 24 | public function save(User $user) : void; |
22 | 25 | } |
@@ -18,6 +18,9 @@ |
||
18 | 18 | |
19 | 19 | interface EventStore |
20 | 20 | { |
21 | + /** |
|
22 | + * @return void |
|
23 | + */ |
|
21 | 24 | public function appendTo(EventStream $stream) : void; |
22 | 25 | |
23 | 26 | public function streamOfId(Id $aggregateRootId) : EventStream; |
@@ -20,5 +20,8 @@ |
||
20 | 20 | { |
21 | 21 | public function eventType() : string; |
22 | 22 | |
23 | + /** |
|
24 | + * @return void |
|
25 | + */ |
|
23 | 26 | public function handle(DomainEvent $event) : void; |
24 | 27 | } |
@@ -49,6 +49,9 @@ |
||
49 | 49 | $this->tokenStorage->getToken()->setUser(new User($this->userId($request))); |
50 | 50 | } |
51 | 51 | |
52 | + /** |
|
53 | + * @return string |
|
54 | + */ |
|
52 | 55 | private function userId(Request $request) : ?string |
53 | 56 | { |
54 | 57 | if ($request->headers->has('Authorization')) { |
@@ -18,5 +18,8 @@ |
||
18 | 18 | { |
19 | 19 | public function get(NotificationId $id) : Notification; |
20 | 20 | |
21 | + /** |
|
22 | + * @return void |
|
23 | + */ |
|
21 | 24 | public function save(Notification $notification) : void; |
22 | 25 | } |
@@ -14,8 +14,8 @@ |
||
14 | 14 | |
15 | 15 | namespace Kreta\Notifier\Infrastructure\Projection\EventHandler\Elasticsearch\Inbox; |
16 | 16 | |
17 | -use Kreta\Notifier\Domain\Model\Inbox\NotificationStatus; |
|
18 | 17 | use Kreta\Notifier\Domain\Model\Inbox\NotificationMarkedAsUnread; |
18 | +use Kreta\Notifier\Domain\Model\Inbox\NotificationStatus; |
|
19 | 19 | use Kreta\SharedKernel\Domain\Model\DomainEvent; |
20 | 20 | use Kreta\SharedKernel\Projection\EventHandler; |
21 | 21 | use ONGR\ElasticsearchBundle\Service\Repository; |