Function createA2AClient

apps/sim/lib/a2a/client.ts:194–222

(
  agentUrl: string,
  apiKey?: string,
  options: { signal?: AbortSignal } = {}
)

 * request is cancelled.
 */
export async function createA2AClient(
  agentUrl: string,
  apiKey?: string,
  options: { signal?: AbortSignal } = {}
): Promise<Client> {
  const validation = await validateUrlWithDNS(agentUrl, 'agentUrl')
  if (!validation.isValid || !validation.resolvedIP) {
    throw new Error(validation.error || 'Agent URL validation failed')
  }
  const { resolvedIP } = validation

  const card = await resolveAgentCard(agentUrl, resolvedIP, options.signal)

  const pinnedFetch = createPinnedFetch(resolvedIP, {
    timeout: RPC_TIMEOUT_MS,
    signal: options.signal,
  })
  const factory = new ClientFactory(
    ClientFactoryOptions.createFrom(ClientFactoryOptions.default, {
      transports: [
        new JsonRpcTransportFactory({ fetchImpl: pinnedFetch }),
        new RestTransportFactory({ fetchImpl: pinnedFetch }),
      ],
      ...(apiKey ? { clientConfig: { interceptors: [new ApiKeyInterceptor(apiKey)] } } : {}),
    })
  )

  return factory.createFromAgentCard(card)
}

/** A file to attach to an outgoing message, resolved to raw bytes from Sim storage. */
export interface A2AFileInput {