summaryrefslogtreecommitdiff
path: root/pkg
diff options
context:
space:
mode:
authorJulien Dessaux2024-03-26 08:31:53 +0100
committerJulien Dessaux2024-03-26 08:31:53 +0100
commitf51843f634ed37d02558ba49cda7c24764f928ac (patch)
treee8c4775268141671e5815a30f2e8976ef1a6dfc8 /pkg
parentchore(packages): removed useless packages list hook function and debian stdli... (diff)
downloadgonf-f51843f634ed37d02558ba49cda7c24764f928ac.tar.gz
gonf-f51843f634ed37d02558ba49cda7c24764f928ac.tar.bz2
gonf-f51843f634ed37d02558ba49cda7c24764f928ac.zip
feat(users): implemented basic user creation promise
Diffstat (limited to 'pkg')
-rw-r--r--pkg/gonf.go8
-rw-r--r--pkg/users.go95
2 files changed, 103 insertions, 0 deletions
diff --git a/pkg/gonf.go b/pkg/gonf.go
index 88edf9c..5e02176 100644
--- a/pkg/gonf.go
+++ b/pkg/gonf.go
@@ -14,6 +14,14 @@ func EnableDebugLogs() {
func Resolve() (status Status) {
for {
+ // ----- Users -------------------------------------------------
+ status = resolveUsers()
+ switch status {
+ case BROKEN:
+ return BROKEN
+ case REPAIRED:
+ continue
+ }
// ----- Files -------------------------------------------------
status = resolveFiles()
switch status {
diff --git a/pkg/users.go b/pkg/users.go
new file mode 100644
index 0000000..ca7913b
--- /dev/null
+++ b/pkg/users.go
@@ -0,0 +1,95 @@
+package gonf
+
+import (
+ "log/slog"
+)
+
+// ----- Globals ---------------------------------------------------------------
+var users []*UserPromise
+
+// users management functions
+var user_add_function func(data UserData) (Status, error)
+
+// ----- Init ------------------------------------------------------------------
+func init() {
+ users = make([]*UserPromise, 0)
+}
+
+// ----- Public ----------------------------------------------------------------
+func SetUsersConfiguration(useradd func(data UserData) (Status, error)) {
+ user_add_function = useradd
+}
+
+func User(data UserData) *UserPromise {
+ if data.Name == "" {
+ panic("User() promise invoked without specifying a username")
+ }
+ return &UserPromise{
+ chain: nil,
+ data: data,
+ states: nil,
+ status: PROMISED,
+ }
+}
+
+type UserData struct {
+ HomeDir string
+ Name string
+ System bool
+}
+
+type UserPromise struct {
+ chain []Promise
+ data UserData
+ states []string
+ status Status
+}
+
+func (u *UserPromise) IfRepaired(p ...Promise) Promise {
+ u.chain = append(u.chain, p...)
+ return u
+}
+
+func (u *UserPromise) Promise() Promise {
+ users = append(users, u)
+ return u
+}
+
+func (u *UserPromise) Resolve() {
+ var err error
+ u.status, err = user_add_function(u.data)
+ switch u.status {
+ case BROKEN:
+ slog.Error("user", "name", u.data.Name, "status", u.status, "error", err)
+ case KEPT:
+ slog.Debug("user", "name", u.data.Name, "status", u.status)
+ case REPAIRED:
+ slog.Info("user", "name", u.data.Name, "status", u.status)
+ if u.status == REPAIRED {
+ for _, pp := range u.chain {
+ pp.Resolve()
+ }
+ }
+ }
+}
+
+func (u UserPromise) Status() Status {
+ return u.status
+}
+
+// ----- Internal --------------------------------------------------------------
+func resolveUsers() (status Status) {
+ status = KEPT
+ for _, c := range users {
+ if c.status == PROMISED {
+ c.Resolve()
+ switch c.status {
+ case BROKEN:
+ return BROKEN
+ case REPAIRED:
+ status = REPAIRED
+ }
+ }
+ }
+ return
+}