ugrpc::server::MiddlewareCallContext Class Reference

#include <userver/ugrpc/server/middlewares/base.hpp>

Detailed Description

Context for middleware-specific data during gRPC call.

Examples

samples/grpc_middleware_service/src/middlewares/server/auth.cpp, samples/grpc_middleware_service/src/middlewares/server/auth.hpp, samples/grpc_middleware_service/src/middlewares/server/meta_filter.cpp, and samples/grpc_middleware_service/src/middlewares/server/meta_filter.hpp.

Definition at line 66 of file base.hpp.

Inheritance diagram for ugrpc::server::MiddlewareCallContext:

Public Member Functions
void	SetError (grpc::Status &&status) noexcept
	Aborts the RPC, returning the specified status to the upstream client, see details below.
RpcType	GetRpcType () const noexcept
const dynamic_config::Snapshot &	GetInitialDynamicConfig () const
	Get values extracted from dynamic_config. Snapshot will be deleted when the last middleware completes.
grpc::ServerContextBase &	GetServerContext ()
const grpc::ServerContextBase &	GetServerContext () const
	This is an overloaded member function, provided for convenience. It differs from the above function only in what argument(s) it accepts.
std::string_view	GetCallName () const
	Name of the RPC in the format full.path.ServiceName/MethodName.
std::string_view	GetServiceName () const
	Get name of gRPC service.
std::string_view	GetMethodName () const
	Get name of called gRPC method.
tracing::Span &	GetSpan ()
	Get the span of the current RPC.
utils::AnyStorage< StorageContext > &	GetStorageContext ()
	Returns call context for storing per-call custom data.

Member Function Documentation

GetRpcType()

RpcType ugrpc::server::MiddlewareCallContext::GetRpcType ( ) const

noexcept

Returns

RPC type

GetServerContext()

grpc::ServerContextBase & ugrpc::server::CallContextBase::GetServerContext ( )

inherited

Returns

the ServerContext used for this RPC

Examples

samples/grpc_middleware_service/src/middlewares/server/auth.cpp, and samples/grpc_middleware_service/src/middlewares/server/meta_filter.cpp.

GetStorageContext()

utils::AnyStorage< StorageContext > & ugrpc::server::CallContextBase::GetStorageContext ( )

inherited

Returns call context for storing per-call custom data.

The context can be used to pass data from server middleware to client handler or from one middleware to another one.

Example usage:

In authentication middleware:

if (password_is_correct) {
  // Username is authenticated, set it in per-call storage context
  context.GetStorageContext().Emplace(kAuthUsername, username);
}

In client handler:

const auto& username = context.GetStorageContext().Get(kAuthUsername);
auto msg = fmt::format("Hello, {}!", username);

SetError()

void ugrpc::server::MiddlewareCallContext::SetError ( grpc::Status && status )

noexcept

Aborts the RPC, returning the specified status to the upstream client, see details below.

It should be the last command in middlewares hooks.

If that method is called in methods:

1. MiddlewareBase::OnCallStart - remaining OnCallStart hooks won't be called. Will be called OnCallFinish hooks of middlewares that was called before SetError
2. MiddlewareBase::PostRecvMessage or ugrpc::server::MiddlewareBase::PreSendMessage :
   • unary: handler won't be called - all. All OnCallFinish hooks will be called.
   • stream: from Read/Write throws a special exception, that ends a handler. All OnCallFinish hooks will be called.
3. MiddlewareBase::OnCallFinish - all OnCallFinish will be called, despite of SetError and exceptions. If the request is going to end with the error status, then the status is replaced with the status of the current hook.

Example usage

Middleware::Middleware() = default;
 
void Middleware::OnCallStart(ugrpc::server::MiddlewareCallContext& context) const {
    const auto& metadata = context.GetServerContext().client_metadata();
 
    auto it = metadata.find(kKey);
 
    if (it == metadata.cend() || it->second != kCredentials) {
        LOG_ERROR() << "Invalid credentials";
        context.SetError(::grpc::Status{::grpc::StatusCode::PERMISSION_DENIED, "Invalid credentials"});
        return;
    }
}

Examples

samples/grpc_middleware_service/src/middlewares/server/auth.cpp, and samples/grpc_middleware_service/src/middlewares/server/meta_filter.cpp.

---

The documentation for this class was generated from the following file:

• userver/ugrpc/server/middlewares/base.hpp