@@ -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; |