Filesystem

from nullspace import Machine

with Machine.create() as machine:
    machine.files.write("/workspace/hello.txt", "hello\n")
    machine.files.write_files([
        ("/workspace/a.txt", "a\n"),
        ("/workspace/b.txt", "b\n"),
    ])
    print(machine.files.read("/workspace/hello.txt"))
    print(machine.files.read("/workspace/hello.txt", format="bytes"))
    print(machine.files.list("/workspace"))

for chunk in machine.files.read("/workspace/large.log", format="stream"):
    process_chunk(chunk)

machine.files.upload("./local.txt", "/workspace/local.txt")
machine.files.upload_dir("./src", "/workspace/src", max_concurrency=4)
machine.files.upload_file(
    "./large.bin",
    "/data/large.bin",
    resumable=True,
    checksum="auto",
    spool_to_disk="auto",
)
url = machine.files.download_url("/workspace/local.txt")
print(url)

info = machine.files.info("/workspace/local.txt")
exists = machine.files.exists("/workspace/local.txt")
matches = machine.files.search_files("/workspace", "*.txt")
print(info.path, exists, matches)

paths = machine.files.search_files("/workspace", "*.py")
count = machine.files.replace_in_files(paths, "old_name", "new_name")
print(count)

def on_event(event):
    print(event.type, event.path)

with machine.files.watch_dir("/workspace", on_event, recursive=True, timeout=30):
    machine.files.write("/workspace/changed.txt", "changed\n")

from nullspace import AsyncMachine

async with await AsyncMachine.create(template="base") as machine:
    await machine.files.write("/workspace/hello.txt", "hello\n")
    text = await machine.files.read("/workspace/hello.txt")
    matches = await machine.files.search_files("/workspace", "*.txt")
    print(text, matches)