Method handleElicitationRequest

go/session.go:979–1024

handleElicitationRequest dispatches an elicitation.requested event to the registered handler and sends the result back via the RPC layer. Auto-cancels on error.

(elicitCtx ElicitationContext, requestID string)

// handleElicitationRequest dispatches an elicitation.requested event to the registered handler
// and sends the result back via the RPC layer. Auto-cancels on error.
func (s *Session) handleElicitationRequest(elicitCtx ElicitationContext, requestID string) {
	handler := s.getElicitationHandler()
	if handler == nil {
		return
	}

	ctx := context.Background()

	result, err := handler(elicitCtx)
	if err != nil {
		// Handler failed — attempt to cancel so the request doesn't hang.
		s.RPC.UI.HandlePendingElicitation(ctx, &rpc.UIHandlePendingElicitationRequest{
			RequestID: requestID,
			Result: rpc.UIElicitationResponse{
				Action: rpc.UIElicitationResponseActionCancel,
			},
		})
		return
	}

	var rpcContent map[string]rpc.UIElicitationFieldValue
	if result.Content != nil {
		rpcContent = make(map[string]rpc.UIElicitationFieldValue, len(result.Content))
		for k, v := range result.Content {
			contentValue, err := toRPCContent(v)
			if err != nil {
				s.RPC.UI.HandlePendingElicitation(ctx, &rpc.UIHandlePendingElicitationRequest{
					RequestID: requestID,
					Result: rpc.UIElicitationResponse{
						Action: rpc.UIElicitationResponseActionCancel,
					},
				})
				return
			}
			rpcContent[k] = contentValue
		}
	}

	s.RPC.UI.HandlePendingElicitation(ctx, &rpc.UIHandlePendingElicitationRequest{
		RequestID: requestID,
		Result: rpc.UIElicitationResponse{
			Action:  result.Action,
			Content: rpcContent,
		},
	})
}

// toRPCContent converts an SDK content value to an RPC elicitation response value.
func toRPCContent(v any) (rpc.UIElicitationFieldValue, error) {