Uploads

machine.files.write_files([
    ("/workspace/app.py", "print('hello')\n"),
    ("/workspace/README.md", "# Demo\n"),
])

nullspace machine file write-files mch_... '[["/workspace/app.py","print(\"hello\")\n"],["/workspace/README.md","# Demo\n"]]'

# batch-write is a multipart request: a JSON `manifest` part plus one part per file field.
printf "print('hello')\n" > app.py
printf '# Demo\n' > README.md
curl -X POST "${NULLSPACE_API_URL}/v1/machines/mch_123/files/batch-write" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}" \
  -F 'manifest={"files":[{"path":"/workspace/app.py","field":"file0"},{"path":"/workspace/README.md","field":"file1"}]}' \
  -F "file0=@app.py" \
  -F "file1=@README.md"

result = machine.files.upload_file("./dist/app.tar.gz", "/workspace/app.tar.gz")
print(result.transport, result.target_path, result.bytes_uploaded)

nullspace machine upload mch_... ./dist/app.tar.gz /workspace/app.tar.gz
# stream from stdin with "-" as the source:
cat ./dist/app.tar.gz | nullspace machine upload mch_... - /workspace/app.tar.gz

# 1. Mint a signed upload URL for the destination path.
URL=$(curl -fsS -X POST "${NULLSPACE_API_URL}/v1/machines/mch_123/files/upload-url" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}" \
  -H "Content-Type: application/json" \
  -d '{"path": "/workspace/app.tar.gz"}' | jq -r .url)

# 2. Stream the file bytes to the signed URL with PUT.
curl -X PUT "${URL}" \
  -H "Content-Type: application/octet-stream" \
  --data-binary @./dist/app.tar.gz

result = machine.files.upload_dir(
    "./src",
    "/workspace/src",
    conflict="merge",
    ignore_patterns=["*.pyc", "!pkg/__init__.py"],
)
print(result.file_count, result.target_path)

nullspace machine upload mch_... ./src /workspace/src --exclude '*.pyc'

# Directory uploads stream a tar archive through a resumable upload session.
# 1. Create the session (kind directory_tar).
tar -czf src.tar.gz ./src
curl -X POST "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}" \
  -H "Content-Type: application/json" \
  -d '{"kind": "directory_tar", "source_kind": "directory_archive", "target_path": "/workspace/src", "content_length": '"$(wc -c < src.tar.gz)"', "conflict": "merge", "archive_format": "tar", "checksum_algorithm": "sha256"}'

# 2. PUT each part (here a single part 0) to the returned upload id.
curl -X PUT "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads/upload_123/parts/0" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}" \
  -H "Content-Type: application/octet-stream" \
  --data-binary @src.tar.gz

# 3. Complete to extract and publish the archive.
curl -X POST "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads/upload_123/complete" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}"

from nullspace import FileUploadError

def on_progress(event) -> None:
    print(event.phase, event.bytes_completed, event.bytes_total, event.transport)

try:
    result = machine.files.upload_file(
        "./large-model.bin",
        "/data/model.bin",
        resumable=True,
        checksum="auto",
        spool_to_disk="auto",
        max_concurrency=4,
        progress=on_progress,
    )
except FileUploadError as exc:
    if exc.upload_id is None:
        raise
    result = machine.files.resume_upload(
        exc.upload_id,
        "./large-model.bin",
        progress=on_progress,
    )

print(result.upload_id, result.bytes_uploaded)

nullspace machine upload mch_... ./large.bin /data/large.bin \
  --resumable always --checksum auto --concurrency 4
# resume an interrupted transfer by upload id:
nullspace machine upload mch_... ./large.bin /data/large.bin --resume upload_...

# Resumable file uploads use the same upload-session primitives.
# 1. Create the session (kind file, source restartable_file).
curl -X POST "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}" \
  -H "Content-Type: application/json" \
  -d '{"kind": "file", "source_kind": "restartable_file", "target_path": "/data/model.bin", "content_length": 1048576, "conflict": "merge", "checksum_algorithm": "sha256"}'

# 2. Upload each part; parts may be replayed and sent out of order.
curl -X PUT "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads/upload_123/parts/0" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}" \
  -H "Content-Type: application/octet-stream" \
  --data-binary @./large-model.bin

# 3. Poll status to resume after an interruption, then complete.
curl -X GET "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads/upload_123" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}"
curl -X POST "${NULLSPACE_API_URL}/v1/machines/mch_123/uploads/upload_123/complete" \
  -H "Authorization: Bearer ${NULLSPACE_API_KEY}"