Function serverInterceptor

grpc_server.go:350–373

(
	req interface{},
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler)

}

func serverInterceptor(
	req interface{},
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler) (err error) {
	// skip the authCallbacks wrapping/authentication for scatter gather calls,
	// as the user is already authenticated at the original node.
	if _, err = extractMetaHeader(ss.Context(), rpcClusterActionKey); err == nil {
		w := wrapServerStream(ss)
		w.wrappedContext = ss.Context()
		return handler(req, w)
	}

	nctx, err := wrapAuthCallbacks(req, ss.Context(), info.FullMethod)
	if err != nil {
		log.Errorf("grpc_server: authenticate err: %+v", err)
		return err
	}

	w := wrapServerStream(ss)
	w.wrappedContext = nctx

	return handler(req, w)
}