Method callAgent

flow/flow.go:306–321

callAgent hands the rendered prompt to a registered agent's Agent.Chat endpoint over RPC and returns its reply.

(ctx context.Context, name, message string)

// callAgent hands the rendered prompt to a registered agent's Agent.Chat
// endpoint over RPC and returns its reply.
func (f *Flow) callAgent(ctx context.Context, name, message string) (string, error) {
	info, _ := ai.RunInfoFrom(ctx)
	body, _ := json.Marshal(map[string]string{"message": message, "parent_id": info.RunID})
	req := f.client.NewRequest(name, "Agent.Chat", &codecbytes.Frame{Data: body})
	var rsp codecbytes.Frame
	if err := f.client.Call(ctx, req, &rsp); err != nil {
		return "", err
	}
	var out struct {
		Reply string `json:"reply"`
	}
	if err := json.Unmarshal(rsp.Data, &out); err != nil {
		return "", err
	}
	return out.Reply, nil
}

// Results returns a copy of all recorded execution results.
func (f *Flow) Results() []Result {