Commands And Processes

from nullspace import Machine

with Machine.create() as machine:
    result = machine.commands.run(
        "echo $GREETING",
        shell=True,
        envs={"GREETING": "hello"},
        cwd="/workspace",
        timeout=30,
    )
    print(result.stdout.strip(), result.exit_code)

process = machine.commands.run("python3 -m http.server 8080", shell=True, background=True)
try:
    print(machine.commands.get_logs(process.pid).stdout)
finally:
    process.kill()
    result = process.wait()
    print(result.exit_code)

process = machine.commands.run(
    "python3 -u worker.py",
    shell=True,
    background=True,
    on_stdout=lambda chunk: print(chunk, end=""),
)
process.disconnect()

def on_stdout(chunk: str) -> None:
    print(chunk, end="")

result = machine.commands.run_streaming(
    "python3 -u script.py",
    shell=True,
    on_stdout=on_stdout,
)

handle = machine.commands.connect(process.pid, on_stdout=on_stdout)
result = handle.wait()

proc = machine.commands.run("python3 -i", shell=True, background=True)
machine.commands.send_stdin(proc.pid, "print('hello')\n")
machine.commands.send_stdin(proc.pid, "exit()\n")

exact = machine.commands.run("python3", args=["-c", "print('argv')"])
print(exact.stdout.strip())

from nullspace import AsyncMachine

async with await AsyncMachine.create() as machine:
    result = await machine.commands.run("echo async", shell=True)
    print(result.stdout.strip())

    proc = await machine.commands.run("sleep 10", shell=True, background=True)
    await proc.kill()

machine.git.configure_user(
    "Example User",
    "user@example.com",
    scope="local",
    path="/tmp/project",
)
machine.git.commit("Update docs", files=["README.md"], path="/tmp/project")