Conditions | 5 |
Paths | 6 |
Total Lines | 13 |
Code Lines | 7 |
Lines | 0 |
Ratio | 0 % |
Tests | 0 |
CRAP Score | 30 |
Changes | 1 | ||
Bugs | 0 | Features | 0 |
1 | <?php |
||
59 | public function retrieveAllAfterVersion(AggregateRootId $id, int $aggregateRootVersion): Generator |
||
60 | { |
||
61 | $lastMessage = null; |
||
62 | |||
63 | foreach ($this->messages as $message) { |
||
64 | if ($id->toString() === $message->header(Header::AGGREGATE_ROOT_ID)->toString() |
||
65 | && $message->header(Header::AGGREGATE_ROOT_VERSION) > $aggregateRootVersion) { |
||
66 | yield $message; |
||
67 | $lastMessage = $message; |
||
68 | } |
||
69 | } |
||
70 | |||
71 | return $lastMessage instanceof Message ? $lastMessage->aggregateVersion() : 0; |
||
72 | } |
||
74 |