command bus #4764
Annotations
11 warnings
Mutation tests (locked, 8.3, ubuntu-latest)
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/Aggregate/AggregateRootAttributeBehaviour.php#L27
Escaped Mutant for Mutator "ProtectedVisibility":
--- Original
+++ New
@@ @@
/** @var (callable(object $event): void)|null */
#[Ignore]
private $recorder = null;
- protected function apply(object $event) : void
+ private function apply(object $event) : void
{
$metadata = static::metadata();
if (!array_key_exists($event::class, $metadata->applyMethods)) {
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/Aggregate/AggregateRootAttributeBehaviour.php#L66
Escaped Mutant for Mutator "AssignCoalesce":
--- Original
+++ New
@@ @@
private function passRecorderToChildAggregates() : void
{
$metadata = static::metadata();
- $this->recorder ??= $this->recordThat(...);
+ $this->recorder = $this->recordThat(...);
foreach ($metadata->childAggregates as $property) {
if (!isset($this->{$property})) {
continue;
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/Aggregate/AggregateRootAttributeBehaviour.php#L81
Escaped Mutant for Mutator "InstanceOf_":
--- Original
+++ New
@@ @@
}
public function aggregateRootId() : AggregateRootId
{
- if ($this->cachedAggregateRootId instanceof AggregateRootId) {
+ if (false) {
return $this->cachedAggregateRootId;
}
$metadata = static::metadata();
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/CommandBus/AggregateHandlerProvider.php#L115
Escaped Mutant for Mutator "Continue_":
--- Original
+++ New
@@ @@
$handle = $handleAttribute->newInstance();
if (!$handle->commandClass) {
$guessType = true;
- continue;
+ break;
}
if ($handle->commandClass === $commandClass) {
return true;
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/CommandBus/DefaultCommandBus.php#L45
Escaped Mutant for Mutator "UnwrapFinally":
--- Original
+++ New
@@ @@
$this->logger?->debug('CommandBus: Is already processing, dont start new processing.');
return;
}
- try {
- $this->processing = true;
- $this->logger?->debug('CommandBus: Start processing queue.');
- while ($command = array_shift($this->queue)) {
- $handler = $this->handlerProvider->handlerForCommand($command::class);
- $handler->callable()($command);
- }
- } finally {
- $this->processing = false;
- $this->logger?->debug('CommandBus: Finished processing queue.');
+ $this->processing = true;
+ $this->logger?->debug('CommandBus: Start processing queue.');
+ while ($command = array_shift($this->queue)) {
+ $handler = $this->handlerProvider->handlerForCommand($command::class);
+ $handler->callable()($command);
}
+ $this->processing = false;
+ $this->logger?->debug('CommandBus: Finished processing queue.');
}
public static function createDefault(RepositoryManager $repositoryManager, ContainerInterface|null $container = null, LoggerInterface|null $logger = null) : self
{
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/CommandBus/DefaultCommandBus.php#L46
Escaped Mutant for Mutator "TrueValue":
--- Original
+++ New
@@ @@
return;
}
try {
- $this->processing = true;
+ $this->processing = false;
$this->logger?->debug('CommandBus: Start processing queue.');
while ($command = array_shift($this->queue)) {
$handler = $this->handlerProvider->handlerForCommand($command::class);
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/CommandBus/DefaultCommandBus.php#L56
Escaped Mutant for Mutator "FalseValue":
--- Original
+++ New
@@ @@
$handler->callable()($command);
}
} finally {
- $this->processing = false;
+ $this->processing = true;
$this->logger?->debug('CommandBus: Finished processing queue.');
}
}
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/Console/Command/DatabaseCreateCommand.php#L49
Escaped Mutant for Mutator "LogicalAnd":
--- Original
+++ New
@@ @@
$tempConnection = $this->helper->copyConnectionWithoutDatabase($this->connection);
$ifNotExists = InputHelper::bool($input->getOption('if-not-exists'));
$hasDatabase = $this->helper->hasDatabase($tempConnection, $databaseName);
- if ($ifNotExists && $hasDatabase) {
+ if ($ifNotExists || $hasDatabase) {
$console->warning(sprintf('Database "%s" already exists. Skipped.', $databaseName));
$tempConnection->close();
return 0;
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/Console/Command/DatabaseCreateCommand.php#L51
Escaped Mutant for Mutator "MethodCallRemoval":
--- Original
+++ New
@@ @@
$hasDatabase = $this->helper->hasDatabase($tempConnection, $databaseName);
if ($ifNotExists && $hasDatabase) {
$console->warning(sprintf('Database "%s" already exists. Skipped.', $databaseName));
- $tempConnection->close();
+
return 0;
}
try {
|
Mutation tests (locked, 8.3, ubuntu-latest):
src/Console/Command/DatabaseCreateCommand.php#L61
Escaped Mutant for Mutator "MethodCallRemoval":
--- Original
+++ New
@@ @@
$console->success(sprintf('Created database "%s"', $databaseName));
} catch (Throwable $e) {
$console->error(sprintf('Could not create database "%s"', $databaseName));
- $console->error($e->getMessage());
+
$tempConnection->close();
return 2;
}
|