Stream PTY Output

import sys

from gravixlayer import GravixLayer

client = GravixLayer()  # defaults to cloud="aws", region="us-east-1"
sandbox = client.runtime.create()  # defaults to template="base-small"
session = sandbox.pty.create()
sid = session.session_id

for event in sandbox.pty.stream(sid):
    if event["type"] == "data":
        print(event["data"].decode("utf-8", "replace"), end="")
    elif event["type"] == "exit":
        print(f"\nsession exited: {event['exit_code']}")
    elif event["type"] == "error":
        print(f"\nstream error: {event['message']}")

# Or with callbacks
sandbox.pty.stream(
    sid,
    on_data=lambda b: sys.stdout.buffer.write(b),
    on_exit=lambda code, status: print("exited", code, status),
)

sandbox.kill()

import { GravixLayer } from 'gravixlayer';

const client = new GravixLayer(); // defaults to cloud="aws", region="us-east-1"
const sandbox = await client.runtime.create(); // defaults to template="base-small"
const session = await sandbox.pty.create();
const sid = session.sessionId;

for await (const event of sandbox.pty.stream(sid)) {
  if (event.type === 'data') {
    process.stdout.write(new TextDecoder().decode(event.data));
  } else if (event.type === 'exit') {
    console.log(`\nsession exited: ${event.exitCode}`);
  } else if (event.type === 'error') {
    console.log(`\nstream error: ${event.message}`);
  }
}

// Or with a handle callback
const terminal = sandbox.pty.handle(sid).connect({
  onData: (chunk) => process.stdout.write(chunk),
  onExit: (code, status) => console.log('exited', code, status),
});

await sandbox.kill();

# Writes raw terminal bytes to stdout, so escape sequences render normally.
gravixlayer runtime pty attach "$RT" "$SID"

curl -N "https://api.gravixlayer.ai/v1/agents/runtime/$RT/pty/$SID/stream" \
  -H "Authorization: Bearer $GRAVIXLAYER_API_KEY"

import codecs

decoder = codecs.getincrementaldecoder("utf-8")(errors="replace")
for event in sandbox.pty.stream(sid):
    if event["type"] == "data":
        print(decoder.decode(event["data"]), end="")

const decoder = new TextDecoder();
for await (const event of sandbox.pty.stream(sid)) {
  if (event.type === 'data') process.stdout.write(decoder.decode(event.data));
}