Skip to content

Commit

Permalink
TASK: Do not discover new subscriptions during catchup
Browse files Browse the repository at this point in the history
We do not expect any changes during runtime. Setup and status should handle this case.
  • Loading branch information
mhsdesign committed Nov 23, 2024
1 parent 5dfa592 commit d5715c7
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@
use Neos\ContentRepository\Core\Subscription\Engine\ProcessedResult;
use Neos\ContentRepository\Core\Subscription\Engine\SubscriptionEngineCriteria;
use Neos\ContentRepository\Core\Subscription\SubscriptionAndProjectionStatus;
use Neos\ContentRepository\Core\Subscription\SubscriptionAndProjectionStatuses;
use Neos\ContentRepository\Core\Subscription\SubscriptionId;
use Neos\ContentRepository\Core\Subscription\SubscriptionStatus;
use Neos\ContentRepository\TestSuite\Fakes\FakeProjectionFactory;
Expand Down Expand Up @@ -69,8 +68,8 @@ public function newProjectionIsFoundConfigurationIsAdded()
// todo status doesnt find this projection yet?
self::assertNull($this->subscriptionStatus('Vendor.Package:NewFakeProjection'));

// do something that finds new subscriptions
$result = $this->subscriptionEngine->catchUpActive();
// do something that finds new subscriptions, trigger a setup on a specific projection:
$result = $this->subscriptionEngine->setup(SubscriptionEngineCriteria::create([SubscriptionId::fromString('contentGraph')]));
self::assertNull($result->errors);

self::assertEquals(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -205,8 +205,6 @@ private function catchUpSubscriptions(SubscriptionEngineCriteria $criteria, Subs
{
$this->logger?->info(sprintf('Subscription Engine: Start catching up subscriptions in state "%s".', $subscriptionStatus->value));

$this->discoverNewSubscriptions();

return $this->subscriptionManager->findForAndUpdate(
SubscriptionCriteria::forEngineCriteriaAndStatus($criteria, $subscriptionStatus),
function (Subscriptions $subscriptions) use ($subscriptionStatus, $progressClosure) {
Expand Down

0 comments on commit d5715c7

Please sign in to comment.