Scripting with Maestro CLI

# Get all agent names
maestro-cli list agents --json | jq -r '.name'

# Filter active agents
maestro-cli list agents --json | jq 'select(.state == "ready")'

# Count agents by type
maestro-cli list agents --json | jq -s 'group_by(.type) | map({type: .[0].type, count: length})'

import subprocess
import json

# Get all agents
result = subprocess.run(
    ['maestro-cli', 'list', 'agents', '--json'],
    capture_output=True,
    text=True
)

agents = [json.loads(line) for line in result.stdout.strip().split('\n')]

for agent in agents:
    print(f"{agent['name']}: {agent['state']}")

const { execSync } = require('child_process');

// Get all playbooks
const output = execSync('maestro-cli list playbooks --json', { encoding: 'utf-8' });
const playbooks = output.trim().split('\n').map(line => JSON.parse(line));

console.log(`Found ${playbooks.length} playbooks`);

maestro-cli playbook my-playbook --json | while read -r event; do
  TYPE=$(echo "$event" | jq -r '.type')
  case $TYPE in
    start)
      echo "Playbook started"
      ;;
    task:start)
      TASK=$(echo "$event" | jq -r '.task')
      echo "Starting task: $TASK"
      ;;
    task:complete)
      echo "Task complete"
      ;;
    complete)
      echo "Playbook finished"
      ;;
  esac
done

#!/bin/bash
AGENT_ID="my-agent"
STATE=$(maestro-cli show agent "$AGENT_ID" --json | jq -r '.state')

if [ "$STATE" = "ready" ]; then
  echo "Agent is ready"
  maestro-cli send "$AGENT_ID" "Run tests"
else
  echo "Agent is busy or offline: $STATE"
  exit 1
fi

#!/bin/bash
set -e

# Run playbook and capture exit code
if maestro-cli playbook nightly-tests --json > /tmp/playbook.log 2>&1; then
  echo "Playbook succeeded"
  # Parse results
  ERRORS=$(grep '"type":"error"' /tmp/playbook.log | wc -l)
  echo "Errors: $ERRORS"
else
  echo "Playbook failed"
  cat /tmp/playbook.log
  exit 1
fi

import subprocess
import json
import sys

process = subprocess.Popen(
    ['maestro-cli', 'playbook', 'my-playbook', '--json'],
    stdout=subprocess.PIPE,
    stderr=subprocess.PIPE,
    text=True
)

for line in iter(process.stdout.readline, ''):
    if not line:
        break
    
    event = json.loads(line)
    event_type = event.get('type')
    
    if event_type == 'task:start':
        print(f"→ {event['task']}", flush=True)
    elif event_type == 'task:complete':
        print("✓", flush=True)
    elif event_type == 'error':
        print(f"✗ Error: {event['message']}", file=sys.stderr, flush=True)

exit_code = process.wait()
sys.exit(exit_code)

name: Run Maestro Playbook
on:
  push:
    branches: [main]

jobs:
  test:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v3
      
      - name: Run Maestro playbook
        run: |
          maestro-cli playbook ci-tests --json | tee /tmp/playbook.log
          
      - name: Parse results
        if: always()
        run: |
          TASKS=$(jq -s '[.[] | select(.type == "task:complete")] | length' /tmp/playbook.log)
          ERRORS=$(jq -s '[.[] | select(.type == "error")] | length' /tmp/playbook.log)
          echo "Tasks completed: $TASKS"
          echo "Errors: $ERRORS"

test:
  script:
    - maestro-cli playbook integration-tests --json > playbook.log
    - cat playbook.log | jq -r 'select(.type == "error") | .message'
  artifacts:
    when: always
    paths:
      - playbook.log

#!/bin/bash

# Capture both stdout and stderr
OUTPUT=$(maestro-cli list agents --json 2>&1)
EXIT_CODE=$?

if [ $EXIT_CODE -ne 0 ]; then
  echo "Error running command: $OUTPUT" >&2
  exit $EXIT_CODE
fi

# Parse successful output
echo "$OUTPUT" | jq -r '.name'