Get Upload URLs for Parts

async function uploadMultipart(projectId: string, file: File, name: string, platform: string) {
  const token = process.env.NUNU_API_TOKEN;

  // Step 1: Initiate
  const initRes = await fetch(`https://nunu.ai/api/v1/project/${projectId}/builds/upload`, {
    method: "POST",
    headers: { "Content-Type": "application/json", "X-Api-Key": token },
    body: JSON.stringify({
      project_id: projectId, name, file_name: file.name,
      file_size: file.size, platform
    }),
  });
  const { upload_id, build_id, object_key, total_parts, part_size } = await initRes.json();

  // Step 2 & 3: Get URLs and upload parts
  const parts = [];
  const concurrency = 3;

  for (let i = 0; i < total_parts; i += concurrency) {
    const partNumbers = Array.from(
      { length: Math.min(concurrency, total_parts - i) },
      (_, j) => i + j + 1
    );

    // Get URLs
    const urlRes = await fetch(
      `https://nunu.ai/api/v1/project/${projectId}/builds/upload/parts?` +
      new URLSearchParams({ upload_id, object_key, part_numbers: partNumbers.join(",") })
    );
    const { upload_urls } = await urlRes.json();

    // Upload parts in parallel
    const uploaded = await Promise.all(
      upload_urls.map(async ({ part_number, url }) => {
        const start = (part_number - 1) * part_size;
        const chunk = file.slice(start, Math.min(start + part_size, file.size));
        const res = await fetch(url, {
          method: "PUT", body: chunk,
          headers: { "Content-Type": "application/octet-stream" }
        });
        return { part_number, etag: res.headers.get("etag")?.replace(/"/g, "") };
      })
    );
    parts.push(...uploaded);
    console.log(`Uploaded ${parts.length}/${total_parts} parts`);
  }

  // Step 4: Complete
  await fetch(`https://nunu.ai/api/v1/project/${projectId}/builds/upload/complete`, {
    method: "POST",
    headers: { "Content-Type": "application/json", "X-Api-Key": token },
    body: JSON.stringify({ build_id, upload_id, object_key, parts }),
  });

  return build_id;
}

import requests
import os

def upload_multipart(project_id: str, file_path: str, name: str, platform: str) -> str:
    token = os.environ["NUNU_API_TOKEN"]
    file_size = os.path.getsize(file_path)

    # Step 1: Initiate
    init_res = requests.post(
        f"https://nunu.ai/api/v1/project/{project_id}/builds/upload",
        headers={"Content-Type": "application/json", "X-Api-Key": token},
        json={"project_id": project_id, "name": name, 
              "file_name": os.path.basename(file_path),
              "file_size": file_size, "platform": platform}
    )
    data = init_res.json()
    upload_id, build_id = data["upload_id"], data["build_id"]
    object_key, total_parts = data["object_key"], data["total_parts"]
    part_size = data["part_size"]

    # Step 2 & 3: Get URLs and upload parts
    parts = []
    with open(file_path, "rb") as f:
        for i in range(0, total_parts, 3):
            part_numbers = list(range(i + 1, min(i + 4, total_parts + 1)))
            
            url_res = requests.get(
                f"https://nunu.ai/api/v1/project/{project_id}/builds/upload/parts",
                params={"upload_id": upload_id, "object_key": object_key,
                        "part_numbers": ",".join(map(str, part_numbers))}
            )
            
            for part_info in url_res.json()["upload_urls"]:
                f.seek((part_info["part_number"] - 1) * part_size)
                chunk = f.read(part_size)
                res = requests.put(part_info["url"], data=chunk,
                                   headers={"Content-Type": "application/octet-stream"})
                parts.append({"part_number": part_info["part_number"],
                              "etag": res.headers["ETag"].strip('"')})
            print(f"Uploaded {len(parts)}/{total_parts} parts")

    # Step 4: Complete
    requests.post(
        f"https://nunu.ai/api/v1/project/{project_id}/builds/upload/complete",
        headers={"Content-Type": "application/json", "X-Api-Key": token},
        json={"build_id": build_id, "upload_id": upload_id,
              "object_key": object_key, "parts": parts}
    )
    return build_id