Function mapRpcFunction

packages/agent-core/src/rpc/client.ts:51–70

(fn: Function)

  }

  function mapRpcFunction(fn: Function): Function {
    return async (payload: any, options?: RPCCallOptions) => {
      const signal = options?.signal;
      const rpcPayload = await simulateNetwork(payload);
      signal?.throwIfAborted();
      let response: RpcResponse;
      try {
        const handlerResult =
          signal === undefined ? fn(rpcPayload) : fn(rpcPayload, { signal });
        const value = await abortableRpc(Promise.resolve(handlerResult), signal);
        response = { ok: true, value };
      } catch (error) {
        signal?.throwIfAborted();
        response = { ok: false, error: toKimiErrorPayload(error) };
      }
      const remoteResponse = await simulateNetwork(response);
      if (remoteResponse.ok) return remoteResponse.value;
      throw fromKimiErrorPayload(remoteResponse.error);
    };
  }

  function bindAllFunctions<T extends Record<string, any>>(obj: T): T {
    const bound: Record<string, unknown> = {};