Method elicitationHandler

pkg/runtime/elicitation.go:141–179

elicitationHandler is the MCP-toolset-side hook that turns an inbound elicitation request from a server into an ElicitationRequest event on the active stream's events channel and waits for the embedder's response on elicitationRequestCh.

(ctx context.Context, req *mcp.ElicitParams)

// active stream's events channel and waits for the embedder's response on
// elicitationRequestCh.
func (r *LocalRuntime) elicitationHandler(ctx context.Context, req *mcp.ElicitParams) (tools.ElicitationResult, error) {
	slog.DebugContext(ctx, "Elicitation request received from MCP server", "message", req.Message)

	// In non-interactive mode (e.g., MCP serve), there is no user to respond
	// to elicitation requests. Decline immediately instead of blocking forever.
	if r.nonInteractive {
		slog.DebugContext(ctx, "Declining elicitation in non-interactive mode", "message", req.Message)
		return tools.ElicitationResult{
			Action: tools.ElicitationActionDecline,
		}, nil
	}

	r.executeOnUserInputHooks(ctx, "", "elicitation")

	slog.DebugContext(ctx, "Sending elicitation request event to client",
		"message", req.Message,
		"mode", req.Mode,
		"requested_schema", req.RequestedSchema,
		"url", req.URL)
	slog.DebugContext(ctx, "Elicitation request meta", "meta", req.Meta)

	if err := r.elicitation.send(
		ElicitationRequest(req.Message, req.Mode, req.RequestedSchema, req.URL, req.ElicitationID, req.Meta, r.currentAgentName()),
	); err != nil {
		return tools.ElicitationResult{}, err
	}

	// Wait for response from the client.
	select {
	case result := <-r.elicitationRequestCh:
		return tools.ElicitationResult{
			Action:  result.Action,
			Content: result.Content,
		}, nil
	case <-ctx.Done():
		slog.DebugContext(ctx, "Context cancelled while waiting for elicitation response")
		return tools.ElicitationResult{}, ctx.Err()
	}
}