mirror of
https://github.com/0rangebananaspy/authelia.git
synced 2024-09-14 22:47:21 +07:00
3f374534ab
* [FIX] LDAP Not Checking for Updated Groups * refactor handlers verifyFromSessionCookie * refactor authorizer selectMatchingObjectRules * refactor authorizer isDomainMatching * add authorizer URLHasGroupSubjects method * add user provider ProviderType method * update tests * check for new LDAP groups and update session when: * user provider type is LDAP * authorization is forbidden * URL has rule with group subjects * Implement Refresh Interval * add default values for LDAP user provider * add default for refresh interval * add schema validator for refresh interval * add various tests * rename hasUserBeenInactiveLongEnough to hasUserBeenInactiveTooLong * use Authelia ctx clock * add check to determine if user is deleted, if so destroy the * make ldap user not found error a const * implement GetRefreshSettings in mock * Use user not found const with FileProvider * comment exports * use ctx.Clock instead of time pkg * add debug logging * use ptr to reference userSession so we don't have to retrieve it again * add documenation * add check for 0 refresh interval to reduce CPU cost * remove badly copied debug msg * add group change delta message * add SliceStringDelta * refactor ldap refresh to use the new func * improve delta add/remove log message * fix incorrect logic in SliceStringDelta * add tests to SliceStringDelta * add always config option * add tests for always config option * update docs * apply suggestions from code review Co-Authored-By: Amir Zarrinkafsh <nightah@me.com> * complete mocks and fix an old one * show warning when LDAP details failed to update for an unknown reason * golint fix * actually fix existing mocks * use mocks for LDAP refresh testing * use mocks for LDAP refresh testing for both added and removed groups * use test mock to verify disabled refresh behaviour * add information to threat model * add time const for default Unix() value * misc adjustments to mocks * Suggestions from code review * requested changes * update emails * docs updates * test updates * misc * golint fix * set debug for dev testing * misc docs and logging updates * misc grammar/spelling * use built function for VerifyGet * fix reviewdog suggestions * requested changes * Apply suggestions from code review Co-authored-by: Amir Zarrinkafsh <nightah@me.com> Co-authored-by: Clément Michaud <clement.michaud34@gmail.com>
146 lines
4.1 KiB
Go
146 lines
4.1 KiB
Go
package authorization
|
|
|
|
import (
|
|
"fmt"
|
|
"net"
|
|
"net/url"
|
|
"strings"
|
|
|
|
"github.com/authelia/authelia/internal/configuration/schema"
|
|
"github.com/authelia/authelia/internal/logging"
|
|
)
|
|
|
|
const userPrefix = "user:"
|
|
const groupPrefix = "group:"
|
|
|
|
// Authorizer the component in charge of checking whether a user can access a given resource.
|
|
type Authorizer struct {
|
|
configuration schema.AccessControlConfiguration
|
|
}
|
|
|
|
// NewAuthorizer create an instance of authorizer with a given access control configuration.
|
|
func NewAuthorizer(configuration schema.AccessControlConfiguration) *Authorizer {
|
|
return &Authorizer{
|
|
configuration: configuration,
|
|
}
|
|
}
|
|
|
|
// Subject subject who to check access control for.
|
|
type Subject struct {
|
|
Username string
|
|
Groups []string
|
|
IP net.IP
|
|
}
|
|
|
|
func (s Subject) String() string {
|
|
return fmt.Sprintf("username=%s groups=%s ip=%s", s.Username, strings.Join(s.Groups, ","), s.IP.String())
|
|
}
|
|
|
|
// Object object to check access control for.
|
|
type Object struct {
|
|
Domain string
|
|
Path string
|
|
}
|
|
|
|
// selectMatchingSubjectRules take a set of rules and select only the rules matching the subject constraints.
|
|
func selectMatchingSubjectRules(rules []schema.ACLRule, subject Subject) []schema.ACLRule {
|
|
selectedRules := []schema.ACLRule{}
|
|
|
|
for _, rule := range rules {
|
|
if len(rule.Subjects) > 0 {
|
|
for _, subjectRule := range rule.Subjects {
|
|
if isSubjectMatching(subject, subjectRule) && isIPMatching(subject.IP, rule.Networks) {
|
|
selectedRules = append(selectedRules, rule)
|
|
}
|
|
}
|
|
} else {
|
|
if isIPMatching(subject.IP, rule.Networks) {
|
|
selectedRules = append(selectedRules, rule)
|
|
}
|
|
}
|
|
}
|
|
|
|
return selectedRules
|
|
}
|
|
|
|
func selectMatchingObjectRules(rules []schema.ACLRule, object Object) []schema.ACLRule {
|
|
selectedRules := []schema.ACLRule{}
|
|
|
|
for _, rule := range rules {
|
|
if isDomainMatching(object.Domain, rule.Domains) && isPathMatching(object.Path, rule.Resources) {
|
|
selectedRules = append(selectedRules, rule)
|
|
}
|
|
}
|
|
return selectedRules
|
|
}
|
|
|
|
func selectMatchingRules(rules []schema.ACLRule, subject Subject, object Object) []schema.ACLRule {
|
|
matchingRules := selectMatchingSubjectRules(rules, subject)
|
|
return selectMatchingObjectRules(matchingRules, object)
|
|
}
|
|
|
|
// PolicyToLevel converts a string policy to int authorization level.
|
|
func PolicyToLevel(policy string) Level {
|
|
switch policy {
|
|
case "bypass":
|
|
return Bypass
|
|
case "one_factor":
|
|
return OneFactor
|
|
case "two_factor":
|
|
return TwoFactor
|
|
case "deny":
|
|
return Denied
|
|
}
|
|
// By default the deny policy applies.
|
|
return Denied
|
|
}
|
|
|
|
// IsSecondFactorEnabled return true if at least one policy is set to second factor.
|
|
func (p *Authorizer) IsSecondFactorEnabled() bool {
|
|
if PolicyToLevel(p.configuration.DefaultPolicy) == TwoFactor {
|
|
return true
|
|
}
|
|
|
|
for _, r := range p.configuration.Rules {
|
|
if PolicyToLevel(r.Policy) == TwoFactor {
|
|
return true
|
|
}
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
// GetRequiredLevel retrieve the required level of authorization to access the object.
|
|
func (p *Authorizer) GetRequiredLevel(subject Subject, requestURL url.URL) Level {
|
|
logging.Logger().Tracef("Check authorization of subject %s and url %s.",
|
|
subject.String(), requestURL.String())
|
|
|
|
matchingRules := selectMatchingRules(p.configuration.Rules, subject, Object{
|
|
Domain: requestURL.Hostname(),
|
|
Path: requestURL.Path,
|
|
})
|
|
|
|
if len(matchingRules) > 0 {
|
|
return PolicyToLevel(matchingRules[0].Policy)
|
|
}
|
|
logging.Logger().Tracef("No matching rule for subject %s and url %s... Applying default policy.",
|
|
subject.String(), requestURL.String())
|
|
|
|
return PolicyToLevel(p.configuration.DefaultPolicy)
|
|
}
|
|
|
|
// IsURLMatchingRuleWithGroupSubjects returns true if the request has at least one
|
|
// matching ACL with a subject of type group attached to it, otherwise false.
|
|
func (p *Authorizer) IsURLMatchingRuleWithGroupSubjects(requestURL url.URL) (hasGroupSubjects bool) {
|
|
for _, rule := range p.configuration.Rules {
|
|
if isDomainMatching(requestURL.Hostname(), rule.Domains) && isPathMatching(requestURL.Path, rule.Resources) {
|
|
for _, subjectRule := range rule.Subjects {
|
|
if strings.HasPrefix(subjectRule, groupPrefix) {
|
|
return true
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return false
|
|
}
|