feat(Body): improving FormFiles

src/lib/Core/File.php

@@ -11,7 +11,6 @@
 use function Amp\File\getStatus;
 use function Amp\File\openFile;
 use Dotenv\Dotenv;
-use Error;
 use Throwable;
 
 readonly class File {
@@ -173,6 +172,25 @@ public static function writeFile(string $filename, string $contents):Unsafe {
  $file->close();
  return ok();
  }
+
+ /**
+ * Stream contents to a file.\
+ * If the file doesn't exist it will be created.
+ * @param ReadableStream $readableStream
+ * @return Unsafe<None>
+ */
+ public static function writeStreamFile(string $filename, ReadableStream $readableStream):Unsafe {
+ $file = File::open($filename, 'w+')->unwrap($error);
+ if ($error) {
+ return error($error);
+ }
+ $file->writeStream($readableStream)->unwrap($error);
+ if ($error) {
+ return error($error);
+ }
+ $file->close();
+ return ok();
+ }
 
  /**
  * Read the contents of a file.

src/lib/Web/Body.php

@@ -6,13 +6,12 @@
 use Amp\Http\Server\Request;
 use function CatPaw\Core\error;
 use function CatPaw\Core\ok;
-
 use CatPaw\Core\Unsafe;
 use Throwable;
 
 class Body {
  private null|Cancellation $cancellation = null;
- private int $sizeLimit = 1024 * 1024 * 120;
+ private int $sizeLimit = 1024 * 1024 * 1024 * 10; // 10GB
  public function __construct(
  public readonly Request $request,
  ) {

src/lib/Web/BodyParser.php

@@ -1,20 +1,14 @@
 <?php
-
 namespace CatPaw\Web;
 
 use Amp\Cancellation;
 use Amp\Http\Server\FormParser\StreamingFormParser;
 use Amp\Http\Server\Request;
-
 use function CatPaw\Core\error;
 use function CatPaw\Core\ok;
-
 use CatPaw\Core\Unsafe;
 use function json_decode;
-
 use stdClass;
-
-
 use Throwable;
 
 class BodyParser {
@@ -48,7 +42,7 @@ public static function parseAsObject(
  if ($field->isFile()) {
  $result->{$name} = new FormFile(
  fileName: $field->getFilename(),
- fileContents: $field->buffer($cancellation),
+ fileContents: $field->buffer()
  );
  } else {
  $result->{$name} = $field->buffer($cancellation);