Fixes

Author: codeSamuraii

lib/callbacks.py

@@ -24,7 +24,7 @@ def raise_http_exception(request: Request) -> Callable[[Exception | str], Awaita
     """Callback to raise an HTTPException with a specific status code."""
 
     async def _raise_http_exception(error: Exception | str) -> None:
-        code = error.status_code if isinstance(error, HTTPException) else 405
+        code = error.status_code if isinstance(error, HTTPException) else 502
         raise StreamTerminated(f"{code}: {str(error)}") from error
 
     return _raise_http_exception

lib/metadata.py

@@ -1,12 +1,12 @@
 from starlette.datastructures import Headers
-from pydantic import BaseModel, Field, field_validator, ByteSize, ConfigDict, AliasChoices
+from pydantic import BaseModel, Field, StrictStr, field_validator, ByteSize, ConfigDict, AliasChoices
 from typing import Optional, Self, Annotated
 
 
 class FileMetadata(BaseModel):
-    name: str = Field(description="File name", min_length=1, max_length=255)
+    name: StrictStr = Field(description="File name", min_length=1, max_length=255)
     size: ByteSize = Field(description="Size in bytes", gt=0)
-    type: str = Field(description="MIME type", default='application/octet-stream')
+    type: StrictStr = Field(description="MIME type", default='application/octet-stream')
 
     model_config = ConfigDict(title="File transfer metadata", alias_generator=lambda s: f'file_{s}', populate_by_name=True, validate_by_name=True)
 
@@ -29,7 +29,7 @@ def get_from_http_headers(cls, headers: Headers, filename: str) -> Self:
         return cls(
             name=filename,
             size=headers.get('content-length', '0'),
-            type=headers.get('content-type', '')
+            type=headers.get('content-type', '')  # Must be a string
         )
 
     @classmethod

lib/transfer.py

@@ -91,7 +91,7 @@ async def consume_upload(self, stream: AsyncIterator[bytes], on_error: Callable[
                 raise TransferError("Incomplete upload", propagate=True)
 
             await self.store.add_chunk(self.DONE_FLAG)
-            self.debug(f"△ Upload complete: {self.bytes_uploaded} bytes")
+            self.debug(f"△ All data chunks uploaded: {self.bytes_uploaded} bytes")
 
         except (ClientDisconnect, WebSocketDisconnect):
             self.error(f"△ Sender disconnected")
@@ -122,7 +122,7 @@ async def produce_download(self, on_error: Callable[[Exception | str], Awaitable
 
                 if chunk == self.DONE_FLAG:
                     if self.bytes_downloaded >= self.file.size:
-                        self.debug(f"▼ Download complete: {self.bytes_downloaded} bytes")
+                        self.debug(f"▼ All data chunks downloaded: {self.bytes_downloaded} bytes")
                     break
 
                 self.bytes_downloaded += len(chunk)

views/http.py

@@ -37,7 +37,7 @@ async def http_upload(request: Request, uid: str, filename: str):
         raise HTTPException(status_code=400, detail="Cannot decode file metadata from HTTP headers.")
     except ValidationError as e:
         log.error("△ Invalid file metadata.", exc_info=e)
-        raise HTTPException(status_code=400, detail=f"Invalid file metadata: {e.errors(False, False, True)}")
+        raise HTTPException(status_code=400, detail=f"Invalid file metadata: {e.errors(include_url=False, include_context=True, include_input=False)}")
 
     if file.size > 1024**3:
         raise HTTPException(status_code=413, detail="File too large. 1GiB maximum for HTTP.")