style: Use the latest v1.1.x code style standard

cclilshy · cclilshy · commit 7b8bb0a0de9b · 2025-04-11T03:24:38.000+08:00
diff --git a/composer.json b/composer.json
@@ -15,7 +15,7 @@
   "require": {
     "php": ">=8.1",
     "ext-sockets": "*",
-    "cloudtay/ripple": "^1.0.5",
+    "cloudtay/ripple": "^1.0",
     "symfony/http-foundation": "*",
     "guzzlehttp/guzzle": "*"
   },
diff --git a/src/Client.php b/src/Client.php
@@ -56,7 +56,7 @@ public function __construct(private readonly array $config = [])
      * @param array            $option
      *
      * @return Response
-     * @throws \Ripple\Stream\Exception\ConnectionException
+     * @throws ConnectionException
      */
     public function request(RequestInterface $request, array $option = []): Response
     {
diff --git a/src/Client/Capture.php b/src/Client/Capture.php
@@ -43,7 +43,7 @@ abstract public function onError(Throwable|Exception $exception): void;
     /**
      * 请求完成
      *
-     * @param \GuzzleHttp\Psr7\Response $response
+     * @param Response $response
      *
      * @return void
      */
diff --git a/src/Client/Capture/ServerSentEvents.php b/src/Client/Capture/ServerSentEvents.php
@@ -16,6 +16,7 @@
 use Exception;
 use GuzzleHttp\Psr7\Response;
 use Iterator;
+use Ripple\Coroutine\Context;
 use Ripple\Coroutine\Coroutine;
 use Ripple\Http\Client\Capture;
 use Throwable;
@@ -34,10 +35,10 @@
  */
 class ServerSentEvents extends Capture
 {
-    /*** @var \Closure|null */
+    /*** @var Closure|null */
     public Closure|null $onEvent = null;
 
-    /*** @var \Closure|null */
+    /*** @var Closure|null */
     public Closure|null $onComplete = null;
 
     /*** @var array */
@@ -86,7 +87,7 @@ public function onError(Throwable|Exception $exception): void
     }
 
     /**
-     * @param \GuzzleHttp\Psr7\Response $response
+     * @param Response $response
      *
      * @return void
      */
@@ -152,7 +153,7 @@ public function processContent(string $content): void
     public function getIterator(): iterable
     {
         return $this->iterators[] = new class ($this) implements Iterator {
-            /*** @var \Ripple\Coroutine\Context[] */
+            /*** @var Context[] */
 
             protected array $waiters = [];
 
diff --git a/src/Client/Connection.php b/src/Client/Connection.php
@@ -34,7 +34,6 @@
 use function fwrite;
 use function hexdec;
 use function implode;
-use function intval;
 use function is_resource;
 use function strlen;
 use function strpos;
@@ -87,7 +86,7 @@ class Connection
     /*** @var mixed|null */
     private mixed $output = null;
 
-    /*** @var \Ripple\Http\Client\Capture|null */
+    /*** @var Capture|null */
     private Capture|null $capture = null;
 
     private WaitGroup $waitGroup;
@@ -129,12 +128,12 @@ private function reset(): void
     }
 
     /**
-     * @param \Psr\Http\Message\RequestInterface $request
+     * @param RequestInterface $request
      * @param array                              $option
      *
-     * @return \GuzzleHttp\Psr7\Response
-     * @throws \Ripple\Stream\Exception\ConnectionException
-     * @throws \Ripple\Stream\Exception\RuntimeException
+     * @return Response
+     * @throws ConnectionException
+     * @throws RuntimeException
      */
     public function request(RequestInterface $request, array $option = []): Response
     {
@@ -149,12 +148,12 @@ public function request(RequestInterface $request, array $option = []): Response
     }
 
     /**
-     * @param \Psr\Http\Message\RequestInterface $request
+     * @param RequestInterface $request
      * @param array                              $option
      *
-     * @return \GuzzleHttp\Psr7\Response
-     * @throws \Ripple\Stream\Exception\ConnectionException
-     * @throws \Ripple\Stream\Exception\RuntimeException
+     * @return Response
+     * @throws ConnectionException
+     * @throws RuntimeException
      */
     private function queue(RequestInterface $request, array $option = []): Response
     {
@@ -246,8 +245,6 @@ private function queue(RequestInterface $request, array $option = []): Response
                     'Connection closed by peer',
                     ConnectionException::CONNECTION_CLOSED,
                     null,
-                    $this->stream,
-                    true
                 );
             }
 
@@ -302,7 +299,7 @@ public function tick(string|false $content): ResponseInterface|null
 
     /**
      * @return ResponseInterface|null
-     * @throws \Ripple\Stream\Exception\RuntimeException
+     * @throws RuntimeException
      */
     public function tickClose(): ResponseInterface|null
     {
@@ -319,8 +316,8 @@ public function tickClose(): ResponseInterface|null
     }
 
     /**
-     * @return \Psr\Http\Message\ResponseInterface|null
-     * @throws \Ripple\Stream\Exception\RuntimeException
+     * @return ResponseInterface|null
+     * @throws RuntimeException
      */
     public function process(): ResponseInterface|null
     {
diff --git a/src/Enum/Status.php b/src/Enum/Status.php
@@ -156,13 +156,13 @@ public function getMessage(): string
     }
 
     /**
-     * 获取状态码对应的消息（使用状态码）
+     * Obtaining the Message Corresponding to a Status Code (Using a Status Code)
      *
-     * @param int $code 状态码
-     * @return string|null 状态消息，不存在则返回null
+     * @param int $code Status code
+     * @return string|null Status message, null if it does not exist
      */
-    public static function getMessageForCode(int $code): ?string
+    public static function getMessageForCode(int $code): string|null
     {
-        return self::tryFrom($code)?->getMessage();
+        return Status::tryFrom($code)?->getMessage();
     }
 }
diff --git a/src/Guzzle.php b/src/Guzzle.php
@@ -44,7 +44,7 @@ protected function __construct()
     /**
      * @param array $config
      *
-     * @return \GuzzleHttp\Client
+     * @return Client
      */
     public static function newClient(array $config = []): Client
     {
diff --git a/src/Guzzle/RippleHandler.php b/src/Guzzle/RippleHandler.php
@@ -26,7 +26,7 @@
 class RippleHandler
 {
     /**
-     * @param \Ripple\Http\Client $httpClient
+     * @param Client $httpClient
      */
     public function __construct(private readonly Client $httpClient)
     {
diff --git a/src/Server.php b/src/Server.php
@@ -45,7 +45,7 @@ class Server
      */
     public Closure $onRequest;
 
-    /*** @var \Ripple\Socket */
+    /*** @var Socket */
     private Socket $server;
 
     /**
@@ -122,7 +122,7 @@ public function listen(): void
     }
 
     /**
-     * @param \Ripple\Socket $stream
+     * @param Socket $stream
      *
      * @return void
      */
@@ -162,9 +162,9 @@ private function listenSocket(Socket $stream): void
                 $stream->close();
             } catch (FormatException) {
                 /**** The message format is illegal*/
-                $response->setStatusCode(Status::BAD_REQUEST)->setBody(Status::MESSAGES[Status::BAD_REQUEST])->respond();
+                $response->setStatusCode(Status::BAD_REQUEST->value)->setBody(Status::getMessageForCode(Status::BAD_REQUEST->value))->respond();
             } catch (Throwable $e) {
-                $response->setStatusCode(Status::INTERNAL_SERVER_ERROR)->setBody($e->getMessage())->respond();
+                $response->setStatusCode(Status::INTERNAL_SERVER_ERROR->value)->setBody($e->getMessage())->respond();
                 Output::exception($e);
             }
         });
diff --git a/src/Server/Connection.php b/src/Server/Connection.php
@@ -24,7 +24,6 @@
 use function array_merge;
 use function count;
 use function explode;
-use function intval;
 use function is_array;
 use function is_string;
 use function json_decode;
diff --git a/tests/HttpAsyncTest.php b/tests/HttpAsyncTest.php
@@ -1,9 +1,11 @@
 <?php declare(strict_types=1);
 
+use GuzzleHttp\Exception\GuzzleException;
 use PHPUnit\Framework\Attributes\Test;
 use PHPUnit\Framework\TestCase;
 use Ripple\Http\Guzzle;
 use Ripple\Http\Server\Request;
+use Ripple\Stream\Exception\ConnectionException;
 
 /**
  *
@@ -14,8 +16,8 @@ class HttpAsyncTest extends TestCase
 
     /**
      * @return void
-     * @throws \GuzzleHttp\Exception\GuzzleException
-     * @throws \Ripple\Stream\Exception\ConnectionException
+     * @throws GuzzleException
+     * @throws ConnectionException
      */
     #[Test]
     public function testStreamDownload(): void
@@ -50,4 +52,92 @@ public function testStreamDownload(): void
 
         $this->assertEquals($size, \filesize($tempFile));
     }
+
+    /**
+     * Test data transfer under simulated slow bandwidth conditions
+     *
+     * @return void
+     * @throws GuzzleException
+     * @throws ConnectionException
+     */
+    #[Test]
+    public function testSlowBandwidthTransfer(): void
+    {
+        $size = 1 * 1024 * 1024;
+        $chunk = 4096;
+        $pattern = \md5(\uniqid('slow_bandwidth_test', true));
+
+        $server = new Ripple\Http\Server($this->testServer);
+        $server->onRequest(function (Request $request) use ($size, $pattern, $chunk) {
+            $generator = function () use ($size, $pattern, $chunk) {
+                $sent = 0;
+                $patternLength = \strlen($pattern);
+
+                while ($sent < $size) {
+                    \Co\sleep(0.1);
+                    $remaining = $size - $sent;
+                    $toSend = \min($chunk, $remaining);
+
+                    $data = '';
+                    $dataSize = 0;
+                    while ($dataSize < $toSend) {
+                        $remainingInChunk = $toSend - $dataSize;
+                        if ($remainingInChunk >= $patternLength) {
+                            $data .= $pattern;
+                            $dataSize += $patternLength;
+                        } else {
+                            $data .= \substr($pattern, 0, $remainingInChunk);
+                            $dataSize += $remainingInChunk;
+                        }
+                    }
+
+                    yield $data;
+                    $sent += $toSend;
+                }
+
+                yield false;
+            };
+
+            $request->respond($generator(), [
+                'Content-Type' => 'application/octet-stream',
+                'Content-Length' => \strval($size),
+            ]);
+        });
+
+        $server->listen();
+        $tempFile = \tempnam(\sys_get_temp_dir(), 'slow_bandwidth_test');
+
+        $client = Guzzle::newClient([
+            'timeout' => 0,
+        ]);
+
+        $response = $client->get($this->testServer, [
+            'sink' => $tempFile,
+        ]);
+
+        $this->assertEquals($size, \filesize($tempFile));
+
+        $fileContent = \file_get_contents($tempFile);
+        $patternLength = \strlen($pattern);
+
+        for ($i = 0; $i < 10; $i++) {
+            $offset = $i * $patternLength;
+            if ($offset + $patternLength <= $size) {
+                $chunk = \substr($fileContent, $offset, $patternLength);
+                $this->assertEquals($pattern, $chunk, "Data integrity failed at offset {$offset}");
+            }
+        }
+
+        $middleOffset = (int)($size / 2);
+        $middleOffset = $middleOffset - ($middleOffset % $patternLength);
+        $middleChunk = \substr($fileContent, $middleOffset, $patternLength);
+        $this->assertEquals($pattern, $middleChunk, "Data integrity failed in the middle at offset {$middleOffset}");
+
+        $endOffset = $size - $patternLength;
+        $endOffset = $endOffset - ($endOffset % $patternLength);
+        $endChunk = \substr($fileContent, $endOffset, $patternLength);
+        $this->assertEquals($pattern, $endChunk, "Data integrity failed at the end at offset {$endOffset}");
+
+        \unlink($tempFile);
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ public function __construct(private readonly array $config = [])`
`56`	`56`	`* @param array $option`
`57`	`57`	`*`
`58`	`58`	`* @return Response`
`59`		`- * @throws \Ripple\Stream\Exception\ConnectionException`
	`59`	`+ * @throws ConnectionException`
`60`	`60`	`*/`
`61`	`61`	`public function request(RequestInterface $request, array $option = []): Response`
`62`	`62`	`{`
Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ abstract public function onError(Throwable\|Exception $exception): void;`
`43`	`43`	`/**`
`44`	`44`	`* 请求完成`
`45`	`45`	`*`
`46`		`- * @param \GuzzleHttp\Psr7\Response $response`
	`46`	`+ * @param Response $response`
`47`	`47`	`*`
`48`	`48`	`* @return void`
`49`	`49`	`*/`
Original file line number	Diff line number	Diff line change
`@@ -156,13 +156,13 @@ public function getMessage(): string`
`156`	`156`	`}`
`157`	`157`
`158`	`158`	`/**`
`159`		`- * 获取状态码对应的消息（使用状态码）`
	`159`	`+ * Obtaining the Message Corresponding to a Status Code (Using a Status Code)`
`160`	`160`	`*`
`161`		`- * @param int $code 状态码`
`162`		`- * @return string\|null 状态消息，不存在则返回null`
	`161`	`+ * @param int $code Status code`
	`162`	`+ * @return string\|null Status message, null if it does not exist`
`163`	`163`	`*/`
`164`		`- public static function getMessageForCode(int $code): ?string`
	`164`	`+ public static function getMessageForCode(int $code): string\|null`
`165`	`165`	`{`
`166`		`- return self::tryFrom($code)?->getMessage();`
	`166`	`+ return Status::tryFrom($code)?->getMessage();`
`167`	`167`	`}`
`168`	`168`	`}`
Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ protected function __construct()`
`44`	`44`	`/**`
`45`	`45`	`* @param array $config`
`46`	`46`	`*`
`47`		`- * @return \GuzzleHttp\Client`
	`47`	`+ * @return Client`
`48`	`48`	`*/`
`49`	`49`	`public static function newClient(array $config = []): Client`
`50`	`50`	`{`
Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@`
`26`	`26`	`class RippleHandler`
`27`	`27`	`{`
`28`	`28`	`/**`
`29`		`- * @param \Ripple\Http\Client $httpClient`
	`29`	`+ * @param Client $httpClient`
`30`	`30`	`*/`
`31`	`31`	`public function __construct(private readonly Client $httpClient)`
`32`	`32`	`{`