Quick Start Guide¶

# save as register_agent.py
import asyncio
from arcp import ARCPClient

async def main():
    # Connect to ARCP server
    client = ARCPClient("http://localhost:8001")

    try:
        print("Registering agent with ARCP...")

        # Register an agent
        agent = await client.register_agent(
            agent_id="my-first-agent",
            name="My First Agent",
            agent_type="testing",
            endpoint="https://my-agent.example.com",
            capabilities=["testing", "demo", "hello-world"],
            context_brief="A simple test agent for learning ARCP",
            version="1.0.0",
            owner="Quick Start User",
            communication_mode="remote",
            agent_key="test-agent-001",  # From your ARCP configuration
            public_key="my-super-secure-public-key-that-is-at-least-32-chars-long",
            metadata={
                "version": "1.0.0",
                "author": "Quick Start User",
                "description": "A simple test agent for learning ARCP",
                "tags": ["demo", "testing", "learning"]
            }
        )

        print(f"Agent registered successfully!")
        print(f"   Name: {agent.name}")
        print(f"   ID: {agent.agent_id}")
        print(f"   Status: {agent.status}")
        print(f"   Registered at: {agent.registered_at}")

        # Search for our agent
        print("\nSearching for agents...")
        results = await client.search_agents("find test agents")

        print(f"Found {len(results)} agents:")
        for result in results:
            print(f"  • {result.name} (similarity: {result.similarity:.3f})")
            print(f"    Capabilities: {', '.join(result.capabilities)}")

        # List all agents
        print("\nAll registered agents:")
        agents = await client.discover_agents()
        for agent in agents:
            print(f"  • {agent.name} ({agent.agent_type}) - {agent.status}")

    except Exception as e:
        print(f"Error: {e}")
        print(f"Error type: {type(e).__name__}")

    finally:
        await client.close()

if __name__ == "__main__":
    asyncio.run(main())

# save as test_heartbeat.py
import asyncio
from arcp import ARCPClient

async def main():
    client = ARCPClient("http://localhost:8001")

    try:
        print("Testing heartbeat functionality...")

        # Request fresh authentication token
        token = await client.request_temp_token(
            agent_id="my-first-agent",
            agent_type="testing",
            agent_key="test-agent-001"
        )

        # Update heartbeat to keep agent alive
        response = await client.update_heartbeat("my-first-agent")
        print(f"Heartbeat updated: {response}")

        # Get agent details
        agent = await client.get_agent("my-first-agent")
        print(f"Agent status: {agent.status}")
        print(f"Last seen: {agent.last_seen}")

    except Exception as e:
        print(f"Error: {e}")

    finally:
        await client.close()

asyncio.run(main())

# save as test_metrics.py
import asyncio
import datetime
from arcp import ARCPClient

async def main():
    client = ARCPClient("http://localhost:8001")

    try:
        print("Testing metrics functionality...")

        # Request fresh authentication token
        token = await client.request_temp_token(
            agent_id="my-first-agent",
            agent_type="testing",
            agent_key="test-agent-001"
        )

        # Report performance metrics
        metrics_data = {
            "total_requests": 100,
            "success_rate": 0.95,
            "avg_response_time": 0.15,
            "last_active": datetime.datetime.now().isoformat()
        }

        response = await client.update_metrics("my-first-agent", metrics_data)
        print(f"Metrics updated: {response}")

        # Get current metrics
        current_metrics = await client.get_metrics("my-first-agent")
        print(f"Current metrics: {current_metrics}")

    except Exception as e:
        print(f"Error: {e}")

    finally:
        await client.close()

asyncio.run(main())

# save as test_websocket.py
import asyncio
from arcp import ARCPClient

async def main():
    client = ARCPClient("http://localhost:8001")

    print("Connecting to WebSocket for real-time updates...")
    print("   (This will run for 30 seconds, then exit)")

    message_count = 0
    async for message in client.websocket_public():
        message_count += 1
        print(f"Message {message_count}: {message.get('type', 'unknown')}")

        # Stop after 30 seconds or 10 messages
        if message_count >= 10:
            break

    print(f"Received {message_count} real-time updates")

asyncio.run(main())