curl "$ATAI_API_URL/agents/nodes/registry" \
  -H "Authorization: Bearer $ATAI_API_KEY"

import os
import requests

base_url = os.environ["ATAI_API_URL"]
api_key = os.environ["ATAI_API_KEY"]

response = requests.get(
    f"{base_url}/agents/nodes/registry",
    headers={"Authorization": f"Bearer {api_key}"},
)

registry = response.json()

for section in ("connectors", "nodes"):
    print(f"{section}:")
    for node in registry[section]:
        inputs = ", ".join(p["name"] for p in node["contract"]["inputs"]) or "-"
        outputs = ", ".join(p["name"] for p in node["contract"]["outputs"]) or "-"
        print(f"  {node['key']}: in=[{inputs}] out=[{outputs}]")

const response = await fetch(`${process.env.ATAI_API_URL}/agents/nodes/registry`, {
  headers: {
    'Authorization': `Bearer ${process.env.ATAI_API_KEY}`
  }
});

const registry = await response.json();

['connectors', 'nodes'].forEach(section => {
  console.log(`${section}:`);
  registry[section].forEach(node => {
    const inputs = node.contract.inputs.map(p => p.name).join(', ') || '-';
    const outputs = node.contract.outputs.map(p => p.name).join(', ') || '-';
    console.log(`  ${node.key}: in=[${inputs}] out=[${outputs}]`);
  });
});

{
  "connectors": [
    {
      "key": "<connector_key>",
      "description": "Reads records from an external data ref.",
      "contract": {
        "inputs": [],
        "outputs": [
          {"name": "out", "type": "Record"}
        ]
      },
      "config_schema": {},
      "default_config": {}
    }
  ],
  "nodes": [
    {
      "key": "<node_key>",
      "description": "Groups records into windows.",
      "contract": {
        "inputs": [
          {"name": "in", "type": "Record"}
        ],
        "outputs": [
          {"name": "out", "type": "Window"}
        ]
      },
      "config_schema": {
        "type": "object",
        "properties": {}
      },
      "default_config": {}
    }
  ]
}