GravForge API.

curl -X POST http://localhost:3000/api/pipeline/full \
  -H "Content-Type: application/json" \
  -d '{
    "description": "A solar-powered soil moisture sensor with WiFi"
  }'

import json
import requests

def run_pipeline(description: str):
    """Run GravForge pipeline with SSE streaming."""
    url = "http://localhost:3000/api/pipeline/full"

    response = requests.post(
        url,
        json={"description": description},
        stream=True
    )

    for line in response.iter_lines():
        if not line:
            continue

        line = line.decode('utf-8')

        if line.startswith('event:'):
            event = line.split(':', 1)[1].strip()
        elif line.startswith('data:'):
            data = json.loads(line.split(':', 1)[1].strip())

            if event == 'stage':
                print(f"[{data['stage']}] {data['status']}")
            elif event == 'complete':
                print(f"✓ Complete in {data['pipeline_time_seconds']:.1f}s")
                return data
            elif event == 'error':
                print(f"✗ Error: {data['message']}")
                return None

result = run_pipeline("A WiFi-enabled temperature sensor")
if result:
    print(f"Device: {result['brief']['name']}")
    print(f"BOM: ${result['bom']['grand_total_usd']:.2f}")

async function runPipeline(description) {
  const response = await fetch('/api/pipeline/full', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ description }),
  });

  const reader = response.body.getReader();
  const decoder = new TextDecoder();

  while (true) {
    const { done, value } = await reader.read();
    if (done) break;

    const chunk = decoder.decode(value);
    const lines = chunk.split('\n');

    let event = '';
    for (const line of lines) {
      if (line.startsWith('event:')) {
        event = line.slice(6).trim();
      } else if (line.startsWith('data:')) {
        const data = JSON.parse(line.slice(5).trim());

        if (event === 'stage') {
          console.log(`[${data.stage}] ${data.status}`);
        } else if (event === 'complete') {
          console.log('✓ Pipeline complete!');
          return data;
        } else if (event === 'error') {
          console.error('Error:', data.message);
          return null;
        }
      }
    }
  }
}

const result = await runPipeline('A WiFi temperature sensor');
console.log('Device:', result.brief.name);
console.log('BOM:', `$${result.bom.grand_total_usd.toFixed(2)}`);

event: error
data: {"message":"Failed to parse description","stage":"describe"}