Skip to content

Commit

Permalink
Merge branch 'feature/4289-overhaul-catchup' into feature/4200-replay…
Browse files Browse the repository at this point in the history
…-progress-bar
  • Loading branch information
bwaidelich committed Aug 26, 2023
2 parents cfc6f49 + d6211ea commit 9bc2085
Show file tree
Hide file tree
Showing 5 changed files with 4 additions and 10 deletions.
6 changes: 3 additions & 3 deletions Classes/CommandHandler/PendingProjections.php
Original file line number Diff line number Diff line change
Expand Up @@ -100,10 +100,10 @@ public static function fromProjectionsAndEventsAndSequenceNumber(
$pendingProjectionsArray = [];
$sequenceNumberPerProjection = [];
foreach ($events as $event) {
if ($event instanceof DecoratedEvent) {
$event = $event->innerEvent;
}
foreach ($allProjections as $projection) {
if ($event instanceof DecoratedEvent) {
$event = $event->innerEvent;
}
if ($projection->canHandle($event)) {
$sequenceNumberPerProjection[$projection::class] = $sequenceNumberInteger;
if (!in_array($projection, $pendingProjectionsArray, true)) {
Expand Down
2 changes: 1 addition & 1 deletion Classes/ContentRepository.php
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@ public function projectionState(string $projectionStateClassName): ProjectionSta
return $projectionState;
}
}
throw new \InvalidArgumentException(sprintf('a projection state of type "%s" is not registered in this content repository instance.', $projectionStateClassName), 1662033650);
throw new \InvalidArgumentException(sprintf('A projection state of type "%s" is not registered in this content repository instance.', $projectionStateClassName), 1662033650);
}

/**
Expand Down
2 changes: 0 additions & 2 deletions Classes/Projection/ContentStream/ContentStreamProjection.php
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,6 @@
use Neos\EventStore\Model\Event\SequenceNumber;
use Neos\EventStore\Model\EventEnvelope;

use function sprintf;

/**
* See {@see ContentStreamFinder} for explanation.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,6 @@
use Neos\EventStore\Model\Event\SequenceNumber;
use Neos\EventStore\Model\EventEnvelope;

use function sprintf;

/**
* TODO: this class needs proper testing
* @internal
Expand Down
2 changes: 0 additions & 2 deletions Classes/Projection/Workspace/WorkspaceProjection.php
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,6 @@
use Neos\EventStore\Model\Event\SequenceNumber;
use Neos\EventStore\Model\EventEnvelope;

use function sprintf;

/**
* @internal
* @implements ProjectionInterface<WorkspaceFinder>
Expand Down

0 comments on commit 9bc2085

Please sign in to comment.