| @@ -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 | } | 
| @@ -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 | } | 
| @@ -16,5 +16,8 @@ | ||
| 16 | 16 | |
| 17 | 17 | interface NotificationSpecificationFactory | 
| 18 | 18 |  { | 
| 19 | + /** | |
| 20 | + * @return \Kreta\Notifier\Infrastructure\Domain\ReadModel\Inbox\Notification\ElasticsearchNotificationsOfUserSpecification | |
| 21 | + */ | |
| 19 | 22 | public function createNotificationsOfUser(string $userId, int $from = 0, int $size = -1, string $status = null); | 
| 20 | 23 | } | 
| @@ -18,9 +18,15 @@ | ||
| 18 | 18 | |
| 19 | 19 | interface NotificationView | 
| 20 | 20 |  { | 
| 21 | + /** | |
| 22 | + * @return Notification | |
| 23 | + */ | |
| 21 | 24 | public function notificationOfId(NotificationId $notificationId) : ?Notification; | 
| 22 | 25 | |
| 23 | 26 | public function search($searchSpecification) : array; | 
| 24 | 27 | |
| 28 | + /** | |
| 29 | + * @return void | |
| 30 | + */ | |
| 25 | 31 | public function save(Notification $notification) : void; | 
| 26 | 32 | } | 
| @@ -20,5 +20,8 @@ | ||
| 20 | 20 |  { | 
| 21 | 21 | public function userOfId(UserId $userId) : ?User; | 
| 22 | 22 | |
| 23 | + /** | |
| 24 | + * @return void | |
| 25 | + */ | |
| 23 | 26 | public function save(User $user) : void; | 
| 24 | 27 | } | 
| @@ -20,5 +20,8 @@ | ||
| 20 | 20 |  { | 
| 21 | 21 | public function isSubscribeTo() : string; | 
| 22 | 22 | |
| 23 | + /** | |
| 24 | + * @return void | |
| 25 | + */ | |
| 23 | 26 | public function handle(DomainEvent $event) : void; | 
| 24 | 27 | } | 
| @@ -16,6 +16,9 @@ | ||
| 16 | 16 | |
| 17 | 17 | interface Serializer | 
| 18 | 18 |  { | 
| 19 | + /** | |
| 20 | + * @param \Kreta\SharedKernel\Event\StoredEvent $object | |
| 21 | + */ | |
| 19 | 22 | public function serialize($object) : string; | 
| 20 | 23 | |
| 21 | 24 | public function deserialize(string $serializedObject); | 
| @@ -16,9 +16,15 @@ | ||
| 16 | 16 | |
| 17 | 17 | interface EventStore | 
| 18 | 18 |  { | 
| 19 | + /** | |
| 20 | + * @return void | |
| 21 | + */ | |
| 19 | 22 | public function append(Stream $stream) : void; | 
| 20 | 23 | |
| 21 | 24 | public function streamOfName(StreamName $name) : Stream; | 
| 22 | 25 | |
| 26 | + /** | |
| 27 | + * @param \DateTimeImmutable $since | |
| 28 | + */ | |
| 23 | 29 | public function eventsSince(?\DateTimeInterface $since, int $offset = 0, int $limit = -1) : array; | 
| 24 | 30 | } |