114
info *grpc.UnaryServerInfo,
115
handler grpc.UnaryHandler,
117
>
err := ni.setNamespaceIfNotPresent(req)
118
>
if err != nil {
119
return nil, err
120
}
122
>
if hasNamespace {
123
>
if err := ni.ValidateName(reqWithNamespace.GetNamespace()); err != nil {
124
return nil, err
125
}
126
}
127
129
}
130
131
// ValidateName validates a namespace name (currently only a max length check).
133
>
if len(ns) > ni.maxNamespaceLength() {
134
return errNamespaceTooLong
135
}
137
}
138
139
func (ni *NamespaceValidatorInterceptor) setNamespaceIfNotPresent(
140
req any,
142
>
switch request := req.(type) {
143
>
case NamespaceNameGetter:
144
>
if request.GetNamespace() == "" {
145
namespaceEntry, err := ni.extractNamespaceFromTaskToken(req)
146
if err != nil {