WebSockets: быстрый старт | Agent Inbox

Скопировать в Cursor / Claude

Скопируйте один из блоков ниже для мгновенной настройки WebSocket.

"""
Agent Inbox WebSockets Quickstart — copy into Cursor/Claude.
client.websockets.connect() → socket.send_subscribe(Subscribe(inbox_ids=[...])) → iterate socket for events.
"""
from agentinbox import Agentinbox, Subscribe, Subscribed, MessageReceivedEvent
client = Agentinbox()
with client.websockets.connect() as socket:
  socket.send_subscribe(Subscribe(inbox_ids=["my-agent@agentinbox.space"]))
  for event in socket:
    if isinstance(event, Subscribed): print(f"Subscribed to {event.inbox_ids}")
    elif isinstance(event, MessageReceivedEvent): print(f"Received from: {event.message.from_}")

Примеры SDK

TypeScript

import { AgentinboxClient } from "agentinbox";
const client = new AgentinboxClient();
async function main() {
  const socket = await client.websockets.connect();
  socket.on("message", async (event) => {
    if (event.type === "subscribed") {
      console.log("Subscribed to", event.inboxIds);
    } else if (
      event.type === "event" &&
      event.eventType === "message.received"
    ) {
      console.log(`Received message from: ${event.message.from}`);
    }
  });
  await socket.waitForOpen();
  socket.sendSubscribe({
    type: "subscribe",
    inboxIds: ["my-agent@agentinbox.space"],
  });
}
main();

Python

from agentinbox import Agentinbox, MessageReceivedEvent, Subscribe, Subscribed
client = Agentinbox()
with client.websockets.connect() as socket:
    socket.send_subscribe(Subscribe(inbox_ids=["my-agent@agentinbox.space"]))
    for event in socket:
        if isinstance(event, Subscribed):
            print(f"Subscribed to {event.inbox_ids}")
        elif isinstance(event, MessageReceivedEvent):
            msg = event.message
            print(f"Received message from: {msg.from_}")