From 86614361255e04e33bdd2001196e6d388d691e63 Mon Sep 17 00:00:00 2001
From: Eli Mallon <eli@iame.li>
Date: Sat, 6 Jun 2026 19:53:37 -0700
Subject: [PATCH] upload: retry tus with tiny chunks

---
 js/app/src/screens/upload.tsx | 29 +++++++++++++++++++++++------
 1 file changed, 23 insertions(+), 6 deletions(-)

diff --git a/js/app/src/screens/upload.tsx b/js/app/src/screens/upload.tsx
index 70e196a8..743395e6 100644
--- a/js/app/src/screens/upload.tsx
+++ b/js/app/src/screens/upload.tsx
@@ -236,6 +236,8 @@ export default function UploadScreen() {
     setThumbnailUrl(undefined);
   }, []);
 
+  const [chunkSize, setChunkSize] = useState<number | undefined>(undefined);
+
   // ── polling ──────────────────────────────────────────────────────────────
 
   const pollStatus = useCallback(
@@ -305,12 +307,23 @@ export default function UploadScreen() {
       const { uploadUrl, uploadToken, uploadId } = res.data;
 
       await new Promise<void>((resolve, reject) => {
-        const upload = new tus.Upload(file, {
+        let retried = false;
+        const params: tus.UploadOptions = {
           uploadUrl,
           retryDelays: [0, 1000, 3000, 5000],
           headers: { Authorization: `Bearer ${uploadToken}` },
           metadata: { filename: file.name, filetype: file.type },
-          onError: reject,
+          onError: (err) => {
+            if (!retried) {
+              retried = true;
+              // <1mb for default nginx proxy settings
+              params.chunkSize = 800000;
+              doTry();
+            } else {
+              console.log(err);
+              reject(err);
+            }
+          },
           onProgress(bytesSent, bytesTotal) {
             setPhase({
               kind: "uploading",
@@ -320,9 +333,13 @@ export default function UploadScreen() {
             });
           },
           onSuccess: () => resolve(),
-        });
-        uploadRef.current = upload;
-        upload.start();
+        };
+        const doTry = () => {
+          const upload = new tus.Upload(file, params);
+          uploadRef.current = upload;
+          upload.start();
+        };
+        doTry();
       });
 
       uploadRef.current = null;
@@ -335,7 +352,7 @@ export default function UploadScreen() {
         message: err instanceof Error ? err.message : String(err),
       });
     }
-  }, [agent, file, pollStatus]);
+  }, [agent, file, pollStatus, chunkSize]);
 
   const cancelUpload = useCallback(() => {
     if (pollRef.current) clearTimeout(pollRef.current);
-- 
2.51.2