modify plugin name

This commit is contained in:
2022-03-03 16:39:46 +08:00
parent f2cf841573
commit e270f9c588
+16 -4
View File
@@ -2,6 +2,7 @@
namespace Kiri\Rpc; namespace Kiri\Rpc;
use Exception;
use Kiri; use Kiri;
use Kiri\Abstracts\Component; use Kiri\Abstracts\Component;
use Kiri\Abstracts\Config; use Kiri\Abstracts\Config;
@@ -12,7 +13,6 @@ use Kiri\Context;
use Kiri\Exception\ConfigException; use Kiri\Exception\ConfigException;
use Kiri\Message\Constrict\RequestInterface; use Kiri\Message\Constrict\RequestInterface;
use Kiri\Message\Handler\DataGrip; use Kiri\Message\Handler\DataGrip;
use Kiri\Message\Handler\Handler;
use Kiri\Message\Handler\Router; use Kiri\Message\Handler\Router;
use Kiri\Message\Handler\RouterCollector; use Kiri\Message\Handler\RouterCollector;
use Kiri\Message\ServerRequest; use Kiri\Message\ServerRequest;
@@ -25,6 +25,7 @@ use Kiri\Server\Events\OnTaskerStart;
use Kiri\Server\Events\OnWorkerExit; use Kiri\Server\Events\OnWorkerExit;
use Kiri\Server\Events\OnWorkerStart; use Kiri\Server\Events\OnWorkerStart;
use Psr\Container\ContainerExceptionInterface; use Psr\Container\ContainerExceptionInterface;
use Psr\Container\ContainerInterface;
use Psr\Container\NotFoundExceptionInterface; use Psr\Container\NotFoundExceptionInterface;
use Psr\Http\Message\ServerRequestInterface; use Psr\Http\Message\ServerRequestInterface;
use ReflectionException; use ReflectionException;
@@ -57,6 +58,17 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
public RouterCollector $collector; public RouterCollector $collector;
/**
* @param ContainerInterface $container
* @param array $config
* @throws Exception
*/
public function __construct(public ContainerInterface $container, array $config = [])
{
parent::__construct($config);
}
/** /**
* @return void * @return void
* @throws ContainerExceptionInterface * @throws ContainerExceptionInterface
@@ -220,11 +232,11 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
try { try {
$handler = $this->collector->find($data['service'], 'GET'); $handler = $this->collector->find($data['service'], 'GET');
if (is_integer($handler) || is_null($handler)) { if (is_integer($handler) || is_null($handler)) {
throw new \Exception('Method not found', -32601); throw new Exception('Method not found', -32601);
} else { } else {
$controller = $handler->callback[0]; $controller = $handler->callback[0];
if (!method_exists($controller, $data['method'])) { if (!method_exists($controller, $data['method'])) {
throw new \Exception('Method not found', -32601); throw new Exception('Method not found', -32601);
} }
$params = $this->container->getMethodParameters($controller::class, $data['method']); $params = $this->container->getMethodParameters($controller::class, $data['method']);
@@ -242,7 +254,7 @@ class RpcJsonp extends Component implements OnConnectInterface, OnReceiveInterfa
/** /**
* @param $params * @param $params
* @return ServerRequestInterface * @return ServerRequestInterface
* @throws \Exception * @throws Exception
*/ */
private function createServerRequest($params): ServerRequestInterface private function createServerRequest($params): ServerRequestInterface
{ {