~james/core

core/rbac/util.go -rw-r--r-- 3.0 KiB
452f17b7 — james chore(import): snapshot james.dad.town/core at f70c71c7696a 17 hours ago
                                                                                
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
package rbac

import (
	"fmt"
	"slices"
	"strings"
)

func (e *Enforcer) getDomainsForUser(did string, keepFunc func(string) bool, stripFunc func(string) string) ([]string, error) {
	domains, err := e.E.GetDomainsForUser(did)
	if err != nil {
		return nil, err
	}

	n := 0
	for _, x := range domains {
		if keepFunc(x) {
			domains[n] = stripFunc(x)
			n++
		}
	}
	domains = domains[:n]

	return domains, nil
}

func (e *Enforcer) addOwner(domain, owner string) error {
	_, err := e.E.AddGroupingPolicy(owner, "server:owner", domain)
	return err
}

func (e *Enforcer) removeOwner(domain, owner string) error {
	_, err := e.E.RemoveGroupingPolicy(owner, "server:owner", domain)
	return err
}

func (e *Enforcer) addMember(domain, member string) (bool, error) {
	return e.E.AddGroupingPolicy(member, "server:member", domain)
}

func (e *Enforcer) removeMember(domain, member string) (bool, error) {
	return e.E.RemoveGroupingPolicy(member, "server:member", domain)
}

func (e *Enforcer) isRole(user, role, domain string) (bool, error) {
	roles, err := e.E.GetImplicitRolesForUser(user, domain)
	if err != nil {
		return false, err
	}
	if slices.Contains(roles, role) {
		return true, nil
	}
	return false, nil
}

func (e *Enforcer) isInviteAllowed(user, domain string) (bool, error) {
	return e.E.Enforce(user, domain, domain, "server:invite")
}

func (e *Enforcer) HasAnyPolicyForUser(user string) (bool, error) {
	pPolicies, err := e.E.GetFilteredNamedPolicy("p", 0, user)
	if err != nil {
		return false, err
	}
	if len(pPolicies) > 0 {
		return true, nil
	}
	gPolicies, err := e.E.GetFilteredNamedGroupingPolicy("g", 0, user)
	if err != nil {
		return false, err
	}
	return len(gPolicies) > 0, nil
}

func (e *Enforcer) wouldHaveAnyPolicyExcludingGrouping(user, role, domain string) (bool, error) {
	pPolicies, err := e.E.GetFilteredNamedPolicy("p", 0, user)
	if err != nil {
		return false, err
	}
	if len(pPolicies) > 0 {
		return true, nil
	}
	gPolicies, err := e.E.GetFilteredNamedGroupingPolicy("g", 0, user)
	if err != nil {
		return false, err
	}
	for _, gp := range gPolicies {
		if len(gp) < 3 {
			return true, nil
		}
		if gp[1] != role || gp[2] != domain {
			return true, nil
		}
	}
	return false, nil
}

func (e *Enforcer) WouldHaveAnyPolicyExcludingSpindleMember(user, domain string) (bool, error) {
	return e.wouldHaveAnyPolicyExcludingGrouping(user, "server:member", intoSpindle(domain))
}

func checkRepoFormat(repo string) error {
	// sanity check, repo must be of the form ownerDid/repo
	if parts := strings.SplitN(repo, "/", 2); !strings.HasPrefix(parts[0], "did:") {
		return fmt.Errorf("invalid repo: %s", repo)
	}

	return nil
}

const spindlePrefix = "spindle:"

func intoSpindle(domain string) string {
	if !isSpindle(domain) {
		return spindlePrefix + domain
	}
	return domain
}

func unSpindle(domain string) string {
	if !isSpindle(domain) {
		return domain
	}
	return strings.TrimPrefix(domain, spindlePrefix)
}

func isSpindle(domain string) bool {
	return strings.HasPrefix(domain, spindlePrefix)
}

func isNotSpindle(domain string) bool {
	return !isSpindle(domain)
}