enki/torrent-gateway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

more fucking UI fixes
Some checks are pending
CI Pipeline / Run Tests (push) Waiting to run
Details
CI Pipeline / Lint Code (push) Waiting to run
Details
CI Pipeline / Security Scan (push) Waiting to run
Details
CI Pipeline / E2E Tests (push) Blocked by required conditions
Details

Browse Source
This commit is contained in:
Enki 2025-08-27 23:36:48 -07:00
parent c82d5554d8
commit 653c291f1d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/api/handlers.go
View File

@ -733,12 +733,15 @@ func (g *Gateway) UploadHandler(w http.ResponseWriter, r *http.Request) {
// Size-based routing: decide between blob and torrent storage // Size-based routing: decide between blob and torrent storage
blobThreshold := g.config.GetBlobThreshold() blobThreshold := g.config.GetBlobThreshold()
log.Printf("DEBUG: Upload routing - File: %s, Size: %d bytes, BlobThreshold: %d bytes", fileName, fileHeader.Size, blobThreshold)
if fileHeader.Size < blobThreshold { if fileHeader.Size < blobThreshold {
// Small file - store as single Blossom blob // Small file - store as single Blossom blob
log.Printf("DEBUG: Routing %s to BLOB storage (size %d < threshold %d)", fileName, fileHeader.Size, blobThreshold)
g.handleBlobUpload(w, r, file, fileName, fileHeader) g.handleBlobUpload(w, r, file, fileName, fileHeader)
return return
} else { } else {
// Large file - use existing chunking logic // Large file - use existing chunking logic
log.Printf("DEBUG: Routing %s to TORRENT storage (size %d >= threshold %d)", fileName, fileHeader.Size, blobThreshold)
g.handleTorrentUpload(w, r, file, fileName, fileHeader) g.handleTorrentUpload(w, r, file, fileName, fileHeader)
return return
} }
@ -746,6 +749,7 @@ func (g *Gateway) UploadHandler(w http.ResponseWriter, r *http.Request) {
// handleBlobUpload handles small files that should be stored as single Blossom blobs // handleBlobUpload handles small files that should be stored as single Blossom blobs
func (g *Gateway) handleBlobUpload(w http.ResponseWriter, r *http.Request, file multipart.File, fileName string, fileHeader *multipart.FileHeader) { func (g *Gateway) handleBlobUpload(w http.ResponseWriter, r *http.Request, file multipart.File, fileName string, fileHeader *multipart.FileHeader) {
log.Printf("DEBUG: handleBlobUpload called for file: %s (size: %d bytes)", fileName, fileHeader.Size)
// Determine content type // Determine content type
contentType := fileHeader.Header.Get("Content-Type") contentType := fileHeader.Header.Get("Content-Type")
if contentType == "" { if contentType == "" {
@ -880,6 +884,7 @@ func (g *Gateway) handleBlobUpload(w http.ResponseWriter, r *http.Request, file
// handleTorrentUpload handles large files that should be chunked for BitTorrent // handleTorrentUpload handles large files that should be chunked for BitTorrent
func (g *Gateway) handleTorrentUpload(w http.ResponseWriter, r *http.Request, file multipart.File, fileName string, fileHeader *multipart.FileHeader) { func (g *Gateway) handleTorrentUpload(w http.ResponseWriter, r *http.Request, file multipart.File, fileName string, fileHeader *multipart.FileHeader) {
log.Printf("DEBUG: handleTorrentUpload called for file: %s (size: %d bytes)", fileName, fileHeader.Size)
// Reset file reader position // Reset file reader position
file.Seek(0, 0) file.Seek(0, 0)