Method handleMCPAuthRequest

go/session.go:942–975

(request MCPAuthRequest)

}

func (s *Session) handleMCPAuthRequest(request MCPAuthRequest) {
	handler := s.getMCPAuthHandler()
	if handler == nil {
		return
	}

	ctx := context.Background()
	cancel := &rpc.MCPOauthPendingRequestResponseCancelled{}
	result, err := handler(request, MCPAuthInvocation{SessionID: s.SessionID})
	if err != nil {
		log.Printf(
			"MCP OAuth handler failed. SessionId=%s, RequestId=%s, Error=%v",
			s.SessionID,
			request.RequestID,
			err,
		)
	}
	if err != nil || result == nil || result.Kind == MCPAuthResultKindCancelled || result.Token == nil {
		s.RPC.MCP.Oauth().HandlePendingRequest(ctx, &rpc.MCPOauthHandlePendingRequest{
			RequestID: request.RequestID,
			Result:    cancel,
		})
		return
	}

	s.RPC.MCP.Oauth().HandlePendingRequest(ctx, &rpc.MCPOauthHandlePendingRequest{
		RequestID: request.RequestID,
		Result: &rpc.MCPOauthPendingRequestResponseToken{
			AccessToken: result.Token.AccessToken,
			TokenType:   result.Token.TokenType,
			ExpiresIn:   result.Token.ExpiresIn,
		},
	})
}

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