EventDispatchingStage::process() - Code Metrics - OpenConext/Stepup-Middleware - Measure and Improve Code Quality continuously with Scrutinizer

EventDispatchingStage::process() A
last analyzed 2025-12-16 10:09 UTC

↳ Parent: EventDispatchingStage

Complexity

Conditions	1
Paths	1

Size

Total Lines	9
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	4
nc	1
nop	1
dl	0
loc	9
rs	10
c	0
b	0
f	0

<?php

/**
 * Copyright 2014 SURFnet bv
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

namespace Surfnet\StepupMiddleware\CommandHandlingBundle\Pipeline;

use Psr\Log\LoggerInterface;
use Surfnet\StepupMiddleware\CommandHandlingBundle\Command\AbstractCommand;
use Surfnet\StepupMiddleware\CommandHandlingBundle\EventHandling\BufferedEventBus;

class EventDispatchingStage implements Stage
{
    public function __construct(
        private readonly LoggerInterface $logger,
        private readonly BufferedEventBus $bufferedEventBus,
    ) {
    }

    public function process(AbstractCommand $command): AbstractCommand
    {
        $this->logger->debug(sprintf('Dispatching Events for "%s"', $command));

        $this->bufferedEventBus->flush();

        $this->logger->debug(sprintf('All events for "%s" have been dispatched', $command));

        return $command;
    }
}


1			<?php
2
3			/**
4			* Copyright 2014 SURFnet bv
5			*
6			* Licensed under the Apache License, Version 2.0 (the "License");
7			* you may not use this file except in compliance with the License.
8			* You may obtain a copy of the License at
9			*
10			* http://www.apache.org/licenses/LICENSE-2.0
11			*
12			* Unless required by applicable law or agreed to in writing, software
13			* distributed under the License is distributed on an "AS IS" BASIS,
14			* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15			* See the License for the specific language governing permissions and
16			* limitations under the License.
17			*/
18
19			namespace Surfnet\StepupMiddleware\CommandHandlingBundle\Pipeline;
20
21			use Psr\Log\LoggerInterface;
22			use Surfnet\StepupMiddleware\CommandHandlingBundle\Command\AbstractCommand;
23			use Surfnet\StepupMiddleware\CommandHandlingBundle\EventHandling\BufferedEventBus;
24
25			class EventDispatchingStage implements Stage
26			{
27			public function __construct(
28			private readonly LoggerInterface $logger,
29			private readonly BufferedEventBus $bufferedEventBus,
30			) {
31			}
32
33			public function process(AbstractCommand $command): AbstractCommand
34			{
35			$this->logger->debug(sprintf('Dispatching Events for "%s"', $command));
36
37			$this->bufferedEventBus->flush();
38
39			$this->logger->debug(sprintf('All events for "%s" have been dispatched', $command));
40
41			return $command;
42			}
43			}
44

OpenConext / Stepup-Middleware

EventDispatchingStage::process() A last analyzed 2025-12-16 10:09 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

EventDispatchingStage::process() A
last analyzed 2025-12-16 10:09 UTC