fix(http): convert Ripple file format to UploadedFile objects

Author: cclilshy

src/HttpWorker.php

@@ -31,11 +31,17 @@
 use Ripple\Stream\Exception\ConnectionException;
 use Ripple\Worker;
 use Symfony\Component\HttpFoundation\BinaryFileResponse;
+use Symfony\Component\HttpFoundation\File\UploadedFile;
 use Throwable;
 
 use function cli_set_process_title;
 use function fopen;
 use function stream_context_create;
+use function file_exists;
+use function is_array;
+
+use const UPLOAD_ERR_NO_FILE;
+use const UPLOAD_ERR_OK;
 
 /**
  * @Author cclilshy
@@ -140,7 +146,7 @@ protected function onRequest(Request $request): void
             $request->POST,
             [],
             $request->COOKIE,
-            $request->FILES,
+            $this->parseFiles($request->FILES),
             $request->SERVER,
             $request->CONTENT,
         );
@@ -204,6 +210,39 @@ protected function onRequest(Request $request): void
         }
     }
 
+    /*** @return array<string, array<UploadedFile>> */
+    protected function parseFiles(array $files): array
+    {
+        if (empty($files)) {
+            return [];
+        }
+
+        $parsed = [];
+        foreach ($files as $name => $items) {
+            if (!is_array($items)) {
+                continue;
+            }
+
+            if (isset($items[0]['path']) && is_array($items[0])) {
+                $parsed[$name] = [];
+                foreach ($items as $item) {
+                    $path = $item['path'];
+                    $parsed[$name][] = new UploadedFile(
+                        $path,
+                        $item['fileName'] ?? '',
+                        $item['contentType'] ?? 'application/octet-stream',
+                        file_exists($path) ? UPLOAD_ERR_OK : UPLOAD_ERR_NO_FILE,
+                        true
+                    );
+                }
+            } else {
+                $parsed[$name] = $items;
+            }
+        }
+
+        return $parsed;
+    }
+
     /**
      * @param Closure $handler
      * @return void

src/Octane/RippleClient.php

@@ -21,9 +21,15 @@
 use Ripple\Runtime\Support\Stdin;
 use Ripple\Stream\Exception\ConnectionException;
 use Symfony\Component\HttpFoundation\BinaryFileResponse;
+use Symfony\Component\HttpFoundation\File\UploadedFile;
 use Throwable;
 
 use function fopen;
+use function file_exists;
+use function is_array;
+
+use const UPLOAD_ERR_NO_FILE;
+use const UPLOAD_ERR_OK;
 
 /**
  *
@@ -42,7 +48,7 @@ public function marshalRequest(RequestContext $context): array
             $rippleHttpRequest->POST,
             [],
             $rippleHttpRequest->COOKIE,
-            $rippleHttpRequest->FILES,
+            $this->parseFiles($rippleHttpRequest->FILES),
             $rippleHttpRequest->SERVER,
             $rippleHttpRequest->CONTENT,
         );
@@ -98,4 +104,37 @@ public function error(Throwable $e, Application $app, Request $request, RequestC
     {
         Stdin::println($e->getMessage());
     }
+
+    /*** @return array<string, array<UploadedFile>> */
+    protected function parseFiles(array $files): array
+    {
+        if (empty($files)) {
+            return [];
+        }
+
+        $parsed = [];
+        foreach ($files as $name => $items) {
+            if (!is_array($items)) {
+                continue;
+            }
+
+            if (isset($items[0]['path']) && is_array($items[0])) {
+                $parsed[$name] = [];
+                foreach ($items as $item) {
+                    $path = $item['path'];
+                    $parsed[$name][] = new UploadedFile(
+                        $path,
+                        $item['fileName'] ?? '',
+                        $item['contentType'] ?? 'application/octet-stream',
+                        file_exists($path) ? UPLOAD_ERR_OK : UPLOAD_ERR_NO_FILE,
+                        true
+                    );
+                }
+            } else {
+                $parsed[$name] = $items;
+            }
+        }
+
+        return $parsed;
+    }
 }