Skip to content

Commit 005e5a0

Browse files
authored
Normalize TCP and Centrifugo interceptor arguments (#119)
1 parent 6a067f9 commit 005e5a0

File tree

3 files changed

+9
-8
lines changed

3 files changed

+9
-8
lines changed

src/Centrifugo/Internal/Server.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public function serve(CentrifugoWorkerInterface $worker): void
6464
new CallContext(
6565
/** @see ServiceInterface::handle() */
6666
Target::fromPair($services->getService($type), 'handle'),
67-
['request' => $request],
67+
[$request],
6868
[RequestType::class => $type],
6969
),
7070
),

src/Tcp/Internal/Server.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public function serve(?WorkerInterface $worker = null): void
7272
static fn(): mixed => $pipeline->handle(new CallContext(
7373
/** @see \Spiral\RoadRunnerBridge\Tcp\Service\ServiceInterface::handle() */
7474
Target::fromPair($services->getService($server), 'handle'),
75-
['request' => $request],
75+
[$request],
7676
['server' => $server],
7777
)),
7878
);

tests/app/Tcp/TestInterceptor.php

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,17 +15,18 @@ class TestInterceptor implements CoreInterceptorInterface
1515

1616
public function process(string $controller, string $action, array $parameters, CoreInterface $core): mixed
1717
{
18+
$request = $parameters[0];
1819
if (\count($this->data) < 5) {
19-
$this->data[] = $parameters['request']->getBody();
20+
$this->data[] = $request->getBody();
2021
}
2122

2223
if (\count($this->data) === 5) {
23-
$parameters['request'] = new Request(
24-
remoteAddr: $parameters['request']->getRemoteAddress(),
25-
event: $parameters['request']->getEvent(),
24+
$parameters[0] = new Request(
25+
remoteAddr: $request->getRemoteAddress(),
26+
event: $request->getEvent(),
2627
body: \json_encode($this->data, JSON_THROW_ON_ERROR),
27-
connectionUuid: $parameters['request']->getConnectionUuid(),
28-
server: $parameters['request']->getServer(),
28+
connectionUuid: $request->getConnectionUuid(),
29+
server: $request->getServer(),
2930
);
3031

3132
return $core->callAction($controller, $action, $parameters);

0 commit comments

Comments
 (0)