Agents

from trustgate import TrustGate

tg = TrustGate()
tg.agents()                                    # every agent the key reaches
planner = tg.agent("Travel planner")           # one, by name or id

import { TrustGate } from "@neuraltrust/trustgate"

const tg = new TrustGate()
await tg.agents()                              // every agent the key reaches
const planner = await tg.agent("Travel planner") // one, by name or id

# pip install "a2a-sdk>=1,<2" httpx
import asyncio

import httpx
from a2a.client import ClientConfig, create_client
from a2a.helpers import get_stream_response_text, new_text_message
from a2a.types import Role, SendMessageRequest


async def main() -> None:
    agent = TrustGate().agent("Travel planner")
    async with httpx.AsyncClient(headers=agent.headers, timeout=120) as http:
        client = await create_client(agent.url, client_config=ClientConfig(httpx_client=http))
        request = SendMessageRequest(message=new_text_message("plan a weekend in Lisbon", role=Role.ROLE_USER))
        async for event in client.send_message(request):
            print(get_stream_response_text(event))


asyncio.run(main())

// npm install @a2a-js/sdk
import { SendMessageRequest } from "@a2a-js/sdk"
import {
  ClientFactory,
  ClientFactoryOptions,
  DefaultAgentCardResolver,
  JsonRpcTransportFactory,
  createAuthenticatingFetchWithRetry,
} from "@a2a-js/sdk/client"

const agent = await new TrustGate().agent("Travel planner")

const fetchImpl = createAuthenticatingFetchWithRetry(fetch, {
  headers: async () => agent.headers,
  shouldRetryWithHeaders: async () => undefined,
})
const factory = new ClientFactory(
  ClientFactoryOptions.createFrom(ClientFactoryOptions.default, {
    transports: [new JsonRpcTransportFactory({ fetchImpl })],
    cardResolver: new DefaultAgentCardResolver({ fetchImpl }),
  })
)
// The whole card URL and an empty path: given the agent's URL, the resolver
// would replace its last segment instead of appending to it.
const client = await factory.createFromUrl(agent.cardUrl, "")

const reply = await client.sendMessage(
  SendMessageRequest.fromJSON({
    message: { messageId: crypto.randomUUID(), role: "ROLE_USER", parts: [{ text: "plan a weekend in Lisbon" }] },
  })
)

planner = tg.agent("Travel planner", end_user="user_123")

const planner = await tg.agent("Travel planner", { endUser: "user_123" })