This commit is contained in:
2021-10-19 17:32:26 +08:00
parent 365cbb0148
commit 2d968c3623
2 changed files with 22 additions and 6 deletions
+14 -4
View File
@@ -2,12 +2,17 @@
namespace Http\Handler; namespace Http\Handler;
use Exception;
use Http\Handler\Abstracts\Middleware; use Http\Handler\Abstracts\Middleware;
use Http\Message\ServerRequest; use Http\Message\ServerRequest;
use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface; use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface; use Psr\Http\Server\RequestHandlerInterface;
/**
*
*/
class CoreMiddleware extends Middleware class CoreMiddleware extends Middleware
{ {
@@ -16,14 +21,19 @@ class CoreMiddleware extends Middleware
* @param ServerRequest $request * @param ServerRequest $request
* @param RequestHandlerInterface $handler * @param RequestHandlerInterface $handler
* @return ResponseInterface * @return ResponseInterface
* @throws \Exception * @throws Exception
*/ */
public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
{ {
$this->response->withAccessControlAllowOrigin('*')
->withAccessControlRequestMethod($request->getAccessControlRequestMethod())
->withAccessControlAllowHeaders($request->getAccessControlAllowHeaders());
$requestMethod = $request->getAccessControlRequestMethod();
$allowHeaders = $request->getAccessControlAllowHeaders();
if (empty($requestMethod)) $requestMethod = '*';
if (empty($allowHeaders)) $allowHeaders = '*';
$this->response->withAccessControlAllowOrigin('*')->withAccessControlRequestMethod($requestMethod)
->withAccessControlAllowHeaders($allowHeaders);
return $handler->handle($request); return $handler->handle($request);
} }
+8 -2
View File
@@ -2,17 +2,23 @@
namespace Server\Abstracts; namespace Server\Abstracts;
use Kiri\Exception\ConfigException;
use Kiri\Kiri; use Kiri\Kiri;
use Psr\EventDispatcher\EventDispatcherInterface; use Psr\EventDispatcher\EventDispatcherInterface;
use ReflectionException;
use Server\ServerManager; use Server\ServerManager;
/**
*
*/
class OnTaskerStart extends WorkerStart implements EventDispatcherInterface class OnTaskerStart extends WorkerStart implements EventDispatcherInterface
{ {
/** /**
* @throws \Kiri\Exception\ConfigException * @throws ConfigException
* @throws \ReflectionException * @throws ReflectionException
*/ */
public function dispatch(object $event) public function dispatch(object $event)
{ {