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