Skip to content

Commit 0db5165

Browse files
committed
Add response header version mapping for DescribeUserScramCredentials and AlterUserScramCredentials
1 parent ae34407 commit 0db5165

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

cmd/plugin-auth-ldap/main.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -253,12 +253,12 @@ func main() {
253253
os.Exit(1)
254254
}
255255
if pluginMeta.bindDN != "" {
256-
logrus.Infof("user-search-base='%s',user-filter='%s'", pluginMeta.userSearchBase,pluginMeta.userFilter)
256+
logrus.Infof("user-search-base='%s',user-filter='%s'", pluginMeta.userSearchBase, pluginMeta.userFilter)
257257

258258
if pluginMeta.userSearchBase == "" {
259259
logrus.Errorf("user-search-base is required")
260260
}
261-
if !strings.Contains(pluginMeta.userFilter,UsernamePlaceholder) {
261+
if !strings.Contains(pluginMeta.userFilter, UsernamePlaceholder) {
262262
logrus.Errorf("user-filter must contain '%s' as username placeholder", UsernamePlaceholder)
263263
}
264264

proxy/protocol/request_key_version.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,10 @@ func (r *RequestKeyVersion) ResponseHeaderVersion() int16 {
258258
return 0
259259
case 49: // AlterClientQuotas
260260
return 0
261+
case 50: // DescribeUserScramCredentials
262+
return 1
263+
case 51: // AlterUserScramCredentials
264+
return 1
261265
default:
262266
// throw new UnsupportedVersionException("Unsupported API key " + apiKey);
263267
return -1

0 commit comments

Comments
 (0)