aboutsummaryrefslogtreecommitdiff
path: root/bind.go
diff options
context:
space:
mode:
authorMark Rushakoff <[email protected]>2018-02-23 09:36:57 -0800
committerMark Rushakoff <[email protected]>2018-02-23 09:36:57 -0800
commit1fb3ada78e9c4f674ad3cf8f3313a1aab73fd231 (patch)
tree6ce6f38b91c5a9ce25dc450d4381c59488432295 /bind.go
parent6dd74f48601c134dd6e3b3b895209c779a8b689d (diff)
Update import paths and go fmt
Diffstat (limited to 'bind.go')
-rw-r--r--bind.go85
1 files changed, 42 insertions, 43 deletions
diff --git a/bind.go b/bind.go
index 171a2e9..a082fff 100644
--- a/bind.go
+++ b/bind.go
@@ -2,12 +2,12 @@
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
-package ldap
+package ldapserver
import (
"errors"
- "github.com/nmcclain/asn1-ber"
+ "github.com/mark-rushakoff/ldapserver/internal/asn1-ber"
)
func (l *Conn) Bind(username, password string) error {
@@ -55,45 +55,44 @@ func (l *Conn) Bind(username, password string) error {
}
func (l *Conn) Unbind() error {
- defer l.Close()
-
- messageID := l.nextMessageID()
-
- packet := ber.Encode(ber.ClassUniversal, ber.TypeConstructed, ber.TagSequence, nil, "LDAP Request")
- packet.AppendChild(ber.NewInteger(ber.ClassUniversal, ber.TypePrimitive, ber.TagInteger, messageID, "MessageID"))
- unbindRequest := ber.Encode(ber.ClassApplication, ber.TypePrimitive, ApplicationUnbindRequest, nil, "Unbind Request")
- packet.AppendChild(unbindRequest)
-
- if l.Debug {
- ber.PrintPacket(packet)
- }
-
- channel, err := l.sendMessage(packet)
- if err != nil {
- return err
- }
- if channel == nil {
- return NewError(ErrorNetwork, errors.New("ldap: could not send message"))
- }
- defer l.finishMessage(messageID)
-
- packet = <-channel
- if packet == nil {
- return NewError(ErrorNetwork, errors.New("ldap: could not retrieve response"))
- }
-
- if l.Debug {
- if err := addLDAPDescriptions(packet); err != nil {
- return err
- }
- ber.PrintPacket(packet)
- }
-
- resultCode, resultDescription := getLDAPResultCode(packet)
- if resultCode != 0 {
- return NewError(resultCode, errors.New(resultDescription))
- }
-
- return nil
-}
+ defer l.Close()
+
+ messageID := l.nextMessageID()
+
+ packet := ber.Encode(ber.ClassUniversal, ber.TypeConstructed, ber.TagSequence, nil, "LDAP Request")
+ packet.AppendChild(ber.NewInteger(ber.ClassUniversal, ber.TypePrimitive, ber.TagInteger, messageID, "MessageID"))
+ unbindRequest := ber.Encode(ber.ClassApplication, ber.TypePrimitive, ApplicationUnbindRequest, nil, "Unbind Request")
+ packet.AppendChild(unbindRequest)
+
+ if l.Debug {
+ ber.PrintPacket(packet)
+ }
+
+ channel, err := l.sendMessage(packet)
+ if err != nil {
+ return err
+ }
+ if channel == nil {
+ return NewError(ErrorNetwork, errors.New("ldap: could not send message"))
+ }
+ defer l.finishMessage(messageID)
+ packet = <-channel
+ if packet == nil {
+ return NewError(ErrorNetwork, errors.New("ldap: could not retrieve response"))
+ }
+
+ if l.Debug {
+ if err := addLDAPDescriptions(packet); err != nil {
+ return err
+ }
+ ber.PrintPacket(packet)
+ }
+
+ resultCode, resultDescription := getLDAPResultCode(packet)
+ if resultCode != 0 {
+ return NewError(resultCode, errors.New(resultDescription))
+ }
+
+ return nil
+}