-
Notifications
You must be signed in to change notification settings - Fork 0
/
rfc2307.go
70 lines (57 loc) · 2.21 KB
/
rfc2307.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
package cli
import (
"github.com/openshift/origin/pkg/auth/ldaputil"
"github.com/openshift/origin/pkg/auth/ldaputil/ldapclient"
"github.com/openshift/origin/pkg/cmd/admin/groups/sync"
"github.com/openshift/origin/pkg/cmd/admin/groups/sync/interfaces"
"github.com/openshift/origin/pkg/cmd/admin/groups/sync/rfc2307"
"github.com/openshift/origin/pkg/cmd/admin/groups/sync/syncerror"
"github.com/openshift/origin/pkg/cmd/server/api"
)
var _ SyncBuilder = &RFC2307Builder{}
var _ PruneBuilder = &RFC2307Builder{}
type RFC2307Builder struct {
ClientConfig ldapclient.Config
Config *api.RFC2307Config
rfc2307LDAPInterface *rfc2307.LDAPInterface
ErrorHandler syncerror.Handler
}
func (b *RFC2307Builder) GetGroupLister() (interfaces.LDAPGroupLister, error) {
return b.getRFC2307LDAPInterface()
}
func (b *RFC2307Builder) GetGroupNameMapper() (interfaces.LDAPGroupNameMapper, error) {
ldapInterface, err := b.getRFC2307LDAPInterface()
if err != nil {
return nil, err
}
if b.Config.GroupNameAttributes != nil {
return syncgroups.NewEntryAttributeGroupNameMapper(b.Config.GroupNameAttributes, ldapInterface), nil
}
return nil, nil
}
func (b *RFC2307Builder) GetUserNameMapper() (interfaces.LDAPUserNameMapper, error) {
return syncgroups.NewUserNameMapper(b.Config.UserNameAttributes), nil
}
func (b *RFC2307Builder) GetGroupMemberExtractor() (interfaces.LDAPMemberExtractor, error) {
return b.getRFC2307LDAPInterface()
}
func (b *RFC2307Builder) getRFC2307LDAPInterface() (*rfc2307.LDAPInterface, error) {
if b.rfc2307LDAPInterface != nil {
return b.rfc2307LDAPInterface, nil
}
groupQuery, err := ldaputil.NewLDAPQueryOnAttribute(b.Config.AllGroupsQuery, b.Config.GroupUIDAttribute)
if err != nil {
return nil, err
}
userQuery, err := ldaputil.NewLDAPQueryOnAttribute(b.Config.AllUsersQuery, b.Config.UserUIDAttribute)
if err != nil {
return nil, err
}
b.rfc2307LDAPInterface = rfc2307.NewLDAPInterface(b.ClientConfig,
groupQuery, b.Config.GroupNameAttributes, b.Config.GroupMembershipAttributes,
userQuery, b.Config.UserNameAttributes, b.ErrorHandler)
return b.rfc2307LDAPInterface, nil
}
func (b *RFC2307Builder) GetGroupDetector() (interfaces.LDAPGroupDetector, error) {
return b.getRFC2307LDAPInterface()
}