package ldap import ( "context" "errors" "fmt" "net" "net/http" "net/http/cookiejar" "net/url" "strings" "time" goldap "github.com/go-ldap/ldap/v3" httptransport "github.com/go-openapi/runtime/client" "github.com/nmcclain/ldap" "goauthentik.io/outpost/pkg/client/core" "goauthentik.io/outpost/pkg/client/flows" "goauthentik.io/outpost/pkg/models" ) const ContextUserKey = "ak_user" type UIDResponse struct { UIDFIeld string `json:"uid_field"` } type PasswordResponse struct { Password string `json:"password"` } func (pi *ProviderInstance) getUsername(dn string) (string, error) { if !strings.HasSuffix(strings.ToLower(dn), strings.ToLower(pi.BaseDN)) { return "", errors.New("invalid base DN") } dns, err := goldap.ParseDN(dn) if err != nil { return "", err } for _, part := range dns.RDNs { for _, attribute := range part.Attributes { if strings.ToLower(attribute.Type) == "cn" { return attribute.Value, nil } } } return "", errors.New("failed to find cn") } func (pi *ProviderInstance) Bind(username string, bindPW string, conn net.Conn) (ldap.LDAPResultCode, error) { jar, err := cookiejar.New(nil) if err != nil { pi.log.WithError(err).Warning("Failed to create cookiejar") return ldap.LDAPResultOperationsError, nil } host, _, err := net.SplitHostPort(conn.RemoteAddr().String()) if err != nil { pi.log.WithError(err).Warning("Failed to get remote IP") return ldap.LDAPResultOperationsError, nil } // Create new http client that also sets the correct ip client := &http.Client{ Jar: jar, Transport: newTransport(map[string]string{ "X-authentik-remote-ip": host, }), } params := url.Values{} params.Add("goauthentik.io/outpost/ldap", "true") passed, err := pi.solveFlowChallenge(username, bindPW, client, params.Encode()) if err != nil { pi.log.WithField("boundDN", username).WithError(err).Warning("failed to solve challenge") return ldap.LDAPResultOperationsError, nil } if !passed { return ldap.LDAPResultInvalidCredentials, nil } _, err = pi.s.ac.Client.Core.CoreApplicationsCheckAccess(&core.CoreApplicationsCheckAccessParams{ Slug: pi.appSlug, Context: context.Background(), HTTPClient: client, }, httptransport.PassThroughAuth) if err != nil { if _, denied := err.(*core.CoreApplicationsCheckAccessForbidden); denied { pi.log.WithField("boundDN", username).Info("Access denied for user") return ldap.LDAPResultInsufficientAccessRights, nil } pi.log.WithField("boundDN", username).WithError(err).Warning("failed to check access") return ldap.LDAPResultOperationsError, nil } pi.log.WithField("boundDN", username).Info("User has access") // Get user info to store in context userInfo, err := pi.s.ac.Client.Core.CoreUsersMe(&core.CoreUsersMeParams{ Context: context.Background(), HTTPClient: client, }, httptransport.PassThroughAuth) if err != nil { pi.log.WithField("boundDN", username).WithError(err).Warning("failed to get user info") return ldap.LDAPResultOperationsError, nil } pi.boundUsersMutex.Lock() pi.boundUsers[username] = UserFlags{ UserInfo: userInfo.Payload.User, CanSearch: pi.SearchAccessCheck(userInfo.Payload.User), } defer pi.boundUsersMutex.Unlock() pi.delayDeleteUserInfo(username) return ldap.LDAPResultSuccess, nil } // SearchAccessCheck Check if the current user is allowed to search func (pi *ProviderInstance) SearchAccessCheck(user *models.User) bool { for _, group := range user.Groups { for _, allowedGroup := range pi.searchAllowedGroups { if &group.Pk == allowedGroup { pi.log.WithField("group", group.Name).Info("Allowed access to search") return true } } } return false } func (pi *ProviderInstance) delayDeleteUserInfo(dn string) { ticker := time.NewTicker(30 * time.Second) quit := make(chan struct{}) go func() { for { select { case <-ticker.C: pi.boundUsersMutex.Lock() delete(pi.boundUsers, dn) pi.boundUsersMutex.Unlock() close(quit) case <-quit: ticker.Stop() return } } }() } func (pi *ProviderInstance) solveFlowChallenge(bindDN string, password string, client *http.Client, urlParams string) (bool, error) { challenge, err := pi.s.ac.Client.Flows.FlowsExecutorGet(&flows.FlowsExecutorGetParams{ FlowSlug: pi.flowSlug, Query: urlParams, Context: context.Background(), HTTPClient: client, }, pi.s.ac.Auth) if err != nil { pi.log.WithError(err).Warning("Failed to get challenge") return false, err } pi.log.WithField("component", challenge.Payload.Component).WithField("type", *challenge.Payload.Type).Debug("Got challenge") responseParams := &flows.FlowsExecutorSolveParams{ FlowSlug: pi.flowSlug, Query: urlParams, Context: context.Background(), HTTPClient: client, } switch challenge.Payload.Component { case "ak-stage-identification": responseParams.Data = &UIDResponse{UIDFIeld: bindDN} case "ak-stage-password": responseParams.Data = &PasswordResponse{Password: password} case "ak-stage-access-denied": return false, errors.New("got ak-stage-access-denied") default: return false, fmt.Errorf("unsupported challenge type: %s", challenge.Payload.Component) } response, err := pi.s.ac.Client.Flows.FlowsExecutorSolve(responseParams, pi.s.ac.Auth) pi.log.WithField("component", response.Payload.Component).WithField("type", *response.Payload.Type).Debug("Got response") if *response.Payload.Type == "redirect" { return true, nil } if err != nil { pi.log.WithError(err).Warning("Failed to submit challenge") return false, err } if len(response.Payload.ResponseErrors) > 0 { for key, errs := range response.Payload.ResponseErrors { for _, err := range errs { pi.log.WithField("key", key).WithField("code", *err.Code).Debug(*err.String) return false, nil } } } return pi.solveFlowChallenge(bindDN, password, client, urlParams) }