add subscription engine result #65
DavidBaduramutation-tests-diff.yml
on: pull_request
Matrix: Mutation tests on diff
Annotations
1 error and 8 warnings
|
Mutation tests on diff (locked, 8.3, ubuntu-latest)
Process completed with exit code 1.
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest)
Node.js 16 actions are deprecated. Please update the following actions to use Node.js 20: actions/cache@v3. For more information see: https://github.blog/changelog/2023-09-22-github-actions-transitioning-from-node-16-to-node-20/.
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L161
Escaped Mutant for Mutator "DecrementInteger":
--- Original
+++ New
@@ @@
return $this->findForUpdate(new SubscriptionCriteria(ids: $criteria->ids, groups: $criteria->groups, status: [Status::Booting]), function ($subscriptions) use($limit) : ProcessedResult {
if (count($subscriptions) === 0) {
$this->logger?->info('Subscription Engine: No subscriptions in booting status, finish booting.');
- return new ProcessedResult(0);
+ return new ProcessedResult(-1);
}
/** @var list<Error> $errors */
$errors = [];
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L161
Escaped Mutant for Mutator "IncrementInteger":
--- Original
+++ New
@@ @@
return $this->findForUpdate(new SubscriptionCriteria(ids: $criteria->ids, groups: $criteria->groups, status: [Status::Booting]), function ($subscriptions) use($limit) : ProcessedResult {
if (count($subscriptions) === 0) {
$this->logger?->info('Subscription Engine: No subscriptions in booting status, finish booting.');
- return new ProcessedResult(0);
+ return new ProcessedResult(1);
}
/** @var list<Error> $errors */
$errors = [];
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L212
Escaped Mutant for Mutator "Continue_":
--- Original
+++ New
@@ @@
}
$error = $this->handleMessage($index, $message, $subscription);
if (!$error) {
- continue;
+ break;
}
$errors[] = $error;
}
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L314
Escaped Mutant for Mutator "DecrementInteger":
--- Original
+++ New
@@ @@
return $this->findForUpdate(new SubscriptionCriteria(ids: $criteria->ids, groups: $criteria->groups, status: [Status::Active]), function (array $subscriptions) use($limit) : ProcessedResult {
if (count($subscriptions) === 0) {
$this->logger?->info('Subscription Engine: No subscriptions to process, finish processing.');
- return new ProcessedResult(0);
+ return new ProcessedResult(-1);
}
/** @var list<Error> $errors */
$errors = [];
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L314
Escaped Mutant for Mutator "IncrementInteger":
--- Original
+++ New
@@ @@
return $this->findForUpdate(new SubscriptionCriteria(ids: $criteria->ids, groups: $criteria->groups, status: [Status::Active]), function (array $subscriptions) use($limit) : ProcessedResult {
if (count($subscriptions) === 0) {
$this->logger?->info('Subscription Engine: No subscriptions to process, finish processing.');
- return new ProcessedResult(0);
+ return new ProcessedResult(1);
}
/** @var list<Error> $errors */
$errors = [];
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L364
Escaped Mutant for Mutator "Continue_":
--- Original
+++ New
@@ @@
}
$error = $this->handleMessage($index, $message, $subscription);
if (!$error) {
- continue;
+ break;
}
$errors[] = $error;
}
|
|
Mutation tests on diff (locked, 8.3, ubuntu-latest):
src/Subscription/Engine/DefaultSubscriptionEngine.php#L766
Escaped Mutant for Mutator "NewObject":
--- Original
+++ New
@@ @@
} catch (Throwable $e) {
$this->logger?->error(sprintf('Subscription Engine: Subscriber "%s" for "%s" could not process the event "%s": %s', $subscriber::class, $subscription->id(), $message->event()::class, $e->getMessage()));
$this->handleError($subscription, $e);
- return new Error($subscription->id(), $e->getMessage(), $e);
+ new Error($subscription->id(), $e->getMessage(), $e);
+ return null;
}
$subscription->changePosition($index);
$subscription->resetRetry();
|