fix part start

src/s3.zig

@@ -1813,7 +1813,7 @@ pub const MultiPartUpload = struct {
             }, .{ .part = @ptrCast(&onPartResponse) }, this);
         }
         pub fn start(this: *@This()) void {
-            if (this.state != .pending) return;
+            if (this.state != .pending or this.ctx.state != .multipart_completed) return;
             this.ctx.ref();
             this.state = .started;
             this.perform();
@@ -1925,10 +1925,12 @@ pub const MultiPartUpload = struct {
 
     fn drainEnqueuedParts(this: *@This()) void {
         // check pending to start or transformed buffered ones into tasks
-        for (this.queue.items) |*part| {
-            if (part.state == .pending) {
-                // lets start the part request
-                part.start();
+        if (this.state == .multipart_completed) {
+            for (this.queue.items) |*part| {
+                if (part.state == .pending) {
+                    // lets start the part request
+                    part.start();
+                }
             }
         }
         const partSize = this.partSizeInBytes();
@@ -2099,7 +2101,7 @@ pub const MultiPartUpload = struct {
                 .search_params = "?uploads=",
                 .content_type = this.content_type,
             }, .{ .download = @ptrCast(&startMultiPartRequestResult) }, this);
-        } else {
+        } else if (this.state == .multipart_completed) {
             part.start();
         }
         return true;

test/js/bun/s3/s3.test.ts

@@ -109,7 +109,7 @@ describe.skipIf(!s3Options.accessKeyId)("s3", () => {
           // 15 MiB big enough to Multipart upload in more than one part
           const buffer = Buffer.alloc(1 * 1024 * 1024, "a");
           {
-            await fetch(tmp_filename + "-large", {
+            await fetch(tmp_filename, {
               method: "PUT",
               body: async function* () {
                 for (let i = 0; i < 15; i++) {
@@ -120,12 +120,9 @@ describe.skipIf(!s3Options.accessKeyId)("s3", () => {
               s3: options,
             }).then(res => res.text());
 
-            const result = await fetch(tmp_filename + "-large", { method: "HEAD", s3: options });
-
+            const result = await fetch(tmp_filename, { method: "HEAD", s3: options });
             expect(result.status).toBe(200);
             expect(result.headers.get("content-length")).toBe("15728640");
-
-            await fetch(tmp_filename + "-large", { method: "DELETE", s3: options });
           }
         }, 10_000);
       });