summaryrefslogtreecommitdiffstats
path: root/conn.go
diff options
context:
space:
mode:
authortmfkams <tmfkams@gmail.com>2014-01-19 23:04:16 +0100
committerSamuel Stauffer <samuel@descolada.com>2014-03-19 21:57:58 +0100
commite45f83457931e08f9f6d5aec48f51fd390a01eb8 (patch)
treed95a79f94932115bf5c0441f2eeb520959bbda0d /conn.go
parentMerge pull request #4 from bollenberger/master (diff)
downloadldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.tar
ldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.tar.gz
ldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.tar.bz2
ldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.tar.lz
ldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.tar.xz
ldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.tar.zst
ldap-e45f83457931e08f9f6d5aec48f51fd390a01eb8.zip
Diffstat (limited to 'conn.go')
-rw-r--r--conn.go428
1 files changed, 208 insertions, 220 deletions
diff --git a/conn.go b/conn.go
index 41e69fb..cfa8772 100644
--- a/conn.go
+++ b/conn.go
@@ -6,296 +6,284 @@
package ldap
import (
- "github.com/mmitton/asn1-ber"
- "crypto/tls"
- "fmt"
- "net"
- "os"
- "sync"
+ "crypto/tls"
+ "errors"
+ "github.com/tmfkams/asn1-ber"
+ "log"
+ "net"
+ "sync"
)
// LDAP Connection
type Conn struct {
- conn net.Conn
- isSSL bool
- Debug bool
-
- chanResults map[ uint64 ] chan *ber.Packet
- chanProcessMessage chan *messagePacket
- chanMessageID chan uint64
-
- closeLock sync.Mutex
+ conn net.Conn
+ isSSL bool
+ Debug debugging
+ chanResults map[uint64]chan *ber.Packet
+ chanProcessMessage chan *messagePacket
+ chanMessageID chan uint64
+ closeLock sync.Mutex
}
// Dial connects to the given address on the given network using net.Dial
// and then returns a new Conn for the connection.
func Dial(network, addr string) (*Conn, *Error) {
- c, err := net.Dial(network, "", addr)
+ c, err := net.Dial(network, addr)
if err != nil {
- return nil, NewError( ErrorNetwork, err )
+ return nil, NewError(ErrorNetwork, err)
}
- conn := NewConn(c)
- conn.start()
+ conn := NewConn(c)
+ conn.start()
return conn, nil
}
// Dial connects to the given address on the given network using net.Dial
// and then sets up SSL connection and returns a new Conn for the connection.
func DialSSL(network, addr string) (*Conn, *Error) {
- c, err := tls.Dial(network, "", addr, nil)
+ c, err := tls.Dial(network, addr, nil)
if err != nil {
- return nil, NewError( ErrorNetwork, err )
+ return nil, NewError(ErrorNetwork, err)
}
- conn := NewConn(c)
- conn.isSSL = true
+ conn := NewConn(c)
+ conn.isSSL = true
- conn.start()
+ conn.start()
return conn, nil
}
// Dial connects to the given address on the given network using net.Dial
// and then starts a TLS session and returns a new Conn for the connection.
func DialTLS(network, addr string) (*Conn, *Error) {
- c, err := net.Dial(network, "", addr)
+ c, err := net.Dial(network, addr)
if err != nil {
- return nil, NewError( ErrorNetwork, err )
+ return nil, NewError(ErrorNetwork, err)
+ }
+ conn := NewConn(c)
+
+ if err := conn.startTLS(); err != nil {
+ conn.Close()
+ return nil, NewError(ErrorNetwork, err.Err)
}
- conn := NewConn(c)
-
- err = conn.startTLS()
- if err != nil {
- conn.Close()
- return nil, NewError( ErrorNetwork, err )
- }
- conn.start()
+ conn.start()
return conn, nil
}
// NewConn returns a new Conn using conn for network I/O.
func NewConn(conn net.Conn) *Conn {
return &Conn{
- conn: conn,
- isSSL: false,
- Debug: false,
- chanResults: map[uint64] chan *ber.Packet{},
- chanProcessMessage: make( chan *messagePacket ),
- chanMessageID: make( chan uint64 ),
+ conn: conn,
+ isSSL: false,
+ Debug: false,
+ chanResults: map[uint64]chan *ber.Packet{},
+ chanProcessMessage: make(chan *messagePacket),
+ chanMessageID: make(chan uint64),
}
}
func (l *Conn) start() {
- go l.reader()
- go l.processMessages()
+ go l.reader()
+ go l.processMessages()
}
// Close closes the connection.
func (l *Conn) Close() *Error {
- l.closeLock.Lock()
- defer l.closeLock.Unlock()
-
- l.sendProcessMessage( &messagePacket{ Op: MessageQuit } )
-
- if l.conn != nil {
- err := l.conn.Close()
- if err != nil {
- return NewError( ErrorNetwork, err )
- }
- l.conn = nil
- }
+ l.closeLock.Lock()
+ defer l.closeLock.Unlock()
+
+ l.sendProcessMessage(&messagePacket{Op: MessageQuit})
+
+ if l.conn != nil {
+ err := l.conn.Close()
+ if err != nil {
+ return NewError(ErrorNetwork, err)
+ }
+ l.conn = nil
+ }
return nil
}
// Returns the next available messageID
func (l *Conn) nextMessageID() (messageID uint64) {
- defer func() { if r := recover(); r != nil { messageID = 0 } }()
- messageID = <-l.chanMessageID
- return
+ defer func() {
+ if r := recover(); r != nil {
+ messageID = 0
+ }
+ }()
+ messageID = <-l.chanMessageID
+ return
}
// StartTLS sends the command to start a TLS session and then creates a new TLS Client
func (l *Conn) startTLS() *Error {
- messageID := l.nextMessageID()
-
- if l.isSSL {
- return NewError( ErrorNetwork, os.NewError( "Already encrypted" ) )
- }
-
- packet := ber.Encode( ber.ClassUniversal, ber.TypeConstructed, ber.TagSequence, nil, "LDAP Request" )
- packet.AppendChild( ber.NewInteger( ber.ClassUniversal, ber.TypePrimative, ber.TagInteger, messageID, "MessageID" ) )
- startTLS := ber.Encode( ber.ClassApplication, ber.TypeConstructed, ApplicationExtendedRequest, nil, "Start TLS" )
- startTLS.AppendChild( ber.NewString( ber.ClassContext, ber.TypePrimative, 0, "1.3.6.1.4.1.1466.20037", "TLS Extended Command" ) )
- packet.AppendChild( startTLS )
- if l.Debug {
- ber.PrintPacket( packet )
- }
-
- _, err := l.conn.Write( packet.Bytes() )
- if err != nil {
- return NewError( ErrorNetwork, err )
- }
-
- packet, err = ber.ReadPacket( l.conn )
- if err != nil {
- return NewError( ErrorNetwork, err )
- }
-
- if l.Debug {
- if err := addLDAPDescriptions( packet ); err != nil {
- return NewError( ErrorDebugging, err )
- }
- ber.PrintPacket( packet )
- }
-
- if packet.Children[ 1 ].Children[ 0 ].Value.(uint64) == 0 {
- conn := tls.Client( l.conn, nil )
- l.isSSL = true
- l.conn = conn
- }
-
- return nil
+ messageID := l.nextMessageID()
+
+ if l.isSSL {
+ return NewError(ErrorNetwork, errors.New("Already encrypted"))
+ }
+
+ packet := ber.Encode(ber.ClassUniversal, ber.TypeConstructed, ber.TagSequence, nil, "LDAP Request")
+ packet.AppendChild(ber.NewInteger(ber.ClassUniversal, ber.TypePrimative, ber.TagInteger, messageID, "MessageID"))
+ startTLS := ber.Encode(ber.ClassApplication, ber.TypeConstructed, ApplicationExtendedRequest, nil, "Start TLS")
+ startTLS.AppendChild(ber.NewString(ber.ClassContext, ber.TypePrimative, 0, "1.3.6.1.4.1.1466.20037", "TLS Extended Command"))
+ packet.AppendChild(startTLS)
+ l.Debug.PrintPacket(packet)
+
+ _, err := l.conn.Write(packet.Bytes())
+ if err != nil {
+ return NewError(ErrorNetwork, err)
+ }
+
+ packet, err = ber.ReadPacket(l.conn)
+ if err != nil {
+ return NewError(ErrorNetwork, err)
+ }
+
+ if l.Debug {
+ if err := addLDAPDescriptions(packet); err != nil {
+ return NewError(ErrorDebugging, err.Err)
+ }
+ ber.PrintPacket(packet)
+ }
+
+ if packet.Children[1].Children[0].Value.(uint64) == 0 {
+ conn := tls.Client(l.conn, nil)
+ l.isSSL = true
+ l.conn = conn
+ }
+
+ return nil
}
const (
- MessageQuit = 0
- MessageRequest = 1
- MessageResponse = 2
- MessageFinish = 3
+ MessageQuit = 0
+ MessageRequest = 1
+ MessageResponse = 2
+ MessageFinish = 3
)
type messagePacket struct {
- Op int
- MessageID uint64
- Packet *ber.Packet
- Channel chan *ber.Packet
+ Op int
+ MessageID uint64
+ Packet *ber.Packet
+ Channel chan *ber.Packet
}
-func (l *Conn) sendMessage( p *ber.Packet ) (out chan *ber.Packet, err *Error) {
- message_id := p.Children[ 0 ].Value.(uint64)
- out = make(chan *ber.Packet)
-
- if l.chanProcessMessage == nil {
- err = NewError( ErrorNetwork, os.NewError( "Connection closed" ) )
- return
- }
- message_packet := &messagePacket{ Op: MessageRequest, MessageID: message_id, Packet: p, Channel: out }
- l.sendProcessMessage( message_packet )
- return
+func (l *Conn) sendMessage(p *ber.Packet) (out chan *ber.Packet, err *Error) {
+ message_id := p.Children[0].Value.(uint64)
+ out = make(chan *ber.Packet)
+
+ if l.chanProcessMessage == nil {
+ err = NewError(ErrorNetwork, errors.New("Connection closed"))
+ return
+ }
+ message_packet := &messagePacket{Op: MessageRequest, MessageID: message_id, Packet: p, Channel: out}
+ l.sendProcessMessage(message_packet)
+ return
}
func (l *Conn) processMessages() {
- defer l.closeAllChannels()
-
- var message_id uint64 = 1
- var message_packet *messagePacket
- for {
- select {
- case l.chanMessageID <- message_id:
- if l.conn == nil {
- return
- }
- message_id++
- case message_packet = <-l.chanProcessMessage:
- if l.conn == nil {
- return
- }
- switch message_packet.Op {
- case MessageQuit:
- // Close all channels and quit
- if l.Debug {
- fmt.Printf( "Shutting down\n" )
- }
- return
- case MessageRequest:
- // Add to message list and write to network
- if l.Debug {
- fmt.Printf( "Sending message %d\n", message_packet.MessageID )
- }
- l.chanResults[ message_packet.MessageID ] = message_packet.Channel
- buf := message_packet.Packet.Bytes()
- for len( buf ) > 0 {
- n, err := l.conn.Write( buf )
- if err != nil {
- if l.Debug {
- fmt.Printf( "Error Sending Message: %s\n", err.String() )
- }
- return
- }
- if n == len( buf ) {
- break
- }
- buf = buf[n:]
- }
- case MessageResponse:
- // Pass back to waiting goroutine
- if l.Debug {
- fmt.Printf( "Receiving message %d\n", message_packet.MessageID )
- }
- chanResult := l.chanResults[ message_packet.MessageID ]
- if chanResult == nil {
- fmt.Printf( "Unexpected Message Result: %d\n", message_id )
- ber.PrintPacket( message_packet.Packet )
- } else {
- go func() { chanResult <- message_packet.Packet }()
- // chanResult <- message_packet.Packet
- }
- case MessageFinish:
- // Remove from message list
- if l.Debug {
- fmt.Printf( "Finished message %d\n", message_packet.MessageID )
- }
- l.chanResults[ message_packet.MessageID ] = nil, false
- }
- }
- }
+ defer l.closeAllChannels()
+
+ var message_id uint64 = 1
+ var message_packet *messagePacket
+ for {
+ select {
+ case l.chanMessageID <- message_id:
+ if l.conn == nil {
+ return
+ }
+ message_id++
+ case message_packet = <-l.chanProcessMessage:
+ if l.conn == nil {
+ return
+ }
+ switch message_packet.Op {
+ case MessageQuit:
+ // Close all channels and quit
+ l.Debug.Printf("Shutting down\n")
+ return
+ case MessageRequest:
+ // Add to message list and write to network
+ l.Debug.Printf("Sending message %d\n", message_packet.MessageID)
+ l.chanResults[message_packet.MessageID] = message_packet.Channel
+ buf := message_packet.Packet.Bytes()
+ for len(buf) > 0 {
+ n, err := l.conn.Write(buf)
+ if err != nil {
+ l.Debug.Printf("Error Sending Message: %s\n", err.Error())
+ return
+ }
+ if n == len(buf) {
+ break
+ }
+ buf = buf[n:]
+ }
+ case MessageResponse:
+ // Pass back to waiting goroutine
+ l.Debug.Printf("Receiving message %d\n", message_packet.MessageID)
+ if chanResult, ok := l.chanResults[message_packet.MessageID]; ok {
+ // If the "Search Result Done" is read before the
+ // "Search Result Entry" no Entry can be returned
+ // go func() { chanResult <- message_packet.Packet }()
+ chanResult <- message_packet.Packet
+ } else {
+ log.Printf("Unexpected Message Result: %d\n", message_id)
+ ber.PrintPacket(message_packet.Packet)
+ }
+ case MessageFinish:
+ // Remove from message list
+ l.Debug.Printf("Finished message %d\n", message_packet.MessageID)
+ l.chanResults[message_packet.MessageID] = nil
+ }
+ }
+ }
}
func (l *Conn) closeAllChannels() {
-fmt.Printf( "closeAllChannels\n" )
- for MessageID, Channel := range l.chanResults {
- if l.Debug {
- fmt.Printf( "Closing channel for MessageID %d\n", MessageID );
- }
- close( Channel )
- l.chanResults[ MessageID ] = nil, false
- }
- close( l.chanMessageID )
- l.chanMessageID = nil
-
- close( l.chanProcessMessage )
- l.chanProcessMessage = nil
+ log.Printf("closeAllChannels\n")
+ for messageID, channel := range l.chanResults {
+ if channel != nil {
+ l.Debug.Printf("Closing channel for MessageID %d\n", messageID)
+ close(channel)
+ l.chanResults[messageID] = nil
+ }
+ }
+ close(l.chanMessageID)
+ l.chanMessageID = nil
+
+ close(l.chanProcessMessage)
+ l.chanProcessMessage = nil
}
-func (l *Conn) finishMessage( MessageID uint64 ) {
- message_packet := &messagePacket{ Op: MessageFinish, MessageID: MessageID }
- l.sendProcessMessage( message_packet )
+func (l *Conn) finishMessage(MessageID uint64) {
+ message_packet := &messagePacket{Op: MessageFinish, MessageID: MessageID}
+ l.sendProcessMessage(message_packet)
}
func (l *Conn) reader() {
- defer l.Close()
- for {
- p, err := ber.ReadPacket( l.conn )
- if err != nil {
- if l.Debug {
- fmt.Printf( "ldap.reader: %s\n", err.String() )
- }
- return
- }
-
- addLDAPDescriptions( p )
-
- message_id := p.Children[ 0 ].Value.(uint64)
- message_packet := &messagePacket{ Op: MessageResponse, MessageID: message_id, Packet: p }
- if l.chanProcessMessage != nil {
- l.chanProcessMessage <- message_packet
- } else {
- fmt.Printf( "ldap.reader: Cannot return message\n" )
- return
- }
- }
+ defer l.Close()
+ for {
+ p, err := ber.ReadPacket(l.conn)
+ if err != nil {
+ l.Debug.Printf("ldap.reader: %s\n", err.Error())
+ return
+ }
+
+ addLDAPDescriptions(p)
+
+ message_id := p.Children[0].Value.(uint64)
+ message_packet := &messagePacket{Op: MessageResponse, MessageID: message_id, Packet: p}
+ if l.chanProcessMessage != nil {
+ l.chanProcessMessage <- message_packet
+ } else {
+ log.Printf("ldap.reader: Cannot return message\n")
+ return
+ }
+ }
}
-func (l *Conn) sendProcessMessage( message *messagePacket ) {
- if l.chanProcessMessage != nil {
- go func() { l.chanProcessMessage <- message }()
- }
+func (l *Conn) sendProcessMessage(message *messagePacket) {
+ if l.chanProcessMessage != nil {
+ go func() { l.chanProcessMessage <- message }()
+ }
}