parent
41122412ff
commit
ad9423da28
@ -1 +1,2 @@ |
||||
ldapmin |
||||
config.json |
||||
|
||||
@ -0,0 +1,7 @@ |
||||
{ |
||||
"ldap": { |
||||
"url": "ldap://ldap.example.com", |
||||
"starttls": true, |
||||
"userformat": "cn=%s,ou=users,dc=example,dc=com" |
||||
} |
||||
} |
||||
@ -1,18 +1,52 @@ |
||||
package main |
||||
|
||||
import "github.com/spf13/pflag" |
||||
import ( |
||||
"encoding/json" |
||||
"errors" |
||||
"fmt" |
||||
"os" |
||||
|
||||
"github.com/spf13/pflag" |
||||
) |
||||
|
||||
type config struct { |
||||
ListenAddr string |
||||
ListenAddr string `json:"listenAddr"` |
||||
Ldap ldapConfig `json:"ldap"` |
||||
} |
||||
|
||||
type ldapConfig struct { |
||||
URL string `json:"url"` |
||||
StartTLS bool `json:"starttls"` |
||||
UserFormat string `json:"userformat"` |
||||
} |
||||
|
||||
func parseConfig() (config, error) { |
||||
c := config{ |
||||
ListenAddr: ":8080", |
||||
} |
||||
configFile := "config.json" |
||||
|
||||
pflag.StringVarP(&c.ListenAddr, "listen-addr", "l", c.ListenAddr, "Network address to listen on.") |
||||
pflag.StringVarP(&configFile, "config", "c", configFile, "Path to configuration file.") |
||||
pflag.Parse() |
||||
|
||||
var c config |
||||
file, err := os.Open(configFile) |
||||
if err != nil { |
||||
return c, fmt.Errorf("can not open configuration file: %s", err) |
||||
} |
||||
|
||||
if err := json.NewDecoder(file).Decode(&c); err != nil { |
||||
return c, fmt.Errorf("can not parse configuration: %s", err) |
||||
} |
||||
|
||||
if c.ListenAddr == "" { |
||||
c.ListenAddr = ":8080" |
||||
} |
||||
|
||||
if c.Ldap.URL == "" { |
||||
return c, errors.New("ldap.url can not be empty") |
||||
} |
||||
|
||||
if c.Ldap.UserFormat == "" { |
||||
return c, errors.New("ldap.userformat can not be empty") |
||||
} |
||||
|
||||
return c, nil |
||||
} |
||||
|
||||
@ -1,11 +1,62 @@ |
||||
package main |
||||
|
||||
type ldapConnection struct{} |
||||
import ( |
||||
"crypto/tls" |
||||
"fmt" |
||||
"net/url" |
||||
|
||||
func newLDAP(cfg config) (*ldapConnection, error) { |
||||
return &ldapConnection{}, nil |
||||
ldap "gopkg.in/ldap.v3" |
||||
) |
||||
|
||||
type ldapConnection struct { |
||||
cfg ldapConfig |
||||
} |
||||
|
||||
func newLDAP(cfg ldapConfig) (*ldapConnection, error) { |
||||
return &ldapConnection{ |
||||
cfg: cfg, |
||||
}, nil |
||||
} |
||||
|
||||
func (l *ldapConnection) ChangePassword(username, password, newPassword string) (bool, error) { |
||||
return false, nil |
||||
userDN := fmt.Sprintf(l.cfg.UserFormat, username) |
||||
|
||||
c, err := ldap.DialURL(l.cfg.URL) |
||||
if err != nil { |
||||
return false, fmt.Errorf("can not connect to LDAP: %s", err) |
||||
} |
||||
|
||||
if l.cfg.StartTLS { |
||||
serverURL, err := url.Parse(l.cfg.URL) |
||||
if err != nil { |
||||
return false, fmt.Errorf("can not parse server URL: %s", err) |
||||
} |
||||
|
||||
tlsConfig := &tls.Config{ |
||||
ServerName: serverURL.Host, |
||||
} |
||||
if err := c.StartTLS(tlsConfig); err != nil { |
||||
return false, fmt.Errorf("can not enable startTLS: %s", err) |
||||
} |
||||
} |
||||
|
||||
if err := c.Bind(userDN, password); err != nil { |
||||
if ldapErr, ok := err.(*ldap.Error); ok && ldapErr.ResultCode == 49 { |
||||
return false, nil |
||||
} |
||||
|
||||
return false, fmt.Errorf("can not bind: %s", err) |
||||
} |
||||
|
||||
passwordReq := &ldap.PasswordModifyRequest{ |
||||
UserIdentity: userDN, |
||||
OldPassword: password, |
||||
NewPassword: newPassword, |
||||
} |
||||
|
||||
if _, err := c.PasswordModify(passwordReq); err != nil { |
||||
return false, fmt.Errorf("can not modify password: %s", err) |
||||
} |
||||
|
||||
return true, nil |
||||
} |
||||
|
||||
Loading…
Reference in new issue