mirror of
				https://codeberg.org/forgejo/forgejo.git
				synced 2025-10-31 06:21:11 +00:00 
			
		
		
		
	F3: Forgejo driver and CLI
user, topic, project, label, milestone, repository, pull_request, release, asset, comment, reaction, review providers Signed-off-by: Earl Warren <contact@earl-warren.org> Preserve file size when creating attachments Introduced inc6f5029708repoList.LoadAttributes has a ctx argument now Rename `repo.GetOwner` to `repo.LoadOwner`bd66fa586aupgrade to the latest gof3 (cherry picked from commitc770713656) [F3] ID remapping logic is in place, remove workaround (cherry picked from commitd0fee30167) [F3] it is experimental, do not enable by default (cherry picked from commitde325b21d0) (cherry picked from commit547e7b3c40) (cherry picked from commit820df3a56b) (cherry picked from commiteaba87689b) (cherry picked from commit1b86896b3b)
This commit is contained in:
		
					parent
					
						
							
								c240b34f59
							
						
					
				
			
			
				commit
				
					
						0046aac1c6
					
				
			
		
					 28 changed files with 2748 additions and 6 deletions
				
			
		
							
								
								
									
										134
									
								
								services/f3/driver/user.go
									
										
									
									
									
										Normal file
									
								
							
							
						
						
									
										134
									
								
								services/f3/driver/user.go
									
										
									
									
									
										Normal file
									
								
							|  | @ -0,0 +1,134 @@ | |||
| // SPDX-License-Identifier: MIT | ||||
| 
 | ||||
| package driver | ||||
| 
 | ||||
| import ( | ||||
| 	"context" | ||||
| 	"fmt" | ||||
| 
 | ||||
| 	"code.gitea.io/gitea/models/db" | ||||
| 	user_model "code.gitea.io/gitea/models/user" | ||||
| 	"code.gitea.io/gitea/modules/util" | ||||
| 	user_service "code.gitea.io/gitea/services/user" | ||||
| 
 | ||||
| 	"lab.forgefriends.org/friendlyforgeformat/gof3/format" | ||||
| 	f3_util "lab.forgefriends.org/friendlyforgeformat/gof3/util" | ||||
| ) | ||||
| 
 | ||||
| type User struct { | ||||
| 	user_model.User | ||||
| } | ||||
| 
 | ||||
| func UserConverter(f *user_model.User) *User { | ||||
| 	return &User{ | ||||
| 		User: *f, | ||||
| 	} | ||||
| } | ||||
| 
 | ||||
| func (o User) GetID() int64 { | ||||
| 	return o.ID | ||||
| } | ||||
| 
 | ||||
| func (o *User) SetID(id int64) { | ||||
| 	o.ID = id | ||||
| } | ||||
| 
 | ||||
| func (o *User) IsNil() bool { | ||||
| 	return o.ID == 0 | ||||
| } | ||||
| 
 | ||||
| func (o *User) Equals(other *User) bool { | ||||
| 	return (o.Name == other.Name) | ||||
| } | ||||
| 
 | ||||
| func (o *User) ToFormat() *format.User { | ||||
| 	return &format.User{ | ||||
| 		Common:   format.NewCommon(o.ID), | ||||
| 		UserName: o.Name, | ||||
| 		Name:     o.FullName, | ||||
| 		Email:    o.Email, | ||||
| 		Password: o.Passwd, | ||||
| 	} | ||||
| } | ||||
| 
 | ||||
| func (o *User) FromFormat(user *format.User) { | ||||
| 	*o = User{ | ||||
| 		User: user_model.User{ | ||||
| 			ID:       user.Index.GetID(), | ||||
| 			Name:     user.UserName, | ||||
| 			FullName: user.Name, | ||||
| 			Email:    user.Email, | ||||
| 			Passwd:   user.Password, | ||||
| 		}, | ||||
| 	} | ||||
| } | ||||
| 
 | ||||
| type UserProvider struct { | ||||
| 	g *Forgejo | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) ToFormat(ctx context.Context, user *User) *format.User { | ||||
| 	return user.ToFormat() | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) FromFormat(ctx context.Context, p *format.User) *User { | ||||
| 	var user User | ||||
| 	user.FromFormat(p) | ||||
| 	return &user | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) GetObjects(ctx context.Context, page int) []*User { | ||||
| 	users, _, err := user_model.SearchUsers(&user_model.SearchUserOptions{ | ||||
| 		Actor:       o.g.GetDoer(), | ||||
| 		Type:        user_model.UserTypeIndividual, | ||||
| 		ListOptions: db.ListOptions{Page: page, PageSize: o.g.perPage}, | ||||
| 	}) | ||||
| 	if err != nil { | ||||
| 		panic(fmt.Errorf("error while listing users: %v", err)) | ||||
| 	} | ||||
| 	return f3_util.ConvertMap[*user_model.User, *User](users, UserConverter) | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) ProcessObject(ctx context.Context, user *User) { | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) Get(ctx context.Context, exemplar *User) *User { | ||||
| 	var user *user_model.User | ||||
| 	var err error | ||||
| 	if exemplar.GetID() > 0 { | ||||
| 		user, err = user_model.GetUserByID(ctx, exemplar.GetID()) | ||||
| 	} else if exemplar.Name != "" { | ||||
| 		user, err = user_model.GetUserByName(ctx, exemplar.Name) | ||||
| 	} else { | ||||
| 		panic("GetID() == 0 and UserName == \"\"") | ||||
| 	} | ||||
| 	if user_model.IsErrUserNotExist(err) { | ||||
| 		return &User{} | ||||
| 	} | ||||
| 	if err != nil { | ||||
| 		panic(fmt.Errorf("user %v %w", exemplar, err)) | ||||
| 	} | ||||
| 	return UserConverter(user) | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) Put(ctx context.Context, user *User) *User { | ||||
| 	overwriteDefault := &user_model.CreateUserOverwriteOptions{ | ||||
| 		IsActive: util.OptionalBoolTrue, | ||||
| 	} | ||||
| 	u := user.User | ||||
| 	err := user_model.CreateUser(&u, overwriteDefault) | ||||
| 	if err != nil { | ||||
| 		panic(err) | ||||
| 	} | ||||
| 	return o.Get(ctx, UserConverter(&u)) | ||||
| } | ||||
| 
 | ||||
| func (o *UserProvider) Delete(ctx context.Context, user *User) *User { | ||||
| 	u := o.Get(ctx, user) | ||||
| 	if !u.IsNil() { | ||||
| 		if err := user_service.DeleteUser(ctx, &user.User, true); err != nil { | ||||
| 			panic(err) | ||||
| 		} | ||||
| 	} | ||||
| 	return u | ||||
| } | ||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue