summaryrefslogtreecommitdiffstats
path: root/services/f3/driver/user.go
diff options
context:
space:
mode:
Diffstat (limited to 'services/f3/driver/user.go')
-rw-r--r--services/f3/driver/user.go128
1 files changed, 128 insertions, 0 deletions
diff --git a/services/f3/driver/user.go b/services/f3/driver/user.go
new file mode 100644
index 0000000..221b06e
--- /dev/null
+++ b/services/f3/driver/user.go
@@ -0,0 +1,128 @@
+// Copyright Earl Warren <contact@earl-warren.org>
+// Copyright Loïc Dachary <loic@dachary.org>
+// SPDX-License-Identifier: MIT
+
+package driver
+
+import (
+ "context"
+ "fmt"
+ "strings"
+
+ user_model "code.gitea.io/gitea/models/user"
+ "code.gitea.io/gitea/modules/optional"
+ user_service "code.gitea.io/gitea/services/user"
+
+ "code.forgejo.org/f3/gof3/v3/f3"
+ f3_tree "code.forgejo.org/f3/gof3/v3/tree/f3"
+ "code.forgejo.org/f3/gof3/v3/tree/generic"
+ f3_util "code.forgejo.org/f3/gof3/v3/util"
+)
+
+var _ f3_tree.ForgeDriverInterface = &user{}
+
+type user struct {
+ common
+
+ forgejoUser *user_model.User
+}
+
+func getSystemUserByName(name string) *user_model.User {
+ switch name {
+ case user_model.GhostUserName:
+ return user_model.NewGhostUser()
+ case user_model.ActionsUserName:
+ return user_model.NewActionsUser()
+ default:
+ return nil
+ }
+}
+
+func (o *user) SetNative(user any) {
+ o.forgejoUser = user.(*user_model.User)
+}
+
+func (o *user) GetNativeID() string {
+ return fmt.Sprintf("%d", o.forgejoUser.ID)
+}
+
+func (o *user) NewFormat() f3.Interface {
+ node := o.GetNode()
+ return node.GetTree().(f3_tree.TreeInterface).NewFormat(node.GetKind())
+}
+
+func (o *user) ToFormat() f3.Interface {
+ if o.forgejoUser == nil {
+ return o.NewFormat()
+ }
+ return &f3.User{
+ Common: f3.NewCommon(fmt.Sprintf("%d", o.forgejoUser.ID)),
+ UserName: o.forgejoUser.Name,
+ Name: o.forgejoUser.FullName,
+ Email: o.forgejoUser.Email,
+ IsAdmin: o.forgejoUser.IsAdmin,
+ Password: o.forgejoUser.Passwd,
+ }
+}
+
+func (o *user) FromFormat(content f3.Interface) {
+ user := content.(*f3.User)
+ o.forgejoUser = &user_model.User{
+ Type: user_model.UserTypeRemoteUser,
+ ID: f3_util.ParseInt(user.GetID()),
+ Name: user.UserName,
+ FullName: user.Name,
+ Email: user.Email,
+ IsAdmin: user.IsAdmin,
+ Passwd: user.Password,
+ }
+}
+
+func (o *user) Get(ctx context.Context) bool {
+ node := o.GetNode()
+ o.Trace("%s", node.GetID())
+ id := node.GetID().Int64()
+ u, err := user_model.GetPossibleUserByID(ctx, id)
+ if user_model.IsErrUserNotExist(err) {
+ return false
+ }
+ if err != nil {
+ panic(fmt.Errorf("user %v %w", id, err))
+ }
+ o.forgejoUser = u
+ return true
+}
+
+func (o *user) Patch(context.Context) {
+}
+
+func (o *user) Put(ctx context.Context) generic.NodeID {
+ if user := getSystemUserByName(o.forgejoUser.Name); user != nil {
+ return generic.NewNodeID(user.ID)
+ }
+
+ o.forgejoUser.LowerName = strings.ToLower(o.forgejoUser.Name)
+ o.Trace("%v", *o.forgejoUser)
+ overwriteDefault := &user_model.CreateUserOverwriteOptions{
+ IsActive: optional.Some(true),
+ }
+ err := user_model.CreateUser(ctx, o.forgejoUser, overwriteDefault)
+ if err != nil {
+ panic(err)
+ }
+
+ return generic.NewNodeID(o.forgejoUser.ID)
+}
+
+func (o *user) Delete(ctx context.Context) {
+ node := o.GetNode()
+ o.Trace("%s", node.GetID())
+
+ if err := user_service.DeleteUser(ctx, o.forgejoUser, true); err != nil {
+ panic(err)
+ }
+}
+
+func newUser() generic.NodeDriverInterface {
+ return &user{}
+}