@@ -11,8 +11,8 @@ |
||
11 | 11 | * @param non-empty-string|null $description |
12 | 12 | */ |
13 | 13 | public function __construct( |
14 | - public readonly string|int $code, |
|
14 | + public readonly string | int $code, |
|
15 | 15 | public readonly ?string $description = null |
16 | - ) { |
|
16 | + ){ |
|
17 | 17 | } |
18 | 18 | } |
@@ -36,7 +36,7 @@ discard block |
||
36 | 36 | |
37 | 37 | public function __construct( |
38 | 38 | private readonly ConfiguratorInterface $config |
39 | - ) { |
|
39 | + ){ |
|
40 | 40 | } |
41 | 41 | |
42 | 42 | public function init(EnvironmentInterface $env): void |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | /** |
48 | 48 | * @param class-string<TracerFactoryInterface>|TracerFactoryInterface|Autowire $driver |
49 | 49 | */ |
50 | - public function registerTracer(string $name, string|TracerFactoryInterface|Autowire $driver): void |
|
50 | + public function registerTracer(string $name, string | TracerFactoryInterface | Autowire $driver): void |
|
51 | 51 | { |
52 | 52 | $this->config->modify( |
53 | 53 | TelemetryConfig::CONFIG, |
@@ -28,7 +28,7 @@ |
||
28 | 28 | * @param non-empty-string|int $code |
29 | 29 | * @param non-empty-string|null $description |
30 | 30 | */ |
31 | - public function setStatus(string|int $code, string $description = null): self; |
|
31 | + public function setStatus(string | int $code, string $description = null): self; |
|
32 | 32 | |
33 | 33 | /** |
34 | 34 | * Get the current span status. |
@@ -23,7 +23,7 @@ |
||
23 | 23 | private readonly ClockInterface $clock, |
24 | 24 | private readonly LoggerInterface $logger, |
25 | 25 | private readonly UuidFactoryInterface $uuidFactory |
26 | - ) { |
|
26 | + ){ |
|
27 | 27 | parent::__construct($scope); |
28 | 28 | } |
29 | 29 |
@@ -22,7 +22,7 @@ |
||
22 | 22 | $tracerFactory->shouldReceive('make') |
23 | 23 | ->once() |
24 | 24 | ->with(['some' => 'data']) |
25 | - ->andReturn( $tracer = new NullTracer()); |
|
25 | + ->andReturn($tracer = new NullTracer()); |
|
26 | 26 | |
27 | 27 | $handler = new Handler( |
28 | 28 | core: $core = m::mock(CoreInterface::class), |
@@ -18,24 +18,24 @@ |
||
18 | 18 | { |
19 | 19 | public function __construct( |
20 | 20 | private readonly QueueConnectionProviderInterface $queueManager |
21 | - ) { |
|
21 | + ){ |
|
22 | 22 | } |
23 | 23 | |
24 | 24 | public function createInjection(ReflectionClass $class, string $context = null): QueueInterface |
25 | 25 | { |
26 | - try { |
|
27 | - if ($context === null) { |
|
26 | + try{ |
|
27 | + if ($context === null){ |
|
28 | 28 | $connection = $this->queueManager->getConnection(); |
29 | - } else { |
|
29 | + }else{ |
|
30 | 30 | // Get Queue by context |
31 | - try { |
|
31 | + try{ |
|
32 | 32 | $connection = $this->queueManager->getConnection($context); |
33 | - } catch (InvalidArgumentException) { |
|
33 | + }catch (InvalidArgumentException){ |
|
34 | 34 | // Case when context doesn't match to configured connections |
35 | 35 | return $this->queueManager->getConnection(); |
36 | 36 | } |
37 | 37 | } |
38 | - } catch (\Throwable $e) { |
|
38 | + }catch (\Throwable $e){ |
|
39 | 39 | throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e); |
40 | 40 | } |
41 | 41 |
@@ -23,19 +23,28 @@ |
||
23 | 23 | |
24 | 24 | public function createInjection(ReflectionClass $class, string $context = null): QueueInterface |
25 | 25 | { |
26 | - try { |
|
27 | - if ($context === null) { |
|
26 | + try |
|
27 | + { |
|
28 | + if ($context === null) |
|
29 | + { |
|
28 | 30 | $connection = $this->queueManager->getConnection(); |
29 | - } else { |
|
31 | + } |
|
32 | + else |
|
33 | + { |
|
30 | 34 | // Get Queue by context |
31 | - try { |
|
35 | + try |
|
36 | + { |
|
32 | 37 | $connection = $this->queueManager->getConnection($context); |
33 | - } catch (InvalidArgumentException) { |
|
38 | + } |
|
39 | + catch (InvalidArgumentException) |
|
40 | + { |
|
34 | 41 | // Case when context doesn't match to configured connections |
35 | 42 | return $this->queueManager->getConnection(); |
36 | 43 | } |
37 | 44 | } |
38 | - } catch (\Throwable $e) { |
|
45 | + } |
|
46 | + catch (\Throwable $e) |
|
47 | + { |
|
39 | 48 | throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e); |
40 | 49 | } |
41 | 50 |
@@ -87,7 +87,7 @@ |
||
87 | 87 | $factory->shouldReceive('make')->andReturnUsing(function (string $name): QueueInterface { |
88 | 88 | $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null; |
89 | 89 | |
90 | - if ($result === null) { |
|
90 | + if ($result === null){ |
|
91 | 91 | throw new NotFoundException(); |
92 | 92 | } |
93 | 93 | return $result; |
@@ -87,7 +87,8 @@ |
||
87 | 87 | $factory->shouldReceive('make')->andReturnUsing(function (string $name): QueueInterface { |
88 | 88 | $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null; |
89 | 89 | |
90 | - if ($result === null) { |
|
90 | + if ($result === null) |
|
91 | + { |
|
91 | 92 | throw new NotFoundException(); |
92 | 93 | } |
93 | 94 | return $result; |
@@ -39,9 +39,9 @@ |
||
39 | 39 | * @return TokenStorageInterface|class-string<TokenStorageInterface>|Autowire |
40 | 40 | * @throws InvalidArgumentException |
41 | 41 | */ |
42 | - public function getStorage(string $name): TokenStorageInterface|string|Autowire |
|
42 | + public function getStorage(string $name): TokenStorageInterface | string | Autowire |
|
43 | 43 | { |
44 | - if (!isset($this->config['storages'][$name])) { |
|
44 | + if (!isset($this->config['storages'][$name])){ |
|
45 | 45 | throw new InvalidArgumentException( |
46 | 46 | \sprintf('Token storage `%s` is not defined.', $name) |
47 | 47 | ); |
@@ -41,7 +41,8 @@ |
||
41 | 41 | */ |
42 | 42 | public function getStorage(string $name): TokenStorageInterface|string|Autowire |
43 | 43 | { |
44 | - if (!isset($this->config['storages'][$name])) { |
|
44 | + if (!isset($this->config['storages'][$name])) |
|
45 | + { |
|
45 | 46 | throw new InvalidArgumentException( |
46 | 47 | \sprintf('Token storage `%s` is not defined.', $name) |
47 | 48 | ); |
@@ -29,7 +29,7 @@ |
||
29 | 29 | TransportRegistry $transportRegistry, |
30 | 30 | ?EventDispatcherInterface $eventDispatcher = null, |
31 | 31 | ?string $storage = null |
32 | - ) { |
|
32 | + ){ |
|
33 | 33 | $this->authMiddleware = new AuthTransportMiddleware( |
34 | 34 | $transportName, |
35 | 35 | $scope, |