as2252258/kiri-router
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

eee

Browse Source
This commit is contained in:
向林
2023-11-04 00:57:06 +08:00
parent 1582c0c241
commit 796676af48
4 changed files with 150 additions and 140 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Constrict/ConstrictResponse.php
+138 -138
View File
@@ -13,62 +13,62 @@ class ConstrictResponse extends Message implements ResponseInterface
{ {
private int $code = 200; private int $code = 200;
private string $reasonPhrase; private string $reasonPhrase;
/** /**
* @param ContentType $contentType * @param ContentType $contentType
* @return $this * @return $this
*/ */
public function withContentType(ContentType $contentType): static public function withContentType(ContentType $contentType): static
{ {
$this->withHeader('Content-Type', $contentType->toString()); $this->withHeader('Content-Type', $contentType->toString());
return $this; return $this;
} }
/** /**
* @param mixed $data * @param mixed $data
* @param int $statusCode * @param int $statusCode
* @param ContentType $type * @param ContentType $type
* @return $this * @return $this
*/ */
public function write(mixed $data, int $statusCode = 200, ContentType $type = ContentType::HTML): static public function write(mixed $data, int $statusCode = 200, ContentType $type = ContentType::HTML): static
{ {
if ($data instanceof \Stringable) { if ($data instanceof \Stringable) {
$this->getBody()->write($data->__toString()); $this->getBody()->write($data->__toString());
} else { } else {
$this->getBody()->write((string)$data); $this->getBody()->write((string)$data);
} }
return $this->withContentType($type)->withStatus($statusCode); return $this->withContentType($type)->withStatus($statusCode);
} }
/** /**
* @param mixed $content * @param mixed $content
* @param int $statusCode * @param int $statusCode
* @return $this * @return $this
*/ */
public function xml(array $content, int $statusCode = 200): static public function xml(array $content, int $statusCode = 200): static
{ {
$this->getBody()->write(Help::toXml($content)); $this->getBody()->write(Help::toXml($content));
return $this->withContentType(ContentType::XML)->withStatus($statusCode); return $this->withContentType(ContentType::XML)->withStatus($statusCode);
} }
/** /**
* @param array $content * @param array $content
* @param int $statusCode * @param int $statusCode
* @return $this * @return $this
*/ */
public function json(array $content, int $statusCode = 200): static public function json(array $content, int $statusCode = 200): static
{ {
$this->getBody()->write(json_encode($content)); $this->getBody()->write(json_encode($content));
return $this->withContentType(ContentType::JSON)->withStatus($statusCode); return $this->withContentType(ContentType::JSON)->withStatus($statusCode);
} }
/** /**
@@ -77,105 +77,105 @@ class ConstrictResponse extends Message implements ResponseInterface
* @param ContentType $contentType * @param ContentType $contentType
* @return $this * @return $this
*/ */
public function raw(string $content, int $statusCode = 200, ContentType $contentType = ContentType::JSON): static public function raw(string $content, int $statusCode = 200, ContentType $contentType = ContentType::JSON): static
{ {
$this->getBody()->write($content); $this->getBody()->write($content);
return $this->withContentType($contentType)->withStatus($statusCode); return $this->withContentType($contentType)->withStatus($statusCode);
} }
/** /**
* @param string $content * @param string $content
* @param int $statusCode * @param int $statusCode
* @return $this * @return $this
*/ */
public function html(string $content = '', int $statusCode = 200): static public function html(string $content = '', int $statusCode = 200): static
{ {
$this->getBody()->write($content); $this->getBody()->write($content);
return $this->withContentType(ContentType::HTML)->withStatus($statusCode); return $this->withContentType(ContentType::HTML)->withStatus($statusCode);
} }
/** /**
* @param string $content * @param string $content
* @param int $statusCode * @param int $statusCode
* @return $this * @return $this
*/ */
public function sendfile(string $content, int $statusCode = 200): ResponseInterface public function sendfile(string $content, int $statusCode = 200): ResponseInterface
{ {
$stream = new StreamResponse(); $stream = new StreamResponse();
$stream->withBody(new Stream(fopen($content, 'r+'))); $stream->withBody(new Stream(fopen($content, 'r+')));
return $stream->withStatus($statusCode); return $stream->withStatus($statusCode);
} }
/** /**
* Gets the response status code. * Gets the response status code.
* *
* The status code is a 3-digit integer result code of the server's attempt * The status code is a 3-digit integer result code of the server's attempt
* to understand and satisfy the request. * to understand and satisfy the request.
* *
* @return int Status code. * @return int Status code.
*/ */
public function getStatusCode(): int public function getStatusCode(): int
{ {
// TODO: Implement getStatusCode() method. // TODO: Implement getStatusCode() method.
return $this->code; return $this->code;
} }
/** /**
* Return an instance with the specified status code and, optionally, reason phrase. * Return an instance with the specified status code and, optionally, reason phrase.
* *
* If no reason phrase is specified, implementations MAY choose to default * If no reason phrase is specified, implementations MAY choose to default
* to the RFC 7231 or IANA recommended reason phrase for the response's * to the RFC 7231 or IANA recommended reason phrase for the response's
* status code. * status code.
* *
* This method MUST be implemented in such a way as to retain the * This method MUST be implemented in such a way as to retain the
* immutability of the message, and MUST return an instance that has the * immutability of the message, and MUST return an instance that has the
* updated status and reason phrase. * updated status and reason phrase.
* *
* @link http://tools.ietf.org/html/rfc7231#section-6 * @link http://tools.ietf.org/html/rfc7231#section-6
* @link http://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml * @link http://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml
* @param int $code The 3-digit integer result code to set. * @param int $code The 3-digit integer result code to set.
* @param string $reasonPhrase The reason phrase to use with the * @param string $reasonPhrase The reason phrase to use with the
* provided status code; if none is provided, implementations MAY * provided status code; if none is provided, implementations MAY
* use the defaults as suggested in the HTTP specification. * use the defaults as suggested in the HTTP specification.
* @return static * @return static
* @throws \InvalidArgumentException For invalid status code arguments. * @throws \InvalidArgumentException For invalid status code arguments.
*/ */
public function withStatus(int $code, string $reasonPhrase = ''): static public function withStatus(int $code, string $reasonPhrase = ''): static
{ {
// TODO: Implement withStatus() method. // TODO: Implement withStatus() method.
$this->code = $code; $this->code = $code;
$this->reasonPhrase = $reasonPhrase; $this->reasonPhrase = $reasonPhrase;
return $this; return $this;
} }
/** /**
* Gets the response reason phrase associated with the status code. * Gets the response reason phrase associated with the status code.
* *
* Because a reason phrase is not a required element in a response * Because a reason phrase is not a required element in a response
* status line, the reason phrase value MAY be null. Implementations MAY * status line, the reason phrase value MAY be null. Implementations MAY
* choose to return the default RFC 7231 recommended reason phrase (or those * choose to return the default RFC 7231 recommended reason phrase (or those
* listed in the IANA HTTP Status Code Registry) for the response's * listed in the IANA HTTP Status Code Registry) for the response's
* status code. * status code.
* *
* @link http://tools.ietf.org/html/rfc7231#section-6 * @link http://tools.ietf.org/html/rfc7231#section-6
* @link http://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml * @link http://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml
* @return string Reason phrase; must return an empty string if none present. * @return string Reason phrase; must return an empty string if none present.
*/ */
public function getReasonPhrase(): string public function getReasonPhrase(): string
{ {
// TODO: Implement getReasonPhrase() method. // TODO: Implement getReasonPhrase() method.
return $this->reasonPhrase; return $this->reasonPhrase;
} }
/** /**
* @param object $response * @param object $response
* @return void * @return void
*/ */
public function end(object $response): void public function end(object $response): void
{ {
$response->end($this->getBody()->getContents()); $response->end($this->getBody()->getContents());
} }
} }
src/SwooleHttpResponseEmitter.php
+1 -1
View File
@@ -67,7 +67,7 @@ class SwooleHttpResponseEmitter implements ResponseEmitterInterface
* @throws NotFoundExceptionInterface * @throws NotFoundExceptionInterface
* @throws ReflectionException * @throws ReflectionException
*/ */
public function sender(ResponseInterface $proxy, object $response, object $request): void public function xxxxxxxxxxxxxxxxxxxxxxxxxSender(ResponseInterface $proxy, object $response, object $request): void
{ {
// TODO: Implement sender() method. // TODO: Implement sender() method.
$this->writeParams($proxy, $response, $request); $this->writeParams($proxy, $response, $request);
src/SwowHttpResponseEmitter.php
+1 -1
View File
@@ -61,7 +61,7 @@ class SwowHttpResponseEmitter implements ResponseEmitterInterface
* @throws NotFoundExceptionInterface * @throws NotFoundExceptionInterface
* @throws ReflectionException * @throws ReflectionException
*/ */
public function sender(ResponseInterface $proxy, object $response, object $request): void public function xxxxxxxxxxxxxxxxxxxxxxxxxSender(ResponseInterface $proxy, object $response, object $request): void
{ {
// TODO: Implement sender() method. // TODO: Implement sender() method.
$proxy->withHeader('Server', 'Swow'); $proxy->withHeader('Server', 'Swow');
src/Validator/FormBase.php
+10
View File
@@ -0,0 +1,10 @@
<?php
namespace Kiri\Router\Validator;
use Kiri\ToArray;
abstract class FormBase implements ToArray, \JsonSerializable, \Stringable
{
}